Home
last modified time | relevance | path

Searched refs:innerProcessInfo (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.cpp154 innerProcessInfo.upLoadInfo.successCount += insertInfo.successCount; in BatchInsert()
155 innerProcessInfo.upLoadInfo.insertCount += insertInfo.successCount; in BatchInsert()
199 innerProcessInfo.upLoadInfo.successCount += updateInfo.successCount; in BatchUpdate()
200 innerProcessInfo.upLoadInfo.updateCount += updateInfo.successCount; in BatchUpdate()
583 innerProcessInfo.upLoadInfo.successCount += deleteInfo.successCount; in BatchDelete()
584 innerProcessInfo.upLoadInfo.deleteCount += deleteInfo.successCount; in BatchDelete()
673 InnerProcessInfo innerProcessInfo; in UpdateProcessInfoWithoutUpload() local
674 innerProcessInfo.tableName = tableName; in UpdateProcessInfoWithoutUpload()
675 innerProcessInfo.upLoadInfo.total = 0; // count is zero in UpdateProcessInfoWithoutUpload()
676 innerProcessInfo.tableStatus = ProcessStatus::FINISHED; in UpdateProcessInfoWithoutUpload()
[all …]
H A Dcloud_syncer.h173 InnerProcessInfo &innerProcessInfo);
175 …tchUpload(CloudSyncData &uploadData, UploadParam &uploadParam, InnerProcessInfo &innerProcessInfo);
177 int PreProcessBatchUpload(UploadParam &uploadParam, const InnerProcessInfo &innerProcessInfo,
243 …BatchUpload(const UploadParam &uploadParam, const InnerProcessInfo &innerProcessInfo, bool lastBat…
354 … int BatchInsert(Info &insertInfo, CloudSyncData &uploadData, InnerProcessInfo &innerProcessInfo);
356 … int BatchUpdate(Info &updateInfo, CloudSyncData &uploadData, InnerProcessInfo &innerProcessInfo);
358 … int BatchDelete(Info &deleteInfo, CloudSyncData &uploadData, InnerProcessInfo &innerProcessInfo);
H A Dcloud_syncer.cpp1112 currentContext_.notifier->UpdateProcess(innerProcessInfo); in NotifyInBatchUpload()
1114 currentContext_.notifier->NotifyProcess(taskInfo, innerProcessInfo); in NotifyInBatchUpload()
1196 InnerProcessInfo &innerProcessInfo) in SaveUploadData() argument
1200 errCode = BatchDelete(deleteInfo, uploadData, innerProcessInfo); in SaveUploadData()
1207 errCode = BatchUpdate(updateInfo, uploadData, innerProcessInfo); in SaveUploadData()
1214 errCode = BatchInsert(insertInfo, uploadData, innerProcessInfo); in SaveUploadData()
1239 bool lastBatch = innerProcessInfo.upLoadInfo.successCount == innerProcessInfo.upLoadInfo.total; in DoBatchUpload()
1241 innerProcessInfo.tableStatus = ProcessStatus::FINISHED; in DoBatchUpload()
1244 NotifyInBatchUpload(uploadParam, innerProcessInfo, lastBatch); in DoBatchUpload()
1318 ret = CloudSyncUtils::CheckCloudSyncDataValid(uploadData, innerProcessInfo.tableName, in PreProcessBatchUpload()
[all …]