Searched refs:cloudDB_ (Results 1 - 6 of 6) sorted by relevance
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 30 : 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()
82 cursor = cloudDB_->Query(query, ValueProxy::Convert(std::move(extend))); in Query()
84 cursor = cloudDB_->Query(tableName, ValueProxy::Convert(std::move(extend))); in Query()
116 return static_cast<GeneralError>(cloudDB_->PreSharing(tableName, extend)); in PreSharing()
132 auto error = cloudDB_->Heartbeat(); in HeartBeat()
138 auto error = cloudDB_->Close(); in Close()
147 return std::make_pair(static_cast<GeneralError>(cloudDB_ in InnerLock()
[all...] |
| H A D | rdb_cloud.h | 69 std::shared_ptr<DistributedData::CloudDB> cloudDB_; member in OHOS::DistributedRdb::RdbCloud
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 76 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()
232 cloudDB_.SetPrepareTraceId(taskInfo.prepareTraceId); // SetPrepareTraceId before task started in DoSync()
1432 ret = cloudDB_.Query(tableName, extend, downloadData.data); in QueryCloudData()
1531 auto res = cloudDB_.Lock(); in LockCloud()
1547 return cloudDB_ in UnlockCloud()
[all...] |
| H A D | cloud_syncer_extend.cpp | 149 int errCode = cloudDB_.BatchInsert(uploadData.tableName, uploadData.insData.record, in BatchInsert()
194 int errCode = cloudDB_.BatchUpdate(uploadData.tableName, uploadData.updData.record, in BatchUpdate()
392 auto deleteCode = cloudDB_.RemoveLocalAssets(info.tableName, downloadItem.gid, downloadItem.prefix, in DownloadAssetsOneByOneInner()
394 auto downloadCode = cloudDB_.Download(info.tableName, downloadItem.gid, downloadItem.prefix, tmpAssetsToDownload); in DownloadAssetsOneByOneInner()
496 auto cloudDBs = cloudDB_.GetCloudDB(); in GenerateCompensatedSync()
539 auto res = cloudDB_.GetEmptyCursor(tableName); in SaveCursorIfNeed()
600 int errCode = cloudDB_.BatchDelete(uploadData.tableName, uploadData.delData.record, in BatchDelete()
625 return cloudDB_.SetCloudDB(cloudDBs); in SetCloudDB()
1008 if (!cloudDB_.IsExistCloudVersionCallback()) { in UploadVersionRecordIfNeed()
1024 std::tie(errCode, newVersion) = cloudDB_ in UploadVersionRecordIfNeed()
[all...] |
| H A D | cloud_syncer.h | 450 CloudDBProxy cloudDB_; member in DistributedDB::CloudSyncer
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_syncer_test.h | 179 this->cloudDB_.SetCloudDB(std::shared_ptr<MockICloudDB>(icloudDB)); in SetMockICloudDB()
184 this->cloudDB_.SetCloudDB(icloudDB); in SetMockICloudDB()
|
Completed in 8 milliseconds