Home
last modified time | relevance | path

Searched refs:syncCond_ (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/multimedia/av_codec/services/utils/
H A Dtask_thread.cpp40 syncCond_.notify_all(); in ~TaskThread()
54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Start()
70 syncCond_.notify_all(); in Start()
80 syncCond_.notify_all(); in Stop()
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
98 syncCond_.notify_all(); in StopAsync()
109 syncCond_.wait(lock, [this] { in Pause()
119 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
164 syncCond_.notify_all(); in Run()
166 syncCond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), in Run()
[all …]
/ohos5.0/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dtask.cpp43 syncCond_.NotifyAll(); in ~Task()
58 syncCond_.NotifyAll(); in Start()
70 syncCond_.NotifyAll(); in Stop()
71 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
96 syncCond_.Wait(lock, [this] { in Pause()
102 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
106 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
146 syncCond_.NotifyAll(); in Run()
148syncCond_.WaitFor(lock, timeoutMs, [this] { return runningState_.load() != RunningState::PAUSED; }… in Run()
153 syncCond_.NotifyAll(); in Run()
/ohos5.0/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dtask.cpp62 syncCond_.NotifyAll(); in ~Task()
76 syncCond_.NotifyAll(); in Start()
87 syncCond_.NotifyAll(); in Stop()
88 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
116 syncCond_.Wait(lock, [this] { in Pause()
122 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
126 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
166 syncCond_.NotifyAll(); in Run()
168syncCond_.WaitFor(lock, timeoutMs, [this] { return runningState_.load() != RunningState::PAUSED; }… in Run()
173 syncCond_.NotifyAll(); in Run()
/ohos5.0/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dpipeline_threadpool.cpp146 syncCond_.NotifyAll(); in Exit()
180 syncCond_.Wait(lock); in Run()
185 syncCond_.WaitFor(lock, (nextJobUs - nowUs + ADJUST_US) / US_PER_MS); in Run()
227 syncCond_.NotifyAll(); in UnLockJobState()
/ohos5.0/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A DtaskInner.h100 ConditionVariable syncCond_; variable
109 ConditionVariable syncCond_{};
H A Dpipeline_threadpool.h53 ConditionVariable syncCond_; variable
/ohos5.0/foundation/multimedia/av_codec/services/utils/include/
H A Dtask_thread.h66 std::condition_variable syncCond_; variable
/ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/
H A Dtask.h69 OSAL::ConditionVariable syncCond_{};
/ohos5.0/foundation/multimedia/av_session/frameworks/js/napi/session/include/
H A Dnapi_avsession.h137 static std::condition_variable syncCond_; variable
/ohos5.0/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_avsession.cpp90 std::condition_variable NapiAVSession::syncCond_; member in OHOS::AVSession::NapiAVSession
535 syncCond_.notify_one(); in PlaybackStateSyncExecutor()
549 auto waitStatus = syncCond_.wait_for(lock, std::chrono::milliseconds(100)); in PlaybackStateAsyncExecutor()