Home
last modified time | relevance | path

Searched refs:cv_ (Results 1 - 25 of 99) sorted by relevance

1234

/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/free_install/
H A Dservice_center_connection.cpp34 cv_.notify_all(); in OnAbilityConnectDone()
41 cv_.notify_all(); in OnAbilityConnectDone()
50 cv_.notify_all(); in OnAbilityConnectDone()
57 cv_.notify_all(); in OnAbilityConnectDone()
71 cv_.notify_all(); in OnAbilityDisconnectDone()
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dblock_data.h33 cv_.notify_one(); in SetValue()
39 cv_.wait_for(lock, Dur(INTERVAL), [this]() { in GetValue()
43 cv_.notify_one(); in GetValue()
52 cv_.notify_one(); in Clear()
60 std::condition_variable cv_; member in OHOS::BlockData
/foundation/distributeddatamgr/pasteboard/framework/framework/include/common/
H A Dblock_object.h31 cv_.notify_one(); in SetValue()
37 cv_.wait_for(lock, std::chrono::milliseconds(interval_), [this]() { in GetValue()
42 cv_.notify_one(); in GetValue()
55 std::condition_variable cv_; member in OHOS::BlockObject
/foundation/filemanagement/dfs_service/utils/system/include/
H A Ddfsu_thread_safe_queue.h50 cv_.notify_one(); in Push()
62 cv_.notify_one(); in PushFront()
69 cv_.wait(lock, [&] { return !queue_.empty() || halted; }); in WaitAndPop()
89 cv_.notify_all(); in Halt()
95 std::condition_variable cv_; member in OHOS::Storage::DistributedFile::DfsuThreadSafeQueue
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/darwin/
H A Drs_vsync_client_darwin.h38 cv_.wait(lock, func); in PopFront()
48 cv_.notify_all(); in Push()
55 cv_.notify_all(); in Push()
61 std::condition_variable cv_; member in OHOS::Rosen::SemQueue
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/windows/
H A Drs_vsync_client_windows.h38 cv_.wait(lock, func); in PopFront()
48 cv_.notify_all(); in Push()
55 cv_.notify_all(); in Push()
61 std::condition_variable cv_; member in OHOS::Rosen::SemQueue
/foundation/resourceschedule/ffrt/src/sync/
H A Drecord_condition_variable.h35 auto ret = ffrt_cond_timedwait(&cv_, lk.mutex()->GetMutex(), &ts);
44 cv_.notify_one();
49 cv_.notify_all();
53 ffrt::condition_variable cv_; member in ffrt::RecordConditionVariable
/foundation/filemanagement/dfs_service/utils/inner_api/
H A Dblock_object.h38 cv_.notify_one(); in SetValue()
44 cv_.wait_for(lock, std::chrono::milliseconds(interval_), [this]() { return isSet_; }); in GetValue()
47 cv_.notify_one(); in GetValue()
60 std::condition_variable cv_; member in OHOS::Storage::DistributedFile::BlockObject
/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dsem_queue.h34 cv_.wait(lock, func); in PopFront()
44 cv_.notify_all(); in Push()
50 std::condition_variable cv_; member in OHOS::Ace::SemQueue
/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()
47 cv_.wait(lock, [this] { return CompareCount(); }); in WaitSemaphore()
55 cv_.notify_one(); in SendSemaphore()
/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/
H A Dmock.h52 cv_.wait(lck); in Wait()
60 cv_.notify_one(); in Notify()
67 std::condition_variable cv_; member in OHOS::DataObsMgrInnerExtTest::MockDataAbilityObserverStub
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/connect_adapter/src/
H A Dconnect.cpp44 cv_.notify_one(); in OnAbilityConnectDone()
56 cv_.notify_one(); in OnAbilityDisconnectDone()
68 cv_.wait_for(lock, std::chrono::seconds(CONNECT_TIMEOUT), [this] { in WaitConnect()
71 cv_.notify_one(); in WaitConnect()
/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/
H A Dsynchronizer.h52 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
67 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
84 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
103 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
123 cv_.NotifyAll(); in Notify()
129 ConditionVariable cv_; member in OHOS::Media::OSAL::Synchronizer
/foundation/multimedia/media_foundation/src/osal/base/
H A Dsynchronizer.h51 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
66 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
83 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
102 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
122 cv_.NotifyAll(); in Notify()
129 ConditionVariable cv_; member in OHOS::Media::Synchronizer
/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dbuffer_pool.h46 cv_.NotifyOne(); in ~BufferPool()
80 cv_.NotifyOne(); in Append()
88 cv_.NotifyOne(); in SetActive()
97 cv_.NotifyOne(); in RecycleBuffer()
105 cv_.Wait(lock, [this] { return !isActive_ || !freeBuffers_.empty(); }); in AllocateBuffer()
182 mutable OSAL::ConditionVariable cv_; member in OHOS::Media::BufferPool
/foundation/graphic/graphic_2d/graphic_test/graphic_test_framework/src/
H A Drs_graphic_test_director.cpp44 cv_.notify_all();
54 cv_.wait_for(lock, std::chrono::milliseconds(ms), [&] { return ready_; }); in Wait()
58 std::condition_variable cv_; member in OHOS::Rosen::__anon8924::TestSurfaceCaptureCallback
83 cv_.notify_all(); in OnVSync()
90 cv_.wait(lock, [this, count] { return counts_ >= count; }); in WaitForVSync()
95 std::condition_variable cv_; member in OHOS::Rosen::VSyncWaiter
/foundation/window/window_manager/test/systemtest/wms/
H A Dwindow_nointeraction_listener_test.cpp49 NoInteractionTesterListener(std::mutex& mutex, std::condition_variable& cv) : mutex_(mutex), cv_(cv) in NoInteractionTesterListener()
60 std::condition_variable& cv_; member in OHOS::Rosen::NoInteractionTesterListener
70 cv_.notify_all(); in OnWindowNoInteractionCallback()
92 static inline std::condition_variable cv_; member in OHOS::Rosen::WindowNoInteractionTest
124 if (!cv_.wait_until(lock, now + std::chrono::milliseconds(NO_INTERACTION_LISTENER_TEST_WATCHER_TIMEOUT), in WaitForCallback()
144 sptr<NoInteractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_); in HWTEST_F()
175 sptr<NoInteractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_); in HWTEST_F()
193 sptr<NoInteractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_); in HWTEST_F()
230 sptr<NoInteractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_); in HWTEST_F()
265 sptr<NoInteractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_); in HWTEST_F()
[all...]
H A Dwindow_visibility_info_test.cpp47 VisibilityChangedListenerImpl(std::mutex& mutex, std::condition_variable& cv) : mutex_(mutex), cv_(cv) {} in VisibilityChangedListenerImpl()
53 std::condition_variable& cv_; member in OHOS::Rosen::VisibilityChangedListenerImpl
68 cv_.notify_all(); in OnWindowVisibilityChanged()
82 static inline std::condition_variable cv_; member in OHOS::Rosen::WindowVisibilityInfoTest
84 new VisibilityChangedListenerImpl(mutex_, cv_);
179 if (!cv_.wait_until(lock, now + std::chrono::milliseconds(WAIT_ASYNC_MS_TIME_OUT), in WaitForCallback()
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/
H A Drs_thread_looper_impl.cpp53 cv_.wait(lock, pred); in WaitForMessage()
61 cv_.wait_until(lock, time, pred); in WaitForMessage()
120 cv_.notify_all(); in WakeUp()
127 cv_.notify_all(); in PostMessage()
136 cv_.notify_all(); in PostMessage()
/foundation/multimedia/audio_framework/services/audio_policy/server/include/service/
H A Dsession_processor.h64 cv_.notify_one(); in Post()
89 cv_.notify_one(); in Stop()
125 cv_.wait(lock, [this] { in Loop()
139 std::condition_variable cv_; member in OHOS::AudioStandard::SessionProcessor
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dtask_queue_factory.cpp89 cv_.notify_all(); in Done()
95 cv_.wait(lock, [this]() { return done_; }); in Wait()
106 std::condition_variable cv_; member in __anon9628::final::State
166 cv_.notify_one();
182 cv_.notify_one();
325 cv_.notify_all(); in Stop()
371 cv_.wait(lock, [this, &func, &isPop, &context]() { in ThreadProc()
390 std::condition_variable cv_; member in __anon9628::final
/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/
H A Dasync_mode.cpp57 cv_.NotifyOne(); in Release()
93 cv_.NotifyOne(); in Configure()
144 cv_.NotifyOne(); in Stop()
164 cv_.NotifyOne(); in FlushStart()
194 cv_.NotifyOne(); in FlushEnd()
235 cv_.Wait(lock); in HandleFrame()
253 cv_.NotifyOne(); in DecodeFrame()
317 cv_.NotifyOne(); in OnOutputBufferDone()
/foundation/bundlemanager/bundle_framework/test/resource/common/src/
H A Devent.cpp72 cv_.wait(lock); in WaitingMessage()
76 if (cv_.wait_for(lock, std::chrono::seconds(timeout_ms)) == std::cv_status::timeout) { in WaitingMessage()
88 cv_.notify_all(); in CompleteMessage()
/foundation/bundlemanager/bundle_tool/frameworks/include/bundle_tool_callback/
H A Dbundle_tool_callback_stub.h33 : cv_(cv), mutex_(mutex), dataReady_(dataReady) in BundleToolCallbackStub()
42 std::condition_variable &cv_; member in OHOS::AppExecFwk::BundleToolCallbackStub
/foundation/communication/netmanager_base/test/netstatsmanager/unittest/net_stats_manager_test/
H A Dnet_stats_callback_test.cpp30 cv_.notify_all(); in NotifyAll()
36 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()

Completed in 8 milliseconds

1234