Home
last modified time | relevance | path

Searched refs:storageProxy_ (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer_extend.cpp259 transactionCode = storageProxy_->Commit(); in DownloadAssetsOneByOne()
286 (void)storageProxy_->Rollback(); in GetDBAssets()
291 errCode = storageProxy_->Commit(); in GetDBAssets()
411 int errCode = storageProxy_->SetLogTriggerStatus(false); in CommitDownloadAssets()
451 int ret = storageProxy_->SetLogTriggerStatus(true); in CommitDownloadAssets()
541 errCode = storageProxy_->IsSharedTable(table, isShared); in PrepareAndDownload()
547 storageProxy_->SetCloudTaskConfig({ !isShared }); in PrepareAndDownload()
611 storageProxy_->CleanAllWaterMark(); in CleanAllWaterMark()
652 ret = storageProxy_->StartTransaction(); in GetUploadCountByTable()
665 storageProxy_->Commit(); in GetUploadCountByTable()
[all …]
H A Dcloud_syncer.cpp40 storageProxy_(std::move(storageProxy)), in CloudSyncer()
47 if (storageProxy_ != nullptr) { in CloudSyncer()
48 id_ = storageProxy_->GetIdentify(); in CloudSyncer()
133 storageProxy_->Close(); in Close()
179 storageProxy_->SetUser(user); in SetProxyUser()
469 storageProxy_->OnSyncFinish(); in DoFinished()
632 errCode = storageProxy_->Commit(); in HandleDownloadResult()
1030 ret = storageProxy_->Commit(); in SaveDataInTransaction()
1287 storageProxy_->OnUploadStart(); in DoUpload()
1679 storageProxy_->Rollback(); in CleanCloudData()
[all …]
H A Dcloud_syncer.h451 std::shared_ptr<StorageProxy> storageProxy_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h141 storageProxy_->StartTransaction();
143 storageProxy_->Commit();