Searched refs:obsPair (Results 1 - 4 of 4) sorted by relevance
| /foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_inner_pref.cpp | 33 auto [obsPair, flag] = observers_.try_emplace(uri.ToString(), std::list<sptr<IDataAbilityObserver>>()); in HandleRegisterObserver()
34 if (!flag && obsPair->second.size() > OBS_NUM_MAX) { in HandleRegisterObserver()
41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver()
49 obsPair->second.push_back(dataObserver); in HandleRegisterObserver()
59 auto obsPair = observers_.find(uri.ToString()); in HandleUnregisterObserver() local
60 if (obsPair == observers_.end()) { in HandleUnregisterObserver()
66 TAG_LOGD(AAFwkTag::DBOBSMGR, "obs num:%{public}zu:%{public}s", obsPair->second.size(), in HandleUnregisterObserver()
68 auto obs = obsPair->second.begin(); in HandleUnregisterObserver()
69 for (; obs != obsPair in HandleUnregisterObserver()
103 auto obsPair = observers_.find(observerKey); HandleNotifyChange() local
[all...] |
| H A D | dataobs_mgr_inner.cpp | 33 auto [obsPair, flag] = observers_.try_emplace(uri.ToString(), std::list<sptr<IDataAbilityObserver>>()); in HandleRegisterObserver()
34 if (!flag && obsPair->second.size() > OBS_NUM_MAX) { in HandleRegisterObserver()
41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver()
49 obsPair->second.push_back(dataObserver); in HandleRegisterObserver()
60 auto obsPair = observers_.find(uri.ToString()); in HandleUnregisterObserver() local
61 if (obsPair == observers_.end()) { in HandleUnregisterObserver()
67 TAG_LOGD(AAFwkTag::DBOBSMGR, "obs num:%{public}zu:%{public}s", obsPair->second.size(), in HandleUnregisterObserver()
69 auto obs = obsPair->second.begin(); in HandleUnregisterObserver()
70 for (; obs != obsPair in HandleUnregisterObserver()
97 auto obsPair = observers_.find(uri.ToString()); HandleNotifyChange() local
[all...] |
| /foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_pref_test/ |
| H A D | dataobs_mgr_inner_pref_test.cpp | 266 auto obsPair = dataObsMgrInnerPref_->observers_.find(uri.ToString()); in HWTEST_F() local
267 EXPECT_EQ((std::size_t)2, obsPair->second.size()); in HWTEST_F()
273 obsPair->second.clear(); in HWTEST_F()
274 obsPair = dataObsMgrInnerPref_->observers_.find(uri.ToString()); in HWTEST_F()
279 obsPair->second.clear(); in HWTEST_F()
280 obsPair = dataObsMgrInnerPref_->observers_.find(uri.ToString()); in HWTEST_F()
|
| /foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_test/ |
| H A D | dataobs_mgr_inner_test.cpp | 266 auto obsPair = dataObsMgrInner_->observers_.find(uri.ToString()); in HWTEST_F() local
267 EXPECT_EQ((std::size_t)2, obsPair->second.size()); in HWTEST_F()
273 obsPair->second.clear(); in HWTEST_F()
274 obsPair = dataObsMgrInner_->observers_.find(uri.ToString()); in HWTEST_F()
279 obsPair->second.clear(); in HWTEST_F()
280 obsPair = dataObsMgrInner_->observers_.find(uri.ToString()); in HWTEST_F()
|
Completed in 3 milliseconds