| /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()
76 AVCODEC_LOGD("task %{public}s stop entered, current state: %{public}d", name_.data(), runningState_.load()); in Stop()
78 if (runningState_.load() != RunningState::STOPPED) { in Stop()
79 runningState_ = RunningState::STOPPING; in Stop()
81 syncCond_.wait(lock, [this] { return runningState_ in Stop()
[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()
83 name_.c_str(), runningState_.load()); in Stop()
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_ 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()
66 name_.c_str(), runningState_.load()); in Stop()
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_ in Pause()
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/ |
| H A D | gatt_service_base.h | 32 GattServiceBase() : runningState_(false), mutexRunningState_() in GattServiceBase()
39 return runningState_; in InRunningState()
44 runningState_ = true; in Start()
49 runningState_ = false; in Stop()
62 bool runningState_; member in OHOS::bluetooth::GattServiceBase
|
| /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_ in StopAsync()
[all...] |
| /foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
| H A D | taskInner.h | 66 virtual bool IsTaskRunning() { return runningState_ == RunningState::STARTED; } in IsTaskRunning()
88 std::atomic<RunningState> runningState_{RunningState::PAUSED};
|
| /foundation/multimedia/av_codec/services/utils/include/ |
| H A D | task_thread.h | 62 std::atomic<RunningState> runningState_; member in OHOS::MediaAVCodec::TaskThread
|
| /foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/ |
| H A D | task.h | 65 std::atomic<RunningState> runningState_{RunningState::PAUSED};
|
| /foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
| H A D | hcodec_state.cpp | 416 codec_->ChangeStateTo(codec_->runningState_); in OnCodecEvent()
727 codec_->ChangeStateTo(codec_->runningState_); in HandleOutputPortEnabled()
849 codec_->ChangeStateTo(codec_->runningState_); in ChangeStateIfWeOwnAllBuffers()
|
| H A D | hcodec.cpp | 313 runningState_ = make_shared<RunningState>(this); in HCodec()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
| H A D | codec_state.cpp | 410 codec_->ChangeStateTo(codec_->runningState_); in OnCodecEvent()
628 codec_->ChangeStateTo(codec_->runningState_); in HandleOutputPortEnabled()
|
| H A D | image_codec.cpp | 172 runningState_ = make_shared<RunningState>(this); in ImageCodec()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/hardware/imagecodec/ |
| H A D | image_codec.h | 418 std::shared_ptr<RunningState> runningState_; member in OHOS::ImagePlugin::ImageCodec
|