Home
last modified time | relevance | path

Searched refs:grpc_endpoint_read (Results 1 – 17 of 17) sorted by relevance

/external/grpc-grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc273 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/
Dendpoint_tests.cc132 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()
Dtcp_posix_test.cc194 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/
DCFStreamEndpointTests.mm190 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/
Dreadahead_handshaker_server_ssl.cc62 grpc_endpoint_read(args->endpoint, args->read_buffer, on_handshake_done); in readahead_handshaker_do_handshake()
/external/grpc-grpc/src/core/lib/iomgr/
Dendpoint.cc25 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_read() function
Dendpoint.h57 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices,
/external/grpc-grpc/src/core/lib/security/transport/
Dsecurity_handshaker.cc242 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()
Dsecure_endpoint.cc245 grpc_endpoint_read(ep->wrapped_ep, &ep->source_buffer, &ep->on_read); in endpoint_read()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dhttp_connect_handshaker.cc136 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/
Dbad_server_response_test.cc129 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/
Dsecure_endpoint_test.cc185 grpc_endpoint_read(f.client_ep, &incoming, &done_closure); in test_leftover()
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc136 grpc_endpoint_read(endpoint_, &read_buffer, state.closure()); in ReadUntilError()
/external/grpc-grpc/test/core/util/
Dtrickle_endpoint.cc52 grpc_endpoint_read(te->wrapped, slices, cb); in te_read()
/external/grpc-grpc/test/core/bad_client/
Dbad_client.cc146 grpc_endpoint_read(sfd->client, &incoming, &read_done_closure); in grpc_run_client_side_validator()
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.cc124 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read); in do_read()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc2549 grpc_endpoint_read(t->ep, &t->read_buffer, &t->read_action_locked); in read_action_locked()