| /foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/ |
| H A D | hid_host_hogp.cpp | 171 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 D | accessible_ability_channel_client.cpp | 93 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 D | fsck.c | 250 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()
|
| /base/telephony/core_service/services/sim/src/ |
| H A D | sim_sms_controller.cpp | 152 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UpdateSmsIcc()
181 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in DelSmsIcc()
208 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AddSmsToIcc()
241 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_TEN_SECOND)) == std::cv_status::timeout) { in ObtainAllSmsOfIcc()
|
| H A D | esim_file.cpp | 58 if (openChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in SyncOpenChannel()
76 if (openChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in SyncOpenChannel()
94 if (closeChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in SyncCloseChannel()
118 if (!getEidCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in ObtainEid()
137 if (!allProfileInfoCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in GetEuiccProfileInfoList()
156 if (!euiccInfo1Cv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in GetEuiccInfo()
676 if (!disableProfileCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in DisableProfile()
696 if (!smdsAddressCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in ObtainSmdsAddress()
716 if (!rulesAuthTableCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM),
in ObtainRulesAuthTable()
736 if (!euiccChallengeCv_.wait_for(loc in ObtainEuiccChallenge()
[all...] |
| /base/msdp/device_status/test/unittest/frameworks/src/ |
| H A D | interaction_manager_test.cpp | 345 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in EnableCooperate()
665 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F()
873 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F()
942 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F()
1104 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
1145 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
1194 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
1241 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
1291 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
1335 ASSERT_TRUE(futureFlag.wait_for(st in HWTEST_F()
[all...] |
| /foundation/barrierfree/accessibility/services/test/xts/src/asac_register_elemnt_operator_test/ |
| H A D | asac_ability_channel_benchmark.cpp | 100 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()
|
| /base/account/os_account/frameworks/account_iam/test/unittest/src/ |
| H A D | account_iam_callback_service_test.cpp | 111 testCallback->cv.wait_for(
in HWTEST_F()
133 testCallback->cv.wait_for(
in HWTEST_F()
141 testCallback->cv.wait_for(
in HWTEST_F()
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_condition.cpp | 110 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/av_codec/services/engine/codec/video/hcodec/ |
| H A D | msg_handle_loop.cpp | 83 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
131 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
| H A D | msg_handle_loop.cpp | 84 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
133 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
| /foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | condition_variable.h | 68 cv_status wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleep_time) noexcept
74 bool wait_for(
|
| /foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcamerahdf/ |
| H A D | dcamera_hdf_operate.cpp | 97 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] { in WaitLoadCameraService()
113 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] { in WaitLoadProviderService()
|
| /foundation/distributedhardware/distributed_audio/services/audiohdiproxy/src/ |
| H A D | daudio_hdf_operate.cpp | 96 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] {
in WaitLoadService()
109 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] {
in WaitLoadService()
|
| /foundation/filemanagement/dfs_service/utils/system/include/ |
| H A D | dfsu_thread.h | 66 sleepCv_.wait_for(lock, std::chrono::milliseconds(interval), [this]() { return !this->running_; }); in RunLoop()
91 sleepCv_.wait_for(lock, std::chrono::milliseconds(duration), [this]() { return !this->running_; }); in RunLoopFlexible()
|
| /foundation/multimedia/player_framework/frameworks/native/audio_haptic/ |
| H A D | audio_haptic_vibrator_impl.cpp | 264 (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()
|
| /foundation/communication/netmanager_ext/test/mdnsmanager/unittest/mdns_manager_test/ |
| H A D | mdns_manager_test.cpp | 213 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_register == TIME_TWO_MS; })) { in DoTestForMdnsClient()
218 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_found >= TIME_FOUR_MS; })) { in DoTestForMdnsClient()
222 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_resolve >= TIME_ONE_MS; })) { in DoTestForMdnsClient()
226 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_resolve >= TIME_TWO_MS; })) { in DoTestForMdnsClient()
231 if (!g_cv.wait_for(lock, std::chrono::seconds(TIME_FIVE_MS), []() { return g_lost >= TIME_ONE_MS; })) { in DoTestForMdnsClient()
|
| /base/account/os_account/frameworks/domain_account/test/moduletest/src/ |
| H A D | domain_account_client_mock_plugin_so_module_test.cpp | 406 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
448 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
487 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
578 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
623 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
681 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
761 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
830 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
|
| /foundation/window/window_manager/window_scene/test/dms_unittest/ |
| H A D | screen_session_ability_connection_test.cpp | 92 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
167 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
309 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
341 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
383 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
425 static_cast<void>(connectedCv_.wait_for(lock, std::chrono::milliseconds(EXTENSION_CONNECT_OUT_TIME))); in HWTEST_F()
|
| /base/msdp/device_status/test/unittest/intention/drag/src/ |
| H A D | drag_manager_test.cpp | 486 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
517 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
549 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
585 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
623 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
660 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
695 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
730 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
765 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
800 EXPECT_TRUE(futureFlag.wait_for(st in HWTEST_F()
[all...] |
| /base/print/print_fwk/services/print_service/src/ |
| H A D | thread_sync_wait.cpp | 24 waitCondition.wait_for(lock, std::chrono::milliseconds(timeout)); in Wait()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
| H A D | kv_store_observer_impl.cpp | 125 waitChangeCv_.wait_for(waitChangeLock, std::chrono::seconds(timeout), waitChangeFunc); in WaitUntilReachChangeCount()
176 waitChangeCv_.wait_for(waitRecordsLock, std::chrono::seconds(timeout), waitRecordsFunc); in WaitUntilReachRecordCount()
|
| /foundation/filemanagement/storage_service/services/storage_daemon/crypto/src/ |
| H A D | iam_client.cpp | 86 iamCon_.wait_for(lock, std::chrono::seconds(GET_SEC_TIMEOUT), [this] { in GetSecureUid()
124 iamCon_.wait_for(lock, std::chrono::seconds(GET_SEC_TIMEOUT), in GetSecUserInfo()
|
| /foundation/filemanagement/app_file_service/services/backup_sa/src/module_ipc/ |
| H A D | svc_backup_connection.cpp | 130 if (condition_.wait_for(lock, std::chrono::seconds(WAIT_TIME), callback)) { in DisconnectBackupExtAbility()
140 if (waitCondition_.wait_for(lock, std::chrono::seconds(WAIT_TIME), in WaitDisconnectDone()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| H A D | conditionvariable.h | 53 // 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
|