| /external/rust/crates/tokio/src/macros/ |
| D | join.rs | 75 let mut is_pending = false; localVariable
86 if fut.poll(cx).is_pending() {
87 is_pending = true;
91 if is_pending {
|
| D | try_join.rs | 82 let mut is_pending = false; localVariable
93 if fut.as_mut().poll(cx).is_pending() {
94 is_pending = true;
100 if is_pending {
|
| D | select.rs | 417 let mut is_pending = false; localVariable
460 is_pending = true;
485 if is_pending {
|
| /external/rust/crates/futures/tests/ |
| D | futures_ordered.rs | 15 assert!(stream.poll_next_unpin(&mut noop_context()).is_pending()); in works_1()
47 assert!(stream.poll_next_unpin(&mut cx).is_pending()); in works_2()
88 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
92 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
94 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
95 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
|
| D | futures_unordered.rs | 133 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
139 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
140 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
361 assert!(tasks.poll_next_unpin(cx).is_pending()); in polled_only_once_at_most_per_iteration()
365 assert!(tasks.poll_next_unpin(cx).is_pending()); in polled_only_once_at_most_per_iteration()
|
| D | sink.rs | 341 assert!(task.poll_unpin(cx).is_pending()); in mpsc_blocking_start_send()
379 assert!(task.poll_unpin(cx).is_pending()); in with_flush()
477 assert!(task.poll_unpin(cx).is_pending()); in with_flush_propagate()
559 assert!(task.poll_unpin(cx).is_pending()); in buffer()
604 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
607 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
611 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
614 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
|
| D | fuse.rs | 11 assert!(future.poll_unpin(&mut cx).is_pending()); in fuse()
|
| D | mutex.rs | 27 assert!(waiter.poll_unpin(&mut cx).is_pending()); in mutex_wakes_waiters()
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | associated_interface_request.h | 51 bool is_pending() const { return handle_.is_valid(); } in is_pending() function
65 return !is_pending() && !other.is_pending(); in Equals()
|
| D | interface_request.h | 55 bool is_pending() const { return handle_.is_valid(); } in is_pending() function
68 return !is_pending() && !other.is_pending(); in Equals()
|
| /external/rust/crates/tokio/src/future/ |
| D | try_join.rs | 54 if me.future1.as_mut().poll(cx).is_pending() { in poll()
60 if me.future2.as_mut().poll(cx).is_pending() { in poll()
66 if me.future3.as_mut().poll(cx).is_pending() { in poll()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | bilock.rs | 23 assert!(b.poll_lock().is_pending()); in smoke()
24 assert!(a.poll_lock().is_pending()); in smoke()
|
| D | all.rs | 163 assert!(f.poll(lw).ok().unwrap().is_pending()); in select_cancels()
164 assert!(f.poll(lw).ok().unwrap().is_pending()); in select_cancels()
211 assert!(f.poll(lw).ok().unwrap().is_pending()); in join_incomplete()
220 assert!(f.poll(lw).ok().unwrap().is_pending()); in join_incomplete()
229 assert!(f.poll(lw).ok().unwrap().is_pending()); in join_incomplete()
238 assert!(f.poll(lw).ok().unwrap().is_pending()); in join_incomplete()
|
| /external/crosvm/cros_async/src/sync/ |
| D | mu.rs | 1447 .is_pending() in wake_all_readers()
1500 if mark.as_mut().poll(&mut cx).is_pending() { in long_wait()
1505 if tl.as_mut().poll(&mut cx).is_pending() { in long_wait()
1612 if tl.as_mut().poll(&mut cx).is_pending() { in cancel_long_wait_after_wake()
1663 if futures[2].as_mut().poll(&mut cx).is_pending() { in designated_waker()
1680 if futures[0].as_mut().poll(&mut cx).is_pending() { in designated_waker()
1685 if futures[1].as_mut().poll(&mut cx).is_pending() { in designated_waker()
1887 if timeout.as_mut().poll(&mut cx).is_pending() { in timeout()
1958 if r1.as_mut().poll(&mut cx).is_pending() { in writer_waiting()
1961 if r2.as_mut().poll(&mut cx).is_pending() { in writer_waiting()
[all …]
|
| /external/rust/crates/futures-channel/tests/ |
| D | oneshot.rs | 14 assert!(tx.poll_canceled(cx).is_pending()); in smoke_poll()
15 assert!(tx.poll_canceled(cx).is_pending()); in smoke_poll()
|
| D | mpsc.rs | 39 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
44 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
53 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
464 assert!(tx.poll_ready(cx).is_pending()); in try_send_2()
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | reap.rs | 87 let registered_interest = self.signal.poll_recv(cx).is_pending(); in poll()
224 assert!(grim.poll_unpin(&mut context).is_pending()); in reaper()
232 assert!(grim.poll_unpin(&mut context).is_pending()); in reaper()
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_iter.rs | 11 if stream.poll_next().is_pending() { in coop()
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | entry.rs | 120 fn is_pending(&self) -> bool { in is_pending() method
569 pub(super) unsafe fn is_pending(&self) -> bool { in is_pending() method
570 unsafe { self.inner.as_ref().state.is_pending() } in is_pending()
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | handle_passing_unittest.cc | 132 EXPECT_TRUE(object_request.is_pending()); in CreateNamedObject()
297 EXPECT_TRUE(object1_request.is_pending()); in TEST_P()
299 EXPECT_FALSE(object1_request.is_pending()); // We've passed the request. in TEST_P()
|
| /external/libkmsxx/kms++/inc/kms++/ |
| D | property.h | 28 bool is_pending() const;
|
| /external/rust/crates/tokio/src/time/driver/tests/ |
| D | mod.rs | 218 assert!(future.as_mut().poll_elapsed(&mut context).is_pending()); in poll_process_levels()
241 assert!(e1.as_mut().poll_elapsed(&mut context).is_pending()); in poll_process_levels_targeted()
|
| /external/libkmsxx/kms++/src/ |
| D | property.cpp | 57 bool Property::is_pending() const in is_pending() function in kms::Property
|
| /external/rust/crates/futures-util/src/future/ |
| D | join_all.rs | 101 if elem.poll(cx).is_pending() { in poll()
|
| /external/rust/crates/tokio/tests/ |
| D | fs_file.rs | 70 if task.poll().is_pending() { in coop()
|