Home
last modified time | relevance | path

Searched refs:listeners_ (Results 1 – 25 of 82) sorted by relevance

1234

/ohos5.0/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()
59 listeners_.erase(it, listeners_.end()); in DeleteListener()
66 … std::for_each(listeners_.begin(), listeners_.end(), [type, argv](const EventListener &listener) { in Emit()
78 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in Emit()
80 listeners_.erase(it, listeners_.end()); in Emit()
112 return std::any_of(listeners_.begin(), listeners_.end(), in HasEventListener()
119 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in DeleteListener()
121 listeners_.erase(it, listeners_.end()); in DeleteListener()
[all …]
/ohos5.0/foundation/communication/netstack/utils/napi_utils/src/
H A Devent_manager.cpp45 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in AddListener()
48 listeners_.erase(it, listeners_.end()); in AddListener()
65 listeners_.erase(it, listeners_.end()); in DeleteListener()
71 auto listeners = listeners_; in Emit()
84 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in Emit()
86 listeners_.erase(it, listeners_.end()); in Emit()
107 }) != listeners_.end(); in EmitByUvWithoutCheckShared()
111 }) != listeners_.end(); in EmitByUvWithoutCheckShared()
231 return std::any_of(listeners_.begin(), listeners_.end(), in HasEventListener()
238 auto it = std::remove_if(listeners_.begin(), listeners_.end(), in DeleteListener()
[all …]
/ohos5.0/base/inputmethod/imf/test/unittest/cpp_test/src/
H A Dime_event_monitor_manager_test.cpp61 ImeEventMonitorManagerImpl::GetInstance().listeners_.clear(); in TearDown()
77 EXPECT_TRUE(ImeEventMonitorManagerImpl::GetInstance().listeners_.empty());
91 EXPECT_TRUE(ImeEventMonitorManagerImpl::GetInstance().listeners_.empty());
105 EXPECT_EQ(ImeEventMonitorManagerImpl::GetInstance().listeners_.size(), 2);
107 ASSERT_NE(it, ImeEventMonitorManagerImpl::GetInstance().listeners_.end());
109 ASSERT_NE(it, ImeEventMonitorManagerImpl::GetInstance().listeners_.end());
123 EXPECT_EQ(ImeEventMonitorManagerImpl::GetInstance().listeners_.size(), 1);
125 ASSERT_NE(it, ImeEventMonitorManagerImpl::GetInstance().listeners_.end());
139 EXPECT_TRUE(ImeEventMonitorManagerImpl::GetInstance().listeners_.empty());
152 EXPECT_TRUE(ImeEventMonitorManagerImpl::GetInstance().listeners_.empty());
[all …]
/ohos5.0/base/useriam/user_auth_framework/services/remote_connect/src/
H A Dremote_connect_listener_manager.cpp50 auto it = std::find(listeners_.begin(), listeners_.end(), info); in RegisterListener()
51 if (it != listeners_.end()) { in RegisterListener()
56 listeners_.push_back(info); in RegisterListener()
74 auto it = std::find(listeners_.begin(), listeners_.end(), info); in UnregisterListener()
75 if (it == listeners_.end()) { in UnregisterListener()
80 listeners_.erase(it); in UnregisterListener()
95 auto it = std::find(listeners_.begin(), listeners_.end(), info); in FindListener()
108 for (auto it = listeners_.begin(); it != listeners_.end(); ++it) { in OnConnectionDown()
118 listeners_.erase(std::remove_if(listeners_.begin(), listeners_.end(), in OnConnectionDown()
120 listeners_.end()); in OnConnectionDown()
[all …]
/ohos5.0/base/msdp/device_status/services/native/src/
H A Ddevicestatus_manager.cpp137 auto iter = listeners_.find(devicestatusData.type); in NotifyDeviceStatusChange()
138 if (iter == listeners_.end()) { in NotifyDeviceStatusChange()
201 auto dtTypeIter = listeners_.find(type); in Subscribe()
202 if (dtTypeIter == listeners_.end()) { in Subscribe()
214 if (iter != listeners_[dtTypeIter->first].end()) { in Subscribe()
245 auto dtTypeIter = listeners_.find(type); in Unsubscribe()
246 if (dtTypeIter == listeners_.end()) { in Unsubscribe()
252 if (iter != listeners_[dtTypeIter->first].end()) { in Unsubscribe()
255 if (listeners_[dtTypeIter->first].empty()) { in Unsubscribe()
256 listeners_.erase(dtTypeIter); in Unsubscribe()
[all …]
/ohos5.0/base/inputmethod/imf/frameworks/native/inputmethod_controller/src/
H A Dime_event_monitor_manager_impl.cpp43 for (const auto &listenerTemp : listeners_) { in RegisterImeEventListener()
57 auto it = listeners_.find(eventMask); in RegisterImeEventListener()
58 if (it == listeners_.end()) { in RegisterImeEventListener()
59 listeners_.insert({ eventMask, { listener } }); in RegisterImeEventListener()
77 auto it = listeners_.find(eventMask); in UnRegisterImeEventListener()
78 if (it == listeners_.end()) { in UnRegisterImeEventListener()
89 listeners_.erase(it); in UnRegisterImeEventListener()
93 for (const auto &listenerTemp : listeners_) { in UnRegisterImeEventListener()
145 auto it = listeners_.find(eventMask); in GetListeners()
146 if (it == listeners_.end()) { in GetListeners()
/ohos5.0/base/msdp/device_status/frameworks/js/napi/interaction/drag/src/
H A Djs_drag_manager.cpp34 listeners_.clear(); in ResetEnv()
81 for (const auto &item : listeners_) { in RegisterListener()
94 listeners_.push_back(std::move(monitor)); in RegisterListener()
105 if (listeners_.empty()) { in UnregisterListener()
109 for (auto iter = listeners_.begin(); iter != listeners_.end();) { in UnregisterListener()
112 iter = listeners_.erase(iter); in UnregisterListener()
117 iter = listeners_.erase(iter); in UnregisterListener()
133 if (listeners_.empty()) { in OnDragMessage()
137 for (auto &item : listeners_) { in OnDragMessage()
169 if (listeners_.empty()) { in CallDragMsg()
[all …]
/ohos5.0/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_debug_manager.cpp33 …std::find_if(listeners_.begin(), listeners_.end(), [&listener](const sptr<IAppDebugListener> &elem… 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> &elem… 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()
166 for (const auto &listener : listeners_) { in RemoveAppDebugInfo()
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()
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/publisher/src/
H A Dpublisher_item_test.cpp45 EXPECT_EQ(true, item.listeners_.empty());
59 EXPECT_EQ(false, item.listeners_.empty());
73 EXPECT_EQ(true, item.listeners_.empty());
78 EXPECT_EQ(true, item.listeners_.empty());
92 EXPECT_EQ(true, item.listeners_.empty());
96 EXPECT_EQ(true, item.listeners_.empty());
112 EXPECT_EQ(false, item.listeners_.empty());
/ohos5.0/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()
192 for (auto iter = listeners_.begin(); iter != listeners_.end(); ++iter) { in OnCooperateMessage()
210 for (auto iter = listeners_.begin(); iter != listeners_.end();) { in OnClientDied()
214 iter = listeners_.erase(iter); in OnClientDied()
H A Dmouse_location.cpp48 listeners_[event.networkId].insert(event.pid); in AddListener()
66 if (listeners_.find(event.networkId) != listeners_.end()) { in RemoveListener()
70 listeners_[event.networkId].erase(event.pid); in RemoveListener()
71 if (listeners_[event.networkId].empty()) { in RemoveListener()
72 listeners_.erase(event.networkId); in RemoveListener()
83 for (auto it = listeners_.begin(); it != listeners_.end();) { in OnClientDied()
91 it = listeners_.erase(it); in OnClientDied()
166 if (listeners_.find(notice.networkId) == listeners_.end()) { in OnRemoteMouseLocation()
177 for (auto pid : listeners_[notice.networkId]) { in OnRemoteMouseLocation()
/ohos5.0/base/msdp/device_status/intention/cooperate/plugin/src/
H A Devent_manager.cpp42 auto iter = std::find_if(listeners_.begin(), listeners_.end(), in RegisterListener()
46 if (iter != listeners_.end()) { in RegisterListener()
49 listeners_.emplace_back(eventInfo); in RegisterListener()
56 listeners_.erase(std::remove_if(listeners_.begin(), listeners_.end(), in UnregisterListener()
59 }), listeners_.end()); in UnregisterListener()
194 for (auto iter = listeners_.begin(); iter != listeners_.end(); ++iter) { in OnCooperateMessage()
212 for (auto iter = listeners_.begin(); iter != listeners_.end();) { in OnClientDied()
216 iter = listeners_.erase(iter); in OnClientDied()
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_.find(notice.networkId) != listeners_.end()) { in OnSoftbusSessionClosed()
113 listeners_.erase(notice.networkId); in OnSoftbusSessionClosed()
186 if (listeners_.find(notice.networkId) == listeners_.end()) { in OnRemoteMouseLocation()
[all …]
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/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()
437 if (listeners_.empty() || listeners_.find(serviceType) == listeners_.end()) { in RegisterListener()
441 listeners_[serviceType] = newListeners; in RegisterListener()
445 auto iterItem = listeners_.find(serviceType); in RegisterListener()
465 if (listeners_.empty() || listeners_.find(serviceType) == listeners_.end()) { in UnregisterListener()
469 auto typeListeners = listeners_.find(serviceType); in UnregisterListener()
[all …]
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/src/
H A Dvsync_generator.cpp250 auto it = listeners_.begin(); in ChangeListenerOffsetInternal()
251 for (; it < listeners_.end(); it++) { in ChangeListenerOffsetInternal()
257 if (it != listeners_.end()) { in ChangeListenerOffsetInternal()
451 listeners_[i].lastTime_ = t; in GetListenerTimeouted()
452 ret.push_back(listeners_[i]); in GetListenerTimeouted()
464 listeners_[i].lastTime_ = t; in GetListenerTimeoutedLTPO()
562 listeners_.push_back(listener); in AddListener()
867 auto it = listeners_.begin(); in RemoveListener()
870 listeners_.erase(it); in RemoveListener()
887 auto it = listeners_.begin(); in ChangePhaseOffset()
[all …]
/ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/
H A Devent_queue.cpp124 auto it = listeners_.find(fileDescriptor); in AddFileDescriptorListener()
125 if (it != listeners_.end()) { in AddFileDescriptorListener()
140 listeners_.emplace(fileDescriptor, listener); in AddFileDescriptorListener()
164 RemoveFileDescriptorListenerLocked(listeners_, ioWaiter_, listenerFilter, useDeamonIoWaiter_); in RemoveFileDescriptorListener()
180 if (listeners_.erase(fileDescriptor) > 0) { in RemoveFileDescriptorListener()
221 listeners_.clear(); in WaitUntilLocked()
235 auto it = listeners_.find(fileDescriptor); in HandleFileDescriptorEvent()
236 if (it == listeners_.end()) { in HandleFileDescriptorEvent()
334 RemoveFileDescriptorListenerLocked(listeners_, ioWaiter_, listenerFilter, useDeamonIoWaiter_); in RemoveInvalidFileDescriptor()
/ohos5.0/foundation/arkui/ace_engine/adapter/ohos/capability/time/
H A Dtime_event_proxy_ohos.cpp90 for (auto it = listeners_.begin(); it != listeners_.end();) { in OnTimeChange()
102 it = listeners_.erase(it); in OnTimeChange()
109 if (listeners_.empty()) { in Register()
112 listeners_.insert({ listener, Container::CurrentId() }); in Register()
/ohos5.0/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_;
/ohos5.0/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_; variable
/ohos5.0/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()

1234