| /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 | 30 ffrtQueue_ = std::make_shared<ffrt::queue>("frame_rate_vote_queue"); in RSFrameRateVote()
40 ffrtQueue_ = nullptr; in ~RSFrameRateVote()
68 if (ffrtQueue_) { in VideoFrameRateVote()
69 ffrtQueue_->submit(initTask); in VideoFrameRateVote()
85 if (ffrtQueue_) { in ReleaseSurfaceMap()
86 ffrtQueue_->submit(initTask); in ReleaseSurfaceMap()
|
| H A D | rs_video_frame_rate_vote.h | 49 std::shared_ptr<ffrt::queue> ffrtQueue_ {nullptr};
|
| H A D | rs_frame_rate_vote.h | 56 std::shared_ptr<ffrt::queue> ffrtQueue_ {nullptr};
|
| /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()
|
| /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()
|
| /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()
|
| /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_; member in OHOS::NetManagerStandard::NetFirewallInterceptRecorder::FirewallCallback
|
| /foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/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()
71 ffrtQueue_->cancel(exitContinuousStartupTask); in RecordIsContinuousStartup()
87 exitContinuousStartupTask = ffrtQueue_->submit_h([this] { in RecordIsContinuousStartup()
|
| /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; member
46 instance_ = std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in SetUpTestCase()
68 auto instance = std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in HWTEST_F()
|
| H A D | ut_net_policy_core.cpp | 42 ffrt::queue ffrtQueue_ = NET_POLICY_STUB_QUEUE; member
57 std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in SetUpTestCase()
|
| /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()
|
| /foundation/communication/bluetooth/frameworks/inner/src/ |
| H A D | bluetooth_switch_module.cpp | 92 taskTimeoutHandle_ = ffrtQueue_.submit_h([switchWptr = weak_from_this()]() { in ProcessBluetoothSwitchAction()
105 ffrtQueue_.cancel(taskTimeoutHandle_); in ProcessBluetoothSwitchAction()
156 ffrtQueue_.cancel(taskTimeoutHandle_);
180 ffrtQueue_.submit([switchWptr = weak_from_this(), event]() {
|
| H A D | bluetooth_switch_module.h | 51 : ffrtQueue_("bt_switch"), switchAction_(std::move(switchAction)) {} in BluetoothSwitchModule()
75 ffrt::queue ffrtQueue_; member in OHOS::Bluetooth::BluetoothSwitchModule
|
| /foundation/resourceschedule/device_usage_statistics/services/packageusage/src/ |
| H A D | bundle_active_report_handler.cpp | 34 ffrtQueue_ = std::make_shared<ffrt::queue>(DEVICE_USAGE_REPORT_HANDLE_QUEUE.c_str(), in Init()
36 if (ffrtQueue_ == nullptr) { in Init()
56 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([reportHandler, eventId, handlerobj]() { in SendEvent()
80 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent()
|
| /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("OnIntercept")); in OnIntercept()
135 ffrtQueue_->submit(callback); in OnIntercept()
|
| /foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/include/ |
| H A D | scene_recognizer_mgr.h | 50 std::shared_ptr<ffrt::queue> ffrtQueue_; member in OHOS::ResourceSchedule::SceneRecognizerMgr
|
| /foundation/communication/netmanager_base/services/netpolicymanager/include/ |
| H A D | net_policy_event_handler.h | 55 ffrt::queue& ffrtQueue_; member in OHOS::NetManagerStandard::NetPolicyEventHandler
|
| /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};
|
| /foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/include/ |
| H A D | app_startup_scene_rec.h | 47 std::shared_ptr<ffrt::queue> ffrtQueue_ = nullptr; member in OHOS::ResourceSchedule::AppStartupSceneRec
|
| /foundation/resourceschedule/device_usage_statistics/services/packageusage/include/ |
| H A D | bundle_active_report_handler.h | 60 std::shared_ptr<ffrt::queue> ffrtQueue_; member in OHOS::DeviceUsageStats::BundleActiveReportHandler
|
| /foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/ |
| H A D | ut_net_policy_core.cpp | 42 ffrt::queue ffrtQueue_ = NET_POLICY_STUB_QUEUE; member
57 std::make_shared<NetPolicyEventHandler>(g_netPolicyCore, ffrtQueue_); in SetUpTestCase()
|
| /foundation/resourceschedule/device_usage_statistics/services/packagegroup/include/ |
| H A D | bundle_active_group_handler.h | 72 std::shared_ptr<ffrt::queue> ffrtQueue_; member in OHOS::DeviceUsageStats::BundleActiveGroupHandler
|
| /foundation/communication/netmanager_base/services/netpolicymanager/include/stub/ |
| H A D | net_policy_service_stub.h | 41 ffrt::queue ffrtQueue_; member in OHOS::NetManagerStandard::NetPolicyServiceStub
|
| /foundation/communication/netmanager_base/services/netpolicymanager/src/stub/ |
| H A D | net_policy_service_stub.cpp | 59 NetPolicyServiceStub::NetPolicyServiceStub() : ffrtQueue_(NET_POLICY_STUB_QUEUE) in NetPolicyServiceStub()
128 handler_ = std::make_shared<NetPolicyEventHandler>(core, ffrtQueue_); in InitEventHandler()
163 auto task = ffrtQueue_.submit_h([this, &data, &reply, &requestFunc, &result]() { in OnRemoteRequest()
166 ffrtQueue_.wait(task); in OnRemoteRequest()
|