Home
last modified time | relevance | path

Searched refs:wait_for (Results 1 - 25 of 29) sorted by relevance

12

/third_party/python/Lib/test/test_asyncio/
H A Dtest_waitfor.py45 asyncio.wait_for(t.run(), t.TASK_TIMEOUT * 2))
56 await asyncio.wait_for(t.run(), t.TASK_TIMEOUT / 2)
69 ret = await asyncio.wait_for(fut, 0)
87 await asyncio.wait_for(foo(), 0)
116 await asyncio.wait_for(fut, timeout)
142 await asyncio.wait_for(fut, 0.1)
154 res = await asyncio.wait_for(coro(), timeout=None)
161 task = asyncio.wait_for(fut, timeout=0.2)
172 result = await asyncio.wait_for(inner(), timeout=.01)
191 await asyncio.wait_for(inner_tas
[all...]
H A Dtest_sslproto.py281 asyncio.wait_for(client(srv.addr),
344 asyncio.wait_for(client(srv.addr),
441 asyncio.wait_for(client(srv.addr),
496 await asyncio.wait_for(
502 asyncio.wait_for(client(srv.addr),
584 await asyncio.wait_for(
625 await asyncio.wait_for(
H A Dtest_futures2.py51 self.assertIn('...', repr(await asyncio.wait_for(func(), timeout=10)))
H A Dtest_ssl.py275 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
478 await asyncio.wait_for(
736 asyncio.wait_for(client(srv.addr),
795 asyncio.wait_for(client(srv.addr),
895 asyncio.wait_for(client(srv.addr),
950 await asyncio.wait_for(
956 asyncio.wait_for(client(srv.addr),
1028 await asyncio.wait_for(
1168 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
1438 await asyncio.wait_for(
[all...]
H A Dtest_sock_lowlevel.py260 self.loop.run_until_complete(asyncio.wait_for(
264 self.loop.run_until_complete(asyncio.wait_for(
269 self.loop.run_until_complete(asyncio.wait_for(
276 self.loop.run_until_complete(asyncio.wait_for(
504 f = asyncio.wait_for(self.loop.sock_accept(listener), 0.1)
H A Dtest_buffered_proto.py67 asyncio.wait_for(client(addr), 5))
H A Dtest_subprocess.py132 task = asyncio.wait_for(task, 60.0)
150 task = asyncio.wait_for(task, support.LONG_TIMEOUT)
530 await asyncio.wait_for(transport._wait(), 5)
H A Dtest_locks.py536 if await cond.wait_for(predicate):
566 res = await cond.wait_for(lambda: [1, 2, 3])
570 await cond.wait_for(lambda: False)
759 await asyncio.wait_for(condition.wait(), timeout=0.5)
936 await asyncio.wait_for(sem.acquire(), timeout=1.0)
H A Dtest_queues.py212 await asyncio.wait_for(queue.get(), 0.1)
/third_party/python/Tools/scripts/
H A 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
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
H A Devent.h59 // wait_for() blocks until the event is signaled, or the timeout has been
61 // If the timeout was reached, then wait_for() return false.
66 MARL_NO_EXPORT inline bool wait_for(
71 // If the timeout was reached, then wait_for() return false.
114 MARL_NO_EXPORT inline bool wait_for(
159 bool Event::Shared::wait_for( in wait_for() function in marl::Event::Shared
162 if (!cv.wait_for(lock, duration, [&] { return signalled; })) { in wait_for()
203 bool Event::wait_for(const std::chrono::duration<Rep, Period>& duration) const { in wait_for() function in marl::Event
204 return shared->wait_for(duration); in wait_for()
H A Dconditionvariable.h53 // wait_for() blocks the current fiber or thread until the predicate is
58 MARL_NO_EXPORT inline bool wait_for(
150 bool ConditionVariable::wait_for( in wait_for() function in marl::ConditionVariable
/third_party/toybox/toys/pending/
H A 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()
/third_party/python/Lib/asyncio/
H A Dlocks.py285 async def wait_for(self, predicate): member in Condition
510 await self._cond.wait_for(
534 await self._cond.wait_for(lambda: self._state is not _BarrierState.FILLING)
H A Dstaggered.py87 # Use asyncio.wait_for() instead of asyncio.wait() here, so
91 await tasks.wait_for(previous_failed.wait(), delay)
H A Dtasks.py6 'wait', 'wait_for', 'as_completed', 'sleep',
426 async def wait_for(fut, timeout): function
473 # after wait_for() returns.
483 # after wait_for() returns.
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
H A Devent_test.cpp137 event.wait_for(duration); in TEST_P()
152 auto triggered = event.wait_for(duration); in TEST_P()
206 event.wait_for(std::chrono::milliseconds(j)); in TEST_P()
H A Dconditionvariable_test.cpp123 cv.wait_for(lock, std::chrono::milliseconds(j), [&] { in TEST_P()
/third_party/vk-gl-cts/external/vulkancts/vkscserver/
H A DvksCommon.hpp51 return f.wait_for(std::chrono::seconds(1)) == std::future_status::ready; in is_ready()
/third_party/lame/frontend/
H A Dparse.c607 wait_for(FILE * const fp, int lessmode) in wait_for() function
761 wait_for(fp, lessmode); in long_help()
793 wait_for(fp, lessmode); in long_help()
811 wait_for(fp, lessmode); in long_help()
838 wait_for(fp, lessmode); in long_help()
841 wait_for(fp, lessmode); in long_help()
867 wait_for(fp, lessmode); in long_help()
892 wait_for(fp, lessmode); in long_help()
896 wait_for(fp, lessmode); in long_help()
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/
H A DEGLReusableSync.cpp65 waitStatus = mCondVar.wait_for(mMutex, duration); in clientWait()
/third_party/skia/third_party/externals/angle2/src/libANGLE/
H A DWorkerThread.cpp128 return mFuture.wait_for(std::chrono::seconds(0)) == std::future_status::ready; in isReady()
/third_party/python/Lib/
H A Dthreading.py336 def wait_for(self, predicate, timeout=None): member in Condition
725 if not self._cond.wait_for(lambda : self._state != 0, timeout):
/third_party/python/Lib/multiprocessing/
H A Dsynchronize.py299 def wait_for(self, predicate, timeout=None): member in Condition
/third_party/python/Lib/test/
H A Dlock_tests.py604 result = cond.wait_for(lambda : state==4)
623 result = cond.wait_for(lambda : state==4, timeout=0.1)

Completed in 21 milliseconds

12