Home
last modified time | relevance | path

Searched refs:wait_for (Results 1 – 25 of 79) sorted by relevance

1234

/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/
Ddirect_tpu_driver.cc271 absl::Span<Event* const> wait_for) override { in Allocate() argument
272 auto tpu_events = MakeEventArray(wait_for); in Allocate()
276 wait_for.size(), tpu_events)); in Allocate()
283 absl::Span<Event* const> wait_for) override { in Allocate() argument
284 auto tpu_events = MakeEventArray(wait_for); in Allocate()
290 wait_for.size(), tpu_events)); in Allocate()
300 absl::Span<Event* const> wait_for) override { in AllocateTuple() argument
301 auto tpu_events = MakeEventArray(wait_for); in AllocateTuple()
312 wait_for.size(), tpu_events)); in AllocateTuple()
321 absl::Span<Event* const> wait_for) override { in Deallocate() argument
[all …]
Drecording_tpu_driver.cc156 absl::Span<Event* const> wait_for) override { in Allocate() argument
157 auto unwrapped_wait_for = UnwrapWaitFor(wait_for); in Allocate()
172 PopulateAndSaveEntry(&r, wait_for, handle_id, thread_id); in Allocate()
180 absl::Span<Event* const> wait_for) override { in Allocate() argument
181 auto unwrapped_wait_for = UnwrapWaitFor(wait_for); in Allocate()
195 PopulateAndSaveEntry(&r, wait_for, handle_id, thread_id); in Allocate()
204 absl::Span<Event* const> wait_for) override { in AllocateTuple() argument
205 auto unwrapped_wait_for = UnwrapWaitFor(wait_for); in AllocateTuple()
233 PopulateAndSaveEntry(&r, wait_for, handle_id, thread_id); in AllocateTuple()
241 absl::Span<Event* const> wait_for) override { in Deallocate() argument
[all …]
Dgrpc_tpu_driver.cc178 absl::Span<Event* const> wait_for);
181 absl::Span<Event* const> wait_for);
185 absl::Span<Event* const> wait_for);
187 absl::Span<Event* const> wait_for);
190 absl::Span<Event* const> wait_for);
192 absl::Span<Event* const> wait_for);
196 absl::Span<Event* const> wait_for);
200 absl::Span<Event* const> wait_for);
203 absl::Span<Event* const> wait_for);
206 absl::Span<Event* const> wait_for);
[all …]
Dtpu_driver.h167 absl::Span<Event* const> wait_for) = 0;
170 absl::Span<Event* const> wait_for) = 0;
184 absl::Span<Event* const> wait_for) = 0;
187 absl::Span<Event* const> wait_for) = 0;
209 absl::Span<Event* const> wait_for) = 0;
212 absl::Span<Event* const> wait_for) = 0;
216 absl::Span<Event* const> wait_for) = 0;
220 absl::Span<Event* const> wait_for) = 0;
223 absl::Span<Event* const> wait_for) = 0;
226 absl::Span<Event* const> wait_for) = 0;
[all …]
/external/libcxx/test/std/thread/futures/futures.shared_future/
Dwait_for.pass.cpp56 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
58 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
72 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
74 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
88 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
90 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
/external/libcxx/test/std/thread/futures/futures.unique_future/
Dwait_for.pass.cpp56 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
58 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
72 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
74 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
88 assert(f.wait_for(ms(300)) == std::future_status::timeout); in main()
90 assert(f.wait_for(ms(300)) == std::future_status::ready); in main()
/external/python/cpython3/Tools/scripts/
Dpep384_macrocheck.py82 wait_for = -1
91 wait_for = status - 1
94 wait_for = status - 1
97 if status == wait_for:
99 wait_for = -1
104 wait_for = status - 1
/external/swiftshader/third_party/marl/include/marl/
Devent.h65 inline bool wait_for(
110 inline bool wait_for(const std::chrono::duration<Rep, Period>& duration);
154 bool Event::Shared::wait_for( in wait_for() function
157 if (!cv.wait_for(lock, duration, [&] { return signalled; })) { in wait_for()
198 bool Event::wait_for(const std::chrono::duration<Rep, Period>& duration) const { in wait_for() function
199 return shared->wait_for(duration); in wait_for()
Dconditionvariable.h56 bool wait_for(std::unique_lock<std::mutex>& lock,
144 bool ConditionVariable::wait_for( in wait_for() function
/external/libcxx/include/
Dcondition_variable51 wait_for(unique_lock<mutex>& lock,
56 wait_for(unique_lock<mutex>& lock,
96 wait_for(Lock& lock,
101 wait_for(Lock& lock,
158 wait_for(_Lock& __lock,
164 wait_for(_Lock& __lock,
245 condition_variable_any::wait_for(_Lock& __lock,
254 condition_variable_any::wait_for(_Lock& __lock,
D__mutex_base334 wait_for(unique_lock<mutex>& __lk,
340 wait_for(unique_lock<mutex>& __lk,
384 wait_for(__lk, __t - _Clock::now());
404 condition_variable::wait_for(unique_lock<mutex>& __lk,
426 condition_variable::wait_for(unique_lock<mutex>& __lk,
Dfuture170 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
197 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
224 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
251 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
278 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
305 wait_for(const chrono::duration<Rep, Period>& rel_time) const;
587 wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const;
613 __assoc_sub_state::wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
1145 wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
1146 {return __state_->wait_for(__rel_time);}
[all …]
/external/u-boot/test/py/tests/
Dtest_efi_loader.py186 u_boot_console.wait_for('grub>')
188 u_boot_console.wait_for('SMBIOS')
191 u_boot_console.wait_for('grub>')
193 u_boot_console.wait_for('r = 0')
/external/clang/tools/scan-build-py/tests/functional/exec/
Dmain.c86 void wait_for(pid_t child) { in wait_for() function
108 wait_for(child); \
245 wait_for(child); in call_posix_spawn()
263 wait_for(child); in call_posix_spawnp()
/external/libcxx/test/std/thread/thread.condition/thread.condition.condvarany/
Dwait_terminates.sh.cpp126 case 3: cv.wait_for(mut, wait); break; in main()
127 case 4: cv.wait_for(mut, wait, pred_function); break; in main()
/external/toybox/toys/pending/
Dfsck.c250 static int wait_for(int for_all) in wait_for() function
323 if ((ret |= wait_for(1)) > 4) return ret; //destruction in filesys. in scan_all()
347 && (TT.nr_run >= TT.max_nr_run))) ret |= wait_for(0); in scan_all()
351 ret |= wait_for(1); in scan_all()
411 toys.exitval |= wait_for(0); in fsck_main()
414 toys.exitval |= wait_for(1); in fsck_main()
/external/tensorflow/tensorflow/cc/training/
Dqueue_runner.cc96 Status QueueRunner::Start(Session* sess, int wait_for) { in Start() argument
106 if (wait_for > 0) { in Start()
107 if (!counter_->WaitFor(std::chrono::milliseconds(wait_for))) { in Start()
/external/tensorflow/tensorflow/core/graph/
Dcollective_order.cc161 absl::flat_hash_map<Node*, absl::flat_hash_set<int32>> wait_for; in InsertControlDependencies() local
167 wait_for[dst_node].insert(src_instance); in InsertControlDependencies()
170 for (const auto& pair : wait_for) { in InsertControlDependencies()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dcoroutine.cpp40 REQUIRE(d.wait_for(std::chrono::seconds(0)) == std::future_status::ready);
101 REQUIRE(d.wait_for(std::chrono::seconds(0)) == std::future_status::ready);
/external/python/cpython3/Doc/library/
Dasyncio-api-index.rst33 * - ``await`` :func:`wait_for`
63 * :ref:`Using asyncio.wait_for() to enforce a timeout
204 - Raised on timeout by functions like :func:`wait_for`.
/external/tensorflow/tensorflow/core/ops/compat/ops_history_v1/
DCollectiveReduce.pbtxt126 name: "wait_for"
197 name: "wait_for"
/external/swiftshader/third_party/marl/src/
Devent_test.cpp138 event.wait_for(duration); in TEST_P()
153 auto triggered = event.wait_for(duration); in TEST_P()
207 event.wait_for(std::chrono::milliseconds(j)); in TEST_P()
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_sslproto.py275 asyncio.wait_for(client(srv.addr), timeout=10))
336 asyncio.wait_for(client(srv.addr), timeout=10))
431 asyncio.wait_for(client(srv.addr),
486 await asyncio.wait_for(
492 asyncio.wait_for(client(srv.addr), timeout=10))
573 await asyncio.wait_for(
614 await asyncio.wait_for(
/external/tensorflow/tensorflow/core/platform/default/
Dmutex.h31 std::cv_status condition_variable::wait_for( in wait_for() function
/external/autotest/client/cros/
Dwebstore_test.py175 def wait_for(self, xpath): member in webstore_test
258 self.wait_for(post_install_xpath)

1234