Home
last modified time | relevance | path

Searched refs:observerMap_ (Results 1 - 19 of 19) sorted by relevance

/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dfree_install_observer_manager.cpp36 observerMap_[recordId] = observer; in AddObserver()
66 for (auto &item : observerMap_) { in RemoveObserver()
68 observerMap_.erase(item.first); in RemoveObserver()
116 auto iter = observerMap_.find(recordId); in HandleOnInstallFinished()
117 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()
143 for (auto &item : observerMap_) { in OnObserverDied()
145 observerMap_.erase(item.first); in OnObserverDied()
H A Dability_first_frame_state_observer_manager.cpp37 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()
81 TAG_LOGD(AAFwkTag::ABILITYMGR, "observerMap_ size:%{public}zu", recipientMap_.size()); in AddObserverDeathRecipient()
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_ in RemoveAbilityFirstFrameStateObserver()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/
H A Daccount_delegate_impl.cpp59 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 Daccount_delegate_impl.h54 ConcurrentMap<std::string, std::shared_ptr<Observer>> observerMap_ {};
/foundation/ability/ability_runtime/test/unittest/ability_first_frame_state_observer_manager_test/
H A Dability_first_frame_state_observer_manager_test.cpp152 stateObserverSetForAllBundles_->observerMap_; in HWTEST_F()
162 stateObserverSetForAllBundles_->observerMap_; in HWTEST_F()
193 stateObserverSetForBundleName_->observerMap_; in HWTEST_F()
208 stateObserverSetForAllBundles_->observerMap_; in HWTEST_F()
243 stateObserverSetForBundleName_->observerMap_; in HWTEST_F()
247 stateObserverSetForAllBundles_->observerMap_; in HWTEST_F()
/foundation/ability/ability_runtime/test/unittest/free_install_observer_manager_test/
H A Dfree_install_observer_manager_test.cpp160 freeInstallObserverManager_->observerMap_[0] = observer; in HWTEST_F()
161 freeInstallObserverManager_->observerMap_[1] = observer; in HWTEST_F()
213 freeInstallObserverManager_->observerMap_[0] = observer; in HWTEST_F()
231 freeInstallObserverManager_->observerMap_[0] = observer; in HWTEST_F()
262 freeInstallObserverManager_->observerMap_[0] = observer; in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_impl.cpp217 if (observerMap_.find(observer) != observerMap_.end()) { in RegisterObserver()
238 observerMap_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, observerHandle)); 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 Dkv_store_delegate_impl.h112 std::map<const KvStoreObserver*, const KvDBObserverHandle*> observerMap_; member in DistributedDB::final
H A Dkv_store_nb_delegate_impl.cpp392 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, observerHandle)); 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 Dkv_store_nb_delegate_impl.h217 std::map<const KvStoreObserver *, const KvDBObserverHandle *> observerMap_; member in DistributedDB::final
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Dflat_object_storage_engine.cpp300 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()
/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dability_first_frame_state_observer_manager.h47 AbilityFirstFrameStateObserverMap observerMap_; member in OHOS::AppExecFwk::final
H A Dfree_install_observer_manager.h54 std::unordered_map<int32_t, sptr<IFreeInstallObserver>> observerMap_; member in OHOS::AAFwk::FreeInstallObserverManager
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
H A Dflat_object_storage_engine.h57 std::map<std::string, std::shared_ptr<TableWatcher>> observerMap_; member in OHOS::ObjectStore::FlatObjectStorageEngine
/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/
H A Dnapi_datashare_helper.cpp972 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()
/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/include/
H A Dnapi_datashare_helper.h74 std::map<std::string, std::list<sptr<NAPIDataShareObserver>>> observerMap_; member in OHOS::DataShare::NapiDataShareHelper
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/
H A Ddistributed_sched_service_second_test.cpp523 DistributedSchedService::GetInstance().observerMap_[connect] = {appStateObserver, localDeviceId, 0, BUNDLE_NAME, in HWTEST_F()
528 DistributedSchedService::GetInstance().observerMap_.clear(); in HWTEST_F()
547 DistributedSchedService::GetInstance().observerMap_[connect] = {appStateObserver, REMOTE_DEVICEID, 0, BUNDLE_NAME, in HWTEST_F()
552 DistributedSchedService::GetInstance().observerMap_.clear(); in HWTEST_F()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddistributed_sched_service.cpp1794 for (auto iter = observerMap_.begin(); iter != observerMap_.end(); iter++) { in ProcessCallResult()
3401 observerMap_[callbackWrapper] = {appStateObserver, callerInfo.sourceDeviceId, connectToken, in RegisterAppStateObserver()
3403 HILOGI("add observerMap_ success"); in RegisterAppStateObserver()
3420 auto it = observerMap_.find(callbackWrapper); in UnregisterAppStateObserver()
3421 if (it == observerMap_.end()) { in UnregisterAppStateObserver()
3427 observerMap_.erase(it); in UnregisterAppStateObserver()
3428 for (auto iter = observerMap_.begin(); iter != observerMap_.end(); iter++) { in UnregisterAppStateObserver()
3479 for (auto iter = observerMap_ in NotifyStateChanged()
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/include/
H A Ddistributed_sched_service.h349 std::map<sptr<IRemoteObject>, ObserverInfo> observerMap_; member in OHOS::DistributedSchedule::DistributedSchedService

Completed in 22 milliseconds