| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
| H A D | auto_cache.cpp | 61 AutoCache::Store AutoCache::GetStore(const StoreMetaData &meta, const Watchers &watchers) in GetStore() argument
73 meta.tokenId, [this, &meta, &watchers, &store](auto &, std::map<std::string, Delegate> &stores) -> bool { in GetStore()
82 if (!watchers.empty()) { in GetStore()
83 it->second.SetObservers(watchers); in GetStore()
95 std::forward_as_tuple(dbStore, watchers, atoi(meta.user.c_str()), meta)); in GetStore()
201 void AutoCache::SetObserver(uint32_t tokenId, const std::string &storeId, const AutoCache::Watchers &watchers) in SetObserver() argument
203 stores_.ComputeIfPresent(tokenId, [&storeId, &watchers](auto &key, auto &stores) { in SetObserver()
205 Anonymous::Change(storeId).c_str(), watchers.size()); in SetObserver()
208 it->second.SetObservers(watchers); in SetObserver()
249 AutoCache::Delegate::Delegate(GeneralStore *delegate, const Watchers &watchers, int32_ argument
303 SetObservers(const AutoCache::Watchers &watchers) SetObservers() argument
331 Watchers watchers; OnChange() local
354 Watchers watchers; OnChange() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | store_test.cpp | 115 AutoCache::Watchers watchers; in HWTEST_F() local
118 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F()
119 delegate.SetObservers(watchers); in HWTEST_F()
138 AutoCache::Watchers watchers; in HWTEST_F() local
141 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F()
142 delegate.SetObservers(watchers); in HWTEST_F()
161 AutoCache::Watchers watchers; in HWTEST_F() local
164 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F()
|
| /foundation/arkui/ace_engine/frameworks/core/common/ |
| H A D | watch_dog.cpp | 430 Watchers watchers = { in Register() local
434 watchers.uiWatcher->SetTaskExecutor(taskExecutor); in Register()
436 watchers.jsWatcher->SetTaskExecutor(taskExecutor); in Register()
438 watchers.jsWatcher = nullptr; in Register()
440 const auto resExecutor = watchMap_.try_emplace(instanceId, watchers); in Register()
461 Watchers watchers = iter->second; in BuriedBomb() local
463 [watchers, bombId]() { in BuriedBomb()
464 if (watchers.jsWatcher) { in BuriedBomb()
465 watchers.jsWatcher->BuriedBomb(bombId); in BuriedBomb()
468 if (watchers in BuriedBomb()
482 Watchers watchers = iter->second; DefusingBomb() local
[all...] |
| H A D | watch_dog_mingw.cpp | 374 Watchers watchers = { in Register() local
378 watchers.uiWatcher->SetTaskExecutor(taskExecutor); in Register()
380 watchers.jsWatcher->SetTaskExecutor(taskExecutor); in Register()
382 watchers.jsWatcher = nullptr; in Register()
384 const auto resExecutor = watchMap_.try_emplace(instanceId, watchers); in Register()
405 Watchers watchers = iter->second; in BuriedBomb() local
407 [watchers, bombId]() { in BuriedBomb()
408 if (watchers.jsWatcher) { in BuriedBomb()
409 watchers.jsWatcher->BuriedBomb(bombId); in BuriedBomb()
412 if (watchers in BuriedBomb()
426 Watchers watchers = iter->second; DefusingBomb() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| H A D | auto_cache.h | 49 API_EXPORT Store GetStore(const StoreMetaData &meta, const Watchers &watchers);
57 API_EXPORT void SetObserver(uint32_t tokenId, const std::string &storeId, const Watchers &watchers);
69 Delegate(GeneralStore *delegate, const Watchers &watchers, int32_t user, const StoreMetaData &meta);
78 void SetObservers(const Watchers &watchers);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 114 auto watchers = GetWatchers(meta.tokenId, meta.storeId); in RdbServiceImpl()
115 auto store = AutoCache::GetInstance().GetStore(meta, watchers); in RdbServiceImpl()
268 auto watchers = GetWatchers(storeMetaData.tokenId, storeMetaData.storeId); in GetStore() local
269 auto store = AutoCache::GetInstance().GetStore(storeMetaData, watchers); in GetStore()
356 AutoCache::Watchers watchers; in GetWatchers() local
357 syncAgents_.ComputeIfPresent(tokenId, [&watchers](auto, SyncAgents &syncAgents) { in GetWatchers()
358 std::for_each(syncAgents.begin(), syncAgents.end(), [&watchers](const auto &item) { in GetWatchers()
360 watchers.insert(item.second.watcher_); in GetWatchers()
365 return watchers; in GetWatchers()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 121 auto watchers = GetWatchers(meta.tokenId, meta.storeId); in Init()
122 auto store = AutoCache::GetInstance().GetStore(meta, watchers); in Init()
776 auto watchers = GetWatchers(storeMeta.tokenId, storeMeta.storeId); in ResolveAutoLaunch() local
777 AutoCache::GetInstance().GetStore(storeMeta, watchers); in ResolveAutoLaunch()
1329 AutoCache::Watchers watchers{}; in GetWatchers()
1330 syncAgents_.ComputeIfPresent(tokenId, [&storeId, &watchers](auto &, SyncAgent &agent) { in GetWatchers()
1334 watchers.insert(watcher); in GetWatchers()
1339 return watchers; in GetWatchers()
|