Home
last modified time | relevance | path

Searched refs:cond_ (Results 1 - 25 of 81) sorted by relevance

1234

/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp31 cond_.notify_all(); in ~AudioThreadTask()
44 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Start()
61 cond_.notify_all(); in Start()
69 cond_.notify_all(); in Stop()
70 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Stop()
90 cond_.notify_all(); in StopAsync()
100 cond_.wait(lock, [this] { in Pause()
106 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Pause()
110 cond_.wait(lock, [this] { return state_.load() == RunningState::PAUSED; }); in Pause()
143 cond_ in RunJob()
[all...]
/foundation/multimedia/player_framework/services/utils/
H A Dwatchdog.cpp55 cond_.notify_all(); in DisableWatchDog()
76 cond_.notify_all(); in PauseWatchDog()
85 cond_.notify_all(); in ResumeWatchDog()
97 cond_.notify_all(); in Notify()
101 cond_.notify_all(); in Notify()
121 cond_.wait(lock, [this] { in WatchDogThread()
130 cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs_), [this] { in WatchDogThread()
H A Dtask_queue.cpp64 cond_.notify_all();
132 cond_.notify_all(); in EnqueueTask()
158 cond_.wait(lock, [this] { return isExit_ || !taskList_.empty(); }); in TaskProcessor()
169 (void)cond_.wait_for(lock, std::chrono::nanoseconds(diff)); in TaskProcessor()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dcondition_variable.cpp32 cond_.notify_one();
37 cond_.notify_all();
42 cond_.wait(lock);
54 auto status = cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs)); in WaitFor()
64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dcondition_variable.cpp48 int rtv = pthread_cond_init(&cond_, &attr); in condInited_()
60 pthread_cond_destroy(&cond_); variable
66 int ret = pthread_cond_signal(&cond_);
75 int ret = pthread_cond_broadcast(&cond_);
84 pthread_cond_wait(&cond_, &(lock.mutex_->nativeHandle_));
100 return pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), in WaitFor()
/foundation/communication/nfc/services/src/nci_adapter/nci_native_default/src/
H A Dsynchronize_event.cpp32 pthread_cond_init(&cond_, &attr); in SynchronizeEvent()
38 pthread_cond_destroy(&cond_); in ~SynchronizeEvent()
59 int const res = pthread_cond_wait(&cond_, &lock_); in Wait()
80 int waitResult = pthread_cond_timedwait(&cond_, &lock_, &absoluteTime); in Wait()
90 int const res = pthread_cond_signal(&cond_); in NotifyOne()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dcondition_variable.cpp52 int rtv = pthread_cond_init(&cond_, &attr); in condInited_()
63 pthread_cond_destroy(&cond_); variable
70 int ret = pthread_cond_signal(&cond_);
77 int ret = pthread_cond_broadcast(&cond_);
84 pthread_cond_wait(&cond_, &(lock.mutex_->nativeHandle_));
108 return pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), &timeout) == 0; in WaitFor()
126 status = pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), &timeout); in WaitFor()
/foundation/resourceschedule/ffrt/src/util/
H A Dts_queue.h36 cond_.notify_one(); in Push()
42 cond_.wait(lg, [this] { return !queue_.empty(); }); in Pop()
51 std::condition_variable cond_; member in ffrt::TSQueue
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/mock/include/
H A Dmock_app_device_change_listener.h36 cond_.notify_all();
43 cond_.wait(lock, [this] { return result_; }); in Wait()
58 mutable std::condition_variable cond_; member in OHOS::ObjectStore::MockAppDeviceStatusChangeListener
/foundation/ai/intelligent_voice_framework/utils/
H A Dmessage_queue.cpp73 result += pthread_cond_init(&cond_, &attr); in MessageQueue()
83 result += pthread_cond_destroy(&cond_); in ~MessageQueue()
94 pthread_cond_wait(&cond_, &lock_); in ReceiveMsg()
121 pthread_cond_signal(&cond_); in SendMsg()
/foundation/graphic/graphic_3d/lume/metaobject/src/
H A Dfuture.cpp32 cond_.wait(lock); in Wait()
41 if (cond_.wait_for(lock, std::chrono::microseconds(time.ToMicroseconds())) == std::cv_status::timeout) { in WaitFor()
52 cond_.wait(lock); in GetResult()
100 cond_.notify_all(); in Cancel()
136 cond_.notify_all(); in SetResult()
151 cond_.notify_all(); in SetAbandoned()
/foundation/multimedia/player_framework/services/utils/include/
H A Dtask_queue.h142 cond_.notify_all();
152 cond_.wait(lock); in GetResult()
161 auto isFinished = cond_.wait_for(lock, std::chrono::milliseconds(milliseconds), in GetResultWithTimeLimit()
178 cond_.notify_all();
224 std::condition_variable cond_; member in OHOS::Media::TaskHandler
257 std::condition_variable cond_; member in OHOS::Media::TaskQueue
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A Dcondition_variable.h48 ffrt::condition_variable cond_; member in OHOS::Media::ConditionVariable
50 pthread_cond_t cond_; member in OHOS::Media::ConditionVariable
/foundation/multimedia/av_codec/test/unittest/video_test/video_test/capbilities/sample_buffer_queue/
H A Dsample_buffer_queue.cpp28 cond_.notify_all(); in QueueBuffer()
36 (void)cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), [this]() { return !bufferQueue_.empty(); }); in DequeueBuffer()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dcast_timer.cpp42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
63 cond_.notify_all(); in Stop()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dcast_timer.cpp42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
63 cond_.notify_all(); in Stop()
/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/
H A Dcondition_variable.h68 status = pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), in WaitFor()
79 pthread_cond_t cond_{};
/foundation/resourceschedule/ffrt/src/queue/
H A Dserial_queue.cpp38 cond_.NotifyOne(); in Push()
52 cond_.WaitFor(lock, std::chrono::microseconds(diff)); in Pull()
H A Dconcurrent_queue.cpp64 cond_.NotifyAll(); in Push()
85 cond_.WaitFor(lock, std::chrono::microseconds(diff)); in Pull()
115 cond_.NotifyAll(); in Stop()
/foundation/multimedia/player_framework/services/services/monitor/server/
H A Dmonitor_server.cpp46 cond_.notify_all(); in ~MonitorServer()
105 cond_.notify_all(); in Click()
121 cond_.notify_all(); in EnableMonitor()
156 cond_.notify_all(); in DisableMonitor()
217 cond_.notify_all(); in OnClientDie()
286 cond_.wait_for(lock, std::chrono::milliseconds(GetWaitTime()), [this] { in MonitorThread()
/foundation/multimedia/media_foundation/engine/plugin/plugins/codec_adapter/
H A Dcodec_cmd_executor.cpp102 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult()
116 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult()
176 cond_.NotifyAll(); in HandleEventCmdComplete()
200 cond_.NotifyAll(); in HandleEventError()
/foundation/multimedia/media_foundation/src/common/
H A Davsharedmemorypool.cpp93 cond_.notify_all(); in ReleaseMemory()
196 cond_.wait(lock); in AcquireMemory()
222 cond_.notify_all(); in SetNonBlocking()
239 cond_.notify_all(); in Reset()
/foundation/multimedia/player_framework/services/dfx/
H A Ddfx_log_dump.cpp45 cond_.notify_all(); in ~DfxLogDump()
114 cond_.notify_all(); in SaveLog()
144 cond_.wait_for(lock, std::chrono::seconds(timeout), in TaskProcessor()
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor.h81 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
111 cond_.notify_all(); in Run()
117 std::condition_variable cond_; member in OHOS::Executor
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor.h95 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
125 cond_.notify_all(); in Run()
131 std::condition_variable cond_; member in OHOS::NativePreferences::Executor

Completed in 8 milliseconds

1234