Home
last modified time | relevance | path

Searched refs:subscriber_ (Results 1 - 25 of 60) sorted by relevance

123

/foundation/resourceschedule/background_task_mgr/interfaces/innerkits/src/
H A Dbackground_task_subscriber.cpp72 BackgroundTaskSubscriber &subscriber) : subscriber_(subscriber) {} in BackgroundTaskSubscriberImpl()
81 subscriber_.OnAppEfficiencyResourcesApply(resourceInfo); in OnAppEfficiencyResourcesApply()
87 subscriber_.OnAppEfficiencyResourcesReset(resourceInfo); in OnAppEfficiencyResourcesReset()
93 subscriber_.OnProcEfficiencyResourcesApply(resourceInfo); in OnProcEfficiencyResourcesApply()
99 subscriber_.OnProcEfficiencyResourcesReset(resourceInfo); in OnProcEfficiencyResourcesReset()
105 subscriber_.OnTransientTaskStart(info); in OnTransientTaskStart()
111 subscriber_.OnTransientTaskEnd(info); in OnTransientTaskEnd()
117 subscriber_.OnTransientTaskErr(info); in OnTransientTaskErr()
123 subscriber_.OnAppTransientTaskStart(info); in OnAppTransientTaskStart()
129 subscriber_ in OnAppTransientTaskEnd()
[all...]
/foundation/arkui/ace_engine/frameworks/core/event/multimodal/
H A Dmultimodal_scene.cpp55 if (!subscriber_) { in SubscribeVoiceEvent()
59 if (!subscriber_->SubscribeVoiceEvents({ voiceEvent })) { in SubscribeVoiceEvent()
72 if (subscriber_) { in UnSubscribeVoiceEvent()
73 subscriber_->UnSubscribeVoiceEvents({ voiceEvent }); in UnSubscribeVoiceEvent()
116 if (subscriber_ && !voiceEvents_.empty()) { in UnSubscribeAllEvents()
117 subscriber_->UnSubscribeVoiceEvents(voiceEvents_); in UnSubscribeAllEvents()
126 if (subscriber_ && !voiceEvents_.empty()) { in Hide()
127 subscriber_->UnSubscribeVoiceEvents(voiceEvents_); in Hide()
133 if (subscriber_ && !voiceEvents_.empty()) { in Resume()
134 subscriber_ in Resume()
[all...]
H A Dmultimodal_manager.cpp27 auto newScene = multiModalScenes_.try_emplace(pageId, MakeRefPtr<MultiModalScene>(pageId, subscriber_)); in GetMultiModalScene()
88 subscriber_ = subscriber; in SetMultimodalSubscriber()
94 if (!subscriber_) { in OpenChannel()
129 subscriber_->RegisterCallback(callback, [weak = WeakClaim(this)]() { in OpenChannel()
H A Dmultimodal_scene.h34 : subscriber_(subscriber), pageId_(pageId) {} in MultiModalScene()
63 RefPtr<MultimodalSubscriber> subscriber_; member in OHOS::Ace::final
/foundation/distributedhardware/device_manager/test/unittest/
H A DUTTest_dm_publish_common_event.cpp97 publshCommonEventManager->subscriber_ in HWTEST_F()
99 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
104 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
107 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
110 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
115 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
118 publshCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
120 EXPECT_NE(publshCommonEventManager->subscriber_->GetSubscriberEventNameVec(), changeEventVec); in HWTEST_F()
H A DUTTest_dm_account_common_event.cpp86 accountCommonEventManager->subscriber_ in HWTEST_F()
88 accountCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
93 accountCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
97 accountCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
101 accountCommonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
102 EXPECT_NE(accountCommonEventManager->subscriber_->GetSubscriberEventNameVec(), changeEventVec); in HWTEST_F()
/foundation/distributedhardware/device_manager/test/commonunittest/
H A DUTTest_dm_common_event_manager.cpp99 std::make_shared<DmCommonEventManager::SystemAbilityStatusChangeListener>(commonEventManager->subscriber_); in HWTEST_F()
115 std::make_shared<DmCommonEventManager::SystemAbilityStatusChangeListener>(commonEventManager->subscriber_); in HWTEST_F()
135 commonEventManager->subscriber_ = std::make_shared<DmEventSubscriber>(subscribeInfo, callback, strEventVec); in HWTEST_F()
137 std::make_shared<DmCommonEventManager::SystemAbilityStatusChangeListener>(commonEventManager->subscriber_); in HWTEST_F()
154 std::make_shared<DmCommonEventManager::SystemAbilityStatusChangeListener>(commonEventManager->subscriber_); in HWTEST_F()
182 commonEventManager->subscriber_ = std::make_shared<DmEventSubscriber>(subscriberInfo, callback, strEventVec); in HWTEST_F()
183 commonEventManager->subscriber_->OnReceiveEvent(data); in HWTEST_F()
184 EXPECT_NE(commonEventManager->subscriber_->GetSubscriberEventNameVec(), changeEventVec); in HWTEST_F()
208 commonEventManager->subscriber_ = std::make_shared<DmEventSubscriber>(subscriberInfo, callback, strEventVec); in HWTEST_F()
209 commonEventManager->subscriber_ in HWTEST_F()
[all...]
/foundation/resourceschedule/memmgr/interface/innerkits/src/
H A Dapp_state_subscriber.cpp60 : subscriber_(subscriber) in AppStateSubscriberImpl()
76 subscriber_.OnConnected(); in OnConnected()
90 subscriber_.OnDisconnected(); in OnDisconnected()
101 subscriber_.OnAppStateChanged(pid, uid, state); in OnAppStateChanged()
112 subscriber_.ForceReclaim(pid, uid); in ForceReclaim()
123 subscriber_.OnTrim(level); in OnTrim()
165 subscriberImpl_.subscriber_.OnRemoteDied(object); in OnRemoteDied()
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/commonevent/
H A Ddm_common_event_manager.cpp62 subscriber_ = std::make_shared<DmEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribeServiceEvent()
66 subscriber_ = nullptr; in SubscribeServiceEvent()
70 new SystemAbilityStatusChangeListener(subscriber_)); in SubscribeServiceEvent()
73 subscriber_ = nullptr; in SubscribeServiceEvent()
101 if (subscriber_ != nullptr) { in UnsubscribeServiceEvent()
103 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribeServiceEvent()
108 subscriber_ = nullptr; in UnsubscribeServiceEvent()
/foundation/distributedhardware/device_manager/services/service/src/publishcommonevent/
H A Ddm_screen_common_event.cpp70 subscriber_ = std::make_shared<DmScreenEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribeScreenCommonEvent()
74 subscriber_ = nullptr; in SubscribeScreenCommonEvent()
77 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribeScreenCommonEvent()
80 subscriber_ = nullptr; in SubscribeScreenCommonEvent()
108 if (subscriber_ != nullptr) { in UnsubscribeScreenCommonEvent()
110 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribeScreenCommonEvent()
115 subscriber_ = nullptr; in UnsubscribeScreenCommonEvent()
H A Ddm_data_share_common_event.cpp71 subscriber_ = std::make_shared<DmDataShareEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribeDataShareCommonEvent()
75 subscriber_ = nullptr; in SubscribeDataShareCommonEvent()
78 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribeDataShareCommonEvent()
81 subscriber_ = nullptr; in SubscribeDataShareCommonEvent()
109 if (subscriber_ != nullptr) { in UnsubscribeDataShareCommonEvent()
111 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribeDataShareCommonEvent()
116 subscriber_ = nullptr; in UnsubscribeDataShareCommonEvent()
H A Ddm_account_common_event.cpp70 subscriber_ = std::make_shared<DmAccountEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribeAccountCommonEvent()
74 subscriber_ = nullptr; in SubscribeAccountCommonEvent()
77 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribeAccountCommonEvent()
80 subscriber_ = nullptr; in SubscribeAccountCommonEvent()
108 if (subscriber_ != nullptr) { in UnsubscribeAccountCommonEvent()
110 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribeAccountCommonEvent()
115 subscriber_ = nullptr; in UnsubscribeAccountCommonEvent()
H A Ddm_package_common_event.cpp70 subscriber_ = std::make_shared<DmPackageEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribePackageCommonEvent()
74 subscriber_ = nullptr; in SubscribePackageCommonEvent()
77 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribePackageCommonEvent()
80 subscriber_ = nullptr; in SubscribePackageCommonEvent()
108 if (subscriber_ != nullptr) { in UnsubscribePackageCommonEvent()
110 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribePackageCommonEvent()
115 subscriber_ = nullptr; in UnsubscribePackageCommonEvent()
H A Ddm_publish_common_event.cpp72 subscriber_ = std::make_shared<DmPublishEventSubscriber>(subscriberInfo, callback, eventNameVec); in SubscribePublishCommonEvent()
76 subscriber_ = nullptr; in SubscribePublishCommonEvent()
79 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribePublishCommonEvent()
82 subscriber_ = nullptr; in SubscribePublishCommonEvent()
98 SetSubscriber(subscriber_); in SubscribePublishCommonEvent()
111 if (subscriber_ != nullptr) { in UnsubscribePublishCommonEvent()
113 if (!CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribePublishCommonEvent()
118 subscriber_ = nullptr; in UnsubscribePublishCommonEvent()
142 subscriber_ = subscriber; in SetSubscriber()
148 return subscriber_; in GetSubscriber()
[all...]
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_common_event.cpp66 if (subscriber_) { in SubscriberEvent()
78 subscriber_ = std::make_shared<AccessibilityCommonEventSubscriber>(subscribeInfo, *this); in SubscriberEvent()
83 bool subscribeResult = EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in SubscriberEvent()
101 if (subscriber_) { in UnSubscriberEvent()
102 bool unSubscribeResult = EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnSubscriberEvent()
104 subscriber_ = nullptr; in UnSubscriberEvent()
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_policy_core.cpp139 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
155 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
171 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
187 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
203 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
221 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
237 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/
H A Dut_net_policy_core.cpp139 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
155 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
171 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
187 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
203 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
221 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
237 g_netPolicyCore->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
/foundation/communication/netmanager_ext/services/netfirewallmanager/src/
H A Dnetfirewall_service.cpp314 } else if (systemAbilityId == COMMON_EVENT_SERVICE_ID && subscriber_ != nullptr) { in OnAddSystemAbility()
369 if (subscriber_ != nullptr) { in OnStop()
370 bool unSubscribeResult = OHOS::EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in OnStop()
371 subscriber_ = nullptr; in OnStop()
385 OHOS::EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in OnRemoveSystemAbility()
386 subscriber_ = nullptr; in OnRemoveSystemAbility()
399 subscriber_ = std::make_shared<ReceiveMessage>(subscribeInfo, shared_from_this()); in SubscribeCommonEvent()
406 if (!EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_)) { in RegisterSubscribeCommonEvent()
408 subscriber_ = nullptr; in RegisterSubscribeCommonEvent()
/foundation/communication/dsoftbus/adapter/common/bus_center/common_event/
H A Dlnn_common_event_monitor.cpp91 std::shared_ptr<CommonEventMonitor> subscriber_ = nullptr; member in OHOS::EventFwk::SubscribeEvent
105 subscriber_ = std::make_shared<CommonEventMonitor>(subscriberInfo); in SubscribeCommonEvent()
106 if (!CommonEventManager::SubscribeCommonEvent(subscriber_)) { in SubscribeCommonEvent()
/foundation/window/window_manager/wmserver/src/
H A Dwindow_common_event.cpp57 subscriber_ = std::make_shared<EventSubscriber>(info, shared_from_this()); in SubscriberEvent()
69 if (EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_)) { in SubscriberEventInner()
80 EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnSubscriberEvent()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/installer/
H A Dinstaller_impl.cpp123 auto res = CommonEventManager::UnSubscribeCommonEvent(subscriber_); in ~InstallerImpl()
131 auto res = CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnsubscribeEvent()
152 subscriber_ = subscriber; in Init()
161 auto succ = CommonEventManager::SubscribeCommonEvent(subscriber_); in GetTask()
/foundation/bundlemanager/bundle_framework/test/resource/common/src/
H A Dstpageabilityevent.cpp47 subscriber_ = std::make_shared<STPageAbilityEventSubscriber>(subscribeInfo, ability, stub); in SubscribeEvent()
48 CommonEventManager::SubscribeCommonEvent(subscriber_); in SubscribeEvent()
53 CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnsubscribeEvent()
/foundation/multimodalinput/input/service/account_manager/src/
H A Daccount_manager.cpp360 subscriber_ = std::make_shared<CommonEventSubscriber>(subscribeInfo); in SubscribeCommonEvent()
362 if (EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_)) { in SubscribeCommonEvent()
367 subscriber_ = nullptr; in SubscribeCommonEvent()
380 if (subscriber_ != nullptr) { in UnsubscribeCommonEvent()
381 if (!EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_)) { in UnsubscribeCommonEvent()
384 subscriber_ = nullptr; in UnsubscribeCommonEvent()
/foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/common_event/src/
H A Devent_controller.cpp191 subscriber_ = std::make_shared<EventController>(subscriberInfo); in OnAddSystemAbility()
192 SubscribeCommonEvent(subscriber_); in OnAddSystemAbility()
364 subscriber_ = nullptr; in OnRemoveSystemAbility()
370 if (subscriber_ == nullptr || lockScreenSubscriber_ == nullptr) { in Stop()
373 CommonEventManager::UnSubscribeCommonEvent(subscriber_); in Stop()
376 subscriber_ = nullptr; in Stop()
/foundation/multimodalinput/input/service/account_manager/test/
H A Daccount_manager_test.cpp66 accountManager.subscriber_ = nullptr; in HWTEST_F()
82 accountManager.subscriber_ = nullptr; in HWTEST_F()
96 accountManager.subscriber_ = nullptr; in HWTEST_F()

Completed in 11 milliseconds

123