| /base/inputmethod/imf/common/include/ |
| H A D | block_queue.h | 49 cv_.wait_for(lock, std::chrono::milliseconds(timeout_), [&data, this]() { return data == queues_.front(); }); in Wait()
|
| /base/hiviewdfx/hiview/plugins/faultlogger/test/common/ |
| H A D | faultevent_listener.cpp | 72 if (keyWordCheckCondition.wait_for(lock, std::chrono::seconds(8), flagCheckFunc)) { in CheckKeyWords()
|
| /base/hiviewdfx/faultloggerd/test/unittest/panic_handler/ |
| H A D | rustpanic_listener.cpp | 75 if (keyWordCheckCondition.wait_for(lock, std::chrono::seconds(6), flagCheckFunc)) { in CheckKeywordInReasons()
|
| /base/request/request/frameworks/js/napi/include/ |
| H A D | block_queue.h | 48 cv_.wait_for(lock, std::chrono::milliseconds(timeout_), [&data, this]() { return IsReady(data); }); in Wait()
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | none_io_waiter.cpp | 50 (void)condition_.wait_for(lock, (duration > oneYear) ? oneYear : duration, [this] { return this->pred_; }); in WaitFor()
|
| /base/telephony/sms_mms/frameworks/js/napi/src/ |
| H A D | napi_mms_pdu_helper.cpp | 43 if (cv_.wait_for(lock, std::chrono::seconds(timeoutSecond)) == std::cv_status::timeout) { in WaitForResult()
|
| /base/telephony/core_service/test/unittest/core_service_gtest/ |
| H A D | core_service_test_helper.cpp | 41 if (cv_.wait_for(lock, std::chrono::seconds(timeoutSecond)) == std::cv_status::timeout) { in WaitForResult()
|
| /base/telephony/sms_mms/test/gtest/ |
| H A D | sms_mms_test_helper.cpp | 40 if (cv_.wait_for(lock, std::chrono::seconds(timeoutSecond)) == std::cv_status::timeout) { in WaitForResult()
|
| /foundation/ai/ai_engine/services/common/platform/semaphore/source/ |
| H A D | semaphore.cpp | 47 if (!condition_.wait_for(lock, milliseconds_type(milliSeconds), [&]()->bool { return count_ > 0; })) { in Wait()
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/ |
| H A D | cast_timer.cpp | 42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/ |
| H A D | cast_timer.cpp | 42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
|
| /foundation/ability/ability_runtime/frameworks/native/appkit/ability_delegator/ |
| H A D | iability_stage_monitor.cpp | 65 if (!cvMatch_.wait_for(matchLock, std::chrono::milliseconds(realTime), condition)) { in WaitForAbilityStage()
|
| /foundation/communication/nfc/services/src/utils/ |
| H A D | nfc_watch_dog.cpp | 39 conditionVariable_.wait_for(lock, std::chrono::milliseconds(timeout_), [this] { return canceled_; });
in MainLoop()
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | block_data.h | 39 cv_.wait_for(lock, Dur(INTERVAL), [this]() { in GetValue()
|
| /foundation/filemanagement/dfs_service/utils/inner_api/ |
| H A D | block_object.h | 44 cv_.wait_for(lock, std::chrono::milliseconds(interval_), [this]() { return isSet_; }); in GetValue()
|
| /foundation/filemanagement/dfs_service/utils/ffrt/src/ |
| H A D | ffrt_timer.cpp | 48 sleepCv_.wait_for(lock, std::chrono::milliseconds(interval), [this]() { return !this->running_; }); in Start()
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_ssl.py | 275 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 D | test_sock_lowlevel.py | 260 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)
|
| /base/telephony/sms_mms/services/sms/ |
| H A D | sms_misc_manager.cpp | 356 if (condVar_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in SendDataToRil()
376 if (condVar_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in GetModemCBRange()
483 if (condVar_.wait_for(lock, std::chrono::seconds(TIME_OUT_SECOND)) == std::cv_status::timeout) { in SetSmscAddr()
505 if (condVar_.wait_for(lock, std::chrono::seconds(TIME_OUT_SECOND)) == std::cv_status::timeout) { in GetSmscAddr()
|
| /foundation/multimedia/av_codec/test/unittest/hcodec_test/helper/ |
| H A D | tester_capi.cpp | 364 bool ret = inputCond_.wait_for(lk, chrono::milliseconds(opt_.timeout), [this] { in WaitForInput()
403 bool ret = inputCond_.wait_for(lk, chrono::milliseconds(opt_.timeout), [this] { in WaitForInput()
438 bool waitRes = outputCond_.wait_for(lk, chrono::milliseconds(opt_.timeout), [this] { in WaitForOutput()
469 bool waitRes = outputCond_.wait_for(lk, chrono::milliseconds(opt_.timeout), [this] { in WaitForOutput()
|
| /base/location/frameworks/native/locator_sdk/source/ |
| H A D | geo_convert_callback_host.cpp | 87 auto waitStatus = condition_.wait_for( in GetResult()
|
| /base/global/i18n/services/src/ |
| H A D | i18n_service_ability_load_manager.cpp | 78 auto isLoadSuccess = loadStateCondition.wait_for(lock, std::chrono::milliseconds(I18N_LOAD_SA_TIMEOUT_MS), [this] { in WaitLoadStateChange()
|
| /base/customization/enterprise_device_management/interfaces/inner_api/common/src/ |
| H A D | edm_load_manager.cpp | 75 auto wait = locatorCon_.wait_for(lock, std::chrono::milliseconds(EDM_LOADSA_TIMEOUT_MS), [this] { in WaitLoadStateChange()
|
| /base/powermgr/power_manager/services/zidl/src/ |
| H A D | power_mgr_async_reply.cpp | 57 cv_.wait_for(lck, std::chrono::milliseconds(timeout), [this]() {
in WaitForAsyncReply()
|
| /base/powermgr/power_manager/test/systemtest/src/ |
| H A D | power_level_event_system_test_on.cpp | 110 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F()
|