Home
last modified time | relevance | path

Searched refs:snapshots_ (Results 1 - 14 of 14) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_asset_loader.cpp28 : 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 Drdb_asset_loader.h44 BindAssets* snapshots_; member in OHOS::DistributedRdb::RdbAssetLoader
H A Drdb_cloud.cpp30 : 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 Drdb_cloud.h70 BindAssets* snapshots_; member in OHOS::DistributedRdb::RdbCloud
H A Drdb_general_store.cpp159 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 Drdb_general_store.h169 BindAssets snapshots_; member in OHOS::DistributedRdb::RdbGeneralStore
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/
H A Dsqlite_local_kvdb_connection.h106 mutable std::set<IKvDBSnapshot *> snapshots_; member in DistributedDB::SQLiteLocalKvDBConnection
H A Dsqlite_local_kvdb_connection.cpp290 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 Dmulti_ver_natural_store_connection.cpp289 snapshots_.insert(snapshot); in GetSnapshot()
303 snapshots_.erase(snapshot); in ReleaseSnapshot()
349 if (snapshots_.size() > 0) { in PreClose()
H A Dmulti_ver_natural_store_connection.h117 mutable std::set<IKvDBSnapshot *> snapshots_; member in DistributedDB::MultiVerNaturalStoreConnection
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dobject_manager_test.cpp429 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 Drdb_general_store_test.cpp277 store->snapshots_.bindAssets = nullptr; in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp1159 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 Dobject_manager.h218 ConcurrentMap<std::string, std::shared_ptr<Snapshot>> snapshots_; // key:bundleName_sessionId member in OHOS::DistributedObject::ObjectStoreManager

Completed in 12 milliseconds