| /ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/ |
| H A D | free_install_observer_manager.cpp | 36 observerMap_[recordId] = observer; in AddObserver()
66 for (auto &item : observerMap_) { in RemoveObserver()
68 observerMap_.erase(item.first); in RemoveObserver()
115 auto iter = observerMap_.find(recordId); in HandleOnInstallFinished()
116 if (iter != observerMap_.end() && iter->second != nullptr) { in HandleOnInstallFinished()
126 auto iter = observerMap_.find(recordId); in HandleOnInstallFinishedByUrl()
127 if (iter != observerMap_.end() && iter->second != nullptr) { in HandleOnInstallFinishedByUrl()
142 for (auto &item : observerMap_) { in OnObserverDied()
144 observerMap_.erase(item.first); in OnObserverDied()
|
| H A D | ability_first_frame_state_observer_manager.cpp | 37 for (auto it : observerMap_) { in AddAbilityFirstFrameStateObserver()
43 observerMap_.emplace(observer, targetBundleName); in AddAbilityFirstFrameStateObserver()
44 TAG_LOGD(AAFwkTag::ABILITYMGR, "observerMap_ size:%{public}zu", observerMap_.size()); in AddAbilityFirstFrameStateObserver()
88 for (auto it = observerMap_.begin(); it != observerMap_.end(); ++it) { in RemoveAbilityFirstFrameStateObserver()
90 observerMap_.erase(it); in RemoveAbilityFirstFrameStateObserver()
91 TAG_LOGD(AAFwkTag::ABILITYMGR, "observerMap_ size:%{public}zu", observerMap_.size()); in RemoveAbilityFirstFrameStateObserver()
128 for (auto it : observerMap_) { in OnAbilityFirstFrameState()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| H A D | account_delegate_impl.cpp | 59 observerMap_.Clear(); in ~AccountDelegateImpl()
64 observerMap_.ForEach([&accountEventInfo] (const auto& key, auto& val) { in NotifyAccountChanged()
70 observerMap_.ForEach([&accountEventInfo] (const auto& key, auto& val) { in NotifyAccountChanged()
84 if (observerMap_.Contains(observer->Name())) { in Subscribe()
88 auto ret = observerMap_.Insert(observer->Name(), observer); in Subscribe()
103 if (!observerMap_.Contains(observer->Name())) { in Unsubscribe()
107 auto ret = observerMap_.Erase(observer->Name()); in Unsubscribe()
|
| H A D | account_delegate_impl.h | 54 ConcurrentMap<std::string, std::shared_ptr<Observer>> observerMap_ {};
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/ability_first_frame_state_observer_manager_test/ |
| H A D | ability_first_frame_state_observer_manager_test.cpp | 152 stateObserverSetForAllBundles_->observerMap_;
162 stateObserverSetForAllBundles_->observerMap_;
193 stateObserverSetForBundleName_->observerMap_;
208 stateObserverSetForAllBundles_->observerMap_;
243 stateObserverSetForBundleName_->observerMap_;
247 stateObserverSetForAllBundles_->observerMap_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_delegate_impl.cpp | 217 if (observerMap_.find(observer) != observerMap_.end()) { in RegisterObserver()
238 …observerMap_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, obser… in RegisterObserver()
255 auto iter = observerMap_.find(observer); in UnRegisterObserver()
256 if (iter == observerMap_.end()) { in UnRegisterObserver()
267 observerMap_.erase(iter); in UnRegisterObserver()
|
| H A D | kv_store_nb_delegate_impl.cpp | 392 if (observerMap_.size() >= DBConstant::MAX_OBSERVER_COUNT) { in RegisterDeviceObserver()
396 if (observerMap_.find(observer) != observerMap_.end()) { in RegisterDeviceObserver()
426 …observerMap_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, obser… in RegisterDeviceObserver()
490 auto iter = observerMap_.find(observer); in UnRegisterDeviceObserver()
491 if (iter == observerMap_.end()) { in UnRegisterDeviceObserver()
502 observerMap_.erase(iter); in UnRegisterDeviceObserver()
|
| H A D | kv_store_delegate_impl.h | 112 std::map<const KvStoreObserver*, const KvDBObserverHandle*> observerMap_; variable
|
| H A D | kv_store_nb_delegate_impl.h | 208 std::map<const KvStoreObserver *, const KvDBObserverHandle *> observerMap_; variable
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 300 if (observerMap_.count(key) != 0) { in RegisterObserver()
314 observerMap_.insert_or_assign(key, watcher); in RegisterObserver()
329 auto iter = observerMap_.find(key); in UnRegisterObserver()
330 if (iter == observerMap_.end()) { in UnRegisterObserver()
343 observerMap_.erase(key); in UnRegisterObserver()
450 if (observerMap_.count(sessionId) == 0) { in NotifyChange()
461 observerMap_[sessionId]->OnChanged(sessionId, data, false); in NotifyChange()
|
| /ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/include/ |
| H A D | ability_first_frame_state_observer_manager.h | 47 AbilityFirstFrameStateObserverMap observerMap_; variable
|
| H A D | free_install_observer_manager.h | 54 std::unordered_map<int32_t, sptr<IFreeInstallObserver>> observerMap_; variable
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/ |
| H A D | flat_object_storage_engine.h | 57 std::map<std::string, std::shared_ptr<TableWatcher>> observerMap_; variable
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/ |
| H A D | napi_datashare_helper.cpp | 972 observerMap_.try_emplace(uri); in RegisteredObserver()
974 auto &list = observerMap_.find(uri)->second; in RegisteredObserver()
998 auto obs = observerMap_.find(uri); in UnRegisteredObserver()
999 if (obs == observerMap_.end()) { in UnRegisteredObserver()
1021 observerMap_.erase(uri); in UnRegisteredObserver()
1029 auto obs = observerMap_.find(uri); in UnRegisteredObserver()
1030 if (obs == observerMap_.end()) { in UnRegisteredObserver()
1046 observerMap_.erase(uri); in UnRegisteredObserver()
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/include/ |
| H A D | napi_datashare_helper.h | 74 std::map<std::string, std::list<sptr<NAPIDataShareObserver>>> observerMap_; variable
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
| H A D | distributed_sched_service.cpp | 1523 for (auto iter = observerMap_.begin(); iter != observerMap_.end(); iter++) { in ProcessCallResult()
3125 observerMap_[callbackWrapper] = {appStateObserver, callerInfo.sourceDeviceId, connectToken, in RegisterAppStateObserver()
3144 auto it = observerMap_.find(callbackWrapper); in UnregisterAppStateObserver()
3145 if (it == observerMap_.end()) { in UnregisterAppStateObserver()
3151 observerMap_.erase(it); in UnregisterAppStateObserver()
3152 for (auto iter = observerMap_.begin(); iter != observerMap_.end(); iter++) { in UnregisterAppStateObserver()
3203 for (auto iter = observerMap_.begin(); iter != observerMap_.end(); iter++) { in NotifyStateChanged()
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/ |
| H A D | distributed_sched_service_second_test.cpp | 527 …DistributedSchedService::GetInstance().observerMap_[connect] = {appStateObserver, localDeviceId, 0…
532 DistributedSchedService::GetInstance().observerMap_.clear();
551 …DistributedSchedService::GetInstance().observerMap_[connect] = {appStateObserver, REMOTE_DEVICEID,…
556 DistributedSchedService::GetInstance().observerMap_.clear();
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
| H A D | distributed_sched_service.h | 324 std::map<sptr<IRemoteObject>, ObserverInfo> observerMap_; variable
|