Home
last modified time | relevance | path

Searched refs:uploadParam (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer_extend.cpp498 NotifyInBatchUpload(uploadParam, info, true); in ChkIgnoredProcess()
911 if (IsNeedGetLocalWater(uploadParam.taskId)) { in GetLocalWater()
914 uploadParam.localMark = res.second; in GetLocalWater()
930 if (IsNeedLock(uploadParam) && !isLocked) { in HandleBatchUpload()
946 RecordWaterMark(uploadParam.taskId, uploadParam.localMark); in HandleBatchUpload()
957 if (isLocked && IsNeedLock(uploadParam)) { in HandleBatchUpload()
969 uploadParam.mode = waterType; in DoUploadInner()
977 ret = UploadVersionRecordIfNeed(uploadParam); in DoUploadInner()
984 if (uploadParam.count == 0) { in UploadVersionRecordIfNeed()
1124 uploadParam.count -= uploadData.ignoredCount; in DoUploadByMode()
[all …]
H A Dcloud_syncer.h175 …int DoBatchUpload(CloudSyncData &uploadData, UploadParam &uploadParam, InnerProcessInfo &innerProc…
177 int PreProcessBatchUpload(UploadParam &uploadParam, const InnerProcessInfo &innerProcessInfo,
180 int PutWaterMarkAfterBatchUpload(const std::string &tableName, UploadParam &uploadParam);
194 int DoUploadInner(const std::string &tableName, UploadParam &uploadParam);
196 …int DoUploadByMode(const std::string &tableName, UploadParam &uploadParam, InnerProcessInfo &info);
243 …void NotifyInBatchUpload(const UploadParam &uploadParam, const InnerProcessInfo &innerProcessInfo,…
348 InnerProcessInfo GetInnerProcessInfo(const std::string &tableName, UploadParam &uploadParam);
381 …kIgnoredProcess(InnerProcessInfo &info, const CloudSyncData &uploadData, UploadParam &uploadParam);
409 std::pair<int, Timestamp> GetLocalWater(const std::string &tableName, UploadParam &uploadParam);
411 … int HandleBatchUpload(UploadParam &uploadParam, InnerProcessInfo &info, CloudSyncData &uploadData,
[all …]
H A Dcloud_syncer.cpp1108 taskInfo = cloudTaskInfos_[uploadParam.taskId]; in NotifyInBatchUpload()
1111 if (uploadParam.lastTable && lastBatch) { in NotifyInBatchUpload()
1244 NotifyInBatchUpload(uploadParam, innerProcessInfo, lastBatch); in DoBatchUpload()
1248 errCode = PutWaterMarkAfterBatchUpload(uploadData.tableName, uploadParam); in DoBatchUpload()
1258 storageProxy_->ReleaseUploadRecord(tableName, uploadParam.mode, uploadParam.localMark); in PutWaterMarkAfterBatchUpload()
1260 if (IsModeForcePush(uploadParam.taskId) || (IsPriorityTask(uploadParam.taskId) && in PutWaterMarkAfterBatchUpload()
1261 !IsQueryListEmpty(uploadParam.taskId))) { in PutWaterMarkAfterBatchUpload()
1264 errCode = storageProxy_->PutWaterMarkByMode(tableName, uploadParam.mode, uploadParam.localMark); in PutWaterMarkAfterBatchUpload()
1314 int ret = CheckTaskIdValid(uploadParam.taskId); in PreProcessBatchUpload()
1328 uploadParam.taskId, uploadParam.localMark); in PreProcessBatchUpload()
[all …]