| /external/rust/crates/tokio-stream/src/ |
| D | pending.rs | 10 pub struct Pending<T>(PhantomData<T>); struct
12 impl<T> Unpin for Pending<T> {} implementation
13 unsafe impl<T> Send for Pending<T> {} implementation
14 unsafe impl<T> Sync for Pending<T> {} implementation
40 pub const fn pending<T>() -> Pending<T> { in pending()
41 Pending(PhantomData) in pending()
44 impl<T> Stream for Pending<T> { implementation
48 Poll::Pending in poll_next()
|
| /external/rust/crates/futures-util/src/future/ |
| D | pending.rs | 10 pub struct Pending<T> { struct
14 impl<T> FusedFuture for Pending<T> { argument
36 pub fn pending<T>() -> Pending<T> { in pending()
37 assert_future::<T, _>(Pending { in pending()
42 impl<T> Future for Pending<T> { implementation
46 Poll::Pending in poll()
50 impl<T> Unpin for Pending<T> { implementation
53 impl<T> Clone for Pending<T> { implementation
|
| D | try_join_all.rs | 25 Pending, enumerator
112 Poll::Pending => state = FinalState::Pending, in poll()
122 FinalState::Pending => Poll::Pending, in poll()
|
| D | select.rs | 101 Poll::Pending => match b.poll_unpin(cx) { in poll()
103 Poll::Pending => { in poll()
105 Poll::Pending in poll()
|
| D | try_select.rs | 73 Poll::Pending => match b.try_poll_unpin(cx) { in poll()
76 Poll::Pending => { in poll()
78 Poll::Pending in poll()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | pending.rs | 10 pub struct Pending<T> { struct
17 pub fn pending<T>() -> Pending<T> { in pending()
18 assert_stream::<T, _>(Pending { _data: marker::PhantomData }) in pending()
21 impl<T> Unpin for Pending<T> {} implementation
23 impl<T> FusedStream for Pending<T> { implementation
29 impl<T> Stream for Pending<T> { implementation
33 Poll::Pending in poll_next()
41 impl<T> Clone for Pending<T> { implementation
|
| /external/rust/crates/futures/tests_disabled/ |
| D | bilock.rs | 18 Poll::Pending => panic!("poll not ready"), in smoke()
33 Poll::Pending => panic!("poll not ready"), in smoke()
71 Poll::Pending => panic!("poll not ready"), in concurrent()
75 Poll::Pending => panic!("poll not ready"), in concurrent()
98 Poll::Pending => return Ok(Poll::Pending), in concurrent()
|
| /external/llvm-project/clang/include/clang/AST/ |
| D | TextNodeDumper.h | 37 llvm::SmallVector<std::function<void(bool IsLastChild)>, 32> Pending; variable
62 while (!Pending.empty()) { in AddChild()
63 Pending.back()(true); in AddChild()
64 Pending.pop_back(); in AddChild()
100 unsigned Depth = Pending.size(); in AddChild()
106 while (Depth < Pending.size()) { in AddChild()
107 Pending.back()(true); in AddChild()
108 this->Pending.pop_back(); in AddChild()
116 Pending.push_back(std::move(DumpWithIndent)); in AddChild()
118 Pending.back()(false); in AddChild()
[all …]
|
| D | JSONNodeDumper.h | 36 llvm::SmallVector<std::function<void(bool IsLastChild)>, 32> Pending; variable
58 while (!Pending.empty()) { in AddChild()
59 Pending.back()(true); in AddChild()
60 Pending.pop_back(); in AddChild()
79 unsigned Depth = Pending.size(); in AddChild()
86 while (Depth < Pending.size()) { in AddChild()
87 Pending.back()(true); in AddChild()
88 this->Pending.pop_back(); in AddChild()
100 Pending.push_back(std::move(DumpWithIndent)); in AddChild()
102 Pending.back()(false); in AddChild()
[all …]
|
| /external/rust/crates/futures-channel/benches/ |
| D | sync_mpsc.rs | 30 assert_eq!(Poll::Pending, rx.poll_next_unpin(&mut cx)); in unbounded_1_tx()
52 assert_eq!(Poll::Pending, rx.poll_next_unpin(&mut cx)); in unbounded_100_tx()
96 assert_eq!(Poll::Pending, tx.as_mut().poll_flush(cx)); in poll_next()
112 assert_eq!(Poll::Pending, tx.poll_next_unpin(&mut cx)); in bounded_1_tx()
138 assert_eq!(Poll::Pending, x.poll_next_unpin(&mut cx)); in bounded_100_tx()
|
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 13 struct Pending(Rc<()>); struct
15 impl Future for Pending { implementation
19 Poll::Pending in poll()
23 fn pending() -> Pending { in pending()
24 Pending(Rc::new(())) in pending()
163 Poll::Pending in try_run_one_returns_on_no_progress()
196 Poll::Pending in try_run_one_runs_sub_futures()
243 Poll::Pending in run_until_stalled_runs_spawned_sub_futures()
338 Poll::Pending in tasks_are_scheduled_fairly()
382 Poll::Pending // Expect to be called again due to (*). in park_unpark_independence()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/MCA/Stages/ |
| D | ExecuteStage.cpp | 55 SmallVector<InstRef, 4> Pending; in issueInstruction() local
58 HWS.issueInstruction(IR, Used, Pending, Ready); in issueInstruction()
72 for (const InstRef &I : Pending) in issueInstruction()
96 SmallVector<InstRef, 4> Pending; in cycleStart() local
99 HWS.cycleEvent(Freed, Executed, Pending, Ready); in cycleStart()
113 for (const InstRef &IR : Pending) in cycleStart()
236 HWInstructionEvent(HWInstructionEvent::Pending, IR)); in notifyInstructionPending()
|
| /external/llvm-project/llvm/lib/MCA/Stages/ |
| D | ExecuteStage.cpp | 55 SmallVector<InstRef, 4> Pending; in issueInstruction() local
58 HWS.issueInstruction(IR, Used, Pending, Ready); in issueInstruction()
72 for (const InstRef &I : Pending) in issueInstruction()
96 SmallVector<InstRef, 4> Pending; in cycleStart() local
99 HWS.cycleEvent(Freed, Executed, Pending, Ready); in cycleStart()
113 for (const InstRef &IR : Pending) in cycleStart()
236 HWInstructionEvent(HWInstructionEvent::Pending, IR)); in notifyInstructionPending()
|
| /external/rust/crates/tokio-test/src/ |
| D | macros.rs | 28 Pending => panic!("pending"),
35 Pending => {
132 Pending => {}
139 Pending => {}
|
| /external/rust/crates/futures-util/src/io/ |
| D | fill_buf.rs | 39 Poll::Pending => { in poll()
44 Poll::Pending => { in poll()
46 Poll::Pending in poll()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | send_all.rs | 71 Poll::Pending => { in try_start_send()
73 Poll::Pending in try_start_send()
106 Poll::Pending => { in poll()
108 return Poll::Pending in poll()
|
| /external/crosvm/cros_async/src/ |
| D | select.rs | 15 Pending(F), enumerator
59 MaybeDone::Future(f) => SelectResult::Pending(f),
65 Poll::Pending
|
| /external/rust/crates/futures-core/src/task/ |
| D | poll.rs | 8 $crate::__private::Poll::Pending =>
9 return $crate::__private::Poll::Pending,
|
| /external/rust/crates/tokio/src/macros/ |
| D | ready.rs | 5 std::task::Poll::Pending => return std::task::Poll::Pending,
|
| /external/llvm-project/flang/runtime/ |
| D | file.h | 70 struct Pending { struct
73 OwningPtr<Pending> next; argument
94 OwningPtr<Pending> pending_;
|
| /external/rust/crates/futures-executor/benches/ |
| D | thread_notify.rs | 28 Poll::Pending in thread_yield_single_thread_one_wait()
56 Poll::Pending in thread_yield_single_thread_many_wait()
93 Poll::Pending in thread_yield_multi_thread()
|
| /external/rust/crates/tokio-stream/src/stream_ext/ |
| D | merge.rs | 76 Pending => done = false, in poll_next()
82 Pending => done = false, in poll_next()
88 Pending in poll_next()
|
| /external/llvm/lib/Target/Hexagon/ |
| D | HexagonMachineScheduler.cpp | 297 Pending.push(SU); in releaseNode()
366 for (unsigned i = 0, e = Pending.size(); i != e; ++i) { in releasePending()
367 SUnit *SU = *(Pending.begin()+i); in releasePending()
380 Pending.remove(Pending.begin()+i); in releasePending()
391 assert(Pending.isInQueue(SU) && "bad ready count"); in removeReady()
392 Pending.remove(Pending.find(SU)); in removeReady()
645 assert(Top.Available.empty() && Top.Pending.empty() && in pickNode()
646 Bot.Available.empty() && Bot.Pending.empty() && "ReadyQ garbage"); in pickNode()
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_buffered.rs | 61 Poll::Ready(None) | Poll::Pending => break, in poll_next()
67 x @ Poll::Pending | x @ Poll::Ready(Some(_)) => return x, in poll_next()
75 Poll::Pending in poll_next()
|
| D | try_buffer_unordered.rs | 58 Poll::Ready(None) | Poll::Pending => break, in poll_next()
64 x @ Poll::Pending | x @ Poll::Ready(Some(_)) => return x, in poll_next()
72 Poll::Pending in poll_next()
|