Home
last modified time | relevance | path

Searched refs:cloudDB_ (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.cpp30 : cloudDB_(std::move(cloudDB)), snapshots_(bindAssets) in RdbCloud()
43 auto error = cloudDB_->BatchInsert(tableName, std::move(records), extends); in BatchInsert()
59 auto error = cloudDB_->BatchUpdate(tableName, std::move(records), extends); in BatchUpdate()
69 auto error = cloudDB_->BatchDelete(tableName, extends); in BatchDelete()
132 auto error = cloudDB_->Heartbeat(); in HeartBeat()
138 auto error = cloudDB_->Close(); in Close()
147 … return std::make_pair(static_cast<GeneralError>(cloudDB_->Lock()), cloudDB_->AliveTime() * TO_MS); in InnerLock()
155 return static_cast<GeneralError>(cloudDB_->Unlock()); in InnerUnLock()
172 auto [error, cursor] = cloudDB_->GetEmptyCursor(tableName); in GetEmptyCursor()
351 if (cloudDB_ == nullptr) { in SetPrepareTraceId()
[all …]
H A Drdb_cloud.h69 std::shared_ptr<DistributedData::CloudDB> cloudDB_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer_extend.cpp152 int errCode = cloudDB_.BatchInsert(uploadData.tableName, uploadData.insData.record, in BatchInsert()
197 int errCode = cloudDB_.BatchUpdate(uploadData.tableName, uploadData.updData.record, in BatchUpdate()
395 …auto deleteCode = cloudDB_.RemoveLocalAssets(info.tableName, downloadItem.gid, downloadItem.prefix, in DownloadAssetsOneByOneInner()
397 …auto downloadCode = cloudDB_.Download(info.tableName, downloadItem.gid, downloadItem.prefix, tmpAs… in DownloadAssetsOneByOneInner()
469 auto cloudDBs = cloudDB_.GetCloudDB(); in GenerateCompensatedSync()
512 auto res = cloudDB_.GetEmptyCursor(tableName); in SaveCursorIfNeed()
581 int errCode = cloudDB_.BatchDelete(uploadData.tableName, uploadData.delData.record, in BatchDelete()
606 return cloudDB_.SetCloudDB(cloudDBs); in SetCloudDB()
988 if (!cloudDB_.IsExistCloudVersionCallback()) { in UploadVersionRecordIfNeed()
1004 std::tie(errCode, newVersion) = cloudDB_.GetCloudVersion(oriVersion); in UploadVersionRecordIfNeed()
H A Dcloud_syncer.cpp76 if (cloudDB_.IsNotExistCloudDB()) { in Sync()
98 cloudDB_.SetCloudDB(cloudDB); in SetCloudDB()
104 return cloudDB_.GetCloudDB(); in GetCloudDB()
110 cloudDB_.SetIAssetLoader(loader); in SetIAssetLoader()
125 cloudDB_.Close(); in Close()
182 cloudDB_.SwitchCloudDB(user); in SetProxyUser()
1531 auto res = cloudDB_.Lock(); in LockCloud()
1547 return cloudDB_.UnLock(); in UnlockCloud()
1603 int ret = cloudDB_.HeartBeat(); in HeartBeat()
1684 errCode = cloudDB_.RemoveLocalAssets(assets); in CleanCloudData()
[all …]
H A Dcloud_syncer.h449 CloudDBProxy cloudDB_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h179 this->cloudDB_.SetCloudDB(std::shared_ptr<MockICloudDB>(icloudDB)); in SetMockICloudDB()
184 this->cloudDB_.SetCloudDB(icloudDB); in SetMockICloudDB()