| /base/notification/distributed_notification_service/services/ans/test/unittest/ |
| H A D | notification_local_live_view_subscriber_manager_test.cpp | 52 static sptr<AnsSubscriberLocalLiveViewInterface> subscriber_; member in OHOS::Notification::NotificationLocalLiveViewSubscriberManagerTest
60 NotificationLocalLiveViewSubscriberManagerTest::subscriber_ = nullptr; member in OHOS::Notification::NotificationLocalLiveViewSubscriberManagerTest
65 subscriber_ = testAnsSubscriber_.GetImpl(); in SetUpTestCase()
70 subscriber_ = nullptr; in TearDownTestCase()
80 notificationLocalLiveViewSubscriberManager_->AddLocalLiveViewSubscriber(subscriber_, info); in SetUp()
85 notificationLocalLiveViewSubscriberManager_->RemoveLocalLiveViewSubscriber(subscriber_, nullptr); in TearDown()
97 ASSERT_EQ(notificationLocalLiveViewSubscriberManager_->AddLocalLiveViewSubscriber(subscriber_, info), (int)ERR_OK); in HWTEST_F()
109 ASSERT_EQ(notificationLocalLiveViewSubscriberManager_->AddLocalLiveViewSubscriber(subscriber_, info), (int)ERR_OK); in HWTEST_F()
111 RemoveLocalLiveViewSubscriber(subscriber_, info), (int)ERR_OK); in HWTEST_F()
123 ASSERT_EQ(notificationLocalLiveViewSubscriberManager_->AddLocalLiveViewSubscriber(subscriber_, inf in HWTEST_F()
[all...] |
| H A D | notification_subscriber_manager_test.cpp | 72 static sptr<AnsSubscriberInterface> subscriber_; member in OHOS::Notification::NotificationSubscriberManagerTest
77 sptr<AnsSubscriberInterface> NotificationSubscriberManagerTest::subscriber_ = nullptr; member in OHOS::Notification::NotificationSubscriberManagerTest
83 subscriber_ = new (std::nothrow) SubscriberListener(testAnsSubscriber); in SetUpTestCase()
88 subscriber_ = nullptr; in TearDownTestCase()
97 notificationSubscriberManager_->AddSubscriber(subscriber_, nullptr); in SetUp()
102 notificationSubscriberManager_->RemoveSubscriber(subscriber_, nullptr); in TearDown()
120 ASSERT_EQ(notificationSubscriberManager_->AddSubscriber(subscriber_, info), (int)ERR_OK); in HWTEST_F()
121 ASSERT_EQ(notificationSubscriberManager_->AddSubscriber(subscriber_, nullptr), (int)ERR_OK); in HWTEST_F()
158 ASSERT_EQ(notificationSubscriberManager_->RemoveSubscriber(subscriber_, info), (int)ERR_OK); in HWTEST_F()
|
| /base/hiviewdfx/hiview/core/param_update/src/ |
| H A D | param_event_manager.cpp | 45 if (subscriber_) { in SubscriberEvent()
54 subscriber_ = std::make_shared<ParamCommonEventSubscriber>(subscribeInfo, *this); in SubscriberEvent()
56 bool subscribeResult = EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in SubscriberEvent()
59 subscriber_ = nullptr; in SubscriberEvent()
66 if (subscriber_) { in UnSubscriberEvent()
67 bool subscribeResult = EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnSubscriberEvent()
69 subscriber_ = nullptr; in UnSubscriberEvent()
|
| /base/notification/distributed_notification_service/frameworks/core/src/ |
| H A D | ans_subscriber_listener.cpp | 24 SubscriberListener::SubscriberListener(std::shared_ptr<NotificationSubscriber> &subscriber) : subscriber_(subscriber) in SubscriberListener()
33 auto subscriber = subscriber_.lock(); in OnConnected()
44 auto subscriber = subscriber_.lock(); in OnDisconnected()
56 auto subscriber = subscriber_.lock(); in OnConsumed()
86 auto subscriber = subscriber_.lock(); in OnCanceled()
103 auto subscriber = subscriber_.lock(); in OnBatchCanceled()
125 auto subscriber = subscriber_.lock(); in OnCanceledList()
141 auto subscriber = subscriber_.lock(); in OnUpdated()
151 auto subscriber = subscriber_.lock(); in OnDoNotDisturbDateChange()
163 auto subscriber = subscriber_ in OnEnabledNotificationChanged()
[all...] |
| /base/theme/screenlock_mgr/services/src/ |
| H A D | commeventsubscriber.cpp | 61 if (subscriber_) { in SubscribeEvent()
70 subscriber_ = std::make_shared<CommEventSubscriber>(subscribeInfo, *this); in SubscribeEvent()
72 bool subscribeResult = EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in SubscribeEvent()
75 subscriber_ = nullptr; in SubscribeEvent()
82 if (subscriber_) { in UnSubscribeEvent()
83 bool subscribeResult = EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in UnSubscribeEvent()
85 subscriber_ = nullptr; in UnSubscribeEvent()
|
| /base/security/security_guard/test/unittest/security_collector/include/ |
| H A D | security_collector_run_manager.h | 52 CollectorListenner(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) : subscriber_(subscriber) {} in CollectorListenner()
55 if (subscriber_) {
56 return subscriber_->GetSecurityCollectorSubscribeInfo().GetEvent().extra;
62 std::shared_ptr<SecurityCollectorSubscriber> subscriber_; member in OHOS::Security::SecurityCollector::SecurityCollectorRunManager::CollectorListenner
|
| /base/notification/distributed_notification_service/frameworks/ans/src/ |
| H A D | notification_local_live_view_subscriber.cpp | 38 NotificationLocalLiveViewSubscriber &subscriber) : subscriber_(subscriber) in SubscriberLocalLiveViewImpl()
51 subscriber_.OnConnected(); in OnConnected()
62 subscriber_.OnDisconnected(); in OnDisconnected()
69 subscriber_.OnResponse(notificationId, buttonOption); in OnResponse()
102 subscriberImpl_.subscriber_.OnDied(); in OnRemoteDied()
|
| /base/account/os_account/services/accountmgr/src/ |
| H A D | account_event_subscribe.cpp | 52 subscriber_ = std::make_shared<AccountEventSubscriberCallback>(subscribeInfo, callback_); in AccountEventSubscriber()
57 EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in ~AccountEventSubscriber()
62 return EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in CreateEventSubscribe()
67 return EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in DestroyEventSubscribe()
|
| /base/security/security_guard/frameworks/common/collector/src/ |
| H A D | security_collector_manager_callback_service.cpp | 26 if (subscriber_ != nullptr) { in OnNotify()
27 subscriber_->OnNotify(event); in OnNotify()
|
| /base/security/security_guard/frameworks/common/acquire/src/ |
| H A D | acquire_data_manager_callback_service.cpp | 26 if (subscriber_ != nullptr) { in OnNotify()
27 subscriber_->OnNotify(event); in OnNotify()
|
| /base/security/security_guard/interfaces/inner_api/acquire/include/ |
| H A D | acquire_data_manager_callback_service.h | 26 const std::shared_ptr<SecurityCollector::ICollectorSubscriber> &subscriber) : subscriber_(subscriber) {} in AcquireDataManagerCallbackService()
32 std::shared_ptr<SecurityCollector::ICollectorSubscriber> subscriber_; member in OHOS::Security::SecurityGuard::AcquireDataManagerCallbackService
|
| /base/security/security_guard/interfaces/inner_api/collector/include/ |
| H A D | security_collector_manager_callback_service.h | 26 : subscriber_(subscriber) {} in SecurityCollectorManagerCallbackService()
32 std::shared_ptr<ICollectorSubscriber> subscriber_; member in OHOS::Security::SecurityCollector::SecurityCollectorManagerCallbackService
|
| /base/telephony/core_service/services/network_search/src/ |
| H A D | device_state_observer.cpp | 53 subscriber_ = std::make_shared<DeviceStateEventSubscriber>(subscriberInfo); in StartEventSubscriber()
54 subscriber_->SetEventHandler(deviceStateHandler); in StartEventSubscriber()
55 subscriber_->InitEventMap(); in StartEventSubscriber()
60 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_, sharingEventCallback_); in StartEventSubscriber()
80 if (subscriber_ != nullptr) { in StopEventSubscriber()
81 bool subscribeResult = CommonEventManager::UnSubscribeCommonEvent(subscriber_); in StopEventSubscriber()
82 subscriber_ = nullptr; in StopEventSubscriber()
|
| /base/security/security_guard/services/security_collector/include/ |
| H A D | security_collector_run_manager.h | 40 CollectorListenner(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) : subscriber_(subscriber) {} in CollectorListenner()
44 std::shared_ptr<SecurityCollectorSubscriber> subscriber_; member in OHOS::Security::SecurityCollector::SecurityCollectorRunManager::CollectorListenner
|
| /base/security/security_guard/test/unittest/security_collector/interface_test/include/ |
| H A D | collector_interface_test.h | 50 CollectorFwkTestImpl(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) : subscriber_(subscriber) {}
in CollectorFwkTestImpl()
53 std::shared_ptr<SecurityCollectorSubscriber> subscriber_;
member in OHOS::Security::OHOS::Security::SecurityCollector::CollectorFwkTestImpl
|
| /base/request/request/services/include/ |
| H A D | get_proxy.h | 61 static std::shared_ptr<SysNetProxySubscriber> subscriber_;
member in SysNetProxyManager
66 std::shared_ptr<SysNetProxySubscriber> SysNetProxyManager::subscriber_ = nullptr;
member in SysNetProxyManager
|
| /base/usb/usb_manager/test/native/mock/src/ |
| H A D | usb_impl_mock.cpp | 87 subscriber_ = subscriber; in BindUsbdSubscriber()
94 subscriber_ = nullptr; in UnbindUsbdSubscriber()
124 auto ret = subscriber_->PortChangedEvent(portInfo_); in SetPortRole()
131 auto ret = subscriber_->DeviceEvent(info); in SubscriberDeviceEvent()
|
| /base/account/os_account/services/accountmgr/src/appaccount/ |
| H A D | app_account_common_event_observer.cpp | 52 subscriber_ = std::make_shared<AppAccountCommonEventSubscriber>( in AppAccountCommonEventObserver()
63 CommonEventManager::UnSubscribeCommonEvent(subscriber_); in ~AppAccountCommonEventObserver()
69 if (CommonEventManager::SubscribeCommonEvent(subscriber_)) { in SubscribeCommonEvent()
|
| /base/powermgr/thermal_manager/services/native/src/thermal_observer/ |
| H A D | thermal_common_event_receiver.cpp | 33 if (subscriber_ != nullptr) { in ~ThermalCommonEventReceiver()
34 CommonEventManager::UnSubscribeCommonEvent(subscriber_); in ~ThermalCommonEventReceiver()
87 subscriber_ = s; in RegisterSubscriber()
|
| /base/notification/distributed_notification_service/services/ans/src/ |
| H A D | advanced_notification_service_ability.cpp | 88 subscriber_ = std::make_shared<SystemEventSubscriber>( in OnAddSystemAbility()
90 if (subscriber_ == nullptr) { in OnAddSystemAbility()
91 ANS_LOGD("subscriber_ is nullptr"); in OnAddSystemAbility()
94 EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in OnAddSystemAbility()
|
| H A D | system_event_observer.cpp | 49 subscriber_ = std::make_shared<SystemEventSubscriber>( in SystemEventObserver()
52 EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in SystemEventObserver()
57 EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in ~SystemEventObserver()
|
| /base/security/security_guard/services/security_collector/src/ |
| H A D | security_collector_run_manager.cpp | 31 if (subscriber_) { in GetExtraInfo()
32 return subscriber_->GetSecurityCollectorSubscribeInfo().GetEvent().extra; in GetExtraInfo()
|
| /base/telephony/call_manager/services/call_earthquake_alarm/src/ |
| H A D | call_earthquake_alarm_subscriber.cpp | 26 std::shared_ptr<LocationSubscriber> LocationSubscriber::subscriber_ = nullptr; member in OHOS::Telephony::LocationSubscriber
41 if (LocationSubscriber::subscriber_ == nullptr) { in Subscriber()
46 LocationSubscriber::subscriber_ = std::make_shared<LocationSubscriber>(subscribeInfo); in Subscriber() member in OHOS::Telephony::LocationSubscriber
47 EventFwk::CommonEventManager::SubscribeCommonEvent(LocationSubscriber::subscriber_); in Subscriber()
|
| /base/security/dlp_permission_service/services/dlp_permission/sa/adapt/ |
| H A D | app_uninstall_observer.h | 39 std::shared_ptr<AppUninstallObserver> subscriber_ = nullptr;
member in OHOS::Security::DlpPermission::DlpEventSubSubscriber
|
| /base/location/services/location_locator/locator/source/ |
| H A D | locator_background_proxy.cpp | 116 if (subscriber_ == nullptr) { in SubscribeSaStatusChangeListerner()
117 subscriber_ = std::make_shared<UserSwitchSubscriber>(subscriberInfo); in SubscribeSaStatusChangeListerner()
120 statusChangeListener_ = new (std::nothrow) SystemAbilityStatusChangeListener(subscriber_); in SubscribeSaStatusChangeListerner()
340 std::shared_ptr<UserSwitchSubscriber> &subscriber) : subscriber_(subscriber) in SystemAbilityStatusChangeListener()
350 if (subscriber_ == nullptr) { in OnAddSystemAbility()
354 bool result = OHOS::EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_); in OnAddSystemAbility()
355 LBSLOGI(LOCATOR_BACKGROUND_PROXY, "SubscribeCommonEvent subscriber_ result = %{public}d", result); in OnAddSystemAbility()
365 if (subscriber_ == nullptr) { in OnRemoveSystemAbility()
369 bool result = OHOS::EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_); in OnRemoveSystemAbility()
370 LBSLOGE(LOCATOR_BACKGROUND_PROXY, "UnSubscribeCommonEvent subscriber_ resul in OnRemoveSystemAbility()
[all...] |