| /foundation/multimedia/camera_lite/frameworks/ |
| H A D | event_handler.cpp | 22 EventHandler::EventHandler() : running_(false)
in EventHandler()
29 while (!running_) {
in ~EventHandler()
32 running_ = false;
in ~EventHandler()
40 return running_;
in IsRunning()
49 hdl->running_ = true;
in EventDispatch()
50 while (hdl->running_) {
in EventDispatch()
|
| /foundation/multimodalinput/input/service/subscriber/test/src/ |
| H A D | timer_manager.cpp | 40 if (running_.load()) { in AddTimer()
43 running_.store(true); in AddTimer()
47 if (!running_.load()) { in AddTimer()
53 } while (running_.load() && (--repeatCount > 0)); in AddTimer()
54 running_.store(false); in AddTimer()
61 running_.store(false); in RemoveTimer()
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | task_scheduler.h | 46 running_ = InnerTask(); in TaskScheduler()
84 if (running_.taskId == taskId && running_.interval != INVALID_INTERVAL) { in Reset()
85 running_.interval = interval; in Reset()
86 return running_.taskId; in Reset()
120 return (!wait || running_.taskId != taskId); in Remove()
166 running_ = it->second; in Loop()
167 exec = running_.exec; in Loop()
168 indexes_.erase(running_.taskId); in Loop()
170 running_ in Loop()
200 InnerTask running_; global() member in OHOS::TaskScheduler
[all...] |
| /foundation/filemanagement/dfs_service/utils/ffrt/src/ |
| H A D | ffrt_timer.cpp | 34 if (running_ == true) { in Start()
39 running_ = true; in Start()
48 sleepCv_.wait_for(lock, std::chrono::milliseconds(interval), [this]() { return !this->running_; }); in Start()
63 if (running_ == false) { in Stop()
71 running_ = false; in Stop()
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor.h | 79 running_ = IS_STOPPING;
81 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
92 return running_ == IS_STOPPING || waits_ != nullptr; in Run()
94 while (running_ == RUNNING && waits_ != nullptr && waits_->Size() > 0) { in Run()
101 if (!idle_(self_) && running_ == RUNNING) { in Run()
105 } while (running_ == RUNNING && in Run()
109 } while (!release_(self_, running_ == IS_STOPPING)); in Run()
110 running_ = STOPPED; in Run()
114 Status running_ = RUNNING; member in OHOS::Executor
|
| H A D | priority_queue.h | 57 running_.emplace(id, temp->second); in Pop()
106 auto running = running_.find(id); in Update()
107 if (running != running_.end()) { in Update()
118 auto it = running_.find(id); in Remove()
119 if (it != running_.end()) { in Remove()
123 return !wait || running_.find(id) == running_.end(); in Remove()
146 auto it = running_.find(id); in Finish()
147 if (it == running_.end()) { in Finish()
156 running_ in Finish()
166 std::map<_Tid, PQMatrix> running_; global() member in OHOS::PriorityQueue
[all...] |
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor.h | 93 running_ = IS_STOPPING;
95 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
106 return running_ == IS_STOPPING || waits_ != nullptr; in Run()
108 while (running_ == RUNNING && waits_ != nullptr && waits_->Size() > 0) { in Run()
115 if (!idle_(self_) && running_ == RUNNING) { in Run()
119 } while (running_ == RUNNING && in Run()
123 } while (!release_(self_, running_ == IS_STOPPING)); in Run()
124 running_ = STOPPED; in Run()
128 Status running_ = RUNNING; member in OHOS::NativePreferences::Executor
|
| H A D | priority_queue.h | 56 running_.emplace(id, temp->second); in Pop()
108 auto running = running_.find(id); in Update()
109 if (running != running_.end()) { in Update()
121 return !wait || running_.find(id) == running_.end(); in Remove()
144 auto it = running_.find(id); in Finish()
145 if (it == running_.end()) { in Finish()
152 running_.erase(it); in Finish()
162 std::map<_Tid, PQMatrix> running_; member in OHOS::NativePreferences::PriorityQueue
|
| /foundation/filemanagement/dfs_service/utils/system/include/ |
| H A D | dfsu_thread.h | 47 running_ = true; in Run()
58 running_ = true; in RunLoop()
66 sleepCv_.wait_for(lock, std::chrono::milliseconds(interval), [this]() { return !this->running_; }); in RunLoop()
82 running_ = true; in RunLoopFlexible()
91 sleepCv_.wait_for(lock, std::chrono::milliseconds(duration), [this]() { return !this->running_; }); in RunLoopFlexible()
109 running_ = false; in Stop()
129 std::atomic_bool running_ {false};
|
| /foundation/ai/ai_engine/services/common/platform/threadpool/source/ |
| H A D | thread.cpp | 42 : running_(false), status_(STOPPED), stackSize_(THREAD_DEFAULT_STACK_SIZE), worker_(nullptr) in Thread()
137 running_ = false; in StopThread()
150 running_ = false; in StopThread()
182 while (running_) { in Run()
216 return running_; in IsRunning()
221 running_ = true; in Execute()
|
| /foundation/graphic/graphic_3d/lume/metaobject/src/animation/ |
| H A D | animation_controller.cpp | 47 running_.clear(); in UpdateAnimations()
54 running_.push_back(weak); in UpdateAnimations()
63 running = running_.size(); in UpdateAnimations()
133 running_.clear(); in Clear()
155 info.running_ = running_.size(); in Step()
168 return running_; in GetRunning()
|
| /foundation/arkui/ace_engine/frameworks/base/thread/ |
| H A D | background_task_executor.cpp | 72 running_ = false; in ~BackgroundTaskExecutor()
89 if (!running_) { in PostTask()
123 if (!running_) { in PostTask()
156 if (!running_ || currentThreadNum_ >= maxThreadNum_) { in StartNewThreads()
174 if (running_) { in StartNewThreads()
196 while (running_) { in ThreadLoop()
|
| H A D | background_task_executor.h | 61 bool running_ { true };
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/darwin/ |
| H A D | rs_vsync_client_darwin.cpp | 31 running_ = false; in ~RSVsyncClientDarwin()
40 running_ = true; in RequestNextVsync()
58 while (running_) { in VsyncThreadMain()
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/windows/ |
| H A D | rs_vsync_client_windows.cpp | 31 running_ = false; in ~RSVsyncClientWindows()
40 running_ = true; in RequestNextVsync()
58 while (running_) { in VsyncThreadMain()
|
| /foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/utils/ |
| H A D | hgm_one_shot_timer.cpp | 184 bool isRunning = running_.exchange(true); in Start()
198 if (running_.exchange(false) && handler_ != nullptr) { in Stop()
205 if (running_.load() && clock_ != nullptr) { in Reset()
216 if (running_.load() && handler_ != nullptr) { in Loop()
226 running_.store(false); in Loop()
|
| /foundation/CastEngine/castengine_wifi_display/services/mediaplayer/src/ |
| H A D | audio_sink.cpp | 71 running_ = true; in Start()
83 if (!running_) { in Stop()
84 SHARING_LOGE("running_ is false playerId: %{public}u!", playerId_); in Stop()
88 running_ = false; in Stop()
296 while (audioRenderer_ && bytesWritten < size && running_) { in Write()
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/src/aging/ |
| H A D | bundle_aging_mgr.cpp | 232 running_ = false; in Process()
254 if (running_) { in Start()
258 running_ = true; in Start()
269 running_ = false; in Start()
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| H A D | event_runner.h | 208 return (deposit_) || (running_.load()); in IsRunning()
214 std::atomic<bool> running_{false};
|
| /foundation/arkui/ace_engine/test/mock/base/ |
| H A D | mock_background_task_executor.cpp | 33 running_ = true; in PostTask()
|
| /foundation/multimodalinput/input/service/subscriber/test/include/ |
| H A D | timer_manager.h | 41 std::atomic_bool running_; member in OHOS::MMI::final
|
| /foundation/filemanagement/dfs_service/utils/inner_api/ |
| H A D | ffrt_timer.h | 38 std::atomic_bool running_{false};
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/include/aging/ |
| H A D | bundle_aging_mgr.h | 61 bool running_ = false; member in OHOS::AppExecFwk::BundleAgingMgr
|
| /foundation/multimedia/camera_lite/interfaces/kits/ |
| H A D | event_handler.h | 52 bool running_;
member in OHOS::Media::EventHandler
|
| /foundation/ai/ai_engine/services/common/platform/threadpool/include/ |
| H A D | thread.h | 192 volatile bool running_; member in OHOS::AI::Thread
|