| /foundation/barrierfree/accessibility/frameworks/acfwk/src/ |
| H A D | accessibility_config_impl.cpp | 160 auto waitStatus = proxyConVar_.wait_for(lock, std::chrono::milliseconds(SA_CONNECT_TIMEOUT), in LoadAccessibilityService()
|
| /foundation/barrierfree/accessibility/frameworks/aafwk/src/ |
| H A D | accessible_ability_client_impl.cpp | 183 auto waitStatus = proxyConVar_.wait_for(lock, std::chrono::milliseconds(SA_CONNECT_TIMEOUT), in LoadAccessibilityService()
|
| /foundation/bundlemanager/bundle_framework/test/systemtest/common/bms/bms_install_system_test/ |
| H A D | bms_install_system_test.cpp | 95 if (future.wait_for(timeout) == std::future_status::timeout) { in GetResultMsg()
|
| /foundation/bundlemanager/bundle_tool/frameworks/src/ |
| H A D | bundle_command.cpp | 192 if (future.wait_for(span) == std::future_status::timeout) { in GetResultCode()
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/ |
| H A D | rs_uifirst_manager.cpp | 1615 notifyCv_.wait_for(lock, TIME_OUT, pred); in CheckAndWaitPreFirstLevelDrawableNotify()
|
| H A D | rs_render_service_connection.cpp | 306 }).wait_for(span); in ExecuteSynchronousTask()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_data_manager.cpp | 1692 if (std::future_status::ready == futureResult.wait_for(std::chrono::seconds(timeout))) { in QueryGeo()
|
| /foundation/communication/ipc/services/dbinder/dbinder_service/src/ |
| H A D | dbinder_service.cpp | 483 if (threadLockInfo->condition.wait_for(lock, std::chrono::seconds(WAIT_FOR_REPLY_MAX_SEC), in InvokerRemoteDBinder()
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| H A D | ipc_process_skeleton.cpp | 931 if (messageInfo->condition.wait_for(lock_unique, std::chrono::seconds(userWaitTime), in AddSendThreadInWait()
|
| /foundation/communication/netstack/frameworks/js/napi/http/http_exec/src/ |
| H A D | http_exec.cpp | 749 staticVariable_.conditionVariable.wait_for(l, std::chrono::seconds(CONDITION_TIMEOUT_S), [] { in AddCurlHandle()
|
| /foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | mediadatashare_unit_test.cpp | 54 cv_.wait_for(lock, std::chrono::seconds(INTERVAL), [this]() { return isSet_; }); in Wait()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 541 bool result = g_processCondition.wait_for(lock, std::chrono::seconds(waitTime), [&syncProcess]() { in WaitForSyncFinish()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 199 (void)cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [¬ify]() { in WaitUntilNotify()
|
| H A D | distributeddb_mock_sync_module_test.cpp | 1697 cv.wait_for(lock, std::chrono::seconds(5), [&callCount]() { // wait 5s in HWTEST_F()
|
| /foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/ |
| H A D | daudio_source_dev.cpp | 617 auto status = rpcWaitCond_.wait_for(lck, std::chrono::seconds(RPC_WAIT_SECONDS), [this, type]() { in WaitForRPC()
|
| /foundation/distributeddatamgr/pasteboard/interfaces/kits/napi/src/ |
| H A D | napi_systempasteboard.cpp | 227 if (pasteboardDelayWorker->cv.wait_for(lock, std::chrono::seconds(DELAY_TIMEOUT), in GetUnifiedData()
|
| /test/xts/hats/telephony/ril/hdi_v1.1_additional/ |
| H A D | hdf_ril_callback_common.cpp | 154 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond));
in WaitFor()
|
| /test/xts/hats/hdf/display/composer/unittest/ |
| H A D | hdi_composer_ut.cpp | 238 ret = vblankCondition_.wait_for(lck, std::chrono::milliseconds(ms), [=] { return hasVblank_; }); in WaitVblank()
|
| /third_party/node/test/fixtures/wpt/resources/ |
| H A D | testharness.js | 890 * `EventWatcher` will assert if an event occurs while there is no `wait_for`
932 // since the Promise's resolve handlers may call wait_for() which will
960 * return watcher.wait_for([ 'animationstart', 'animationend' ],
966 this.wait_for = function(types, options) {
979 // or during a subsequent call to wait_for, ignore it.
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_tasks.py | 403 async def wait_for(fut): function
407 task = self.new_task(self.loop, wait_for(fut))
410 '<Task .* wait_for=%s>' % re.escape(repr(fut)))
|
| /foundation/window/window_manager/window_scene/screen_session_manager/src/ |
| H A D | screen_session_manager.cpp | 1852 if (screenOnCV_.wait_for(lock, std::chrono::milliseconds(CV_WAIT_SCREENON_MS)) == std::cv_status::timeout) { in BlockScreenOnByCV()
1864 if (screenOffCV_.wait_for(lock, std::chrono::milliseconds(screenOffDelay_)) == std::cv_status::timeout) { in BlockScreenOffByCV()
5169 if (scbSwitchCV_.wait_for(lock, std::chrono::milliseconds(CV_WAIT_SCBSWITCH_MS)) in ScbClientDeathCallback()
|
| /third_party/python/Lib/test/ |
| H A D | _test_multiprocessing.py | 1563 result = cond.wait_for(lambda : state.value==4)
1578 result = cond.wait_for(lambda : state.value==0)
1597 result = cond.wait_for(lambda : state.value==4, timeout=expected)
|
| /base/telephony/core_service/test/unittest/tel_ril_gtest/ |
| H A D | tel_ril_test_util.cpp | 2362 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/ |
| H A D | distributed_sched_stub_test.cpp | 87 taskDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in WaitHandlerTaskDone()
|
| /foundation/bundlemanager/bundle_framework/test/systemtest/common/bms/bms_client_system_test/ |
| H A D | bundle_mgr_client_system_test.cpp | 103 if (future.wait_for(timeout) == std::future_status::timeout) { in GetResultMsg()
|