/base/notification/distributed_notification_service/services/ans/src/ |
H A D | system_event_observer.cpp | 28 SystemEventObserver::SystemEventObserver(const ISystemEvent &callbacks) : callbacks_(callbacks) in SystemEventObserver() 81 if (callbacks_.onBundleRemoved != nullptr) { in OnReceiveEvent() 84 callbacks_.onBundleRemoved(bundleOption); in OnReceiveEvent() 89 if (callbacks_.onScreenOn != nullptr) { in OnReceiveEvent() 90 callbacks_.onScreenOn(); in OnReceiveEvent() 93 if (callbacks_.onScreenOff != nullptr) { in OnReceiveEvent() 94 callbacks_.onScreenOff(); in OnReceiveEvent() 114 if (callbacks_.onResourceRemove != nullptr) { in OnReceiveEvent() 115 callbacks_.onResourceRemove(userId); in OnReceiveEvent() 118 if (callbacks_ in OnReceiveEvent() [all...] |
/base/msdp/device_status/utils/common/include/ |
H A D | msg_handler.h | 39 callbacks_.clear(); in Clear() 49 for (auto &iter : callbacks_) { in GetDebugInfo() 62 auto it = callbacks_.find(msg.id); in RegisterEvent() 63 if (it != callbacks_.end()) { in RegisterEvent() 66 callbacks_[msg.id] = msg.fun; in RegisterEvent() 74 auto iter = callbacks_.find(id); in GetMsgCallback() 75 if (iter == callbacks_.end()) { in GetMsgCallback() 82 std::map<K, V> callbacks_; member in OHOS::Msdp::DeviceStatus::MsgHandler
|
/base/powermgr/power_manager/services/native/src/hibernate/ |
H A D | hibernate_controller.cpp | 29 callbacks_.insert(cb); in RegisterSyncHibernateCallback() 35 callbacks_.erase(cb); in UnregisterSyncHibernateCallback() 40 for (const auto &cb : callbacks_) { in PreHibernate() 49 for (const auto &cb : callbacks_) { in PostHibernate()
|
H A D | hibernate_controller.h | 38 std::set<sptr<ISyncHibernateCallback>> callbacks_; member in OHOS::PowerMgr::HibernateController
|
/base/telephony/call_manager/services/distributed_call/src/distributed_communication/ |
H A D | distributed_device_observer.cpp | 56 callbacks_.push_back(callback); in RegisterDevStatusCallback() 63 auto iter = std::find(callbacks_.begin(), callbacks_.end(), callback); in UnRegisterDevStatusCallback() 64 if (iter != callbacks_.end()) { in UnRegisterDevStatusCallback() 65 callbacks_.erase(iter); in UnRegisterDevStatusCallback() 101 for (auto callback : callbacks_) { in OnDeviceOnline() 112 for (auto callback : callbacks_) { in OnDeviceOffline() 123 for (auto callback : callbacks_) { in OnDistributedAudioDeviceChange() 133 for (auto callback : callbacks_) { in OnRemoveSystemAbility()
|
/base/msdp/device_status/intention/cooperate/plugin/src/ |
H A D | hot_area.cpp | 42 auto [iter, isOk] = callbacks_.emplace(info); in AddListener() 44 callbacks_.erase(iter); in AddListener() 45 callbacks_.emplace(info); in AddListener() 53 callbacks_.erase(HotAreaInfo { .pid = event.pid }); in RemoveListener() 131 for (const auto &callback : callbacks_) { in OnHotAreaMessage() 139 callbacks_.erase(HotAreaInfo { .pid = event.pid }); in OnClientDied()
|
/base/msdp/device_status/rust/subsystem/device_profile/binding/src/ |
H A D | fusion_device_profile_adapter.cpp | 74 std::map<std::string, std::shared_ptr<ProfileEventCallback>> callbacks_; member in FusionDeviceProfileAdapter 231 auto cbIter = callbacks_.find(deviceId); in UnregisterCrossStateListener() 232 if (cbIter == callbacks_.end()) { in UnregisterCrossStateListener() 241 callbacks_.erase(cbIter); in UnregisterCrossStateListener() 250 auto cbIter = callbacks_.find(deviceId); in SaveSubscribeInfos() 251 if ((cbIter == callbacks_.end()) || (cbIter->second == nullptr)) { in SaveSubscribeInfos() 258 callbacks_.insert_or_assign(deviceId, callback); in SaveSubscribeInfos() 278 auto cbIter = callbacks_.find(deviceId); in RemoveFailedSubscriptions() 279 if (cbIter == callbacks_.end()) { in RemoveFailedSubscriptions() 284 callbacks_ in RemoveFailedSubscriptions() [all...] |
/base/msdp/device_status/libs/src/ |
H A D | devicestatus_msdp_mock.cpp | 55 callbacks_.clear(); in ~DeviceStatusMsdpMock() 142 auto [_, ret] = callbacks_.insert(std::make_pair(timerFd_, &DeviceStatusMsdpMock::TimerCallback)); in InitTimer() 241 if (callbacks_.empty()) { in LoopingThreadEntry() 242 FI_HILOGD("callbacks_ is empty"); in LoopingThreadEntry() 245 size_t cbct = callbacks_.size(); in LoopingThreadEntry() 257 (callbacks_.find(events[n].data.fd)->second)(func); in LoopingThreadEntry()
|
/base/msdp/device_status/intention/ipc/socket/src/ |
H A D | socket_client.cpp | 45 auto [_, inserted] = callbacks_.emplace(id, callback); in RegisterEvent() 143 auto iter = callbacks_.find(id); in OnMsgHandler() 144 if (iter == callbacks_.end()) { in OnMsgHandler()
|
H A D | socket_session_manager.cpp | 318 auto [_, inserted] = callbacks_.emplace(pid, callback);
in AddSessionDeletedCallback() 329 callbacks_.erase(pid);
in RemoveSessionDeletedCallback() 335 if (auto iter = callbacks_.find(session->GetPid()); iter != callbacks_.end()) {
in NotifySessionDeleted() 339 callbacks_.erase(iter);
in NotifySessionDeleted()
|
/base/msdp/device_status/services/native/src/ |
H A D | stream_server.cpp | 341 auto it = callbacks_.find(pid);
in AddSessionDeletedCallback() 342 if (it != callbacks_.end()) {
in AddSessionDeletedCallback() 346 callbacks_[pid] = callback;
in AddSessionDeletedCallback() 352 auto it = callbacks_.find(ses->GetPid());
in NotifySessionDeleted() 353 if (it != callbacks_.end()) {
in NotifySessionDeleted() 355 callbacks_.erase(it);
in NotifySessionDeleted()
|
/base/powermgr/power_manager/services/native/src/ |
H A D | power_mode_module.cpp | 290 auto retIt = callbacks_.insert(object); in AddCallback() 295 callbacks_.size(), retIt.second); in AddCallback() 303 auto it = find(callbacks_.begin(), callbacks_.end(), object); in RemoveCallback() 304 if (it != callbacks_.end()) { in RemoveCallback() 305 callbacks_.erase(it); in RemoveCallback() 308 POWER_HILOGD(FEATURE_POWER_MODE, "callbacks.size = %{public}zu", callbacks_.size()); in RemoveCallback() 322 for (auto& obj: callbacks_) { in WaitingCallback()
|
/base/powermgr/battery_manager/charger/src/ |
H A D | battery_thread.cpp | 105 callbacks_.insert(std::make_pair(ueventFd_, &BatteryThread::UeventCallback)); in InitUevent() 174 size_t size = callbacks_.size(); in LoopingThreadEntry() 198 (callbacks_.find(events[n].data.fd)->second)(func, arg); in LoopingThreadEntry()
|
/base/security/access_token/services/tokensyncmanager/src/remote/ |
H A D | soft_bus_channel.cpp | 46 : deviceId_(deviceId), mutex_(), callbacks_(), responseResult_(""), loadedCond_() in SoftBusChannel() 158 callbacks_.insert(std::pair<std::string, std::function<void(std::string)>>(uuid, callback)); in InsertCallback() 195 callbacks_.erase(uuid); in ExecuteCommand() 203 callbacks_.erase(uuid); in ExecuteCommand() 437 auto callback = callbacks_.find(id); in HandleResponse() 438 if (callback != callbacks_.end()) { in HandleResponse() 440 callbacks_.erase(callback); in HandleResponse()
|
/base/notification/distributed_notification_service/services/ans/include/ |
H A D | system_event_observer.h | 53 ISystemEvent callbacks_; member in OHOS::Notification::SystemEventObserver
|
/base/msdp/device_status/frameworks/js/napi/src/ |
H A D | devicestatus_napi.cpp | 47 std::map<int32_t, sptr<IRemoteDevStaCallback>> DeviceStatusNapi::callbacks_; 94 callbacks_.clear(); in DeviceStatusNapi() 368 auto callbackIter = callbacks_.find(type); in SubscribeDeviceStatusCallback() 369 if (callbackIter != callbacks_.end()) { in SubscribeDeviceStatusCallback() 381 auto ret = callbacks_.insert(std::pair<int32_t, sptr<IRemoteDevStaCallback>>(type, callback)); in SubscribeDeviceStatusCallback() 435 auto callbackIter = callbacks_.find(type); in UnsubscribeCallback() 436 if (callbackIter == callbacks_.end()) { in UnsubscribeCallback() 445 callbacks_.erase(type); in UnsubscribeCallback()
|
/base/sensors/sensor/services/hdi_connection/hardware/include/ |
H A D | hdi_service_impl.h | 50 static std::vector<RecordSensorCallback> callbacks_;
member in OHOS::Sensors::HdiServiceImpl
|
/base/inputmethod/imf/frameworks/js/napi/inputmethodability/ |
H A D | panel_listener_impl.cpp | 41 callbacks_.Compute(windowId, in Subscribe() 55 callbacks_.ComputeIfPresent(windowId, in RemoveInfo() 129 callbacks_.ComputeIfPresent(windowId, [&type, &callBack](uint32_t id, auto callbacks) { in GetCallback()
|
H A D | panel_listener_impl.h | 58 ConcurrentMap<uint32_t, std::map<std::string, std::shared_ptr<JSCallbackObject>>> callbacks_; member in OHOS::MiscServices::PanelListenerImpl
|
/base/msdp/device_status/intention/cooperate/plugin/include/ |
H A D | hot_area.h | 76 std::set<HotAreaInfo> callbacks_;
member in OHOS::Msdp::DeviceStatus::Cooperate::final
|
/base/powermgr/battery_manager/charger/include/ |
H A D | battery_thread.h | 59 std::map<int32_t, Callback> callbacks_;
|
/base/msdp/device_status/intention/ipc/socket/include/ |
H A D | socket_client.h | 54 std::map<MessageId, std::function<int32_t(const StreamClient&, NetPacket&)>> callbacks_; member in OHOS::Msdp::DeviceStatus::final
|
H A D | socket_session_manager.h | 81 std::map<int32_t, std::function<void(SocketSessionPtr)>> callbacks_; member in OHOS::Msdp::DeviceStatus::final
|
/base/sensors/sensor/services/hdi_connection/hardware/src/ |
H A D | hdi_service_impl.cpp | 79 std::vector<RecordSensorCallback> HdiServiceImpl::callbacks_;
member in OHOS::Sensors::HdiServiceImpl 201 for (const auto &it : callbacks_) {
in DataReportThread() 306 callbacks_.push_back(cb);
in Register()
|
/base/powermgr/power_manager/services/native/include/ |
H A D | power_mode_module.h | 57 std::set<sptr<IRemoteObject>> callbacks_; member in OHOS::PowerMgr::PowerModeModule::CallbackManager
|