| /external/rust/crates/futures/tests/ |
| D | ready_queue.rs | 26 assert!(!queue.poll_next_unpin(cx).is_ready()); in basic_usage()
31 assert!(!queue.poll_next_unpin(cx).is_ready()); in basic_usage()
60 assert!(!queue.poll_next_unpin(cx).is_ready()); in resolving_errors()
65 assert!(!queue.poll_next_unpin(cx).is_ready()); in resolving_errors()
96 assert!(!tx1.poll_canceled(cx).is_ready()); in dropping_ready_queue()
97 assert!(!tx2.poll_canceled(cx).is_ready()); in dropping_ready_queue()
98 assert!(!tx3.poll_canceled(cx).is_ready()); in dropping_ready_queue()
102 assert!(tx1.poll_canceled(cx).is_ready()); in dropping_ready_queue()
103 assert!(tx2.poll_canceled(cx).is_ready()); in dropping_ready_queue()
104 assert!(tx3.poll_canceled(cx).is_ready()); in dropping_ready_queue()
|
| D | mutex.rs | 9 assert!(mutex.lock().poll_unpin(&mut panic_context()).is_ready()); in mutex_acquire_uncontested()
23 assert!(lock.is_ready()); in mutex_wakes_waiters()
33 assert!(waiter.poll_unpin(&mut panic_context()).is_ready()); in mutex_wakes_waiters()
|
| D | futures_ordered.rs | 46 assert!(stream.poll_next_unpin(&mut cx).is_ready()); in works_2()
49 assert!(stream.poll_next_unpin(&mut cx).is_ready()); in works_2()
|
| D | fuse.rs | 10 assert!(future.poll_unpin(&mut cx).is_ready()); in fuse()
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | pending.rs | 24 PendingOnce { is_ready: false } in pending_once()
30 is_ready: bool, field
36 if self.is_ready { in poll()
39 self.is_ready = true; in poll()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | fanout.rs | 73 let sink1_ready = this.sink1.poll_ready(cx)?.is_ready(); in poll_ready()
74 let sink2_ready = this.sink2.poll_ready(cx)?.is_ready(); in poll_ready()
96 let sink1_ready = this.sink1.poll_flush(cx)?.is_ready(); in poll_flush()
97 let sink2_ready = this.sink2.poll_flush(cx)?.is_ready(); in poll_flush()
108 let sink1_ready = this.sink1.poll_close(cx)?.is_ready(); in poll_close()
109 let sink2_ready = this.sink2.poll_close(cx)?.is_ready(); in poll_close()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | never.rs | 87 self.is_ready() in register()
99 fn is_ready(&self) -> bool { in is_ready() method
105 self.is_ready() in watch()
|
| D | tick.rs | 144 self.is_ready() in register()
156 fn is_ready(&self) -> bool { in is_ready() method
162 self.is_ready() in watch()
|
| D | at.rs | 179 self.is_ready() in register()
191 fn is_ready(&self) -> bool { in is_ready() method
197 self.is_ready() in watch()
|
| D | array.rs | 582 self.is_ready() in register()
593 fn is_ready(&self) -> bool { in is_ready() method
599 self.is_ready() in watch()
618 self.is_ready() in register()
629 fn is_ready(&self) -> bool { in is_ready() method
635 self.is_ready() in watch()
|
| D | list.rs | 616 self.is_ready() in register()
627 fn is_ready(&self) -> bool { in is_ready() method
633 self.is_ready() in watch()
651 self.is_ready() in register()
660 fn is_ready(&self) -> bool { in is_ready() method
665 self.is_ready() in watch()
|
| /external/tensorflow/tensorflow/python/training/ |
| D | session_manager.py | 313 is_ready, msg = self._model_ready(sess)
314 if not is_ready:
376 is_ready, msg = self._model_ready(sess)
377 if not is_ready:
425 is_ready, not_ready_msg = self._model_ready(sess)
426 if is_ready:
|
| /external/adhd/sound_card_init/dsm/src/ |
| D | zero_player.rs | 67 |&mut is_ready| !is_ready, in start()
201 let mut is_ready = lock.lock()?; in run() localVariable
202 *is_ready = true; in run()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | bilock.rs | 27 assert!(b.poll_lock().is_ready()); in smoke()
28 assert!(a.poll_lock().is_ready()); in smoke()
46 .is_ready()); in smoke()
|
| /external/autotest/client/common_lib/cros/ |
| D | assistant_util.py | 113 is_ready = utils.poll_for_condition(
118 if is_ready == -1:
|
| /external/rust/crates/futures-channel/tests/ |
| D | oneshot.rs | 17 assert!(tx.poll_canceled(cx).is_ready()); in smoke_poll()
18 assert!(tx.poll_canceled(cx).is_ready()); in smoke_poll()
76 assert!(tx.poll_canceled(cx).is_ready()); in close()
|
| D | mpsc.rs | 34 assert!(tx.as_mut().poll_flush(cx).is_ready()); in send_recv_no_buffer()
35 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
48 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
51 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
57 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | channel.rs | 1372 fn is_ready(&self) -> bool { in is_ready() method
1374 SenderFlavor::Array(chan) => chan.sender().is_ready(), in is_ready()
1375 SenderFlavor::List(chan) => chan.sender().is_ready(), in is_ready()
1376 SenderFlavor::Zero(chan) => chan.sender().is_ready(), in is_ready()
1453 fn is_ready(&self) -> bool { in is_ready() method
1455 ReceiverFlavor::Array(chan) => chan.receiver().is_ready(), in is_ready()
1456 ReceiverFlavor::List(chan) => chan.receiver().is_ready(), in is_ready()
1457 ReceiverFlavor::Zero(chan) => chan.receiver().is_ready(), in is_ready()
1458 ReceiverFlavor::At(chan) => chan.is_ready(), in is_ready()
1459 ReceiverFlavor::Tick(chan) => chan.is_ready(), in is_ready()
[all …]
|
| D | select.rs | 113 fn is_ready(&self) -> bool; in is_ready() method
143 fn is_ready(&self) -> bool { in is_ready() method
144 (**self).is_ready() in is_ready()
348 if handle.is_ready() { in run_ready()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | scheduler.cc | 110 bool is_ready = UpdatePending(out_edge, &pending_count); in ComputeAsap() local
111 if (is_ready) { in ComputeAsap()
252 bool is_ready = UpdatePending(out_edge, &pending_count); in ComputeSchedule() local
253 if (is_ready) { in ComputeSchedule()
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | scheduled_io.rs | 62 is_ready: bool,
250 waiter.is_ready = true; in wake0()
393 is_ready: false,
494 if w.is_ready {
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_tensor_handle_data.cc | 89 bool is_ready) in RemoteTensorHandleData() argument
90 : is_ready_(is_ready), in RemoteTensorHandleData()
|
| D | remote_tensor_handle_data.h | 36 bool is_ready);
|
| /external/rust/crates/futures-util/src/future/ |
| D | try_join.rs | 72 all_done &= futures.Fut1.as_mut().poll(cx)?.is_ready();
74 all_done &= futures.$Fut.as_mut().poll(cx)?.is_ready();
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | block.rs | 122 if !is_ready(ready_bits, offset) { in read()
354 fn is_ready(bits: usize, slot: usize) -> bool { in is_ready() function
|