Searched refs:write_done (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-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);
211 grpc_closure write_done;
226 init_event_closure(&write_done, &write);
227 grpc_endpoint_write(ep_, &write_slices, &write_done);
260 grpc_closure write_done;
275 init_event_closure(&write_done, &write);
276 grpc_endpoint_write(ep_, &write_slices, &write_done);
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | endpoint_tests.cc | 112 int write_done; member
162 state->write_done = 1 + (error == GRPC_ERROR_NONE); in read_and_write_test_write_handler()
201 state.write_done = 0; in read_and_write_test()
232 while (!state.read_done || !state.write_done) { in read_and_write_test()
|
| D | tcp_posix_test.cc | 303 int write_done; member
330 static void write_done(void* user_data /* write_socket_state */, in write_done() function
336 state->write_done = 1; in write_done()
436 state.write_done = 0; in write_test()
442 GRPC_CLOSURE_INIT(&write_done_closure, write_done, &state, in write_test()
456 if (state.write_done && in write_test()
|
| /external/grpc-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
|
| /external/grpc-grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 83 bool write_done; member
260 state.write_done = 0; in poll_server_until_read_done()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | named_pipe.rs | 237 write: Overlapped::new(write_done), in from_raw_handle()
660 fn write_done(status: &OVERLAPPED_ENTRY, events: Option<&mut Vec<Event>>) { in write_done() function
|