Searched refs:read_done (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/tokio/src/io/util/ |
| D | copy.rs | 10 read_done: bool, field
20 read_done: false, in new()
41 if self.pos == self.cap && !self.read_done { in poll_copy()
47 self.read_done = true; in poll_copy()
71 if self.pos == self.cap && self.read_done { in poll_copy()
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 154 grpc_closure read_done;
189 init_event_closure(&read_done, &read);
190 grpc_endpoint_read(ep_, &read_one_slice, &read_done);
208 grpc_closure read_done;
220 init_event_closure(&read_done, &read);
221 grpc_endpoint_read(ep_, &read_slices, &read_done);
257 grpc_closure read_done;
268 init_event_closure(&read_done, &read);
270 grpc_endpoint_read(ep_, &read_slices, &read_done);
304 grpc_closure read_done;
[all …]
|
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 427 read_done: bool, field
437 read_done: false, in new()
460 if !self.read_done { in poll()
464 self.read_done = true; in poll()
469 if self.read_done { in poll()
490 if !self.read_done || !self.finished { in on_drop()
|
| D | mod.rs | 515 read_done: bool, field
523 read_done: false, in new()
547 if !self.read_done { in poll()
551 self.read_done = true; in poll()
556 if self.read_done { in poll()
577 if !self.read_done || self.close_f.is_some() { in on_drop()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | endpoint_tests.cc | 111 int read_done; member
128 state->read_done = 1 + (error == GRPC_ERROR_NONE); in read_and_write_test_read_handler()
200 state.read_done = 0; in read_and_write_test()
232 while (!state.read_done || !state.write_done) { in read_and_write_test()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 338 next_state_ = &ServerRpcContextStreamingImpl::read_done; in request_done()
343 bool read_done(bool ok) { in read_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
361 next_state_ = &ServerRpcContextStreamingImpl::read_done; in write_done()
417 next_state_ = &ServerRpcContextStreamingFromClientImpl::read_done; in request_done()
422 bool read_done(bool ok) { in read_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingFromClientImpl
|
| /external/grpc-grpc/test/core/bad_client/ |
| D | bad_client.cc | 74 gpr_event* read_done = static_cast<gpr_event*>(arg); in set_read_done() local
75 gpr_event_set(read_done, (void*)1); in set_read_done()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | named_pipe.rs | 236 read: Overlapped::new(read_done), in from_raw_handle()
628 fn read_done(status: &OVERLAPPED_ENTRY, events: Option<&mut Vec<Event>>) { in read_done() function
|