/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_asset_loader.cpp | 28 : assetLoader_(std::move(cloudAssetLoader)), snapshots_(bindAssets) in RdbAssetLoader() 74 if (snapshots_->bindAssets == nullptr) { in PostEvent() 77 auto it = snapshots_->bindAssets->find(downLoadAsset.uri); in PostEvent() 78 if (it == snapshots_->bindAssets->end() || it->second == nullptr) { in PostEvent()
|
H A D | rdb_asset_loader.h | 44 BindAssets* snapshots_; member in OHOS::DistributedRdb::RdbAssetLoader
|
H A D | rdb_cloud.cpp | 30 : cloudDB_(std::move(cloudDB)), snapshots_(bindAssets) in RdbCloud() 304 if (snapshots_->bindAssets == nullptr) { in PostEventAsset() 307 auto it = snapshots_->bindAssets->find(asset.uri); in PostEventAsset() 308 if (it == snapshots_->bindAssets->end() || it->second == nullptr) { in PostEventAsset()
|
H A D | rdb_cloud.h | 70 BindAssets* snapshots_; member in OHOS::DistributedRdb::RdbCloud
|
H A D | rdb_general_store.cpp | 159 if (snapshots_.bindAssets == nullptr) { in BindSnapshots() 160 snapshots_.bindAssets = bindAssets; in BindSnapshots() 192 rdbCloud_ = std::make_shared<RdbCloud>(bindInfo_.db_, &snapshots_); in Bind() 193 rdbLoader_ = std::make_shared<RdbAssetLoader>(bindInfo_.loader_, &snapshots_); in Bind()
|
H A D | rdb_general_store.h | 169 BindAssets snapshots_; member in OHOS::DistributedRdb::RdbGeneralStore
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
H A D | sqlite_local_kvdb_connection.h | 106 mutable std::set<IKvDBSnapshot *> snapshots_; member in DistributedDB::SQLiteLocalKvDBConnection
|
H A D | sqlite_local_kvdb_connection.cpp | 290 snapshots_.insert(dbSnapshot); in GetSnapshot() 302 snapshots_.erase(snapshot); in ReleaseSnapshot() 343 if (snapshots_.size() != 0) { in PreClose()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
H A D | multi_ver_natural_store_connection.cpp | 289 snapshots_.insert(snapshot); in GetSnapshot() 303 snapshots_.erase(snapshot); in ReleaseSnapshot() 349 if (snapshots_.size() > 0) { in PreClose()
|
H A D | multi_ver_natural_store_connection.h | 117 mutable std::set<IKvDBSnapshot *> snapshots_; member in DistributedDB::MultiVerNaturalStoreConnection
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | object_manager_test.cpp | 429 manager->snapshots_.Insert(snapshotKey, snapshot); in HWTEST_F() 446 auto snapshots = manager->snapshots_.Find(snapshotKey).second; in HWTEST_F() 450 manager->snapshots_.Insert(snapshotKey, snapshot); in HWTEST_F() 451 snapshots = manager->snapshots_.Find(snapshotKey).second; in HWTEST_F()
|
H A D | rdb_general_store_test.cpp | 277 store->snapshots_.bindAssets = nullptr;
in HWTEST_F()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_manager.cpp | 1159 snapshots_.ComputeIfAbsent(
in BindAsset() 1168 auto snapshots = snapshots_.Find(snapshotKey).second;
in BindAsset() 1187 snapshots_.Compute(snapshotKey, [this, &asset, &bindInfo, &storeInfo] (const auto &key, auto &value) {
in BindAsset() 1213 bool exist = snapshots_.ComputeIfPresent(snapshotKey,
in OnAssetChanged() 1251 auto snapshot = snapshots_.Find(snapshotKey).second;
in DeleteSnapshot() 1266 snapshots_.Erase(snapshotKey);
in DeleteSnapshot()
|
H A D | object_manager.h | 218 ConcurrentMap<std::string, std::shared_ptr<Snapshot>> snapshots_; // key:bundleName_sessionId
member in OHOS::DistributedObject::ObjectStoreManager
|