| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_queue_ffrt.cpp | 110 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveOrphanByHandlerId()
133 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveAll()
157 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove()
181 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove()
206 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove()
230 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove()
253 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent()
275 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent()
419 if (ffrtQueue_) { in GetFfrtQueue()
490 ffrtQueue_->wait(handle); in SubmitEventAtEnd()
[all …]
|
| /ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packagegroup/src/ |
| H A D | bundle_active_group_handler.cpp | 59 ffrtQueue_ = std::make_shared<ffrt::queue>(DEVICE_GROUP_HANDLE_QUEUE.c_str(), in Init()
61 if (ffrtQueue_ == nullptr) { in Init()
85 … checkBundleTaskMap_[msgKey] = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj, msgKey]() { in SendCheckBundleMsg()
104 ffrtQueue_->cancel(checkBundleTaskMap_[msgKey]); in RemoveCheckBundleMsg()
133 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj]() { in SendEvent()
157 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent()
169 auto taskHandle = ffrtQueue_->submit_h(fuc); in PostSyncTask()
170 ffrtQueue_->wait(taskHandle); in PostSyncTask()
179 ffrtQueue_->submit(fuc); in PostTask()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/frame_rate_vote/ |
| H A D | rs_video_frame_rate_vote.cpp | 36 ffrtQueue_ = std::make_shared<ffrt::queue>(queueName.c_str()); in RSVideoFrameRateVote()
44 ffrtQueue_ = nullptr; in ~RSVideoFrameRateVote()
77 if (ffrtQueue_) { in SendDelayTask()
78 taskHandler_ = ffrtQueue_->submit_h(initTask, taskAttr); in SendDelayTask()
86 ffrtQueue_->cancel(taskHandler_); in CancelDelayTask()
|
| H A D | rs_frame_rate_vote.cpp | 31 ffrtQueue_ = std::make_shared<ffrt::queue>("frame_rate_vote_queue"); in RSFrameRateVote()
42 ffrtQueue_ = nullptr; in ~RSFrameRateVote()
70 if (ffrtQueue_) { in VideoFrameRateVote()
71 ffrtQueue_->submit(initTask); in VideoFrameRateVote()
87 if (ffrtQueue_) { in ReleaseSurfaceMap()
88 ffrtQueue_->submit(initTask); in ReleaseSurfaceMap()
|
| H A D | rs_video_frame_rate_vote.h | 49 std::shared_ptr<ffrt::queue> ffrtQueue_ {nullptr};
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/ |
| H A D | scene_recognizer_mgr.cpp | 36 ffrtQueue_ = std::make_shared<ffrt::queue>("scene_recognizers_queue", in SceneRecognizerMgr()
43 if (ffrtQueue_ != nullptr) { in ~SceneRecognizerMgr()
44 ffrtQueue_.reset(); in ~SceneRecognizerMgr()
51 if (ffrtQueue_ == nullptr) { in DispatchResource()
56 ffrtQueue_->submit([resType, value, payload, recognizer]() { in DispatchResource()
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/src/ |
| H A D | network_latency_controller.cpp | 66 ffrtQueue_ = std::make_shared<ffrt::queue>("network_manager_ffrtQueue", in Init()
68 if (ffrtQueue_ == nullptr) { in Init()
79 if (!switcher || ffrtQueue_ == nullptr) { in HandleRequest()
104 ffrtQueue_->cancel(iter->second); in HandleAddRequest()
118 taskHandlerMap_[identity] = ffrtQueue_->submit_h( in HandleAddRequest()
134 ffrtQueue_->cancel(iter->second); in HandleDelRequest()
|
| /ohos5.0/foundation/communication/netmanager_ext/services/netfirewallmanager/include/ |
| H A D | netfirewall_intercept_recorder.h | 35 ffrtQueue_ = in FirewallCallback()
41 ffrtQueue_.reset(); in ~FirewallCallback()
42 ffrtQueue_ = nullptr; in ~FirewallCallback()
49 std::shared_ptr<ffrt::queue> ffrtQueue_; variable
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/cgroup_sched/framework/sched_controller/ |
| H A D | app_startup_scene_rec.cpp | 35 ffrtQueue_ = std::make_shared<ffrt::queue>(RUNNER_NAME.c_str(), in Init()
41 ffrtQueue_->cancel(exitContinuousStartupTask); in Deinit()
44 ffrtQueue_.reset(); in Deinit()
72 ffrtQueue_->cancel(exitContinuousStartupTask); in RecordIsContinuousStartup()
90 exitContinuousStartupTask = ffrtQueue_->submit_h([this] { in RecordIsContinuousStartup()
|
| /ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packageusage/src/ |
| H A D | bundle_active_report_handler.cpp | 33 ffrtQueue_ = std::make_shared<ffrt::queue>(DEVICE_USAGE_REPORT_HANDLE_QUEUE.c_str(), in Init()
35 if (ffrtQueue_ == nullptr) { in Init()
55 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([reportHandler, eventId, handlerobj]() { in SendEvent()
79 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent()
|
| /ohos5.0/base/hiviewdfx/hiview/base/ |
| H A D | event_dispatch_queue.cpp | 54 ffrtQueue_ = nullptr; in Stop()
62 ffrtQueue_ = std::make_unique<ffrt::queue>(threadName_.c_str()); in Start()
85 ffrtQueue_->submit([event, queuePtr] { in Enqueue()
|
| /ohos5.0/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
| H A D | ut_net_policy_event_handler.cpp | 30 ffrt::queue ffrtQueue_ = NET_POLICY_STUB_QUEUE; variable
46 instance_ = std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in SetUpTestCase()
68 auto instance = std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_);
|
| H A D | ut_net_policy_core.cpp | 42 ffrt::queue ffrtQueue_ = NET_POLICY_STUB_QUEUE; variable
57 std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in SetUpTestCase()
|
| /ohos5.0/foundation/communication/bluetooth/frameworks/inner/src/ |
| H A D | bluetooth_switch_module.cpp | 95 taskTimeoutHandle_ = ffrtQueue_.submit_h([switchWptr = weak_from_this()]() { in ProcessBluetoothSwitchAction()
108 ffrtQueue_.cancel(taskTimeoutHandle_); in ProcessBluetoothSwitchAction()
164 ffrtQueue_.cancel(taskTimeoutHandle_); in ProcessBluetoothSwitchActionEnd()
188 ffrtQueue_.submit([switchWptr = weak_from_this(), event]() { in ProcessBluetoothSwitchCachedEvent()
|
| H A D | bluetooth_switch_module.h | 51 : ffrtQueue_("bt_switch"), switchAction_(std::move(switchAction)) {} in BluetoothSwitchModule()
75 ffrt::queue ffrtQueue_; variable
|
| /ohos5.0/foundation/communication/netmanager_ext/services/netfirewallmanager/src/ |
| H A D | netfirewall_intercept_recorder.cpp | 126 ffrtQueue_->cancel(recordTaskHandle_); in OnIntercept()
133 …ffrtQueue_->submit_h(callback, ffrt::task_attr().delay(RECORD_TASK_DELAY_TIME_MS).name("OnIntercep… in OnIntercept()
135 ffrtQueue_->submit(callback); in OnIntercept()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netpolicymanager/src/common/ |
| H A D | net_policy_event_handler.cpp | 24 : core_(core), ffrtQueue_(ffrtQueue) in NetPolicyEventHandler()
41 ffrtQueue_.submit([this, eventId, eventData] { ProcessEvent(eventId, eventData); }, in SendEvent()
|
| /ohos5.0/base/hiviewdfx/hiview/framework/native/unified_collection/collector/utils/ |
| H A D | trace_worker.cpp | 31 ffrtQueue_->submit(ucollectionTask, ffrt::task_attr().name("dft_uc_trace")); in HandleUcollectionTask()
|
| /ohos5.0/base/hiviewdfx/hiview/framework/native/unified_collection/collector/inner_include/ |
| H A D | trace_worker.h | 39 std::unique_ptr<ffrt::queue> ffrtQueue_ = std::make_unique<ffrt::queue>("dft_trace_worker"); variable
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/include/ |
| H A D | scene_recognizer_mgr.h | 50 std::shared_ptr<ffrt::queue> ffrtQueue_; variable
|
| /ohos5.0/foundation/communication/netmanager_base/services/netpolicymanager/include/ |
| H A D | net_policy_event_handler.h | 55 ffrt::queue& ffrtQueue_; variable
|
| /ohos5.0/base/hiviewdfx/hiview/base/include/ |
| H A D | event_dispatch_queue.h | 48 std::unique_ptr<ffrt::queue> ffrtQueue_; variable
|
| /ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packageusage/include/ |
| H A D | bundle_active_report_handler.h | 53 std::shared_ptr<ffrt::queue> ffrtQueue_; variable
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/cgroup_sched/framework/sched_controller/include/ |
| H A D | app_startup_scene_rec.h | 48 std::shared_ptr<ffrt::queue> ffrtQueue_ = nullptr; variable
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/include/latency_control/ |
| H A D | network_latency_controller.h | 49 std::shared_ptr<ffrt::queue> ffrtQueue_{nullptr};
|