| /base/telephony/core_service/utils/common/src/ |
| H A D | tel_event_handler.cpp | 53 queue_ = std::make_shared<TelEventQueue>(name); in TelEventHandler()
70 if (!queue_) { in SendEvent()
74 queue_->Submit(event, priority); in SendEvent()
86 if (!queue_) { in SendExecuteNowEvent()
90 queue_->Submit(event, Priority::IMMEDIATE); in SendExecuteNowEvent()
96 if (!queue_) { in RemoveEvent()
100 queue_->RemoveEvent(innerEventId); in RemoveEvent()
105 if (!queue_) { in HasInnerEvent()
109 return queue_->HasInnerEvent(innerEventId); in HasInnerEvent()
114 if (!queue_) { in RemoveAllEvents()
[all...] |
| H A D | tel_event_queue.cpp | 31 queue_ = std::make_shared<ffrt::queue>(name_.c_str()); in TelEventQueue()
39 if (!queue_) { in ~TelEventQueue()
46 queue_->wait(curTask_); in ~TelEventQueue()
48 queue_ = nullptr; in ~TelEventQueue()
107 if (!curTask_ || !queue_) { in ClearCurrentTask()
110 queue_->cancel(curTask_); in ClearCurrentTask()
121 if (!queue_) { in SubmitInner()
155 curTask_ = queue_->submit_h( in SubmitToFFRT()
|
| /base/msdp/device_status/intention/common/channel/include/ |
| H A D | channel.h | 177 std::deque<Event> queue_; member in OHOS::Msdp::DeviceStatus::Channel
199 queue_.clear(); in Disable()
209 if (queue_.size() >= QUEUE_CAPACITY) { in Send()
212 bool needNotify = queue_.empty(); in Send()
213 queue_.push_back(event); in Send()
224 if (queue_.empty()) { in Peek()
226 return !queue_.empty(); in Peek()
229 return queue_.front(); in Peek()
236 if (queue_.empty()) { in Pop()
238 return !queue_ in Pop()
[all...] |
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_runner.cpp | 297 queue_ = std::make_shared<EventQueueBase>(); in EventRunnerImpl()
303 queue_->RemoveAll();
336 queue_->Prepare();
365 queue_->Finish();
372 for (auto event = queue_->GetExpiredEvent(nextWakeTime); event; event = in NoWaitModeLoop()
373 queue_->GetExpiredEvent(nextWakeTime)) { in NoWaitModeLoop()
377 queue_->CheckFileDescriptorEvent(); in NoWaitModeLoop()
379 for (auto event = queue_->GetExpiredEvent(nextWakeTime); event; event = in NoWaitModeLoop()
380 queue_->GetExpiredEvent(nextWakeTime)) { in NoWaitModeLoop()
388 for (auto event = queue_ in DefaultModeLoop()
[all...] |
| /base/powermgr/power_manager/services/native/src/screenoffpre/ |
| H A D | screen_off_pre_controller.cpp | 34 queue_ = std::make_shared<FFRTQueue>("screen_off_pre_controller"); in ScreenOffPreController()
84 if (queue_) { in Reset()
85 queue_.reset(); in Reset()
166 if (!queue_) { in HandleEyeDetectTimeout()
167 POWER_HILOGE(FEATURE_SCREEN_OFF_PRE, "queue_ is nullptr"); in HandleEyeDetectTimeout()
170 eyeDetectTimeOutHandle_ = FFRTUtils::SubmitDelayTask(handletask, delayTime, queue_); in HandleEyeDetectTimeout()
176 if (!queue_) { in CancelEyeDetectTimeout()
177 POWER_HILOGE(FEATURE_SCREEN_OFF_PRE, "queue_ is nullptr"); in CancelEyeDetectTimeout()
180 FFRTUtils::CancelTask(eyeDetectTimeOutHandle_, queue_); in CancelEyeDetectTimeout()
|
| H A D | screen_off_pre_controller.h | 59 std::shared_ptr<FFRTQueue> queue_; member in OHOS::PowerMgr::ScreenOffPreController
|
| /base/powermgr/power_manager/utils/ffrt/src/ |
| H A D | ffrt_utils.cpp | 85 FFRTTimer::FFRTTimer(): queue_("ffrt_timer")
in FFRTTimer()
89 FFRTTimer::FFRTTimer(const char *timer_name): queue_(timer_name)
in FFRTTimer()
96 // queue_ will be destructed thereafter.
in ~FFRTTimer()
130 handleMap_[timerId] = FFRTUtils::SubmitDelayTask(task, delayMs, queue_);
in SetTimer()
155 FFRTUtils::CancelTask(p.second, queue_);
in CancelAllTimerInner()
165 FFRTUtils::CancelTask(handleMap_[timerId], queue_);
in CancelTimerInner()
|
| /base/update/sys_installer/services/module_update/service/src/ |
| H A D | module_update_queue.cpp | 26 queue_.resize(MAX_SIZE); in ModuleUpdateQueue()
47 queue_[tail_] = saStatus; in Put()
63 std::pair<int32_t, std::string> saStatus = std::move(queue_[head_]); in Pop()
|
| H A D | module_update_producer.cpp | 41 : queue_(queue), in ModuleUpdateProducer()
69 queue_.Put(saStatusPair); in AddAbnormalSa()
95 queue_.Put(appResultPair); in AddAbnormalApp()
117 queue_.Stop(); in Run()
|
| H A D | module_update_consumer.cpp | 34 : queue_(queue), in ModuleUpdateConsumer()
79 if (exit_ == 1 && queue_.IsEmpty()) { in Run()
80 queue_.Stop(); in Run()
83 std::pair<int32_t, std::string> saStatusPair = queue_.Pop(); in Run()
|
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| H A D | event_inner_runner.h | 41 return queue_; in GetEventQueue()
65 std::shared_ptr<EventQueue> queue_; member in OHOS::AppExecFwk::EventInnerRunner
|
| /base/notification/common_event_service/frameworks/core/src/ |
| H A D | common_event_death_recipient.cpp | 75 queue_ = std::make_shared<ffrt::queue>("cesResubMain"); in SystemAbilityStatusChangeListener()
90 queue_->submit(resubscrebeFund); in OnAddSystemAbility()
|
| /base/theme/screenlock_mgr/services/src/ |
| H A D | screenlock_system_ability.cpp | 73 std::shared_ptr<ffrt::queue> ScreenLockSystemAbility::queue_; member in OHOS::ScreenLock::ScreenLockSystemAbility
152 queue_->submit(callback, ffrt::task_attr().delay(INIT_INTERVAL)); in OnStart()
188 queue_->submit(callback, ffrt::task_attr().delay(DELAY_TIME)); in RegisterDisplayPowerEventListener()
198 if (queue_ != nullptr) { in InitServiceHandler()
202 queue_ = std::make_shared<ffrt::queue>("ScreenLockSystemAbility"); in InitServiceHandler()
239 queue_ = nullptr; in OnStop()
493 if (queue_ != nullptr) { in OnSystemEvent()
494 queue_->submit(callback); in OnSystemEvent()
738 if (queue_ != nullptr) { in SystemEventCallBack()
739 queue_ in SystemEventCallBack()
[all...] |
| /base/notification/common_event_service/frameworks/core/include/ |
| H A D | common_event_death_recipient.h | 45 std::shared_ptr<ffrt::queue> queue_ = nullptr; member in OHOS::EventFwk::CommonEventDeathRecipient::SystemAbilityStatusChangeListener
|
| /base/update/sys_installer/services/module_update/service/include/ |
| H A D | module_update_queue.h | 44 std::vector<std::pair<int32_t, std::string>> queue_; member in OHOS::SysInstaller::ModuleUpdateQueue
|
| H A D | module_update_consumer.h | 34 ModuleUpdateQueue &queue_; member in OHOS::SysInstaller::ModuleUpdateConsumer
|
| H A D | module_update_producer.h | 35 ModuleUpdateQueue &queue_; member in OHOS::SysInstaller::ModuleUpdateProducer
|
| /base/powermgr/power_manager/services/native/src/shutdown/ |
| H A D | shutdown_dialog.h | 65 FFRTQueue queue_ {"shutdown_dialog"};
|
| /base/notification/distributed_notification_service/test/fuzztest/reminderdatamanager_fuzzer/ |
| H A D | reminderdatamanager_fuzzer.cpp | 131 if (manager->queue_ != nullptr) { in Clear()
132 auto handler = manager->queue_->submit_h(std::bind([]() {})); in Clear()
133 manager->queue_->wait(handler); in Clear()
|
| /base/notification/eventhandler/interfaces/inner_api/ |
| H A D | event_runner.h | 172 return queue_; in GetEventQueue()
344 std::shared_ptr<EventQueue> queue_; member in OHOS::AppExecFwk::final
|
| /base/security/device_security_level/baselib/msglib/src/standard/ |
| H A D | messenger_device_status_manager.cpp | 52 queue_ = queue; in Reset()
67 return queue_; in GetQueue()
72 WorkQueue *queue_ {nullptr};
|
| /base/powermgr/power_manager/utils/ffrt/include/ |
| H A D | ffrt_utils.h | 166 FFRTQueue queue_;
member in OHOS::PowerMgr::FFRTTimer
|
| /base/powermgr/power_manager/services/native/src/actions/default/ |
| H A D | system_suspend_controller.h | 72 FFRTQueue queue_ {"power_system_suspend_controller"};
|
| /base/telephony/core_service/utils/common/include/ |
| H A D | tel_event_queue.h | 63 std::shared_ptr<ffrt::queue> queue_ = nullptr; member in OHOS::Telephony::TelEventQueue
|
| /base/powermgr/display_manager/brightness_manager/src/ |
| H A D | brightness_service.cpp | 106 queue_ = std::make_shared<FFRTQueue> ("brightness_manager");
in Init()
107 if (queue_ == nullptr) {
in Init()
139 if (queue_) {
in DeInit()
140 queue_.reset();
in DeInit()
727 FFRTUtils::CancelTask(g_waitForFirstLuxTaskHandle, queue_);
in UpdateCurrentBrightnessLevel()
789 FFRTUtils::CancelTask(g_waitForFirstLuxTaskHandle, queue_);
in SetScreenOnBrightness()
797 queue_);
in SetScreenOnBrightness()
930 FFRTUtils::CancelTask(g_cancelBoostTaskHandle, queue_);
in BoostBrightness()
932 g_cancelBoostTaskHandle = FFRTUtils::SubmitDelayTask(task, timeoutMs, queue_);
in BoostBrightness()
945 FFRTUtils::CancelTask(g_cancelBoostTaskHandle, queue_);
in CancelBoostBrightness()
[all...] |