Home
last modified time | relevance | path

Searched refs:listeners_ (Results 1 - 25 of 70) sorted by relevance

123

/foundation/communication/netmanager_base/utils/napi_utils/src/
H A Devent_manager.cpp44 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in AddListener()
46 if (it != listeners_.end()) { in AddListener()
47 listeners_.erase(it, listeners_.end()); in AddListener()
49 listeners_.emplace_back(EventListener(env, type, callback, once, asyncCallback)); in AddListener()
56 std::remove_if(listeners_.begin(), listeners_.end(), [type, callback](const EventListener &listener) -> bool { in DeleteListener()
59 listeners_.erase(it, listeners_ in DeleteListener()
[all...]
/foundation/communication/netstack/utils/napi_utils/src/
H A Devent_manager.cpp41 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in AddListener()
43 if (it != listeners_.end()) { in AddListener()
44 listeners_.erase(it, listeners_.end()); in AddListener()
47 listeners_.emplace_back(GetCurrentThreadId(), env, type, callback, once, asyncCallback); in AddListener()
54 std::remove_if(listeners_.begin(), listeners_.end(), [type, callback](const EventListener &listener) -> bool { in DeleteListener()
57 listeners_.erase(it, listeners_ in DeleteListener()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/publisher/src/
H A Dpublisher_item_test.cpp45 EXPECT_EQ(true, item.listeners_.empty()); in HWTEST_F()
59 EXPECT_EQ(false, item.listeners_.empty()); in HWTEST_F()
73 EXPECT_EQ(true, item.listeners_.empty()); in HWTEST_F()
78 EXPECT_EQ(true, item.listeners_.empty()); in HWTEST_F()
92 EXPECT_EQ(true, item.listeners_.empty()); in HWTEST_F()
96 EXPECT_EQ(true, item.listeners_.empty()); in HWTEST_F()
112 EXPECT_EQ(false, item.listeners_.empty()); in HWTEST_F()
/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_running_status_module.cpp40 auto itemFind = std::find_if(listeners_.begin(), listeners_.end(), findTask); in RegisterListener()
41 if (itemFind != listeners_.end()) { in RegisterListener()
53 listeners_.emplace(listener, deathRecipient); in RegisterListener()
73 for (const auto &item : listeners_) { in NotifyAppRunningStatusEvent()
114 auto itemFind = std::find_if(listeners_.begin(), listeners_.end(), findTask); in RemoveListenerAndDeathRecipient()
115 if (itemFind == listeners_.end()) { in RemoveListenerAndDeathRecipient()
121 listeners_.erase(itemFind); in RemoveListenerAndDeathRecipient()
H A Dapp_debug_manager.cpp33 std::find_if(listeners_.begin(), listeners_.end(), [&listener](const sptr<IAppDebugListener> &element) { in RegisterAppDebugListener()
39 if (finder == listeners_.end()) { in RegisterAppDebugListener()
40 listeners_.emplace(listener); in RegisterAppDebugListener()
59 std::find_if(listeners_.begin(), listeners_.end(), [&listener](const sptr<IAppDebugListener> &element) { in UnregisterAppDebugListener()
65 if (finder != listeners_.end()) { in UnregisterAppDebugListener()
66 listeners_.erase(finder); in UnregisterAppDebugListener()
81 for (const auto &listener : listeners_) { in StartDebug()
108 for (const auto &listener : listeners_) { in StopDebug()
[all...]
/foundation/arkui/ace_engine/adapter/ohos/capability/package/
H A Dpackage_event_proxy_ohos.cpp68 auto it = listeners_.begin(); in OnPackageChange()
69 while (it != listeners_.end()) { in OnPackageChange()
76 it = listeners_.erase(it); in OnPackageChange()
77 if (listeners_.empty()) { in OnPackageChange()
86 if (listeners_.empty()) { in Register()
89 listeners_.insert({ listener, Container::CurrentId() }); in Register()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/publisher/
H A Dpublisher_item.cpp37 listeners_.clear(); in ~PublisherItem()
48 listeners_.insert(listener); in AddListener()
59 for (const auto &lis : listeners_) { in RemoveListener()
61 listeners_.erase(lis); in RemoveListener()
73 for (const auto &listener : listeners_) { in PublishMessage()
/foundation/filemanagement/dfs_service/frameworks/native/distributed_file_inner/src/asset/
H A Dasset_adapter_sa_client.cpp73 listeners_.emplace_back(listener); in AddListener()
113 for (auto iter = listeners_.begin(); iter != listeners_.end();) { in RemoveListener()
115 iter = listeners_.erase(iter); in RemoveListener()
144 LOGI("Sa client on add system ability listener size %{public}d", (int32_t)listeners_.size()); in OnAddSystemAbility()
145 for (auto iter = listeners_.begin(); iter != listeners_.end(); iter++) { in OnAddSystemAbility()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp62 for (auto &iter : listeners_) { in ~FutureFactory()
65 listeners_.clear(); in ~FutureFactory()
141 listeners_[transactionId] = listener; in RegisterListener()
147 auto iter = listeners_.find(transactionId); in UnregisterListener()
148 if (iter != listeners_.end()) { in UnregisterListener()
151 listeners_.erase(transactionId); in UnregisterListener()
198 auto findProc = listeners_.find(transactionId); in FindListener()
199 CHK_RET(findProc == listeners_.end(), nullptr); in FindListener()
/foundation/multimodalinput/input/intention/cooperate/plugin/src/
H A Devent_manager.cpp43 auto iter = std::find_if(listeners_.begin(), listeners_.end(), in RegisterListener()
47 if (iter != listeners_.end()) { in RegisterListener()
50 listeners_.emplace_back(eventInfo); in RegisterListener()
57 listeners_.erase(std::remove_if(listeners_.begin(), listeners_.end(), in UnregisterListener()
60 }), listeners_.end()); in UnregisterListener()
200 for (auto iter = listeners_.begin(); iter != listeners_ in OnCooperateMessage()
[all...]
H A Dmouse_location.cpp51 listeners_[event.networkId].insert(event.pid); in AddListener()
71 if (listeners_.find(event.networkId) == listeners_.end()) { in RemoveListener()
75 listeners_[event.networkId].erase(event.pid); in RemoveListener()
76 if (listeners_[event.networkId].empty()) { in RemoveListener()
77 listeners_.erase(event.networkId); in RemoveListener()
88 for (auto it = listeners_.begin(); it != listeners_.end();) { in OnClientDied()
96 it = listeners_.erase(it); in OnClientDied()
112 if (listeners_ in OnSoftbusSessionClosed()
[all...]
/foundation/arkui/ace_engine/frameworks/bridge/cj_frontend/cppview/
H A Ddata_change_listener.h44 for (auto it = listeners_.begin(); it != listeners_.end();) { in NotifyAll()
47 it = listeners_.erase(it); in NotifyAll()
56 std::set<WeakPtr<V2::DataChangeListener>> listeners_; member in OHOS::Ace::Framework::CJDataChangeListener
H A Ddata_change_listener.cpp28 listeners_.emplace(listener); in AddListener()
33 listeners_.erase(listener); in RemoveListener()
/foundation/CastEngine/castengine_wifi_display/services/event/
H A Devent_manager.cpp73 auto it = listeners_.find(listener->GetListenerClassType()); in AddListener()
74 if (it != listeners_.end()) { in AddListener()
80 listeners_.emplace(newClassList); in AddListener()
83 SHARING_LOGD("listeners type count %{public}zu.", listeners_.size()); in AddListener()
98 listeners_.clear(); in DrainAllListeners()
121 for (auto listenMap : listeners_) { in PushSyncEvent()
154 for (auto &listenMap : listeners_) { in ProcessEvent()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_transport_softbus_adapter.cpp323 if (listeners_.empty()) { in NotifyListenersSessionShutdown()
327 for (auto iterItem = listeners_.begin(); iterItem != listeners_.end(); iterItem++) { in NotifyListenersSessionShutdown()
413 if (listeners_.empty()) { in OnDataReady()
417 auto iterItem = listeners_.find(dataType); in OnDataReady()
418 if (iterItem == listeners_.end()) { in OnDataReady()
419 HILOGE("get iterItem failed from listeners_, type %{public}d, sessionId: %{public}d", dataType, sessionId); in OnDataReady()
437 if (listeners_.empty() || listeners_.find(serviceType) == listeners_ in RegisterListener()
[all...]
/foundation/ability/ability_runtime/frameworks/js/napi/mission_manager/
H A Ddms_sa_client.cpp51 listeners_[type] = listener; in AddListener()
69 listeners_.erase(type); in DelListener()
78 TAG_LOGI(AAFwkTag::MISSION, "listeners size: %{public}zu", listeners_.size()); in OnAddSystemAbility()
79 for (auto& listener : listeners_) { in OnAddSystemAbility()
93 for (auto& listener : listeners_) { in OnRemoveSystemAbility()
/foundation/arkui/ace_engine/adapter/ohos/capability/time/
H A Dtime_event_proxy_ohos.cpp89 for (auto it = listeners_.begin(); it != listeners_.end();) { in OnTimeChange()
101 it = listeners_.erase(it); in OnTimeChange()
108 if (listeners_.empty()) { in Register()
111 listeners_.insert({ listener, Container::CurrentId() }); in Register()
/foundation/CastEngine/castengine_cast_framework/service/src/
H A Dcast_session_manager_service.cpp627 if (std::find_if(listeners_.begin(), listeners_.end(), in AddListenerLocked()
629 listeners_.end()) { in AddListenerLocked()
630 listeners_.push_back({ pid, listener }); in AddListenerLocked()
642 auto iter = std::find_if(listeners_.begin(), listeners_.end(), in RemoveListenerLocked()
644 if (iter != listeners_.end()) { in RemoveListenerLocked()
646 listeners_.erase(iter); in RemoveListenerLocked()
647 if (listeners_.size() == 0) { in RemoveListenerLocked()
657 listeners_ in ClearListenersLocked()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/src/
H A Dvsync_generator.cpp254 auto it = listeners_.begin(); in ChangeListenerOffsetInternal()
255 for (; it < listeners_.end(); it++) { in ChangeListenerOffsetInternal()
261 if (it != listeners_.end()) { in ChangeListenerOffsetInternal()
315 for (uint32_t i = 0; i < listeners_.size(); i++) { in ComputeNextVSyncTimeStamp()
316 int64_t t = ComputeListenerNextVSyncTimeStamp(listeners_[i], now, referenceTime); in ComputeNextVSyncTimeStamp()
328 for (uint32_t i = 0; i < listeners_.size(); i++) { in CheckTimingCorrect()
329 int64_t t = ComputeListenerNextVSyncTimeStamp(listeners_[i], now, referenceTime); in CheckTimingCorrect()
330 if ((t - nextVSyncTime < errorThreshold) && (listeners_[i].phase_ == 0)) { in CheckTimingCorrect()
452 for (uint32_t i = 0; i < listeners_.size(); i++) { in GetListenerTimeouted()
453 int64_t t = ComputeListenerNextVSyncTimeStamp(listeners_[ in GetListenerTimeouted()
[all...]
/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/jsview/
H A Djs_data_change_listener.h37 listeners_.emplace(listener); in AddListener()
42 listeners_.erase(listener); in RemoveListener()
292 for (auto it = listeners_.begin(); it != listeners_.end();) { in NotifyAll()
295 it = listeners_.erase(it); in NotifyAll()
307 for (auto it = listeners_.begin(); it != listeners_.end();) { in NotifyAll()
310 it = listeners_.erase(it); in NotifyAll()
318 std::set<WeakPtr<V2::DataChangeListener>> listeners_; member in OHOS::Ace::Framework::JSDataChangeListener
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dkvdb_observer_handle.cpp26 for (auto &listener : listeners_) { in ~KvDBObserverHandle()
37 listeners_.push_back(listener); in InsertListener()
/foundation/communication/netmanager_base/utils/napi_utils/include/
H A Devent_manager.h47 return listeners_.empty(); in IsListenerListEmpty()
52 return listeners_.size(); in GetListenerListNum()
64 std::list<EventListener> listeners_; member in OHOS::NetManagerStandard::EventManager
/foundation/ability/dmsfwk/interfaces/innerkits/distributed_event/src/
H A Ddms_sa_client.cpp67 listeners_[type] = listener; in AddDSchedEventListener()
92 listeners_.erase(type); in DelDSchedEventListener()
143 HILOGI("%{public}s listeners size: %{public}zu .", __func__, listeners_.size()); in OnAddSystemAbility()
144 for (auto& listener : listeners_) { in OnAddSystemAbility()
/foundation/ability/ability_runtime/test/unittest/app_debug_manager_test/
H A Dapp_debug_manager_test.cpp59 manager_->listeners_.insert(listener_); in SetUp()
79 EXPECT_EQ(manager_->listeners_.size(), SIZE_TWO); in HWTEST_F()
84 EXPECT_EQ(manager_->listeners_.size(), SIZE_TWO); in HWTEST_F()
98 EXPECT_EQ(manager_->listeners_.size(), SIZE_ONE); in HWTEST_F()
103 EXPECT_TRUE(manager_->listeners_.empty()); in HWTEST_F()
/foundation/graphic/graphic_3d/lume/LumeEcsSerializer/EcsSerializer/src/ecs_serializer/
H A Decs_asset_loader.cpp107 listeners_.emplace_back(&listener);
113 for (size_t i = 0; i < listeners_.size(); ++i) {
114 if (&listener == listeners_[i]) {
115 listeners_.erase(listeners_.begin() + static_cast<int64_t>(i));
198 for (auto* listener : listeners_) {
301 for (auto* listener : listeners_) { in ContinueLoading()
566 vector<IEcsAssetLoader::IListener*> listeners_; member in final

Completed in 26 milliseconds

123