/external/grpc-grpc/test/core/end2end/fixtures/ |
D | http_proxy_fixture.cc | 273 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_client_read_done() 304 grpc_endpoint_read(conn->server_endpoint, &conn->server_read_buffer, in on_server_read_done() 325 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_write_response_done() 327 grpc_endpoint_read(conn->server_endpoint, &conn->server_read_buffer, in on_write_response_done() 407 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_read_request_done() 505 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_accept()
|
/external/grpc-grpc/test/core/iomgr/ |
D | endpoint_tests.cc | 132 grpc_endpoint_read(state->read_ep, &state->incoming, &state->done_read); in read_and_write_test_read_handler() 219 grpc_endpoint_read(state.read_ep, &state.incoming, &state.done_read); in read_and_write_test() 283 grpc_endpoint_read(f.client_ep, &slice_buffer, in multiple_shutdown_test() 290 grpc_endpoint_read(f.client_ep, &slice_buffer, in multiple_shutdown_test()
|
D | tcp_posix_test.cc | 194 grpc_endpoint_read(state->ep, &state->incoming, &state->read_cb); in read_cb() 232 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in read_test() 283 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in large_read_test() 522 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in release_fd_test()
|
/external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
D | CFStreamEndpointTests.mm | 190 grpc_endpoint_read(ep_, &read_one_slice, &read_done); 221 grpc_endpoint_read(ep_, &read_slices, &read_done); 270 grpc_endpoint_read(ep_, &read_slices, &read_done); 309 grpc_endpoint_read(ep_, &read_slices, &read_done);
|
/external/grpc-grpc/test/core/handshake/ |
D | readahead_handshaker_server_ssl.cc | 62 grpc_endpoint_read(args->endpoint, args->read_buffer, on_handshake_done); in readahead_handshaker_do_handshake()
|
/external/grpc-grpc/src/core/lib/iomgr/ |
D | endpoint.cc | 25 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_read() function
|
D | endpoint.h | 57 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices,
|
/external/grpc-grpc/src/core/lib/security/transport/ |
D | security_handshaker.cc | 242 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_next_done_locked() 265 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_next_done_locked() 354 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_data_sent_to_peer()
|
D | secure_endpoint.cc | 245 grpc_endpoint_read(ep->wrapped_ep, &ep->source_buffer, &ep->on_read); in endpoint_read()
|
/external/grpc-grpc/src/core/ext/filters/client_channel/ |
D | http_connect_handshaker.cc | 136 grpc_endpoint_read(handshaker->args->endpoint, in on_write_done() 199 grpc_endpoint_read(handshaker->args->endpoint, in on_read_done()
|
/external/grpc-grpc/test/core/end2end/ |
D | bad_server_response_test.cc | 129 grpc_endpoint_read(state.tcp, &state.temp_incoming_buffer, &on_read); in handle_read() 145 grpc_endpoint_read(tcp, &state.temp_incoming_buffer, &on_read); in on_connect()
|
/external/grpc-grpc/test/core/security/ |
D | secure_endpoint_test.cc | 185 grpc_endpoint_read(f.client_ep, &incoming, &done_closure); in test_leftover()
|
/external/grpc-grpc/test/core/transport/chttp2/ |
D | settings_timeout_test.cc | 136 grpc_endpoint_read(endpoint_, &read_buffer, state.closure()); in ReadUntilError()
|
/external/grpc-grpc/test/core/util/ |
D | trickle_endpoint.cc | 52 grpc_endpoint_read(te->wrapped, slices, cb); in te_read()
|
/external/grpc-grpc/test/core/bad_client/ |
D | bad_client.cc | 146 grpc_endpoint_read(sfd->client, &incoming, &read_done_closure); in grpc_run_client_side_validator()
|
/external/grpc-grpc/src/core/lib/http/ |
D | httpcli.cc | 124 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read); in do_read()
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | chttp2_transport.cc | 2549 grpc_endpoint_read(t->ep, &t->read_buffer, &t->read_action_locked); in read_action_locked()
|