| /ohos5.0/foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | condition_variable.h | 50 bool wait_until( in wait_until() function
54 if (wait_until(lk, tp) == cv_status::timeout) { in wait_until()
62 …cv_status wait_until(std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& … in wait_until() function
77 … return wait_until(lk, std::chrono::steady_clock::now() + sleepTime, std::forward<Pred>(pred)); in wait_for()
|
| /ohos5.0/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| H A D | future.h | 51 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept in wait_until() function
54 …return m_cv.wait_until(lk, tp, [this] { return get_derived().has_value(); }) ? future_status::read… in wait_until()
187 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept
189 return m_state->wait_until(tp);
|
| /ohos5.0/base/telephony/call_manager/services/spam_call/src/ |
| H A D | time_wait_helper.cpp | 47 … if (cv_.wait_until(lock, now + std::chrono::seconds(waitTime_)) == ffrt::cv_status::timeout) { in WaitForResult()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_select.cpp | 48 wakeUpCondition_.wait_until(lockGuard, to); in Poll()
|
| /ohos5.0/foundation/multimedia/ringtone_library/test/unittest/ringtone_unittest_utils/src/ |
| H A D | ringtone_unittest_utils.cpp | 86 …callback->condVar_.wait_until(lock, std::chrono::system_clock::now() + std::chrono::seconds(waitSe… in WaitForCallback()
|
| /ohos5.0/base/update/updateservice/frameworks/js/napi/session/src/ |
| H A D | napi_session.cpp | 66 … conditionVariable_.wait_until(lock, now + 40000ms, [this] { return asyncExecuteComplete_; }); in ExecuteWork()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor.h | 106 … condition_.wait_until(lock, std::chrono::steady_clock::now() + TIME_OUT, [this]() { in Run()
|
| H A D | priority_queue.h | 52 popCv_.wait_until(lock, waitTme); in Pop()
|
| /ohos5.0/foundation/arkui/ace_engine/adapter/ohos/osal/ |
| H A D | resource_theme_style.cpp | 238 … future_.wait_until(std::chrono::system_clock::now() + std::chrono::milliseconds(WAIT_FOR_TIME)); in CheckThemeStyleLoaded()
|
| /ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audiopolicy/test/unittest/volume_change_test/src/ |
| H A D | audio_volume_change_unit_test.cpp | 65 g_condVar.wait_until(lock, std::chrono::system_clock::now() + std::chrono::minutes(1), in WaitForCallback()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/ |
| H A D | rs_thread_looper_impl.cpp | 61 cv_.wait_until(lock, time, pred); in WaitForMessage()
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor.h | 120 … condition_.wait_until(lock, std::chrono::steady_clock::now() + TIME_OUT, [this]() { in Run()
|
| H A D | priority_queue.h | 51 popCv_.wait_until(lock, waitTme); in Pop()
|
| /ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_csync.cpp | 373 EXPECT_EQ(static_cast<int>(cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms)), in WaitUntilTimeoutTest()
405 … EXPECT_TRUE(!cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms, [&] { return flag; })); in WaitUtilFlagTest_1()
432 … EXPECT_TRUE(cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms, [&] { return flag; })); in WaitUtilFlagTest_2()
|
| /ohos5.0/foundation/arkui/ace_engine/adapter/ohos/entrance/timepicker/ |
| H A D | timepicker_haptic_controller.cpp | 148 threadCv_.wait_until(lock, startTime + 40ms); in ThreadLoop()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/sync/ |
| H A D | wait_queue.cpp | 63 if (wn->cv.wait_until(nl, tp) == std::cv_status::timeout) { in ThreadWaitUntil()
|
| /ohos5.0/foundation/window/window_manager/test/systemtest/wms/ |
| H A D | window_visibility_info_test.cpp | 179 if (!cv_.wait_until(lock, now + std::chrono::milliseconds(WAIT_ASYNC_MS_TIME_OUT), in WaitForCallback()
|
| H A D | window_nointeraction_listener_test.cpp | 124 …if (!cv_.wait_until(lock, now + std::chrono::milliseconds(NO_INTERACTION_LISTENER_TEST_WATCHER_TIM… in WaitForCallback()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_dfx/src/ |
| H A D | dfx_worker.cpp | 226 workCv_.wait_until(lock, GetWaitTime(), in WaitForTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | task_scheduler.h | 162 condition_.wait_until(lock, time); in Loop()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/stream_tunnel/standard/ |
| H A D | stream_tunnel.cpp | 221 if (!finishCV_.wait_until(l, timeout, [this] { in WaitForAllBufferReturned()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | connection_pool.cpp | 656 while (count < total_ && cond_.wait_until(lock, time, [this]() { in AcquireAll()
683 … while (failed = !func(nodes), failed && cond_.wait_until(lock, time) != std::cv_status::timeout) { in AcquireAll()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_unittest_utils/src/ |
| H A D | medialibrary_unittest_utils.cpp | 305 …callback->condVar_.wait_until(lock, std::chrono::system_clock::now() + std::chrono::seconds(waitSe… in WaitForCallback()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/source_node/ |
| H A D | source_node.cpp | 360 if (!rbcv.wait_until(l, timeout, [this] { in DistributeBuffers()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/ |
| H A D | rs_uni_render_thread.cpp | 502 return displayNodeBufferReleasedCond_.wait_until(lock, std::chrono::system_clock::now() + in WaitUntilDisplayNodeBufferReleased()
|