Home
last modified time | relevance | path

Searched refs:cv (Results 1 - 25 of 60) sorted by relevance

123

/foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/transaction/
H A Drs_render_thread_client.cpp39 auto cv = std::make_shared<std::condition_variable>(); in ExecuteSynchronousTask() local
41 renderThread.PostTask([task, cv, &renderThread]() { in ExecuteSynchronousTask()
46 cv->notify_all(); in ExecuteSynchronousTask()
48 cv->wait_for(lock, std::chrono::nanoseconds(task->GetTimeout())); in ExecuteSynchronousTask()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp261 ffrt::condition_variable cv; in HWTEST_F() member
278 ffrt::condition_variable* cvAddr = &m.cv; in HWTEST_F()
526 ffrt::condition_variable cv; in HWTEST_F() local
532 cv.notify_one(); in HWTEST_F()
541 cv.wait_for(lk, 1us); in HWTEST_F()
550 cv.wait_for(lk, 1us); in HWTEST_F()
557 cv.notify_one(); in HWTEST_F()
565 static void NotifyOneTest(ffrt::mutex& mtx, ffrt::condition_variable& cv) in NotifyOneTest() argument
573 cv.wait(lk, [&] { return flag; }); in NotifyOneTest()
587 cv in NotifyOneTest()
596 WaitUntilTimeoutTest(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitUntilTimeoutTest() argument
626 WaitUtilFlagTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitUtilFlagTest_1() argument
656 WaitUtilFlagTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitUtilFlagTest_2() argument
684 WaitForTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitForTest_1() argument
712 WaitForTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitForTest_2() argument
736 WaitForTest_3(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitForTest_3() argument
765 WaitForTest_4(ffrt::mutex& mtx, ffrt::condition_variable& cv) WaitForTest_4() argument
796 ffrt::condition_variable cv; HWTEST_F() local
[all...]
/foundation/multimedia/audio_framework/frameworks/native/audiocapturer/test/unittest/capturer_test/src/
H A Daudio_fast_capturer_unit_test.cpp98 std::condition_variable cv; in HWTEST_F() local
100 cb->Install([&count, &audioCapturer, &mutex, &cv](size_t length) { in HWTEST_F()
102 cv.notify_one(); in HWTEST_F()
124 cv.wait_for(lock, 1s, [&count] { in HWTEST_F()
/foundation/arkui/napi/interfaces/inner_api/cjffi/ark_interop/
H A Dark_interop_engine.cpp177 std::condition_variable cv; in ARKTS_DestroyEngine() local
179 engine->eventHandler->PostTask([engine, &cv, &isComplete] { in ARKTS_DestroyEngine()
182 cv.notify_one(); in ARKTS_DestroyEngine()
187 cv.wait_for(lock, std::chrono::seconds(1)); in ARKTS_DestroyEngine()
297 std::condition_variable cv; in ARKTS_CreateEngineWithNewThread() local
299 auto postSuccess = handler->PostTask([&result, &cv, &createComplete] { in ARKTS_CreateEngineWithNewThread()
302 cv.notify_one(); in ARKTS_CreateEngineWithNewThread()
309 cv.wait_for(lock, std::chrono::milliseconds(1)); in ARKTS_CreateEngineWithNewThread()
/foundation/bundlemanager/bundle_tool/frameworks/include/bundle_tool_callback/
H A Dbundle_tool_callback_stub.h32 BundleToolCallbackStub(std::condition_variable &cv, std::mutex &mutex, bool &dataReady) in BundleToolCallbackStub() argument
33 : cv_(cv), mutex_(mutex), dataReady_(dataReady) in BundleToolCallbackStub()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/free_install/
H A Dservice_center_connection.h32 ServiceCenterConnection(int32_t &connectState, std::condition_variable &cv, in ServiceCenterConnection() argument
34 : connectState_(connectState), cv_(cv), connectAbilityMgr_(connectAbilityMgr) in ServiceCenterConnection()
/foundation/bundlemanager/bundle_framework/test/fuzztest/fuzztest_others/servicecenterconnection_fuzzer/
H A Dservicecenterconnection_fuzzer.cpp42 std::condition_variable cv; in DoSomethingInterestingWithMyAPI() local
44 ServiceCenterConnection serviceCenterConnection(connectState, cv, connectAbilityMgr); in DoSomethingInterestingWithMyAPI()
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_quota_policy.cpp135 std::for_each(recv.begin(), recv.end(), [this](const auto &cv) { in HWTEST_F()
136 EXPECT_EQ(cv.networkmatchrule.simId, GetQuota().networkmatchrule.simId); in HWTEST_F()
137 EXPECT_EQ(cv.networkmatchrule.ident, GetQuota().networkmatchrule.ident); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dref_object.cpp128 bool RefObject::WaitLockedUntil(std::condition_variable &cv, in WaitLockedUntil() argument
141 cv.wait_for(lock, std::chrono::seconds(seconds)); in WaitLockedUntil()
145 cv.wait(lock); in WaitLockedUntil()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_auto_launch_test.cpp265 std::condition_variable cv; in HWTEST_F() local
269 auto notifier = [&cvMutex, &cv, &finished, &statusMap] (const std::string &userId, const std::string &appId, in HWTEST_F()
278 cv.notify_one(); in HWTEST_F()
308 cv.wait(lock, [&finished] {return finished;}); in HWTEST_F()
326 cv.wait(lock, [&finished] {return finished;}); in HWTEST_F()
342 std::condition_variable cv; in HWTEST_F() local
346 auto notifier = [&cvMutex, &cv, &finished, &statusMap] (const std::string &userId, const std::string &appId, in HWTEST_F()
354 cv.notify_one(); in HWTEST_F()
386 cv.wait(lock, [&finished] {return finished;}); in HWTEST_F()
404 cv in HWTEST_F()
486 std::condition_variable cv; HWTEST_F() local
564 std::condition_variable cv; HWTEST_F() local
[all...]
H A Ddistributeddb_thread_pool_test.cpp448 std::condition_variable cv; in HWTEST_F() local
450 int errCode = RuntimeContext::GetInstance()->ScheduleTask([&finishedTaskCount, &dataMutex, &cv]() { in HWTEST_F()
457 cv.notify_one(); in HWTEST_F()
463 [i, &finishedTaskCount, &dataMutex, &cv]() { in HWTEST_F()
469 cv.notify_one(); in HWTEST_F()
477 cv.wait(uniqueLock, [&finishedTaskCount]() { in HWTEST_F()
/foundation/arkui/ace_engine/frameworks/base/network/
H A Ddownload_manager_impl.cpp137 downloadCondition->cv.notify_all();
148 downloadCondition->cv.notify_all();
163 downloadCondition->cv.notify_all();
242 downloadCondition->cv.notify_all();
253 downloadCondition->cv.notify_all();
283 downloadCondition->cv.notify_all(); in OnFail()
321 downloadCondition->cv.wait_for( in HandleDownloadResult()
346 downloadCondition->cv.wait_for( in HandleDownloadResult()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp80 std::condition_variable cv; in Sync() local
82 const auto callback = [&callCount, &syncProcess, &processMutex, &cv]( in Sync()
95 cv.notify_all(); in Sync()
101 cv.wait(uniqueLock, [&syncProcess]() { in Sync()
454 std::condition_variable cv; in HWTEST_F() local
456 const auto callback = [&finished, &processMutex, &cv](const std::map<std::string, SyncProcess> &process) { in HWTEST_F()
466 cv.notify_all(); in HWTEST_F()
474 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&finished]() { in HWTEST_F()
723 std::condition_variable cv; in HWTEST_F() local
724 cloudSyncer->SetCurrentTaskInfo([&callCount, &cv](cons in HWTEST_F()
[all...]
H A Ddistributeddb_cloud_kv_syncer_test.cpp156 std::condition_variable cv; in BlockSync() local
159 auto callback = [expectDBStatus, &last, &cv, &dataMutex, &finish, &option](const std::map<std::string, in BlockSync()
175 cv.notify_one(); in BlockSync()
184 cv.wait(uniqueLock, [&finish]() { in BlockSync()
668 std::condition_variable cv; in HWTEST_F() local
686 cv.notify_one(); in HWTEST_F()
695 cv.wait(uniqueLock, [&finish]() { return finish; }); in HWTEST_F()
/foundation/arkui/ace_engine/interfaces/inner_api/form_render/src/
H A Dform_renderer_dispatcher_impl.cpp56 std::condition_variable cv; in DispatchPointerEvent() member
62 serializedResultData->cv.notify_all(); in DispatchPointerEvent()
67 if (serializedResultData->cv.wait_for(lock, std::chrono::milliseconds(PROCESS_WAIT_TIME)) == in DispatchPointerEvent()
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dparallel_task_queue.cpp40 std::condition_variable cv; member
73 state_.cv.notify_one(); in operator ()()
193 state.cv.wait(lock, [this, &waiting, &state]() { in Execute()
/foundation/resourceschedule/ffrt/src/sync/
H A Dshared_mutex.cpp110 ctx->wn.cv.wait(lk); in Wait()
137 wue->cv.notify_one(); in NotifyOne()
158 wue->cv.notify_one(); in NotifyAll()
H A Dwait_queue.cpp43 wn->cv.wait(nl); in ThreadWait()
63 if (wn->cv.wait_until(nl, tp) == std::cv_status::timeout) { in ThreadWaitUntil()
109 // timeout processes wue first, cv will not be processed again. timeout is responsible for destroying wue. in WeTimeoutProc()
224 we->cv.notify_one();
/foundation/arkui/napi/test/unittest/cj_native/
H A Dtest_ark_interop.cpp258 std::condition_variable cv; in main() local
260 auto success = handler->PostTask([&ret, &cv] { in main()
264 cv.notify_all(); in main()
271 auto status = cv.wait_for(lock, std::chrono::seconds(10)); in main()
/foundation/resourceschedule/ffrt/src/eu/
H A Dscpuworker_manager.cpp57 sleepCtl[qos].cv.notify_all(); in ~SCPUWorkerManager()
116 if (ctl.cv.wait_for(lk, std::chrono::seconds(waiting_seconds), [this, thread] { in WorkerIdleAction()
137 ctl.cv.wait(lk, [this, thread] { in WorkerIdleAction()
217 ctl.cv.notify_one(); in WakeupWorkers()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dgeneric_virtual_device.cpp40 std::condition_variable cv; in ~GenericVirtualDevice() local
53 context_->OnLastRef([storage, &cv, &cvMutex, &finished]() { in ~GenericVirtualDevice()
59 cv.notify_one(); in ~GenericVirtualDevice()
63 cv.wait(lock, [&finished] { return finished; }); in ~GenericVirtualDevice()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_check_sync_test.cpp83 std::condition_variable cv; in BlockSync() local
85 auto callback = [&actualDBStatus, &cv, &dataMutex, &finish](const std::map<std::string, SyncProcess> &process) { in BlockSync()
93 cv.notify_one(); in BlockSync()
105 cv.wait(uniqueLock, [&finish]() { in BlockSync()
114 std::condition_variable cv; in BlockPrioritySync() local
116 auto callback = [&cv, &dataMutex, &finish](const std::map<std::string, SyncProcess> &process) { in BlockPrioritySync()
123 cv.notify_one(); in BlockPrioritySync()
132 cv.wait(uniqueLock, [&finish]() { in BlockPrioritySync()
142 std::condition_variable cv; in BlockCompensatedSync() local
144 auto callback = [&processCallback, &cv, in BlockCompensatedSync()
506 std::condition_variable cv; PriorityAndNormalSync() local
1300 std::condition_variable cv; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Dref_object.h55 bool WaitLockedUntil(std::condition_variable &cv,
/foundation/multimedia/audio_framework/frameworks/native/audiorenderer/test/unittest/renderer_test/src/
H A Daudio_fast_renderer_unit_test.cpp515 std::condition_variable cv; in HWTEST_F() local
517 cb->Install([&count, &audioRenderer, &mutex, &cv, sleepTime](size_t length) { in HWTEST_F()
519 cv.notify_one(); in HWTEST_F()
542 cv.wait_for(lock, 1s, [&count] { in HWTEST_F()
/foundation/window/window_manager/test/systemtest/wms/
H A Dwindow_visibility_info_test.cpp47 VisibilityChangedListenerImpl(std::mutex& mutex, std::condition_variable& cv) : mutex_(mutex), cv_(cv) {} in VisibilityChangedListenerImpl() argument

Completed in 15 milliseconds

123