/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
H A D | auto_cache.cpp | 15 #define LOG_TAG "AutoCache" 26 AutoCache &AutoCache::GetInstance() in GetInstance() 28 static AutoCache cache; in GetInstance() 32 int32_t AutoCache::RegCreator(int32_t type, Creator creator) in RegCreator() 41 void AutoCache::Bind(std::shared_ptr<Executor> executor) in Bind() 49 AutoCache::AutoCache() in AutoCache() function in OHOS::DistributedData::AutoCache 53 AutoCache::~AutoCache() in ~AutoCache() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
H A D | store_test.cpp | 106 * @tc.desc: AutoCache Delegate OnChange 115 AutoCache::Watchers watchers; in HWTEST_F() 118 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F() 129 * @tc.desc: AutoCache Delegate OnChange 138 AutoCache::Watchers watchers; in HWTEST_F() 141 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F() 152 * @tc.desc: AutoCache Delegate operator Store() 161 AutoCache::Watchers watchers; in HWTEST_F() 164 AutoCache::Delegate delegate(store, watchers, user, meta); in HWTEST_F() 165 AutoCache in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
H A D | auto_cache.h | 32 class AutoCache { class 43 API_EXPORT static AutoCache &GetInstance(); 64 AutoCache(); 65 ~AutoCache();
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_asset_machine.cpp | 60 static AutoCache::Store GetStore(ChangedAssetInfo& changedAsset); 61 static VBuckets GetMigratedData(AutoCache::Store& store, AssetBindInfo& assetBindInfo, const Asset& newAsset); 199 static VBuckets GetMigratedData(AutoCache::Store& store, AssetBindInfo& assetBindInfo, const Asset& newAsset) in GetMigratedData() 290 static AutoCache::Store GetStore(ChangedAssetInfo& changedAsset) in GetStore() 303 return AutoCache::GetInstance().GetStore(meta, {}); in GetStore()
|
H A D | object_service_impl.cpp | 357 auto store = AutoCache::GetInstance().GetStore(meta, {}); in ObjectServiceImpl()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
H A D | sync_manager.h | 39 using AutoCache = DistributedData::AutoCache; 45 static AutoCache::Store GetStore(const StoreMetaData &meta, int32_t user, bool mustBind = true);
|
H A D | cloud_service_impl.h | 102 using AutoCache = DistributedData::AutoCache; 140 std::pair<bool, StatisticInfo> QueryTableStatistic(const std::string &tableName, AutoCache::Store store);
|
H A D | cloud_service_impl.cpp | 224 auto store = AutoCache::GetInstance().GetStore(meta, {}); in DoClean() 470 auto store = AutoCache::GetInstance().GetStore(storeMetaData, {}); in QueryStatistics() 488 AutoCache::Store store) in QueryTableStatistic() 1016 AutoCache::Store store = SyncManager::GetStore(meta, storeInfo.user, true); in PreShare()
|
H A D | sync_manager.cpp | 555 AutoCache::Store SyncManager::GetStore(const StoreMetaData &meta, int32_t user, bool mustBind) 566 auto store = AutoCache::GetInstance().GetStore(meta, {});
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
H A D | kvdb_service_impl.cpp | 79 AutoCache::GetInstance().RegCreator(KvStoreType::SINGLE_VERSION, creator); in Factory() 80 AutoCache::GetInstance().RegCreator(KvStoreType::DEVICE_COLLABORATION, creator); in Factory() 122 auto store = AutoCache::GetInstance().GetStore(meta, watchers); in Init() 201 AutoCache::GetInstance().CloseStore(tokenId, storeId); in Delete() 214 AutoCache::GetInstance().CloseStore(tokenId, storeId); in Close() 560 AutoCache::GetInstance().SetObserver(tokenId, storeId, GetWatchers(tokenId, storeId)); in Subscribe() 589 AutoCache::GetInstance().SetObserver(tokenId, storeId, GetWatchers(tokenId, storeId)); in Unsubscribe() 631 auto stores = AutoCache::GetInstance().GetStoresIfPresent(meta.tokenId, storeId); in SetConfig() 747 auto stores = AutoCache::GetInstance().GetStoresIfPresent(tokenId); in OnAppExit() 777 AutoCache in ResolveAutoLaunch() [all...] |
H A D | kvdb_service_impl.h | 143 DistributedData::AutoCache::Watchers GetWatchers(uint32_t tokenId, const std::string &storeId);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_service_impl.cpp | 77 AutoCache::GetInstance().RegCreator(RDB_DEVICE_COLLABORATION, [](const StoreMetaData& metaData) -> GeneralStore* { in Factory() 115 auto store = AutoCache::GetInstance().GetStore(meta, watchers); in RdbServiceImpl() 180 AutoCache::GetInstance().GetStore(entry, GetWatchers(entry.tokenId, entry.storeId)); in ResolveAutoLaunch() 204 auto stores = AutoCache::GetInstance().GetStoresIfPresent(tokenId); in OnAppExit() 210 AutoCache::GetInstance().Enable(tokenId); in OnAppExit() 269 auto store = AutoCache::GetInstance().GetStore(storeMetaData, watchers); in GetStore() 354 AutoCache::Watchers RdbServiceImpl::GetWatchers(uint32_t tokenId, const std::string &storeName) in GetWatchers() 356 AutoCache::Watchers watchers; in GetWatchers() 590 AutoCache::GetInstance().SetObserver(tokenId, RemoveSuffix(param.storeName_), 619 AutoCache [all...] |
H A D | rdb_service_impl.h | 109 using Watchers = DistributedData::AutoCache::Watchers;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
H A D | water_version_manager.cpp | 70 auto store = AutoCache::GetInstance().GetStore(StoreMetaData(storeMeta), {}); in Init() 197 auto store = AutoCache::GetInstance().GetStore(storeMetaData, {}); in InitMeta()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | cloud_data_test.cpp | 380 AutoCache::GetInstance().RegCreator(DistributedRdb::RDB_DEVICE_COLLABORATION, creator); in HWTEST_F() 417 AutoCache::GetInstance().RegCreator(DistributedRdb::RDB_DEVICE_COLLABORATION, creator); in HWTEST_F()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
H A D | kvstore_data_service.cpp | 268 AutoCache::GetInstance().Bind(executors_); in OnStart()
|