| /third_party/glib/gio/tests/ |
| D | stream-rw_all.c | 60 write_done (GObject *source, in write_done() function
95 g_output_stream_write_all_async (ms, "0123456789", 10, 0, NULL, write_done, NULL); in test_write_all_async_memory()
98 g_output_stream_write_all_async (ms, "0123456789", 10, 0, NULL, write_done, NULL); in test_write_all_async_memory()
104 g_output_stream_write_all_async (ms, "0123456789", 10, 0, NULL, write_done, NULL); in test_write_all_async_memory()
108 g_output_stream_write_all_async (ms, "0123456789", 10, 0, NULL, write_done, NULL); in test_write_all_async_memory()
187 g_output_stream_write_all_async (out, "0123456789", 10, 0, cancellable, write_done, NULL); in test_read_write_all_async_pipe()
198 g_output_stream_write_all_async (out, "0123456789", 10, 0, NULL, write_done, NULL); in test_read_write_all_async_pipe()
|
| /third_party/grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 158 grpc_closure write_done;
169 init_event_closure(&write_done, &write);
170 grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr);
211 grpc_closure write_done;
226 init_event_closure(&write_done, &write);
227 grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr);
260 grpc_closure write_done;
275 init_event_closure(&write_done, &write);
276 grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr);
|
| /third_party/grpc/test/core/iomgr/ |
| D | endpoint_tests.cc | 112 int write_done; member
185 state->write_done = 1 + (error == GRPC_ERROR_NONE); in read_and_write_test_write_handler()
224 state.write_done = 0; in read_and_write_test()
259 while (!state.read_done || !state.write_done) { in read_and_write_test()
|
| D | tcp_posix_test.cc | 304 int write_done; member
331 static void write_done(void* user_data /* write_socket_state */, in write_done() function
337 state->write_done = 1; in write_done()
437 state.write_done = 0; in write_test()
443 GRPC_CLOSURE_INIT(&write_done_closure, write_done, &state, in write_test()
457 if (state.write_done && in write_test()
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_async.cc | 349 next_state_ = &ServerRpcContextStreamingImpl::write_done; in read_done()
358 bool write_done(bool ok) { in write_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
490 next_state_ = &ServerRpcContextStreamingFromServerImpl::write_done; in request_done()
495 bool write_done(bool ok) { in write_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingFromServerImpl
|
| /third_party/grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 83 bool write_done; member
263 state.write_done = 0; in poll_server_until_read_done()
|
| /third_party/node/test/cctest/ |
| D | test_inspector_socket.cc | 238 void write_done(uv_write_t* req, int status) { req->data = nullptr; } in write_done() function
249 buf, 1, write_done)); in do_write()
|