| /external/grpc-grpc/test/core/util/ |
| D | passthru_endpoint.cc | 43 grpc_closure* on_read; member
67 m->on_read = cb; in me_read()
86 } else if (m->on_read != nullptr) { in me_write()
90 GRPC_CLOSURE_SCHED(m->on_read, GRPC_ERROR_NONE); in me_write()
91 m->on_read = nullptr; in me_write()
114 if (m->on_read) { in me_shutdown()
116 m->on_read, in me_shutdown()
118 m->on_read = nullptr; in me_shutdown()
121 if (m->on_read) { in me_shutdown()
123 m->on_read, in me_shutdown()
[all …]
|
| D | mock_endpoint.cc | 39 grpc_closure* on_read; member
51 m->on_read = cb; in me_read()
77 if (m->on_read) { in me_shutdown()
78 GRPC_CLOSURE_SCHED(m->on_read, in me_shutdown()
81 m->on_read = nullptr; in me_shutdown()
130 m->on_read = nullptr; in grpc_mock_endpoint_create()
137 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
139 GRPC_CLOSURE_SCHED(m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
140 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 110 grpc_closure on_read; member
178 static void on_read(void* tcpp, grpc_error* error) { in on_read() function
249 GRPC_CLOSURE_SCHED(&tcp->on_read, GRPC_ERROR_NONE); in win_read()
262 GRPC_CLOSURE_SCHED(&tcp->on_read, in win_read()
268 grpc_socket_notify_on_read(tcp->socket, &tcp->on_read); in win_read()
460 GRPC_CLOSURE_INIT(&tcp->on_read, on_read, tcp, grpc_schedule_on_exec_ctx); in grpc_tcp_create()
|
| D | tcp_server_posix.cc | 183 static void on_read(void* arg, grpc_error* err) { in on_read() function
495 GRPC_CLOSURE_INIT(&sp->read_closure, on_read, sp, in tcp_server_start()
505 GRPC_CLOSURE_INIT(&sp->read_closure, on_read, sp, in tcp_server_start()
|
| D | udp_server.cc | 105 static void on_read(void* arg, grpc_error* error);
462 void GrpcUdpListener::on_read(void* arg, grpc_error* error) { in on_read() function in GrpcUdpListener
726 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 57 grpc_closure on_read; member
124 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read); in do_read()
127 static void on_read(void* user_data, grpc_error* error) { in on_read() function
246 GRPC_CLOSURE_INIT(&req->on_read, on_read, req, grpc_schedule_on_exec_ctx); in internal_request_begin()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 52 grpc_closure on_read; member
145 static void on_read(void* user_data, grpc_error* error) { in on_read() function
241 on_read(ep, GRPC_ERROR_NONE); in endpoint_read()
245 grpc_endpoint_read(ep->wrapped_ep, &ep->source_buffer, &ep->on_read); in endpoint_read()
425 GRPC_CLOSURE_INIT(&ep->on_read, on_read, ep, grpc_schedule_on_exec_ctx); in grpc_secure_endpoint_create()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 90 static grpc_closure on_read; variable
129 grpc_endpoint_read(state.tcp, &state.temp_incoming_buffer, &on_read); in handle_read()
138 GRPC_CLOSURE_INIT(&on_read, handle_read, nullptr, grpc_schedule_on_exec_ctx); in on_connect()
145 grpc_endpoint_read(tcp, &state.temp_incoming_buffer, &on_read); in on_connect()
|