Searched refs:subscribers_ (Results 1 - 8 of 8) sorted by relevance
| /base/security/security_guard/frameworks/js/napi/ |
| H A D | security_guard_sdk_adaptor.cpp | 43 sptr<AcquireDataManagerCallbackService>> SecurityGuardSdkAdaptor::subscribers_ {};
245 if (subscribers_.find(subscriber) != subscribers_.end()) { in Subscribe()
268 subscribers_[subscriber] = obj; in Subscribe()
280 auto iter = subscribers_.find(subscriber); in Unsubscribe()
281 if (iter == subscribers_.end()) { in Unsubscribe()
291 int32_t ret = proxy->Unsubscribe(subscribers_[subscriber]); in Unsubscribe()
298 subscribers_.erase(iter); in Unsubscribe()
|
| H A D | security_guard_sdk_adaptor.h | 48 sptr<AcquireDataManagerCallbackService>> subscribers_; member in OHOS::Security::SecurityGuard::SecurityGuardSdkAdaptor
|
| /base/notification/common_event_service/services/test/unittest/ |
| H A D | common_event_freeze_unit_test.cpp | 102 ASSERT_EQ(expectSize, commonEventSubscriberManager.subscribers_.size()); in HWTEST_F()
104 EXPECT_EQ(true, commonEventSubscriberManager.subscribers_[0]->isFreeze); in HWTEST_F()
134 ASSERT_EQ(expectSize, commonEventSubscriberManager.subscribers_.size()); in HWTEST_F()
136 EXPECT_EQ(false, commonEventSubscriberManager.subscribers_[0]->isFreeze); in HWTEST_F()
439 ASSERT_EQ(commonEventSubscriberManager.subscribers_.size(), expectSize); in HWTEST_F()
441 EXPECT_EQ(commonEventSubscriberManager.subscribers_[0]->isFreeze, true); in HWTEST_F()
469 ASSERT_EQ(commonEventSubscriberManager.subscribers_.size(), expectSize); in HWTEST_F()
471 EXPECT_EQ(commonEventSubscriberManager.subscribers_[0]->isFreeze, false); in HWTEST_F()
582 ASSERT_EQ(commonEventSubscriberManager.subscribers_.size(), expectSize); in HWTEST_F()
|
| H A D | common_event_subscriber_manager_test.cpp | 406 commonEventSubscriberManager->subscribers_.emplace_back(record);
in HWTEST_F()
430 commonEventSubscriberManager->subscribers_.emplace_back(record);
in HWTEST_F()
544 commonEventSubscriberManager->subscribers_.emplace_back(record);
in HWTEST_F()
|
| /base/notification/common_event_service/services/src/ |
| H A D | common_event_subscriber_manager.cpp | 138 for (auto it = subscribers_.begin(); it != subscribers_.end(); ++it) { in GetSubscriberRecord()
320 subscribers_.emplace_back(record); in InsertSubscriberRecordLocked()
340 for (auto it = subscribers_.begin(); it != subscribers_.end(); ++it) { in RemoveSubscriberRecordLocked()
348 subscribers_.erase(it); in RemoveSubscriberRecordLocked()
468 records = subscribers_; in GetSubscriberRecordsByEvent()
470 for (auto recordPtr : subscribers_) { in GetSubscriberRecordsByEvent()
500 for (auto recordPtr : subscribers_) { in UpdateFreezeInfo()
520 for (auto recordPtr : subscribers_) { in UpdateFreezeInfo()
[all...] |
| /base/notification/distributed_notification_service/frameworks/core/src/ |
| H A D | ans_notification.cpp | 671 auto item = subscribers_.begin(); in UnSubscribeNotification()
672 while (item != subscribers_.end()) { in UnSubscribeNotification()
677 subscribers_.erase(item); in UnSubscribeNotification()
708 auto item = subscribers_.begin(); in UnSubscribeNotification()
709 while (item != subscribers_.end()) { in UnSubscribeNotification()
714 subscribers_.erase(item); in UnSubscribeNotification()
1965 auto item = subscribers_.begin(); in CreateSubscribeListener()
1966 while (item != subscribers_.end()) { in CreateSubscribeListener()
1976 subscribers_[subscriber] = listener; in CreateSubscribeListener()
1987 for (auto item : subscribers_) { in OnServiceDied()
[all...] |
| /base/notification/common_event_service/services/include/ |
| H A D | common_event_subscriber_manager.h | 248 std::vector<SubscriberRecordPtr> subscribers_; member in OHOS::EventFwk::CommonEventSubscriberManager
|
| /base/notification/distributed_notification_service/frameworks/core/include/ |
| H A D | ans_notification.h | 1168 std::map<std::shared_ptr<NotificationSubscriber>, sptr<SubscriberListener>> subscribers_; member in OHOS::Notification::AnsNotification
|
Completed in 10 milliseconds