| /foundation/multimedia/audio_framework/services/audio_service/common/src/ |
| H A D | audio_thread_task.cpp | 24 AudioThreadTask::AudioThreadTask(const std::string &name) : name_(name), state_(RunningState::STOPPED), loop_(nullptr) in AudioThreadTask()
30 state_ = RunningState::STOPPED; in ~AudioThreadTask()
43 if (state_.load() == RunningState::STOPPING) { in Start()
44 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Start()
46 if (state_.load() == RunningState::STOPPED) { in Start()
55 state_ = RunningState::STARTED; in Start()
67 if (state_.load() != RunningState::STOPPED) { in Stop()
68 state_ = RunningState::STOPPING; in Stop()
70 cond_.wait(lock, [this] { return state_.load() == RunningState::STOPPED; }); in Stop()
82 return state_.load() == RunningState
[all...] |
| /foundation/multimedia/av_codec/services/utils/ |
| H A D | task_thread.cpp | 25 TaskThread::TaskThread(std::string_view name) : name_(name), runningState_(RunningState::STOPPED), loop_(nullptr) in TaskThread()
39 runningState_ = RunningState::STOPPED; in ~TaskThread()
53 if (runningState_.load() == RunningState::STOPPING) { in Start()
54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Start()
56 if (runningState_.load() == RunningState::STOPPED) { in Start()
65 runningState_ = RunningState::STARTED; in Start()
78 if (runningState_.load() != RunningState::STOPPED) { in Stop()
79 runningState_ = RunningState::STOPPING; in Stop()
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
96 if (runningState_.load() != RunningState in StopAsync()
[all...] |
| /foundation/multimedia/media_foundation/src/osal/task/ffrt/ |
| H A D | task.cpp | 46 : name_(std::move(name)), priority_(priority), runningState_(RunningState::STOPPED) in Task()
61 runningState_ = RunningState::STOPPED; in ~Task()
69 runningState_ = RunningState::STARTED; in Start()
85 if (runningState_.load() != RunningState::STOPPED) { in Stop()
86 runningState_ = RunningState::STOPPING; in Stop()
88 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
103 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
104 runningState_ = RunningState::STOPPING; in StopAsync()
111 RunningState state = runningState_.load(); in Pause()
114 case RunningState in Pause()
[all...] |
| /foundation/multimedia/media_foundation/engine/foundation/osal/thread/ |
| H A D | task.cpp | 25 : name_(std::move(name)), priority_(priority), runningState_(RunningState::STOPPED) in Task()
42 runningState_ = RunningState::STOPPED; in ~Task()
51 runningState_ = RunningState::STARTED; in Start()
68 if (runningState_.load() != RunningState::STOPPED) { in Stop()
69 runningState_ = RunningState::STOPPING; in Stop()
71 syncCond_.Wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
83 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
84 runningState_ = RunningState::STOPPING; in StopAsync()
91 RunningState state = runningState_.load(); in Pause()
94 case RunningState in Pause()
[all...] |
| /foundation/multimedia/media_foundation/src/osal/task/pthread/ |
| H A D | taskInner.cpp | 51 : name_(std::move(name)), runningState_(RunningState::PAUSED), singleLoop_(singleLoop) in TaskInner()
76 runningState_ = RunningState::STOPPED; in DeInit()
97 if (runningState_ != RunningState::STARTED) { in UpdateDelayTime()
112 runningState_ = RunningState::STARTED; in Start()
129 runningState_ = RunningState::STOPPED; in Stop()
137 if (runningState_.load() == RunningState::STOPPED) { in Stop()
141 runningState_ = RunningState::STOPPED; in Stop()
151 runningState_ = RunningState::STOPPED; in StopAsync()
159 if (runningState_.load() != RunningState::STOPPED) { in StopAsync()
160 runningState_ = RunningState in StopAsync()
[all...] |
| /foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/ |
| H A D | task.h | 53 enum class RunningState { class in OHOS::Media::OSAL::Task
65 std::atomic<RunningState> runningState_{RunningState::PAUSED};
|
| /foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
| H A D | taskInner.h | 66 virtual bool IsTaskRunning() { return runningState_ == RunningState::STARTED; } in IsTaskRunning()
79 enum class RunningState : int { class in OHOS::Media::TaskInner
88 std::atomic<RunningState> runningState_{RunningState::PAUSED};
|
| /foundation/multimedia/audio_framework/services/audio_service/common/include/ |
| H A D | audio_thread_task.h | 46 enum class RunningState { class in OHOS::AudioStandard::AudioThreadTask
54 std::atomic<RunningState> state_;
|
| /foundation/multimedia/av_codec/services/utils/include/ |
| H A D | task_thread.h | 54 enum class RunningState { class in OHOS::MediaAVCodec::TaskThread
62 std::atomic<RunningState> runningState_;
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
| H A D | codec_state.cpp | 444 /**************************** RunningState Start ********************************/
445 void ImageCodec::RunningState::OnStateEntered() in OnStateEntered()
450 void ImageCodec::RunningState::OnMsgReceived(const MsgInfo &info) in OnMsgReceived()
468 void ImageCodec::RunningState::OnCodecEvent(CodecEventType event, uint32_t data1, uint32_t data2) in OnCodecEvent()
501 void ImageCodec::RunningState::OnShutDown(const MsgInfo &info) in OnShutDown()
517 /**************************** RunningState End ********************************/
|
| H A D | image_codec.cpp | 172 runningState_ = make_shared<RunningState>(this); in ImageCodec()
|
| /foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
| H A D | hcodec_state.cpp | 454 /**************************** RunningState Start ********************************/
455 void HCodec::RunningState::OnStateEntered() in OnStateEntered()
460 void HCodec::RunningState::OnMsgReceived(const MsgInfo &info) in OnMsgReceived()
510 void HCodec::RunningState::OnCodecEvent(CodecEventType event, uint32_t data1, uint32_t data2) in OnCodecEvent()
543 void HCodec::RunningState::OnShutDown(const MsgInfo &info) in OnShutDown()
561 void HCodec::RunningState::OnFlush(const MsgInfo &info) in OnFlush()
574 /**************************** RunningState End ********************************/
|
| H A D | hcodec.h | 445 struct RunningState : BaseState { struct in OHOS::MediaAVCodec::HCodec
446 explicit RunningState(HCodec *codec) : BaseState(codec, "Running", RESUBMIT_BUFFER, RESUBMIT_BUFFER) {} in RunningState() function
536 std::shared_ptr<RunningState> runningState_;
|
| H A D | hcodec.cpp | 313 runningState_ = make_shared<RunningState>(this); in HCodec()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/hardware/imagecodec/ |
| H A D | image_codec.h | 347 struct RunningState : BaseState { struct in OHOS::ImagePlugin::ImageCodec
348 explicit RunningState(ImageCodec *codec) : BaseState(codec, "Running", RESUBMIT_BUFFER, RESUBMIT_BUFFER) {} in RunningState() function
418 std::shared_ptr<RunningState> runningState_;
|