/ohos5.0/base/notification/common_event_service/frameworks/core/src/ |
H A D | common_event.cpp | 181 if (eventListener != eventListeners_.end()) { in SubscribeCommonEvent() 182 eventListeners_.erase(eventListener); in SubscribeCommonEvent() 209 auto eventListener = eventListeners_.find(subscriber); in UnSubscribeCommonEvent() 210 if (eventListener != eventListeners_.end()) { in UnSubscribeCommonEvent() 214 eventListeners_.erase(eventListener); in UnSubscribeCommonEvent() 386 auto eventListener = eventListeners_.find(subscriber); in CreateCommonEventListener() 387 if (eventListener != eventListeners_.end()) { in CreateCommonEventListener() 392 if (eventListeners_.size() == SUBSCRIBER_MAX_SIZE) { in CreateCommonEventListener() 403 eventListeners_[subscriber] = listener; in CreateCommonEventListener() 436 for (auto it = eventListeners_.begin(); it != eventListeners_.end();) { in Resubscribe() [all …]
|
/ohos5.0/base/security/security_guard/interfaces/inner_api/collector/src/ |
H A D | collector_manager.cpp | 32 if (eventListeners_.find(subscriber) != eventListeners_.end()) { in Subscribe() 63 eventListeners_[subscriber] = callback; in Subscribe() 77 if (eventListeners_.find(subscriber) == eventListeners_.end()) { in Unsubscribe() 88 int32_t ret = proxy->Unsubscribe(eventListeners_[subscriber]); in Unsubscribe() 90 eventListeners_.erase(subscriber); in Unsubscribe() 112 eventListeners_.clear(); in HandleDecipient()
|
/ohos5.0/base/account/os_account/frameworks/ohosaccount/native/src/ |
H A D | ohos_account_kits_impl.cpp | 251 eventListeners_.erase(callback); in SubscribeDistributedAccountEvent() 272 auto eventListener = eventListeners_.find(callback); in UnsubscribeDistributedAccountEvent() 273 if (eventListener == eventListeners_.end()) { in UnsubscribeDistributedAccountEvent() 286 eventListeners_.erase(eventListener); in UnsubscribeDistributedAccountEvent() 302 auto eventListener = eventListeners_.find(callback); in CreateDistributedAccountEventService() 303 if (eventListener != eventListeners_.end()) { in CreateDistributedAccountEventService() 312 if (eventListeners_.size() == Constants::DISTRIBUTED_SUBSCRIBER_MAX_SIZE) { in CreateDistributedAccountEventService() 323 eventListeners_[callback] = listener; in CreateDistributedAccountEventService() 336 for (auto it = eventListeners_.begin(); it != eventListeners_.end(); ++it) { in RestoreSubscribe()
|
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/interfaces/innerkits/ressched_client/src/ |
H A D | res_sched_client.cpp | 447 eventListeners_.clear(); in ~InnerEventListener() 458 auto item = eventListeners_.find(eventType); in RegisterEventListener() 459 if (item == eventListeners_.end()) { in RegisterEventListener() 484 auto item = eventListeners_.find(eventType); in UnRegisterEventListener() 485 if (item == eventListeners_.end()) { in UnRegisterEventListener() 499 eventListeners_.erase(eventType); in UnRegisterEventListener() 517 auto item = eventListeners_.find(eventType); in OnReceiveEvent() 518 if (item == eventListeners_.end()) { in OnReceiveEvent() 537 auto item = eventListeners_.find(eventType); in IsInnerEventMapEmpty() 538 if (item == eventListeners_.end()) { in IsInnerEventMapEmpty() [all …]
|
/ohos5.0/base/account/os_account/services/accountmgr/test/unittest/app_account/ |
H A D | app_account_test.cpp | 95 AppAccount::GetInstance().eventListeners_.clear(); in TearDown() 431 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), SUBSCRIBER_ZERO); 436 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), SUBSCRIBER_ONE); 441 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), SUBSCRIBER_ONE); 466 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), SUBSCRIBER_ZERO); 476 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), counter); 479 EXPECT_EQ(AppAccount::GetInstance().eventListeners_.size(), counter - 1);
|
/ohos5.0/base/account/os_account/frameworks/osaccount/core/src/ |
H A D | os_account.cpp | 60 if (eventListeners_.empty()) { in RestoreListenerRecords() 64 for (const auto &item : eventListeners_) { in RestoreListenerRecords() 590 eventListeners_.erase(subscriber); in SubscribeOsAccount() 622 auto eventListener = eventListeners_.find(subscriber); in UnsubscribeOsAccount() 623 if (eventListener != eventListeners_.end()) { in UnsubscribeOsAccount() 627 eventListeners_.erase(eventListener); in UnsubscribeOsAccount() 628 ACCOUNT_LOGI("Unsubscribe success, %{public}zu.", eventListeners_.size()); in UnsubscribeOsAccount() 750 auto eventListener = eventListeners_.find(subscriber); in CreateOsAccountEventListener() 751 if (eventListener != eventListeners_.end()) { in CreateOsAccountEventListener() 756 if (eventListeners_.size() == Constants::SUBSCRIBER_MAX_SIZE) { in CreateOsAccountEventListener() [all …]
|
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/event_monitor/ |
H A D | events_monitor.cpp | 55 std::map<EventType, std::vector<std::weak_ptr<IEventsListener>>> eventListeners_; in RegisterEventsListener() local 57 eventListeners_ = userIdToeventListeners_[userId]; in RegisterEventsListener() 60 eventListeners_[event].push_back(listener); in RegisterEventsListener() 62 userIdToeventListeners_[userId] = eventListeners_; in RegisterEventsListener()
|
/ohos5.0/base/account/os_account/frameworks/appaccount/native/src/ |
H A D | app_account.cpp | 621 eventListeners_.erase(subscriber); in SubscribeAppAccount() 644 auto eventListener = eventListeners_.find(subscriber); in UnsubscribeAppAccount() 645 if (eventListener != eventListeners_.end()) { in UnsubscribeAppAccount() 649 eventListeners_.erase(eventListener); in UnsubscribeAppAccount() 717 auto eventListener = eventListeners_.find(subscriber); in CreateAppAccountEventListener() 718 if (eventListener != eventListeners_.end()) { in CreateAppAccountEventListener() 723 if (eventListeners_.size() == Constants::APP_ACCOUNT_SUBSCRIBER_MAX_SIZE) { in CreateAppAccountEventListener() 734 eventListeners_[subscriber] = listener; in CreateAppAccountEventListener()
|
/ohos5.0/base/security/security_guard/interfaces/inner_api/collector/include/ |
H A D | collector_manager.h | 46 …::shared_ptr<ICollectorSubscriber>, sptr<SecurityCollectorManagerCallbackService>> eventListeners_; variable
|
/ohos5.0/base/security/security_guard/test/unittest/security_collector/interface_test/src/ |
H A D | collector_interface_test.cpp | 159 manager.eventListeners_.insert({subscriber, callback}); 194 manager.eventListeners_.insert({subscriber, callback});
|
/ohos5.0/base/account/os_account/services/accountmgr/test/unittest/os_account/ |
H A D | os_account_event_manager_multiple_thread_test.cpp | 106 OsAccount::GetInstance().eventListeners_.erase(subscriber); in TestWriteReadFileInfo()
|
/ohos5.0/base/notification/common_event_service/frameworks/core/include/ |
H A D | common_event.h | 236 std::map<std::shared_ptr<CommonEventSubscriber>, sptr<CommonEventListener>> eventListeners_; variable
|
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/ |
H A D | worker.cpp | 2024 auto iter = eventListeners_.find(listener); in HandleEventListeners() 2025 if (iter == eventListeners_.end()) { in HandleEventListeners() 2146 auto iter = eventListeners_.find(typestr); in AddListenerInner() 2147 if (iter == eventListeners_.end()) { in AddListenerInner() 2150 eventListeners_[typestr] = listeners; in AddListenerInner() 2165 auto iter = eventListeners_.find(typestr); in RemoveListenerInner() 2166 if (iter == eventListeners_.end()) { in RemoveListenerInner() 2181 eventListeners_.erase(typestr); in RemoveListenerInner() 2197 for (auto iter = eventListeners_.begin(); iter != eventListeners_.end(); iter++) { in RemoveAllListenerInner() 2204 eventListeners_.clear(); in RemoveAllListenerInner()
|
H A D | worker.h | 602 std::map<std::string, std::list<WorkerListener*>> eventListeners_ {};
|
/ohos5.0/base/account/os_account/interfaces/innerkits/ohosaccount/native/include/ |
H A D | ohos_account_kits_impl.h | 80 sptr<DistributedAccountEventService>> eventListeners_; variable
|
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/interfaces/innerkits/ressched_client/include/ |
H A D | res_sched_client.h | 176 std::list<sptr<ResSchedEventListener>>>> eventListeners_; variable
|
/ohos5.0/base/account/os_account/frameworks/osaccount/core/include/ |
H A D | os_account.h | 121 std::map<std::shared_ptr<OsAccountSubscriber>, sptr<OsAccountEventListener>> eventListeners_; variable
|
/ohos5.0/base/account/os_account/frameworks/appaccount/native/include/ |
H A D | app_account.h | 125 std::map<std::shared_ptr<AppAccountSubscriber>, sptr<AppAccountEventListener>> eventListeners_; variable
|
/ohos5.0/base/account/os_account/frameworks/appaccount/native/test/unittest/ |
H A D | app_account_manager_test.cpp | 2071 … AppAccount::GetInstance().eventListeners_[appAccountSubscriberPtr] = appAccountEventListenerSptr;
|