Home
last modified time | relevance | path

Searched refs:subscriber (Results 1 - 25 of 209) sorted by relevance

123456789

/base/notification/distributed_notification_service/frameworks/core/src/
H A Dans_subscriber_listener.cpp24 SubscriberListener::SubscriberListener(std::shared_ptr<NotificationSubscriber> &subscriber) : subscriber_(subscriber) in SubscriberListener() argument
33 auto subscriber = subscriber_.lock(); in OnConnected() local
34 if (subscriber == nullptr) { in OnConnected()
38 subscriber->OnConnected(); in OnConnected()
44 auto subscriber = subscriber_.lock(); in OnDisconnected() local
45 if (subscriber == nullptr) { in OnDisconnected()
49 subscriber->OnDisconnected(); in OnDisconnected()
56 auto subscriber = subscriber_.lock(); in OnConsumed() local
57 if (subscriber in OnConsumed()
86 auto subscriber = subscriber_.lock(); OnCanceled() local
103 auto subscriber = subscriber_.lock(); OnBatchCanceled() local
125 auto subscriber = subscriber_.lock(); OnCanceledList() local
141 auto subscriber = subscriber_.lock(); OnUpdated() local
151 auto subscriber = subscriber_.lock(); OnDoNotDisturbDateChange() local
163 auto subscriber = subscriber_.lock(); OnEnabledNotificationChanged() local
174 auto subscriber = subscriber_.lock(); OnBadgeChanged() local
186 auto subscriber = subscriber_.lock(); OnBadgeEnabledChanged() local
[all...]
H A Dans_manager_proxy_subscribe.cpp30 ErrCode AnsManagerProxy::Subscribe(const sptr<AnsSubscriberInterface> &subscriber, in Subscribe() argument
33 if (subscriber == nullptr) { in Subscribe()
34 ANS_LOGE("[Subscribe] fail: subscriber is empty."); in Subscribe()
44 bool ret = data.WriteRemoteObject(subscriber->AsObject()); in Subscribe()
46 ANS_LOGE("[Subscribe] fail: write subscriber failed."); in Subscribe()
77 ErrCode AnsManagerProxy::SubscribeSelf(const sptr<AnsSubscriberInterface> &subscriber) in SubscribeSelf() argument
79 if (subscriber == nullptr) { in SubscribeSelf()
80 ANS_LOGE("[SubscribeSelf] fail: subscriber is empty."); in SubscribeSelf()
90 bool ret = data.WriteRemoteObject(subscriber->AsObject()); in SubscribeSelf()
92 ANS_LOGE("[SubscribeSelf] fail: write subscriber faile in SubscribeSelf()
112 SubscribeLocalLiveView(const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &info, const bool isNative) SubscribeLocalLiveView() argument
165 Unsubscribe( const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &info) Unsubscribe() argument
[all...]
/base/notification/common_event_service/interfaces/kits/cj/src/
H A Dcommon_event.h19 #include "subscriber.h"
26 std::shared_ptr<SubscriberImpl> subscriber = nullptr; member
39 void SetSubscribeInfo(std::shared_ptr<SubscriberImpl> subscriber,
44 void DeleteSubscribe(std::shared_ptr<SubscriberImpl> subscriber);
46 void GetSubscriberCode(std::shared_ptr<SubscriberImpl> subscriber, int64_t &code);
48 int32_t SetSubscriberCode(std::shared_ptr<SubscriberImpl> subscriber, int32_t code);
50 std::string GetSubscriberData(std::shared_ptr<SubscriberImpl> subscriber);
52 int32_t SetSubscriberData(std::shared_ptr<SubscriberImpl> subscriber, const char *data);
54 int32_t SetSubscriberCodeAndData(std::shared_ptr<SubscriberImpl> subscriber, int32_t code, const char *data);
56 void IsCommonEventSticky(std::shared_ptr<SubscriberImpl> subscriber, boo
[all...]
H A Dcommon_event.cpp60 void SetSubscribeInfo(std::shared_ptr<SubscriberImpl> subscriber, in SetSubscribeInfo() argument
64 subscriber->SetCallback(callback); in SetSubscribeInfo()
66 .callback = callback, .subscriber = subscriber}; in SetSubscribeInfo()
72 subscriberImpls[asyncCallbackInfo->subscriber].asyncCallbackInfo.emplace_back(asyncCallbackInfo); in SetSubscribeInfo()
100 void DeleteSubscribe(std::shared_ptr<SubscriberImpl> subscriber) in DeleteSubscribe() argument
104 auto subscribe = subscriberImpls.find(subscriber); in DeleteSubscribe()
110 subscriber->SetCallback(nullptr); in DeleteSubscribe()
115 void GetSubscriberCode(std::shared_ptr<SubscriberImpl> subscriber, int64_t &code) in GetSubscriberCode() argument
117 std::shared_ptr<AsyncCommonEventResult> result = GetAsyncResult(subscriber in GetSubscriberCode()
125 SetSubscriberCode(std::shared_ptr<SubscriberImpl> subscriber, int32_t code) SetSubscriberCode() argument
134 GetSubscriberData(std::shared_ptr<SubscriberImpl> subscriber) GetSubscriberData() argument
144 SetSubscriberData(std::shared_ptr<SubscriberImpl> subscriber, const char *data) SetSubscriberData() argument
153 SetSubscriberCodeAndData(std::shared_ptr<SubscriberImpl> subscriber, int32_t code, const char *data) SetSubscriberCodeAndData() argument
162 IsCommonEventSticky(std::shared_ptr<SubscriberImpl> subscriber, bool &data) IsCommonEventSticky() argument
172 IsCommonEventOrdered(std::shared_ptr<SubscriberImpl> subscriber, bool &data) IsCommonEventOrdered() argument
[all...]
/base/notification/distributed_notification_service/frameworks/test/moduletest/mock/
H A Dmock_common_event_manager.cpp27 for (auto subscriber : subscriberList) { in PublishCommonEvent()
28 subscriber->OnReceiveEvent(data); in PublishCommonEvent()
39 const std::shared_ptr<CommonEventSubscriber> &subscriber) in PublishCommonEvent()
44 bool CommonEventManager::SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in SubscribeCommonEvent() argument
46 subscriberList.push_back(subscriber); in SubscribeCommonEvent()
50 bool CommonEventManager::UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in UnSubscribeCommonEvent() argument
52 subscriberList.remove(subscriber); in UnSubscribeCommonEvent()
38 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) PublishCommonEvent() argument
/base/notification/common_event_service/test/fuzztest/commonevent_fuzzer/
H A Dcommonevent_fuzzer.cpp67 std::shared_ptr<EventFwk::TestSubscriber> subscriber = in DoSomethingInterestingWithMyAPI() local
69 subscriber->SetCode(code); in DoSomethingInterestingWithMyAPI()
70 subscriber->GetCode(); in DoSomethingInterestingWithMyAPI()
71 subscriber->SetData(stringData); in DoSomethingInterestingWithMyAPI()
72 subscriber->GetData(); in DoSomethingInterestingWithMyAPI()
73 subscriber->SetCodeAndData(code, stringData); in DoSomethingInterestingWithMyAPI()
74 subscriber->AbortCommonEvent(); in DoSomethingInterestingWithMyAPI()
75 subscriber->ClearAbortCommonEvent(); in DoSomethingInterestingWithMyAPI()
76 subscriber->GetAbortCommonEvent(); in DoSomethingInterestingWithMyAPI()
77 subscriber in DoSomethingInterestingWithMyAPI()
[all...]
/base/notification/common_event_service/frameworks/native/src/
H A Dcommon_event_manager.cpp61 const std::shared_ptr<CommonEventSubscriber> &subscriber) in PublishCommonEvent()
63 return PublishCommonEventAsUser(data, publishInfo, subscriber, UNDEFINED_USER); in PublishCommonEvent()
67 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, in PublishCommonEventAsUser()
70 return NewPublishCommonEventAsUser(data, publishInfo, subscriber, userId) == ERR_OK ? true : false; in PublishCommonEventAsUser()
74 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, in NewPublishCommonEventAsUser()
77 return CommonEvent::GetInstance()->PublishCommonEventAsUser(data, publishInfo, subscriber, in NewPublishCommonEventAsUser()
82 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid, const int32_t &callerToken) in PublishCommonEvent()
84 return PublishCommonEventAsUser(data, publishInfo, subscriber, uid, callerToken, UNDEFINED_USER); in PublishCommonEvent()
88 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, in PublishCommonEventAsUser()
91 return CommonEvent::GetInstance()->PublishCommonEventAsUser(data, publishInfo, subscriber, ui in PublishCommonEventAsUser()
60 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) PublishCommonEvent() argument
66 PublishCommonEventAsUser(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const int32_t &userId) PublishCommonEventAsUser() argument
73 NewPublishCommonEventAsUser(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const int32_t &userId) NewPublishCommonEventAsUser() argument
81 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid, const int32_t &callerToken) PublishCommonEvent() argument
87 PublishCommonEventAsUser(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid, const int32_t &callerToken, const int32_t &userId) PublishCommonEventAsUser() argument
95 SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) SubscribeCommonEvent() argument
100 NewSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) NewSubscribeCommonEvent() argument
105 UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) UnSubscribeCommonEvent() argument
110 NewUnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) NewUnSubscribeCommonEvent() argument
[all...]
/base/security/security_guard/services/security_collector/src/
H A Dsecurity_collector_run_manager.cpp44 bool SecurityCollectorRunManager::StartCollector(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) in StartCollector() argument
47 if (subscriber == nullptr) { in StartCollector()
48 LOGE("subscriber is null"); in StartCollector()
51 std::string appName = subscriber->GetAppName(); in StartCollector()
52 int64_t eventId = subscriber->GetSecurityCollectorSubscribeInfo().GetEvent().eventId; in StartCollector()
59 auto collectorListenner = std::make_shared<SecurityCollectorRunManager::CollectorListenner>(subscriber); in StartCollector()
65 collectorRunManager_.emplace(eventId, subscriber); in StartCollector()
69 bool SecurityCollectorRunManager::StopCollector(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) in StopCollector() argument
72 if (subscriber == nullptr) { in StopCollector()
73 LOGE("subscriber i in StopCollector()
[all...]
H A Dsecurity_collector_subscriber_manager.cpp52 for (const auto &subscriber : it->second) { in NotifySubscriber()
53 if (subscriber != nullptr) { in NotifySubscriber()
54 subscriber->OnChange(event); in NotifySubscriber()
64 count = std::count_if(subscribers.begin(), subscribers.end(), [appName] (const auto &subscriber) { in GetAppSubscribeCount()
65 return subscriber->GetAppName() == appName; in GetAppSubscribeCount()
75 if (std::any_of(subscribers.begin(), subscribers.end(), [appName] (const auto &subscriber) { in GetAppSubscribeCount()
76 return subscriber->GetAppName() == appName; in GetAppSubscribeCount()
91 [remote] (const auto &subscriber) { return subscriber->GetRemote() == remote; }); in FindEventIds()
116 const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) in SubscribeCollector()
115 SubscribeCollector( const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) SubscribeCollector() argument
[all...]
/base/location/test/location_locator/mock/src/
H A Dmock_common_event_manager.cpp32 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) in PublishCommonEvent()
34 return Location::MockCommonEventManager::GetInstance().PublishCommonEvent(data, publishInfo, subscriber); in PublishCommonEvent()
38 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid) in PublishCommonEvent()
40 return Location::MockCommonEventManager::GetInstance().PublishCommonEvent(data, publishInfo, subscriber, uid); in PublishCommonEvent()
43 bool CommonEventManager::SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in SubscribeCommonEvent() argument
45 return Location::MockCommonEventManager::GetInstance().SubscribeCommonEvent(subscriber); in SubscribeCommonEvent()
48 bool CommonEventManager::UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in UnSubscribeCommonEvent() argument
50 return Location::MockCommonEventManager::GetInstance().UnSubscribeCommonEvent(subscriber); in UnSubscribeCommonEvent()
31 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) PublishCommonEvent() argument
37 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid) PublishCommonEvent() argument
/base/location/test/location_manager/mock/src/
H A Dmock_common_event_manager.cpp32 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) in PublishCommonEvent()
34 return Location::MockCommonEventManager::GetInstance().PublishCommonEvent(data, publishInfo, subscriber); in PublishCommonEvent()
38 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid) in PublishCommonEvent()
40 return Location::MockCommonEventManager::GetInstance().PublishCommonEvent(data, publishInfo, subscriber, uid); in PublishCommonEvent()
43 bool CommonEventManager::SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in SubscribeCommonEvent() argument
45 return Location::MockCommonEventManager::GetInstance().SubscribeCommonEvent(subscriber); in SubscribeCommonEvent()
48 bool CommonEventManager::UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber) in UnSubscribeCommonEvent() argument
50 return Location::MockCommonEventManager::GetInstance().UnSubscribeCommonEvent(subscriber); in UnSubscribeCommonEvent()
31 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber) PublishCommonEvent() argument
37 PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid) PublishCommonEvent() argument
/base/security/security_guard/frameworks/common/collector/src/
H A Dcollector_manager.cpp25 int32_t CollectorManager::Subscribe(const std::shared_ptr<ICollectorSubscriber> &subscriber) in Subscribe() argument
28 if (subscriber == nullptr) { in Subscribe()
29 LOGE("subscriber is null"); in Subscribe()
33 if (eventListeners_.find(subscriber) != eventListeners_.end()) { in Subscribe()
57 new (std::nothrow) SecurityCollectorManagerCallbackService(subscriber); in Subscribe()
62 int32_t ret = proxy->Subscribe(subscriber->GetSubscribeInfo(), callback); in Subscribe()
64 eventListeners_[subscriber] = callback; in Subscribe()
70 int32_t CollectorManager::Unsubscribe(const std::shared_ptr<ICollectorSubscriber> &subscriber) in Unsubscribe() argument
73 if (subscriber == nullptr) { in Unsubscribe()
74 LOGE("subscriber i in Unsubscribe()
137 CollectorStart(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber) CollectorStart() argument
161 CollectorStop(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber) CollectorStop() argument
[all...]
/base/notification/distributed_notification_service/frameworks/js/napi/src/manager/
H A Dlocal_live_view_subscribe.cpp32 LocalLiveViewSubscriberInstance *subscriber = nullptr; member
197 subscriberInfo.subscriber = new (std::nothrow) LocalLiveViewSubscriberInstance(); in GetNotificationSubscriber()
198 if (subscriberInfo.subscriber == nullptr) { in GetNotificationSubscriber()
199 ANS_LOGE("subscriber is null"); in GetNotificationSubscriber()
218 subscriberInfo.subscriber->SetCallbackInfo(env, RESPONSE, result); in GetNotificationSubscriber()
231 if (subscriberInfo.subscriber == nullptr) { in AddSubscriberInstancesInfo()
232 ANS_LOGE("subscriberInfo.subscriber is null"); in AddSubscriberInstancesInfo()
241 bool DelSubscriberInstancesInfo(const napi_env &env, const LocalLiveViewSubscriberInstance *subscriber) in DelSubscriberInstancesInfo() argument
244 if (subscriber == nullptr) { in DelSubscriberInstancesInfo()
245 ANS_LOGE("subscriber i in DelSubscriberInstancesInfo()
264 ParseParameters(const napi_env &env, const napi_callback_info &info, LocalLiveViewSubscriberInstance *&subscriber, napi_ref &callback) ParseParameters() argument
326 AddDeletingSubscriber(LocalLiveViewSubscriberInstance *subscriber) AddDeletingSubscriber() argument
338 DelDeletingSubscriber(LocalLiveViewSubscriberInstance *subscriber) DelDeletingSubscriber() argument
[all...]
/base/notification/distributed_notification_service/services/ans/src/
H A Dnotification_local_live_view_subscriber_manager.cpp37 sptr<AnsSubscriberLocalLiveViewInterface> subscriber {nullptr};
68 const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) in AddLocalLiveViewSubscriber()
71 if (subscriber == nullptr) { in AddLocalLiveViewSubscriber()
72 ANS_LOGE("subscriber is null."); in AddLocalLiveViewSubscriber()
96 notificationButtonQueue_->submit_h(std::bind([this, &subscriber, &bundleOption, &result]() { in AddLocalLiveViewSubscriber()
98 result = this->AddSubscriberInner(subscriber, bundleOption); in AddLocalLiveViewSubscriber()
106 const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) in RemoveLocalLiveViewSubscriber()
109 if (subscriber == nullptr) { in RemoveLocalLiveViewSubscriber()
110 ANS_LOGE("subscriber is null."); in RemoveLocalLiveViewSubscriber()
120 ffrt::task_handle handler = notificationButtonQueue_->submit_h(std::bind([this, &subscriber, in RemoveLocalLiveViewSubscriber()
67 AddLocalLiveViewSubscriber( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) AddLocalLiveViewSubscriber() argument
105 RemoveLocalLiveViewSubscriber( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) RemoveLocalLiveViewSubscriber() argument
182 FindSubscriberRecord( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber) FindSubscriberRecord() argument
195 CreateSubscriberRecord( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationBundleOption> &bundleOption) CreateSubscriberRecord() argument
212 AddSubscriberInner( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationBundleOption> &bundleOption) AddSubscriberInner() argument
234 RemoveSubscriberInner( const sptr<AnsSubscriberLocalLiveViewInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) RemoveSubscriberInner() argument
[all...]
H A Dnotification_subscriber_manager.cpp41 sptr<AnsSubscriberInterface> subscriber {nullptr};
74 const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) in AddSubscriber()
77 if (subscriber == nullptr) { in AddSubscriber()
78 ANS_LOGE("subscriber is null."); in AddSubscriber()
106 ffrt::task_handle handler = notificationSubQueue_->submit_h(std::bind([this, &subscriber, &subInfo, &result]() { in AddSubscriber()
107 result = this->AddSubscriberInner(subscriber, subInfo); in AddSubscriber()
117 const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) in RemoveSubscriber()
120 if (subscriber == nullptr) { in RemoveSubscriber()
121 ANS_LOGE("subscriber is null."); in RemoveSubscriber()
131 ffrt::task_handle handler = notificationSubQueue_->submit_h(std::bind([this, &subscriber, in RemoveSubscriber()
73 AddSubscriber( const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) AddSubscriber() argument
116 RemoveSubscriber( const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) RemoveSubscriber() argument
303 FindSubscriberRecord( const sptr<AnsSubscriberInterface> &subscriber) FindSubscriberRecord() argument
316 CreateSubscriberRecord( const sptr<AnsSubscriberInterface> &subscriber) CreateSubscriberRecord() argument
365 AddSubscriberInner( const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) AddSubscriberInner() argument
392 RemoveSubscriberInner( const sptr<AnsSubscriberInterface> &subscriber, const sptr<NotificationSubscribeInfo> &subscribeInfo) RemoveSubscriberInner() argument
[all...]
/base/notification/common_event_service/interfaces/inner_api/
H A Dcommon_event_manager.h89 * @param subscriber Indicates the common event subscriber.
93 const std::shared_ptr<CommonEventSubscriber> &subscriber);
100 * @param subscriber Indicates the common event subscriber.
105 const std::shared_ptr<CommonEventSubscriber> &subscriber, const int32_t &userId);
112 * @param subscriber Indicates the common event subscriber.
117 const std::shared_ptr<CommonEventSubscriber> &subscriber, const int32_t &userId);
124 * @param subscriber Indicate
[all...]
/base/security/security_guard/test/unittest/security_collector/include/
H A Dsecurity_collector_run_manager.h34 virtual bool StartCollector(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) = 0;
35 virtual bool StopCollector(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) = 0;
47 MOCK_METHOD1(StartCollector, bool(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber));
48 MOCK_METHOD1(StopCollector, bool (const std::shared_ptr<SecurityCollectorSubscriber> &subscriber));
52 CollectorListenner(const std::shared_ptr<SecurityCollectorSubscriber> &subscriber) : subscriber_(subscriber) {} in CollectorListenner() argument
/base/notification/common_event_service/frameworks/native/test/unittest/
H A Dcommon_event_subscribe_test.cpp158 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); in HWTEST_F() local
159 bool subscribeResult = CommonEventManager::SubscribeCommonEvent(subscriber); in HWTEST_F()
198 // expect the subscriber could receive the event within 5 seconds. in HWTEST_F()
210 * 2. different subscriber subscribe event
237 * 2. fail subscribe common event kit with null subscriber
260 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); in HWTEST_F() local
262 bool subscribeResult = CommonEventManager::SubscribeCommonEvent(subscriber); in HWTEST_F()
281 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); in HWTEST_F() local
283 CommonEventManager::SubscribeCommonEvent(subscriber); in HWTEST_F()
285 bool subscribeResult = CommonEventManager::SubscribeCommonEvent(subscriber); in HWTEST_F()
329 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
392 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
423 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
447 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
641 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
661 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
680 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
700 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
720 std::shared_ptr<SubscriberTest> subscriber = std::make_shared<SubscriberTest>(subscribeInfo); HWTEST_F() local
[all...]
/base/notification/common_event_service/services/src/
H A Dstatic_subscriber_manager.cpp67 StaticSubscriber subscriber = { .events = s}; in InitAllowList() local
68 staticSubscribers_.insert(std::make_pair(bundleName, subscriber)); in InitAllowList()
91 // get all static subscriber type extensions in InitValidSubscribers()
151 EVENT_LOGD("Ready to connect to subscriber %{public}s in bundle %{public}s", in PublishCommonEventConnecAbility()
163 for (auto subscriber : targetSubscribers->second) { in PublishCommonEventInner()
164 if (IsDisableEvent(subscriber.bundleName, targetSubscribers->first)) { in PublishCommonEventInner()
165 EVENT_LOGW("subscriber %{public}s is disable.", subscriber.bundleName.c_str()); in PublishCommonEventInner()
166 SendStaticEventProcErrHiSysEvent(userId, bundleName, subscriber.bundleName, data.GetWant().GetAction()); in PublishCommonEventInner()
169 if (subscriber in PublishCommonEventInner()
322 StaticSubscriberInfo subscriber = { .name = extensionName, ParseEvents() local
351 AddToValidSubscribers(const std::string &eventName, const StaticSubscriberInfo &subscriber) AddToValidSubscribers() argument
[all...]
/base/security/security_guard/test/unittest/mock/collector_manager/
H A Dcollector_manager.h36 virtual int32_t Subscribe(const std::shared_ptr<ICollectorSubscriber> &subscriber) = 0;
37 virtual int32_t Unsubscribe(const std::shared_ptr<ICollectorSubscriber> &subscriber) = 0;
40 virtual int32_t CollectorStart(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber) = 0;
41 virtual int32_t CollectorStop(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber) = 0;
53 MOCK_METHOD1(Subscribe, int32_t(const std::shared_ptr<ICollectorSubscriber> &subscriber));
54 MOCK_METHOD1(Unsubscribe, int32_t(const std::shared_ptr<ICollectorSubscriber> &subscriber));
57 MOCK_METHOD1(CollectorStart, int32_t(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber));
58 MOCK_METHOD1(CollectorStop, int32_t(const SecurityCollector::SecurityCollectorSubscribeInfo &subscriber));
/base/security/security_guard/frameworks/common/acquire/src/
H A Dacquire_data_manager.cpp45 int32_t AcquireDataManager::Subscribe(const std::shared_ptr<SecurityCollector::ICollectorSubscriber> &subscriber) in Subscribe() argument
48 if (subscriber == nullptr) { in Subscribe()
49 SGLOGE("subscriber is nullptr"); in Subscribe()
53 if (eventListeners_.find(subscriber) != eventListeners_.end()) { in Subscribe()
83 sptr<AcquireDataManagerCallbackService> callback = new (std::nothrow) AcquireDataManagerCallbackService(subscriber); in Subscribe()
89 int32_t ret = proxy->Subscribe(subscriber->GetSubscribeInfo(), callback); in Subscribe()
91 eventListeners_[subscriber] = callback; in Subscribe()
97 int32_t AcquireDataManager::Unsubscribe(const std::shared_ptr<SecurityCollector::ICollectorSubscriber> &subscriber) in Unsubscribe() argument
106 if (eventListeners_.find(subscriber) == eventListeners_.end()) { in Unsubscribe()
118 int32_t ret = proxy->Unsubscribe(eventListeners_[subscriber]); in Unsubscribe()
[all...]
/base/location/test/location_locator/mock/include/
H A Dmock_common_event_manager.h31 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber));
33 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber));
35 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid));
36 MOCK_METHOD(bool, SubscribeCommonEvent, (const std::shared_ptr<CommonEventSubscriber> &subscriber));
37 MOCK_METHOD(bool, UnSubscribeCommonEvent, (const std::shared_ptr<CommonEventSubscriber> &subscriber));
/base/location/test/location_manager/mock/include/
H A Dmock_common_event_manager.h31 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber));
33 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber));
35 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid));
36 MOCK_METHOD(bool, SubscribeCommonEvent, (const std::shared_ptr<CommonEventSubscriber> &subscriber));
37 MOCK_METHOD(bool, UnSubscribeCommonEvent, (const std::shared_ptr<CommonEventSubscriber> &subscriber));
/base/notification/common_event_service/interfaces/kits/ndk/src/
H A Doh_commonevent_wrapper.cpp102 void SubscriberManager::DestroySubscriber(CommonEvent_Subscriber* subscriber) in DestroySubscriber() argument
104 if (subscriber != nullptr) { in DestroySubscriber()
105 auto subscriberPtr = reinterpret_cast<std::shared_ptr<SubscriberObserver>*>(subscriber); in DestroySubscriber()
111 CommonEvent_ErrCode SubscriberManager::Subscribe(const CommonEvent_Subscriber* subscriber) in Subscribe() argument
113 if (subscriber == nullptr) { in Subscribe()
114 EVENT_LOGE("subscriber is null"); in Subscribe()
117 auto observer = *(reinterpret_cast<const std::shared_ptr<SubscriberObserver>*>(subscriber)); in Subscribe()
125 CommonEvent_ErrCode SubscriberManager::UnSubscribe(const CommonEvent_Subscriber* subscriber) in UnSubscribe() argument
127 if (subscriber == nullptr) { in UnSubscribe()
128 EVENT_LOGE("subscriber i in UnSubscribe()
[all...]
/base/security/security_guard/test/unittest/security_collector/interface_test/src/
H A Dcollector_interface_test.cpp83 std::shared_ptr<SecurityCollector::SecurityCollectorSubscriber> subscriber = in HWTEST_F() local
86 SecurityCollector::SecurityCollectorRunManager::CollectorListenner(subscriber); in HWTEST_F()
90 SecurityCollector::CollectorFwkTestImpl(subscriber); in HWTEST_F()
124 SecurityCollector::CollectorSubscriberTestImpl subscriber{event, duration, true}; in HWTEST_F()
125 SecurityCollector::SecurityCollectorSubscribeInfo result = subscriber.GetSubscribeInfo(); in HWTEST_F()
148 auto subscriber = std::make_shared<SecurityGuardTest::SecurityCollectorSubscriber>(event); in HWTEST_F() local
151 manager.eventListeners_.insert({subscriber, callback}); in HWTEST_F()
152 int ret = manager.Subscribe(subscriber); in HWTEST_F()
160 auto subscriber = std::make_shared<SecurityGuardTest::SecurityCollectorSubscriber>(event); in HWTEST_F() local
161 int ret = manager.Subscribe(subscriber); in HWTEST_F()
180 auto subscriber = std::make_shared<SecurityGuardTest::SecurityCollectorSubscriber>(event); HWTEST_F() local
192 auto subscriber = std::make_shared<SecurityGuardTest::SecurityCollectorSubscriber>(event); HWTEST_F() local
[all...]

Completed in 9 milliseconds

123456789