Home
last modified time | relevance | path

Searched refs:cloudWaterMark (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp903 param.cloudWaterMark = {}; in SaveData()
905 param.cloudWaterMark = std::get<std::string>(lastData[CloudDbConstant::CURSOR_FIELD]); in SaveData()
1131 int ret = storageProxy_->GetCloudWaterMark(param.tableName, param.cloudWaterMark); in DoDownload()
1337 std::string cloudWaterMark; in SaveCloudWaterMark() local
1353 int errCode = storageProxy_->SetCloudWaterMark(tableName, cloudWaterMark); in SaveCloudWaterMark()
1428 int ret = FillDownloadExtend(taskId, tableName, cloudWaterMark, extend); in QueryCloudData()
1438 cloudWaterMark = std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]); in QueryCloudData()
2014 ret = storageProxy_->GetCloudWaterMark(param.tableName, param.cloudWaterMark); in GetSyncParamForDownload()
2041 ret = storageProxy_->GetCloudWaterMark(param.tableName, param.cloudWaterMark); in GetSyncParamForDownload()
2046 ReloadCloudWaterMarkIfNeed(param.tableName, param.cloudWaterMark); in GetSyncParamForDownload()
[all …]
H A Dicloud_syncer.h68 std::string cloudWaterMark; member
H A Dcloud_syncer.h200 int QueryCloudData(TaskId taskId, const std::string &tableName, std::string &cloudWaterMark,
270 … FillDownloadExtend(TaskId taskId, const std::string &tableName, const std::string &cloudWaterMark,
340 void ReloadCloudWaterMarkIfNeed(const std::string &tableName, std::string &cloudWaterMark);
H A Dcloud_syncer_extend.cpp43 … CloudSyncer::ReloadCloudWaterMarkIfNeed(const std::string &tableName, std::string &cloudWaterMark) in ReloadCloudWaterMarkIfNeed() argument
47 cloudWaterMark = cacheCloudWaterMark.empty() ? cloudWaterMark : cacheCloudWaterMark; in ReloadCloudWaterMarkIfNeed()
74 …:FillDownloadExtend(TaskId taskId, const std::string &tableName, const std::string &cloudWaterMark, in FillDownloadExtend() argument
78 {CloudDbConstant::CURSOR_FIELD, cloudWaterMark} in FillDownloadExtend()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_meta_data.cpp257 std::string cloudWaterMark; in CleanWaterMark() local
258 int ret = WriteMarkToMeta(tableName, 0, cloudWaterMark); in CleanWaterMark()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp1082 param.cloudWaterMark = "waterMark";
1085 cloudSyncer->SetCloudWaterMarks(param.tableName, param.cloudWaterMark);
1091 EXPECT_EQ(actualParam.cloudWaterMark, expectCloudWaterMark);
1124 param.cloudWaterMark = "waterMark";
1127 cloudSyncer->SetCloudWaterMarks(param.tableName, param.cloudWaterMark);
1133 EXPECT_EQ(actualParam.cloudWaterMark, expectCloudWaterMark);
H A Ddistributeddb_cloud_syncer_download_test.cpp768 param.cloudWaterMark = expectCloudWaterMark;
771 g_cloudSyncer->SetCloudWaterMarks(param.tableName, param.cloudWaterMark);
775 EXPECT_EQ(actualParam.cloudWaterMark, expectCloudWaterMark);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store.cpp1313 std::string cloudWaterMark; in CleanWaterMark() local
1315 errCode = DBCommon::SerializeWaterMark(0, cloudWaterMark, blobMetaVal); in CleanWaterMark()