Home
last modified time | relevance | path

Searched refs:wait_for (Results 51 - 75 of 512) sorted by relevance

12345678910>>...21

/base/account/os_account/services/accountmgr/test/unittest/account_iam/
H A Daccount_iam_manager_test.cpp583 testCallback->cv.wait_for( in HWTEST_F()
605 testCallback->cv.wait_for( in HWTEST_F()
613 testCallback->cv.wait_for( in HWTEST_F()
703 testCallback->cv.wait_for( in HWTEST_F()
711 testCallback->cv.wait_for( in HWTEST_F()
734 testCallback->cv.wait_for( in HWTEST_F()
742 testCallback->cv.wait_for( in HWTEST_F()
/third_party/python/Lib/test/test_asyncio/
H A Dtest_sslproto.py281 asyncio.wait_for(client(srv.addr),
344 asyncio.wait_for(client(srv.addr),
441 asyncio.wait_for(client(srv.addr),
496 await asyncio.wait_for(
502 asyncio.wait_for(client(srv.addr),
584 await asyncio.wait_for(
625 await asyncio.wait_for(
H A Dtest_futures2.py51 self.assertIn('...', repr(await asyncio.wait_for(func(), timeout=10)))
/third_party/python/Lib/asyncio/
H A Dlocks.py285 async def wait_for(self, predicate): member in Condition
510 await self._cond.wait_for(
534 await self._cond.wait_for(lambda: self._state is not _BarrierState.FILLING)
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
H A Devent_test.cpp137 event.wait_for(duration); in TEST_P()
152 auto triggered = event.wait_for(duration); in TEST_P()
206 event.wait_for(std::chrono::milliseconds(j)); in TEST_P()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/
H A Dmock_bundle_status.cpp34 std::future_status status = future.wait_for(std::chrono::seconds(1)); in GetResultCode()
H A Dmock_status_receiver.cpp48 if (future.wait_for(std::chrono::seconds(WAIT_TIME)) == std::future_status::ready) { in GetResultCode()
/foundation/communication/netmanager_base/utils/common_utils/include/
H A Dtiny_count_down_latch.h37 return conditionVar_.wait_for(lk, time, [this] { return count_ == 0; }); in Await()
/foundation/communication/netmanager_base/test/netstatsmanager/unittest/net_stats_manager_test/
H A Dnet_stats_callback_test.cpp36 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dsemaphore_utils.cpp36 bool result = cv_.wait_for(lock, std::chrono::seconds(waitSecond), in WaitSemaphore()
/base/telephony/core_service/services/sim/src/
H A Dicc_dialling_numbers_manager.cpp190 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UpdateIccDiallingNumbers()
219 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in DelIccDiallingNumbers()
247 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AddIccDiallingNumbers()
277 processWait_.wait_for( in QueryIccDiallingNumbers()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/src/
H A Dnotify_test.cpp96 if (obs->condition_.wait_for(lock, 2s) == cv_status::no_timeout) { in CheckFileNotify()
148 if (obs->condition_.wait_for(lock, 2s) == cv_status::no_timeout) { in CheckAlbumNotify()
185 if (obs->condition_.wait_for(lock, 2s) == cv_status::no_timeout) { in CheckCloseAssetNotify()
205 if (obs->condition_.wait_for(lock, 1s) == cv_status::no_timeout || in CheckInfo()
/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dfuture.h43 future_status wait_for(const std::chrono::duration<Rep, Period>& waitTime) const noexcept
46 return m_cv.wait_for(lk, waitTime, [this] { return get_derived().has_value(); }) ? future_status::ready :
181 future_status wait_for(const std::chrono::duration<Rep, Period>& waitTime) const noexcept
183 return m_state->wait_for(waitTime);
/base/hiviewdfx/faultloggerd/test/unittest/crash_exception/
H A Dcrash_exception_listener.cpp64 if (keyWordCheckCondition.wait_for(lock, std::chrono::seconds(6), flagCheckFunc)) { in CheckKeywordInReasons()
/foundation/bundlemanager/bundle_tool/frameworks/src/
H A Dquick_fix_status_callback_host_impl.cpp57 if (future.wait_for(std::chrono::seconds(WAITTING_TIME)) == std::future_status::ready) { in GetResultCode()
/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/
H A Dnone_io_waiter.cpp49 (void)condition_.wait_for(lock, (duration > oneYear) ? oneYear : duration, [this] { return this->pred_; }); in WaitFor()
/foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/transaction/
H A Drs_render_thread_client.cpp48 cv->wait_for(lock, std::chrono::nanoseconds(task->GetTimeout())); in ExecuteSynchronousTask()
/foundation/multimedia/av_codec/test/unittest/video_test/video_test/capbilities/sample_buffer_queue/
H A Dsample_buffer_queue.cpp36 (void)cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), [this]() { return !bufferQueue_.empty(); }); in DequeueBuffer()
/foundation/communication/netmanager_base/test/netconnmanager/unittest/net_conn_manager_test/
H A Dnet_detection_callback_test.cpp37 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
/foundation/distributeddatamgr/pasteboard/framework/framework/include/common/
H A Dblock_object.h37 cv_.wait_for(lock, std::chrono::milliseconds(interval_), [this]() { in GetValue()
/third_party/vk-gl-cts/external/vulkancts/vkscserver/
H A DvksCommon.hpp51 return f.wait_for(std::chrono::seconds(1)) == std::future_status::ready; in is_ready()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/
H A Dblocking_queue.h125 cvEmpty_.wait_for(lock, timeoutMs, [this] { return !isActive_ || !que_.empty(); }); in Pop()
142 cvEmpty_.wait_for(lock, std::chrono::milliseconds(timeoutMs), in GetBackElement()
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/src/
H A Dav_sender_engine_adapter.cpp209 auto status = chnCreatedCondVar_.wait_for(lock, std::chrono::milliseconds(WAIT_TIMEOUT_MS), in WaitForChannelCreated()
225 auto status = transStartedCondVar_.wait_for(lock, std::chrono::milliseconds(WAIT_TIMEOUT_MS), in WaitForAVTransStarted()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp501 cond.wait_for(lck, 100ms, [&] { return a == 1; }); in HWTEST_F()
508 cond.wait_for(lck, 150ms, [&] { return a == 2; }); in HWTEST_F()
541 cv.wait_for(lk, 1us); in HWTEST_F()
550 cv.wait_for(lk, 1us); in HWTEST_F()
692 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::timeout)); in WaitForTest_1()
724 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::no_timeout)); in WaitForTest_2()
746 EXPECT_TRUE(!cv.wait_for(lk, 30ms, [&] { return flag; })); in WaitForTest_3()
773 EXPECT_TRUE(cv.wait_for(lk, 30ms, [&] { return flag; })); in WaitForTest_4()
/base/inputmethod/imf/frameworks/js/napi/inputmethodability/
H A Dffrt_block_queue.h49 cv_.wait_for(lock, std::chrono::milliseconds(timeout_), [&data, this]() { return data == queues_.front(); }); in Wait()

Completed in 15 milliseconds

12345678910>>...21