| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | block_data.h | 34 cv_.notify_one(); in SetValue()
40 cv_.wait_for(lock, std::chrono::seconds(INTERVAL), [this]() { in GetValue()
44 cv_.notify_one(); in GetValue()
53 cv_.notify_one();
61 std::condition_variable cv_; variable
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/free_install/ |
| H A D | service_center_connection.cpp | 34 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()
|
| /ohos5.0/foundation/window/window_manager/test/systemtest/wms/ |
| H A D | window_nointeraction_listener_test.cpp | 49 …oInteractionTesterListener(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_TIM… in WaitForCallback()
144 …eractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_);
175 …eractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_);
193 …eractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_);
230 …eractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_);
265 …eractionTesterListener> noInteractionTesterListener = new NoInteractionTesterListener(mutex_, cv_);
[all …]
|
| H A D | window_visibility_info_test.cpp | 47 …lityChangedListenerImpl(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()
|
| /ohos5.0/foundation/filemanagement/dfs_service/utils/system/include/ |
| H A D | dfsu_thread_safe_queue.h | 50 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_; variable
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/include/common/ |
| H A D | block_object.h | 33 cv_.notify_one(); in SetValue()
39 cv_.wait_for(lock, std::chrono::milliseconds(interval_), [this]() { return isSet_; }); in GetValue()
42 cv_.notify_one(); in GetValue()
55 std::condition_variable cv_; variable
|
| /ohos5.0/foundation/filemanagement/dfs_service/utils/inner_api/ |
| H A D | block_object.h | 38 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_; variable
|
| /ohos5.0/foundation/multimedia/media_foundation/src/osal/base/ |
| H A D | synchronizer.h | 51 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_.… 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_.… in WaitFor()
122 cv_.NotifyAll();
129 ConditionVariable cv_; variable
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/ |
| H A D | synchronizer.h | 52 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_.… 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_.… in WaitFor()
123 cv_.NotifyAll();
129 ConditionVariable cv_; variable
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/ |
| H A D | buffer_pool.cpp | 159 cv_.notify_one(); in AddBuffer()
178 cv_.wait(l, [this] { in AcquireBuffer()
192 if (cv_.wait_for(l, std::chrono::seconds(timeout), [this] { in AcquireBuffer()
223 cv_.notify_one(); in ReturnBuffer()
232 cv_.notify_one(); in ReturnBuffer()
252 cv_.notify_all(); in NotifyStop()
259 cv_.notify_all(); in NotifyStart()
|
| /ohos5.0/base/inputmethod/imf/frameworks/common/ |
| H A D | block_data.h | 39 cv_.notify_one(); in SetValue()
45 cv_.wait_for(lock, std::chrono::milliseconds(INTERVAL), [this]() { return isSet_; }); in GetValue()
53 cv_.wait_for(lock, std::chrono::milliseconds(INTERVAL), [this]() { return isSet_; }); in GetValue()
70 std::condition_variable cv_; variable
|
| /ohos5.0/base/telephony/core_service/services/sim/src/ |
| H A D | sim_state_manager.cpp | 143 cv_.notify_one(); in SyncCmdResponse()
158 … if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND)) == std::cv_status::timeout) { in UnlockPin()
226 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AlterPin()
308 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in GetLockState()
343 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UnlockPin2()
377 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UnlockPuk2()
411 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AlterPin2()
464 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UnlockSimLock()
502 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in SimAuthentication()
526 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in SendSimMatchedOperatorInfo()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_2d/graphic_test/graphic_test_framework/src/ |
| H A D | rs_graphic_test_director.cpp | 44 cv_.notify_all(); in OnSurfaceCapture()
54 cv_.wait_for(lock, std::chrono::milliseconds(ms), [&] { return ready_; }); in Wait()
58 std::condition_variable cv_; member in OHOS::Rosen::__anon40089e1f0110::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
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
| H A D | buffer_pool.h | 46 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_; variable
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue_factory.cpp | 89 cv_.notify_all(); in Done()
95 cv_.wait(lock, [this]() { return done_; }); in Wait()
106 std::condition_variable cv_; member in __anondcf869ec0110::TaskResult::State
166 cv_.notify_one(); in Push()
182 cv_.notify_one(); in PushNoWait()
325 cv_.notify_all(); in Stop()
371 cv_.wait(lock, [this, &func, &isPop, &context]() { in ThreadProc()
390 std::condition_variable cv_; member in __anondcf869ec0110::ThreadPool
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/ |
| H A D | capture_request.cpp | 75 semp_->cv_.notify_all(); in DisableSync()
77 semr_->cv_.notify_all(); in DisableSync()
161 cv_.notify_all(); in ~RequestSemaphore()
173 cv_.wait(l); in Sync()
178 cv_.notify_all(); in Sync()
|
| H A D | capture_message.cpp | 61 cv_.notify_one(); in ~CaptureMessageOperator()
85 cv_.notify_one(); in SendMessage()
102 cv_.notify_one(); in SendMessage()
113 cv_.notify_one(); in SendMessage()
151 cv_.wait(l, [this] { return !running_ || wakeup_; }); in HandleMessage()
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/ |
| H A D | async_mode.cpp | 57 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()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/connect_adapter/src/ |
| H A D | connect.cpp | 44 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()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/ |
| H A D | sem_queue.h | 34 cv_.wait(lock, func); in PopFront()
44 cv_.notify_all(); in Push()
50 std::condition_variable cv_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | semaphore_utils.cpp | 36 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()
|
| /ohos5.0/foundation/multimedia/audio_framework/services/audio_policy/server/include/service/ |
| H A D | session_processor.h | 64 cv_.notify_one(); in Post()
89 cv_.notify_one(); in Stop()
125 cv_.wait(lock, [this] { in Loop()
139 std::condition_variable cv_; variable
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/ |
| H A D | rs_thread_looper_impl.cpp | 53 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()
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/ |
| H A D | mock.h | 52 cv_.wait(lck); in Wait()
60 cv_.notify_one(); in Notify()
67 std::condition_variable cv_; variable
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/darwin/ |
| H A D | rs_vsync_client_darwin.h | 38 cv_.wait(lock, func); in PopFront()
48 cv_.notify_all(); in Push()
54 std::condition_variable cv_; variable
|