Home
last modified time | relevance | path

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

12345678910>>...20

/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...]
/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()
/foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/
H A Ddevice_networking_collect_test.cpp82 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
122 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
152 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
184 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
221 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
256 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
292 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
485 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
515 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
543 caseDoneCondition_.wait_for(loc in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/utils/
H A Dtimeout_timer.cpp69 waitSignal_.wait_for(waitLock, std::chrono::milliseconds(TIMER_TIMEOUT)); in StartTimer()
88 waitSignal_.wait_for(waitLock, std::chrono::milliseconds(TIMER_TIMEOUT)); in StopTimer()
114 cancelSignal_.wait_for(taskLock, std::chrono::seconds(timeout_)); in MainLoop()
/kernel/linux/linux-5.10/drivers/gpu/drm/v3d/
H A Dv3d_mmu.c40 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all()
52 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all()
59 ret = wait_for(!(V3D_READ(V3D_MMUC_CONTROL) & in v3d_mmu_flush_all()
/kernel/linux/linux-6.6/drivers/gpu/drm/v3d/
H A Dv3d_mmu.c40 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all()
52 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all()
59 ret = wait_for(!(V3D_READ(V3D_MMUC_CONTROL) & in v3d_mmu_flush_all()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dcondition_variable.cpp54 auto status = cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs)); in WaitFor()
64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_stability_test/
H A Dui_extension_stability_test.cpp157 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilProcessCreated()
168 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilProcessDied()
179 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in CheckProcessNotDied()
191 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilAbilityForeground()
203 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilAbilityBackground()
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_policy_callback.cpp180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
290 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/
H A Dut_net_policy_callback.cpp180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
290 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_connect_module_test/
H A Dui_extension_connect_module_test.cpp157 auto waitStatus = connection->connectCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilConnectDone()
169 auto waitStatus = connection->connectCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilDisConnectDone()
180 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilProcessCreated()
191 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilProcessDied()
202 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in CheckProcessNotDied()
214 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilAbilityForeground()
226 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilAbilityBackground()
/foundation/bundlemanager/bundle_tool/frameworks/src/
H A Dstatus_receiver_impl.cpp62 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultCode()
72 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultMsg()
/kernel/linux/linux-6.6/fs/fscache/
H A Dcookie.c383 struct fscache_cookie *wait_for) in fscache_wait_on_collision()
385 enum fscache_cookie_state *statep = &wait_for->state; in fscache_wait_on_collision()
387 wait_var_event_timeout(statep, fscache_cookie_is_dropped(wait_for), in fscache_wait_on_collision()
389 if (!fscache_cookie_is_dropped(wait_for)) { in fscache_wait_on_collision()
391 candidate->debug_id, wait_for->debug_id); in fscache_wait_on_collision()
392 wait_var_event(statep, fscache_cookie_is_dropped(wait_for)); in fscache_wait_on_collision()
403 struct fscache_cookie *cursor, *wait_for = NULL; in fscache_hash_cookie() local
416 wait_for = fscache_get_cookie(cursor, in fscache_hash_cookie()
428 if (wait_for) { in fscache_hash_cookie()
429 fscache_wait_on_collision(candidate, wait_for); in fscache_hash_cookie()
382 fscache_wait_on_collision(struct fscache_cookie *candidate, struct fscache_cookie *wait_for) fscache_wait_on_collision() argument
[all...]
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessible_ability_channel.cpp100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByAccessibilityId()
153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText()
206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo()
258 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch()
372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction()
428 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindow()
502 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindows()
575 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition()
623 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SendSimulateGesture()
657 ffrt::future_status wait = syncFuture.wait_for(st in SetTargetBundleName()
[all...]
/foundation/multimedia/player_framework/frameworks/native/player/test/unittest/src/
H A Dplayer_mock.cpp59 condVarPrepare_.wait_for(lockPrepare, std::chrono::seconds(waitsecond)); in PrepareSync()
71 condVarPlay_.wait_for(lockPlay, std::chrono::seconds(waitsecond)); in PlaySync()
83 condVarPause_.wait_for(lockPause, std::chrono::seconds(waitsecond)); in PauseSync()
95 condVarStop_.wait_for(lockStop, std::chrono::seconds(waitsecond)); in StopSync()
107 condVarReset_.wait_for(lockReset, std::chrono::seconds(waitsecond)); in ResetSync()
119 condVarSeek_.wait_for(lockSeek, std::chrono::seconds(waitsecond)); in SeekSync()
131 condVarSpeed_.wait_for(lockSpeed, std::chrono::seconds(waitsecond)); in SpeedSync()
143 condVarTrackDone_.wait_for(lockTrackDone, std::chrono::seconds(waitsecond)); in TrackSync()
158 condVarTrackInfoUpdate_.wait_for(lock, std::chrono::seconds(waitsecond), [this]() { in TrackInfoUpdateSync()
251 condVarText_.wait_for(loc in SubtitleTextUpdate()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_hogp.cpp171 if (cvfull_.wait_for(lock, in SendGetReport()
211 if (cvfull_.wait_for(lock, in SendSetReport()
373 if (cvfull_.wait_for(lock, in GetPnpInformation()
403 if (cvfull_.wait_for(lock, in GetHidInformation()
441 if (cvfull_.wait_for(lock, in GetBatteryInformation()
460 if (cvfull_.wait_for(lock, in GetHidReportMap()
492 if (cvfull_.wait_for(lock, in GetExternalRptRefInfo()
514 if (cvfull_.wait_for(lock, in GetExternalCfgInfo()
550 if (cvfull_.wait_for(lock, in GetHidReport()
662 if (cvfull_.wait_for(loc in SetInputReportNotification()
[all...]
/foundation/barrierfree/accessibility/frameworks/aafwk/src/
H A Daccessible_ability_channel_client.cpp93 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo()
149 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition()
193 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction()
263 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByAccessibilityId()
351 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText()
392 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch()
/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()
/kernel/linux/linux-5.10/drivers/mmc/host/
H A Dsh_mmcif.c234 enum sh_mmcif_wait_for wait_for; member
588 host->state, host->wait_for); in sh_mmcif_error_manage()
592 host->state, host->wait_for); in sh_mmcif_error_manage()
596 host->state, host->wait_for); in sh_mmcif_error_manage()
628 host->wait_for = MMCIF_WAIT_FOR_READ; in sh_mmcif_single_read()
652 host->wait_for = MMCIF_WAIT_FOR_READ_END; in sh_mmcif_read_block()
668 host->wait_for = MMCIF_WAIT_FOR_MREAD; in sh_mmcif_multi_read()
708 host->wait_for = MMCIF_WAIT_FOR_WRITE; in sh_mmcif_single_write()
732 host->wait_for = MMCIF_WAIT_FOR_WRITE_END; in sh_mmcif_write_block()
748 host->wait_for in sh_mmcif_multi_write()
[all...]
/kernel/linux/linux-6.6/drivers/mmc/host/
H A Dsh_mmcif.c233 enum sh_mmcif_wait_for wait_for; member
589 host->state, host->wait_for); in sh_mmcif_error_manage()
593 host->state, host->wait_for); in sh_mmcif_error_manage()
597 host->state, host->wait_for); in sh_mmcif_error_manage()
629 host->wait_for = MMCIF_WAIT_FOR_READ; in sh_mmcif_single_read()
653 host->wait_for = MMCIF_WAIT_FOR_READ_END; in sh_mmcif_read_block()
669 host->wait_for = MMCIF_WAIT_FOR_MREAD; in sh_mmcif_multi_read()
709 host->wait_for = MMCIF_WAIT_FOR_WRITE; in sh_mmcif_single_write()
733 host->wait_for = MMCIF_WAIT_FOR_WRITE_END; in sh_mmcif_write_block()
749 host->wait_for in sh_mmcif_multi_write()
[all...]
/foundation/barrierfree/accessibility/services/test/xts/src/asac_register_elemnt_operator_test/
H A Dasac_ability_channel_benchmark.cpp100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByA11yBenchmarkId()
153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText()
206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo()
258 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch()
372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction()
428 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindow()
502 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindows()
575 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition()
623 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SendSimulateGesture()
/arkcompiler/runtime_core/static_core/plugins/ets/tests/debugger/src/arkdb/
H A Ddebug_connection.py66 async def wait_for(self, event_type: typing.Type[T], buffer_size=10) -> AsyncGenerator[Proxy[T], None]: member in ArkConnection
69 async with self._conn.wait_for(event_type, buffer_size) as cmd_proxy:
79 async with self.wait_for(event_type, buffer_size) as proxy:
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_condition.cpp110 cond.wait_for(lck, 100ms, [&] { return a == 1; }); in HWTEST_F()
135 status = cond.wait_for(lck, 100ms); in HWTEST_F()
150 status = cond.wait_for(lck, 100ms); in HWTEST_F()
/foundation/multimedia/player_framework/frameworks/native/audio_haptic/
H A Daudio_haptic_vibrator_impl.cpp264 (void)vibrateCV_.wait_for(lock, std::chrono::milliseconds(patternTime), in StartVibrateForSoundPool()
287 (void)vibrateCV_.wait_for(lock, std::chrono::milliseconds(patternTime), in RunVibrationPatterns()
299 (void)vibrateCV_.wait_for(lock, std::chrono::milliseconds(lastPatternDuration), in RunVibrationPatterns()
352 (void)vibrateCV_.wait_for(lock, std::chrono::milliseconds(patternTime), in StartVibrateForAVPlayer()
370 (void)vibrateCV_.wait_for(lock, std::chrono::milliseconds(MILLISECONDS_FOR_ONE_SECOND), in StartVibrateForAVPlayer()

Completed in 18 milliseconds

12345678910>>...20