Home
last modified time | relevance | path

Searched refs:queue_ (Results 1 - 25 of 48) sorted by relevance

12

/base/telephony/core_service/utils/common/src/
H A Dtel_event_handler.cpp53 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 Dtel_event_queue.cpp31 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 Dchannel.h177 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 Devent_runner.cpp297 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 Dscreen_off_pre_controller.cpp34 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 Dscreen_off_pre_controller.h59 std::shared_ptr<FFRTQueue> queue_; member in OHOS::PowerMgr::ScreenOffPreController
/base/powermgr/power_manager/utils/ffrt/src/
H A Dffrt_utils.cpp85 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 Dmodule_update_queue.cpp26 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 Dmodule_update_producer.cpp41 : queue_(queue), in ModuleUpdateProducer()
69 queue_.Put(saStatusPair); in AddAbnormalSa()
95 queue_.Put(appResultPair); in AddAbnormalApp()
117 queue_.Stop(); in Run()
H A Dmodule_update_consumer.cpp34 : 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 Devent_inner_runner.h41 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 Dcommon_event_death_recipient.cpp75 queue_ = std::make_shared<ffrt::queue>("cesResubMain"); in SystemAbilityStatusChangeListener()
90 queue_->submit(resubscrebeFund); in OnAddSystemAbility()
/base/theme/screenlock_mgr/services/src/
H A Dscreenlock_system_ability.cpp73 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 Dcommon_event_death_recipient.h45 std::shared_ptr<ffrt::queue> queue_ = nullptr; member in OHOS::EventFwk::CommonEventDeathRecipient::SystemAbilityStatusChangeListener
/base/update/sys_installer/services/module_update/service/include/
H A Dmodule_update_queue.h44 std::vector<std::pair<int32_t, std::string>> queue_; member in OHOS::SysInstaller::ModuleUpdateQueue
H A Dmodule_update_consumer.h34 ModuleUpdateQueue &queue_; member in OHOS::SysInstaller::ModuleUpdateConsumer
H A Dmodule_update_producer.h35 ModuleUpdateQueue &queue_; member in OHOS::SysInstaller::ModuleUpdateProducer
/base/powermgr/power_manager/services/native/src/shutdown/
H A Dshutdown_dialog.h65 FFRTQueue queue_ {"shutdown_dialog"};
/base/notification/distributed_notification_service/test/fuzztest/reminderdatamanager_fuzzer/
H A Dreminderdatamanager_fuzzer.cpp131 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 Devent_runner.h172 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 Dmessenger_device_status_manager.cpp52 queue_ = queue; in Reset()
67 return queue_; in GetQueue()
72 WorkQueue *queue_ {nullptr};
/base/powermgr/power_manager/utils/ffrt/include/
H A Dffrt_utils.h166 FFRTQueue queue_; member in OHOS::PowerMgr::FFRTTimer
/base/powermgr/power_manager/services/native/src/actions/default/
H A Dsystem_suspend_controller.h72 FFRTQueue queue_ {"power_system_suspend_controller"};
/base/telephony/core_service/utils/common/include/
H A Dtel_event_queue.h63 std::shared_ptr<ffrt::queue> queue_ = nullptr; member in OHOS::Telephony::TelEventQueue
/base/powermgr/display_manager/brightness_manager/src/
H A Dbrightness_service.cpp106 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...]

Completed in 12 milliseconds

12