| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 38 assert!(tx1.is_closed()); in multiple_senders_disconnect()
39 assert!(tx3.is_closed()); in multiple_senders_disconnect()
40 assert!(!tx4.is_closed()); in multiple_senders_disconnect()
60 assert!(tx1.is_closed()); in multiple_senders_disconnect()
61 assert!(tx3.is_closed()); in multiple_senders_disconnect()
62 assert!(!tx4.is_closed()); in multiple_senders_disconnect()
82 assert!(tx1.is_closed()); in multiple_senders_close_channel()
83 assert!(tx2.is_closed()); in multiple_senders_close_channel()
98 assert!(tx1.is_closed()); in multiple_senders_close_channel()
99 assert!(tx2.is_closed()); in multiple_senders_close_channel()
[all …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 426 pub fn is_closed(&self) -> bool { in is_closed() method
430 state.is_closed() in is_closed()
481 if state.is_closed() { in poll_closed()
492 if state.is_closed() { in poll_closed()
512 if state.is_closed() { in poll_closed()
668 } else if state.is_closed() { in try_recv()
711 if prev.is_closed() { in complete()
738 } else if state.is_closed() { in poll_recv()
876 fn is_closed(self) -> bool { in is_closed() method
915 .field("is_closed", &self.is_closed()) in fmt()
|
| D | semaphore.rs | 292 pub fn is_closed(&self) -> bool { in is_closed() method
293 self.ll_sem.is_closed() in is_closed()
|
| /external/rust/crates/tokio/src/io/util/ |
| D | mem.rs | 57 is_closed: bool, field
147 is_closed: false, in new()
155 self.is_closed = true; in close()
180 } else if self.is_closed { in poll_read()
195 if self.is_closed { in poll_write()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | chan.rs | 43 fn is_closed(&self) -> bool; in is_closed() method
150 pub(crate) fn is_closed(&self) -> bool { in is_closed() method
151 self.inner.semaphore.is_closed() in is_closed()
160 if self.inner.semaphore.is_closed() { in closed()
326 fn is_closed(&self) -> bool { in is_closed() method
327 self.0.is_closed() in is_closed()
354 fn is_closed(&self) -> bool { in is_closed() method
|
| D | bounded.rs | 584 pub fn is_closed(&self) -> bool { in is_closed() method
585 self.chan.is_closed() in is_closed()
807 if semaphore.is_closed() && semaphore.is_idle() { in drop()
|
| D | unbounded.rs | 291 pub fn is_closed(&self) -> bool { in is_closed() method
292 self.chan.is_closed() in is_closed()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | mod.rs | 498 fn is_closed(&self) -> bool { in is_closed() method
679 fn is_closed(&self) -> bool { in is_closed() method
769 pub fn is_closed(&self) -> bool { in is_closed() method
770 self.0.as_ref().map(BoundedSenderInner::is_closed).unwrap_or(true) in is_closed()
823 pub fn is_closed(&self) -> bool { in is_closed() method
824 self.0.as_ref().map(UnboundedSenderInner::is_closed).unwrap_or(true) in is_closed()
1051 if state.is_closed() { in next_message()
1138 if state.is_closed() { in drop()
1195 if state.is_closed() { in next_message()
1270 if state.is_closed() { in drop()
[all …]
|
| /external/rust/crates/tokio/src/runtime/ |
| D | queue.rs | 57 is_closed: bool, field
472 is_closed: false, in new()
490 if p.is_closed { in close()
494 p.is_closed = true; in close()
498 pub(super) fn is_closed(&self) -> bool { in is_closed() method
499 self.pointers.lock().is_closed in is_closed()
511 if p.is_closed { in push()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 82 assert!(tx.is_closed()); in close_rx()
122 assert!(tx.is_closed()); in explicit_close_poll()
138 assert!(tx.is_closed()); in explicit_close_poll()
165 assert!(tx.is_closed()); in explicit_close_try_recv()
|
| D | sync_broadcast.rs | 342 assert!(is_closed(err)); in dropping_tx_notifies_rx()
345 assert!(is_closed(err)); in dropping_tx_notifies_rx()
455 fn is_closed(err: broadcast::error::RecvError) -> bool { in is_closed() function
|
| /external/openscreen/platform/impl/ |
| D | udp_socket_posix.cc | 177 if (is_closed()) { in Bind()
227 if (is_closed()) { in SetMulticastOutboundInterface()
263 if (is_closed()) { in JoinMulticastGroup()
459 if (is_closed()) { in ReceiveMessage()
499 if (is_closed()) { in SendMessage()
552 if (is_closed()) { in SetDscp()
|
| D | udp_socket_posix.h | 63 bool is_closed() const { return handle_.fd < 0; } in is_closed() function
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v2/ |
| D | QueueIsClosedV2.pbtxt | 8 name: "is_closed"
|
| D | QueueIsClosed.pbtxt | 9 name: "is_closed"
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v1/ |
| D | QueueIsClosed.pbtxt | 9 name: "is_closed"
|
| D | QueueIsClosedV2.pbtxt | 8 name: "is_closed"
|
| /external/rust/crates/quiche/examples/ |
| D | client.rs | 181 if conn.is_closed() { in main()
259 if conn.is_closed() { in main()
|
| D | http3-client.rs | 201 if conn.is_closed() { in main()
311 if conn.is_closed() { in main()
|
| /external/iperf3/src/ |
| D | iperf_util.h | 41 int is_closed(int);
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | queue_interface.h | 81 virtual bool is_closed() const = 0;
|
| /external/rust/crates/crossbeam-channel/ |
| D | CHANGELOG.md | 138 - Remove `Sender::is_closed` and `Receiver::is_closed`.
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.-queue-base.pbtxt | 58 name: "is_closed"
|
| D | tensorflow.io.-random-shuffle-queue.pbtxt | 59 name: "is_closed"
|
| D | tensorflow.-priority-queue.pbtxt | 59 name: "is_closed"
|