| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | propagator_state.cc | 55 TaggedNodeSeq* ready) { in ActivateRoots() argument
60 ready->emplace_back(item, root_frame_, root_iter, false); in ActivateRoots()
62 root_iter->outstanding_ops = ready->size(); in ActivateRoots()
67 TaggedNodeSeq* ready) { in PropagateOutputs() argument
86 DCHECK(ready->empty()); in PropagateOutputs()
97 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
105 output_frame->AddLoopInv(item, (*outputs)[0], ready); in PropagateOutputs()
108 item, is_dead, output_iter, outputs, ready); in PropagateOutputs()
109 output_frame->AdjustOutstandingOpsLocked(output_iter, activated, ready); in PropagateOutputs()
113 is_frame_done = input_frame->DecrementOutstandingOps(input_iter, ready); in PropagateOutputs()
[all …]
|
| D | propagator_state.h | 307 TaggedNodeSeq* ready);
310 TaggedNodeSeq* ready)
319 TaggedNodeSeq* ready);
322 TaggedNodeSeq* ready);
334 IterationState* IncrementIteration(TaggedNodeSeq* ready)
338 void ActivateNexts(IterationState* iter_state, TaggedNodeSeq* ready)
342 void ActivateLoopInvs(IterationState* iter_state, TaggedNodeSeq* ready)
348 TaggedNodeSeq* ready) TF_EXCLUSIVE_LOCKS_REQUIRED(mu);
362 TaggedNodeSeq* ready);
367 TaggedNodeSeq* ready)
[all …]
|
| /external/rust/crates/unicode-normalization/src/ |
| D | decompose.rs | 36 ready: Range<usize>, field
45 ready: 0..0, in new_canonical()
55 ready: 0..0, in new_compatible()
67 self.ready.end = self.buffer.len(); in push_back()
77 self.buffer[self.ready.end..].sort_by_key(|k| k.0); in sort_pending()
84 let pending = self.buffer.len() - self.ready.end; in reset_buffer()
86 self.buffer[i] = self.buffer[i + self.ready.end]; in reset_buffer()
89 self.ready = 0..0; in reset_buffer()
94 let next = self.ready.start + 1; in increment_next_ready()
95 if next == self.ready.end { in increment_next_ready()
[all …]
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | scheduled_io.rs | 210 pub(super) fn wake(&self, ready: Ready) { in wake()
211 self.wake0(ready, false); in wake()
214 fn wake0(&self, ready: Ready, shutdown: bool) { in wake0()
225 if ready.is_readable() { in wake0()
233 if ready.is_writable() { in wake0()
242 let mut iter = waiters.list.drain_filter(|w| ready.satisfies(w.interest)); in wake0()
286 ready: interest.mask() & Ready::from_usize(READINESS.unpack(curr)), in ready_event()
302 let ready = direction.mask() & Ready::from_usize(READINESS.unpack(curr)); in poll_readiness() localVariable
304 if ready.is_empty() { in poll_readiness()
328 let ready = direction.mask() & Ready::from_usize(READINESS.unpack(curr)); in poll_readiness() localVariable
[all …]
|
| D | ready.rs | 39 let mut ready = Ready::EMPTY; in from_mio() localVariable
42 ready |= Ready::READABLE; in from_mio()
46 ready |= Ready::WRITABLE; in from_mio()
50 ready |= Ready::READ_CLOSED; in from_mio()
54 ready |= Ready::WRITE_CLOSED; in from_mio()
57 ready in from_mio()
171 let mut ready = Ready::EMPTY; localVariable
174 ready |= Ready::READABLE;
175 ready |= Ready::READ_CLOSED;
179 ready |= Ready::WRITABLE;
[all …]
|
| D | platform.rs | 12 pub(crate) fn is_hup(ready: Ready) -> bool { in is_hup()
13 UnixReady::from(ready).is_hup() in is_hup()
20 pub(crate) fn is_error(ready: Ready) -> bool { in is_error()
21 UnixReady::from(ready).is_error() in is_error()
|
| /external/rust/crates/futures/tests/ |
| D | join_all.rs | 19 use futures_util::future::{join_all,ready}; in collect_collects()
21 util::assert_done(|| Box::new(join_all(vec![ready(1), ready(2)])), vec![1, 2]); in collect_collects()
22 util::assert_done(|| Box::new(join_all(vec![ready(1)])), vec![1]); in collect_collects()
31 use futures_util::future::{join_all,ready}; in join_all_iter_lifetime()
36 let iter = bufs.into_iter().map(|b| ready::<usize>(b.len())); in join_all_iter_lifetime()
45 use futures_util::future::{JoinAll,ready}; in join_all_from_iter()
48 || Box::new(vec![ready(1), ready(2)].into_iter().collect::<JoinAll<_>>()), in join_all_from_iter()
|
| D | async_await_macros.rs | 172 let mut outer_fut = future::ready(1); in select_nested()
173 let mut inner_fut = future::ready(2); in select_nested()
192 let mut ready = future::ready(0i32); in select_size() localVariable
194 _ = ready => {}, in select_size()
200 let mut ready1 = future::ready(0i32); in select_size()
201 let mut ready2 = future::ready(0i32); in select_size()
285 x = future::ready(7) => x, in select_can_be_used_as_expression()
286 y = future::ready(3) => y + 1, in select_can_be_used_as_expression()
381 let ready = future::ready(0i32); in join_size() localVariable
382 join!(ready) in join_size()
[all …]
|
| D | basic_combinators.rs | 11 let fut = future::ready(1) in basic_future_combinators()
15 future::ready(3) in basic_future_combinators()
43 let fut = future::ready(Ok(1)) in basic_try_future_combinators()
47 future::ready(Ok(3)) in basic_try_future_combinators()
52 future::ready(Ok(-1)) in basic_try_future_combinators()
72 future::ready(Err(-1)) in basic_try_future_combinators()
77 future::ready(Err(9)) in basic_try_future_combinators()
|
| /external/llvm-project/llvm/test/Transforms/Coroutines/ |
| D | coro-debug-frame-variable.ll | 36 ; CHECK: init.ready:
39 ; CHECK: await.ready:
49 ; CHECK: init.ready:
52 ; CHECK: await.ready:
88 %ready = call i1 @await_ready()
89 br i1 %ready, label %init.ready, label %init.suspend
96 i8 0, label %init.ready
103 init.ready: ; preds = %init.suspend, %coro.init
107 %i.init.ready.load = load i32, i32* %i, align 4
108 %i.init.ready.inc = add nsw i32 %i.init.ready.load, 1
[all …]
|
| /external/scapy/scapy/layers/tls/crypto/ |
| D | cipher_stream.py | 49 self.ready = {"key": True}
51 self.ready["key"] = False
79 self.ready["key"] = True
84 if False in six.itervalues(self.ready):
90 if False in six.itervalues(self.ready):
97 c.ready = self.ready.copy()
119 self.ready = {"key": True}
126 c.ready = self.ready.copy()
|
| D | cipher_aead.py | 74 self.ready = {"key": True, "fixed_iv": True, "nonce_explicit": True}
76 self.ready["key"] = False
79 self.ready["fixed_iv"] = False
82 self.ready["nonce_explicit"] = False
107 self.ready["key"] = True
109 self.ready["fixed_iv"] = True
113 self.ready["nonce_explicit"] = True
138 if False in six.itervalues(self.ready):
182 if False in six.itervalues(self.ready):
214 c.ready = self.ready.copy()
[all …]
|
| D | cipher_block.py | 46 self.ready = {"key": True, "iv": True}
48 self.ready["key"] = False
55 self.ready["iv"] = False
70 self.ready["key"] = True
74 self.ready["iv"] = True
83 if False in six.itervalues(self.ready):
96 if False in six.itervalues(self.ready):
105 c.ready = self.ready.copy()
|
| /external/adhd/sound_card_init/dsm/src/ |
| D | zero_player.rs | 63 let (lock, cvar) = &*(thread_info.ready); in start()
99 ready: Arc<(Mutex<bool>, Condvar)>, field
114 let ready = Arc::new((Mutex::new(false), Condvar::new())); in new() localVariable
115 let mut worker = PlayZeroWorker::new(min_playback_time, thread_run.clone(), ready.clone()); in new()
122 ready, in new()
146 ready: Arc<(Mutex<bool>, Condvar)>, field
158 ready: Arc<(Mutex<bool>, Condvar)>, in new()
163 ready, in new()
200 let (lock, cvar) = &*self.ready; in run()
|
| /external/rust/crates/futures-util/src/io/ |
| D | into_sink.rs | 1 use futures_core::ready;
46 let written = ready!(this.writer.as_mut().poll_write(cx, &bytes[buffer.offset..]))?; in poll_flush_buffer()
67 ready!(self.poll_flush_buffer(cx))?; in poll_ready()
87 ready!(self.as_mut().poll_flush_buffer(cx))?; in poll_flush()
88 ready!(self.project().writer.poll_flush(cx))?; in poll_flush()
97 ready!(self.as_mut().poll_flush_buffer(cx))?; in poll_close()
98 ready!(self.project().writer.poll_close(cx))?; in poll_close()
|
| D | buf_reader.rs | 1 use futures_core::ready;
91 let res = ready!(self.as_mut().project().inner.poll_read(cx, buf)); in poll_read()
95 let mut rem = ready!(self.as_mut().poll_fill_buf(cx))?; in poll_read()
108 let res = ready!(self.as_mut().project().inner.poll_read_vectored(cx, bufs)); in poll_read_vectored()
112 let mut rem = ready!(self.as_mut().poll_fill_buf(cx))?; in poll_read_vectored()
138 *this.cap = ready!(this.inner.poll_read(cx, this.buffer))?; in poll_fill_buf()
195 … result = ready!(self.as_mut().project().inner.poll_seek(cx, SeekFrom::Current(offset)))?; in poll_seek()
198 ready!(self.as_mut().project().inner.poll_seek(cx, SeekFrom::Current(-remainder)))?; in poll_seek()
200 result = ready!(self.as_mut().project().inner.poll_seek(cx, SeekFrom::Current(n)))?; in poll_seek()
204 result = ready!(self.as_mut().project().inner.poll_seek(cx, pos))?; in poll_seek()
|
| /external/angle/src/tests/gl_tests/ |
| D | TimerQueriesTest.cpp | 131 GLuint ready = GL_FALSE; in TEST_P() local
132 while (ready == GL_FALSE && timeout > 0) in TEST_P()
135 glGetQueryObjectuivEXT(query1, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P()
138 ready = GL_FALSE; in TEST_P()
139 while (ready == GL_FALSE && timeout > 0) in TEST_P()
142 glGetQueryObjectuivEXT(query2, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P()
211 GLuint ready = GL_FALSE; in TEST_P() local
212 while (ready == GL_FALSE && timeout > 0) in TEST_P()
215 glGetQueryObjectuivEXT(query, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P()
453 GLuint ready = GL_FALSE; in TEST_P() local
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | destroy_tensor_handle_node.h | 34 bool ready) in DestroyTensorHandleNode() argument
38 ready_(ready) {} in DestroyTensorHandleNode()
44 bool ready = ready_; in RunAsync() local
51 [response, ready, done](const tensorflow::Status& s) { in RunAsync()
56 if (!s.ok() && ready && s.code() != errors::Code::UNAVAILABLE) { in RunAsync()
|
| /external/libcxx/test/std/re/re.results/re.results.state/ |
| D | ready.pass.cpp | 25 assert(m.ready() == false); in test1()
27 assert(m.ready() == true); in test1()
35 assert(m.ready() == false); in test2()
37 assert(m.ready() == true); in test2()
|
| /external/llvm-project/libcxx/test/std/re/re.results/re.results.state/ |
| D | ready.pass.cpp | 24 assert(m.ready() == false); in test1()
26 assert(m.ready() == true); in test1()
34 assert(m.ready() == false); in test2()
36 assert(m.ready() == true); in test2()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 1 use futures_core::ready;
33 ready!(self.0.poll_lock(cx)).as_pin_mut().poll_next(cx) in poll_next()
70 ready!(inner.as_mut().poll_ready(cx))?; in poll_flush_slot()
79 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_lock_and_flush_slot()
92 ready!(self.as_mut().poll_lock_and_flush_slot(cx))?; in poll_ready()
103 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_flush()
104 ready!(Self::poll_flush_slot(inner.as_pin_mut(), &mut this.slot, cx))?; in poll_flush()
110 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_close()
111 ready!(Self::poll_flush_slot(inner.as_pin_mut(), &mut this.slot, cx))?; in poll_close()
|
| /external/python/cpython3/Lib/ |
| D | selectors.py | 322 ready = []
326 return ready
338 ready.append((key, events & key.events))
339 return ready
414 ready = []
418 return ready
428 ready.append((key, events & key.events))
429 return ready
467 ready = []
471 return ready
[all …]
|
| /external/webrtc/pc/ |
| D | rtp_transport_unittest.cc | 53 bool ready() const { return ready_; } in ready() function in webrtc::SignalObserver
54 void OnReadyToSend(bool ready) { ready_ = ready; } in OnReadyToSend() argument
92 EXPECT_FALSE(observer.ready()); in TEST()
94 EXPECT_TRUE(observer.ready()); in TEST()
106 EXPECT_FALSE(observer.ready()); in TEST()
108 EXPECT_TRUE(observer.ready()); in TEST()
118 EXPECT_TRUE(observer.ready()); in TEST()
128 EXPECT_TRUE(observer.ready()); in TEST()
131 EXPECT_FALSE(observer.ready()); in TEST()
141 EXPECT_FALSE(observer.ready()); in TEST()
[all …]
|
| /external/rust/crates/tokio-stream/src/stream_ext/ |
| D | take_while.rs | 50 self.as_mut().project().stream.poll_next(cx).map(|ready| { in poll_next()
51 let ready = ready.and_then(|item| { in poll_next() localVariable
59 if ready.is_none() { in poll_next()
63 ready in poll_next()
|
| /external/mesa3d/src/gallium/frontends/lavapipe/ |
| D | lvp_query.c | 106 bool ready = false; in lvp_GetQueryPoolResults() local
108 ready = device->queue.ctx->get_query_result(device->queue.ctx, in lvp_GetQueryPoolResults()
116 if (!ready && !(flags & VK_QUERY_RESULT_PARTIAL_BIT)) in lvp_GetQueryPoolResults()
119 if (ready || (flags & VK_QUERY_RESULT_PARTIAL_BIT)) { in lvp_GetQueryPoolResults()
137 if (ready || (flags & VK_QUERY_RESULT_PARTIAL_BIT)) { in lvp_GetQueryPoolResults()
163 *(uint64_t *)dptr = ready; in lvp_GetQueryPoolResults()
165 *(uint32_t *)dptr = ready; in lvp_GetQueryPoolResults()
|