Searched refs:on_write (Results 1 – 5 of 5) sorted by relevance
/external/grpc-grpc/test/core/util/ |
D | mock_endpoint.cc | 36 void (*on_write)(grpc_slice slice); member 61 m->on_write(slices->slices[i]); in me_write() 119 grpc_endpoint* grpc_mock_endpoint_create(void (*on_write)(grpc_slice slice), in grpc_mock_endpoint_create() 129 m->on_write = on_write; in grpc_mock_endpoint_create()
|
D | mock_endpoint.h | 24 grpc_endpoint* grpc_mock_endpoint_create(void (*on_write)(grpc_slice slice),
|
/external/grpc-grpc/src/core/lib/iomgr/ |
D | tcp_windows.cc | 111 grpc_closure on_write; member 272 static void on_write(void* tcpp, grpc_error* error) { in on_write() function 370 grpc_socket_notify_on_write(socket, &tcp->on_write); in win_write() 461 GRPC_CLOSURE_INIT(&tcp->on_write, on_write, tcp, grpc_schedule_on_exec_ctx); in grpc_tcp_create()
|
D | udp_server.cc | 106 static void on_write(void* arg, grpc_error* error); 527 void GrpcUdpListener::on_write(void* arg, grpc_error* error) { in on_write() function in GrpcUdpListener 729 GRPC_CLOSURE_INIT(&write_closure_, on_write, this, grpc_schedule_on_exec_ctx); in StartListening()
|
/external/grpc-grpc/test/core/end2end/ |
D | bad_server_response_test.cc | 91 static grpc_closure on_write; variable 107 grpc_endpoint_write(state.tcp, &state.outgoing_buffer, &on_write, nullptr); in handle_write() 139 GRPC_CLOSURE_INIT(&on_write, done_write, nullptr, grpc_schedule_on_exec_ctx); in on_connect()
|