Home
last modified time | relevance | path

Searched refs:subscribers (Results 1 - 12 of 12) sorted by relevance

/base/security/security_guard/services/security_collector/src/
H A Dsecurity_collector_subscriber_manager.cpp63 const auto &subscribers = element.second; in GetAppSubscribeCount() local
64 count = std::count_if(subscribers.begin(), subscribers.end(), [appName] (const auto &subscriber) { in GetAppSubscribeCount()
74 const auto &subscribers = eventToSubscribers_[eventId]; in GetAppSubscribeCount() local
75 if (std::any_of(subscribers.begin(), subscribers.end(), [appName] (const auto &subscriber) { in GetAppSubscribeCount()
89 const auto &subscribers = element.second; in FindEventIds() local
90 auto it = std::find_if(subscribers.begin(), subscribers.end(), in FindEventIds()
92 if (it != subscribers in FindEventIds()
103 std::set<std::shared_ptr<SecurityCollectorSubscriber>> subscribers; FindSecurityCollectorSubscribers() local
167 auto subscribers = FindSecurityCollectorSubscribers(remote); UnsubscribeCollector() local
[all...]
/base/notification/common_event_service/services/test/unittest/static_subscriber_manager_unit_test/
H A Dstatic_subscriber_manager_unit_test.cpp132 StaticSubscriber subscribers = { .events = events }; in HWTEST_F() local
133 manager->staticSubscribers_.emplace(testExtensionBundleName, subscribers); in HWTEST_F()
136 // expect valid subscribers map is not empty in HWTEST_F()
169 // expect valid subscribers map is not empty in HWTEST_F()
193 // expect valid subscribers map is empty in HWTEST_F()
221 // expect valid subscribers map is empty in HWTEST_F()
248 // expect valid subscribers map is empty in HWTEST_F()
281 // expect valid subscribers map is empty in HWTEST_F()
314 // expect valid subscribers map is empty in HWTEST_F()
347 // expect valid subscribers ma in HWTEST_F()
620 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
685 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
790 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
844 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1300 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1337 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1411 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1443 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1475 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1563 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1614 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1785 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1862 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1893 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
1999 auto subscribers = manager->validSubscribers_[testEventName]; HWTEST_F() local
2177 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
2240 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
2810 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
2880 StaticSubscriber subscribers = { .events = events }; HWTEST_F() local
2999 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3049 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3099 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3149 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3206 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3256 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
3315 auto subscribers = manager->validSubscribers_[testNormalEventName]; HWTEST_F() local
[all...]
/base/account/os_account/frameworks/appaccount/cj/src/
H A Dappaccount_impl.cpp350 void CJAppAccountImpl::GetSubscriberByUnsubscribe(std::vector<std::shared_ptr<SubscribePtr>> &subscribers) in GetSubscriberByUnsubscribe() argument
354 subscribers.emplace_back(item->subscriber); in GetSubscriberByUnsubscribe()
366 std::vector<std::shared_ptr<SubscribePtr>> subscribers = {nullptr}; in off() local
367 GetSubscriberByUnsubscribe(subscribers); in off()
368 context->subscribers = subscribers; in off()
371 for (auto offSubscriber : context->subscribers) { in off()
381 for (size_t idx = 0; idx < context->subscribers.size(); ++idx) { in off()
382 if (!IsSameFunction(&context->callbackRef, &context->subscribers[idx]->ref_)) { in off()
385 ret = AppAccountManager::UnsubscribeAppAccount(context->subscribers[id in off()
[all...]
/base/account/os_account/frameworks/appaccount/cj/include/
H A Dappaccount_common.h48 std::vector<std::shared_ptr<SubscribePtr>> subscribers = {nullptr}; member
H A Dappaccount_impl.h80 void GetSubscriberByUnsubscribe(std::vector<std::shared_ptr<SubscribePtr>> &subscribers);
/base/security/security_guard/frameworks/js/napi/
H A Dsecurity_guard_napi.h196 std::vector<std::shared_ptr<SubscriberPtr>> subscribers; member
/base/notification/common_event_service/services/src/
H A Dcommon_event_control_manager.cpp375 auto subscribers = spinstance->GetSubscriberRecords(eventRecord); in ProcessOrderedEvent() local
381 std::sort(subscribers.begin(), subscribers.end(), OrderedSubscriberCompareFunc); in ProcessOrderedEvent()
386 eventRecordPtr->receivers = subscribers; in ProcessOrderedEvent()
1239 title = "\tSubscribers:\tTotal " + std::to_string(record->receivers.size()) + " subscribers\n\tNO " + in DumpStateBySubscriberRecord()
1285 " subscribers\n\tNO " + title + "\n"; in DumpHistoryStateBySubscriberRecord()
/base/account/os_account/interfaces/kits/napi/osaccount/include/
H A Dnapi_os_account.h226 std::vector<std::shared_ptr<SubscriberPtr>> subscribers; member
/base/account/os_account/interfaces/kits/napi/appaccount/include/
H A Dnapi_app_account_common.h197 std::vector<std::shared_ptr<SubscriberPtr>> subscribers = {nullptr}; member
/base/account/os_account/interfaces/kits/napi/appaccount/src/
H A Dnapi_app_account.cpp1734 std::vector<std::shared_ptr<SubscriberPtr>> subscribers = {nullptr}; in Unsubscribe() local
1735 napi_value result = GetSubscriberByUnsubscribe(env, subscribers, context, isFind); in Unsubscribe()
1740 context->subscribers = subscribers; in Unsubscribe()
H A Dnapi_app_account_common.cpp859 napi_value GetSubscriberByUnsubscribe(const napi_env &env, std::vector<std::shared_ptr<SubscriberPtr>> &subscribers, in GetSubscriberByUnsubscribe() argument
870 subscribers.emplace_back(item->subscriber); in GetSubscriberByUnsubscribe()
921 for (auto offSubscriber : asyncContextForOff->subscribers) { in UnsubscribeExecuteCB()
/base/account/os_account/frameworks/osaccount/native/test/moduletest/
H A Dos_account_manager_module_test.cpp2088 std::vector<std::shared_ptr<OsAccountSubscriber>> subscribers; in HWTEST_F() local
2093 subscribers.emplace_back(subscriber); in HWTEST_F()
2100 EXPECT_EQ(ERR_OK, OsAccountManager::UnsubscribeOsAccount(subscribers[i])); in HWTEST_F()

Completed in 21 milliseconds