Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp287 return uploadData.insData.extend.empty() && uploadData.insData.record.empty() && in CheckCloudSyncDataEmpty()
288 uploadData.updData.extend.empty() && uploadData.updData.record.empty() && in CheckCloudSyncDataEmpty()
289 uploadData.delData.extend.empty() && uploadData.delData.record.empty() && in CheckCloudSyncDataEmpty()
290 uploadData.lockData.rowid.empty(); in CheckCloudSyncDataEmpty()
306 int ret = CloudSyncUtils::CheckCloudSyncDataValid(uploadData, uploadData.tableName, count); in UpdateExtendTime()
312 if (uploadData.insData.record.size() != uploadData.insData.extend.size()) { in UpdateExtendTime()
323 if (uploadData.updData.record.size() != uploadData.updData.extend.size()) { in UpdateExtendTime()
334 if (uploadData.delData.record.size() != uploadData.delData.extend.size()) { in UpdateExtendTime()
561 AssetOperationUtils::UpdateAssetsFlag(uploadData.insData.record, uploadData.insData.assets); in UpdateAssetsFlag()
562 AssetOperationUtils::UpdateAssetsFlag(uploadData.updData.record, uploadData.updData.assets); in UpdateAssetsFlag()
[all …]
H A Dcloud_syncer_extend.cpp152 int errCode = cloudDB_.BatchInsert(uploadData.tableName, uploadData.insData.record, in BatchInsert()
153 uploadData.insData.extend, insertInfo); in BatchInsert()
160 if (uploadData.isCloudVersionRecord) { in BatchInsert()
197 int errCode = cloudDB_.BatchUpdate(uploadData.tableName, uploadData.updData.record, in BatchUpdate()
198 uploadData.updData.extend, updateInfo); in BatchUpdate()
205 if (uploadData.isCloudVersionRecord) { in BatchUpdate()
581 int errCode = cloudDB_.BatchDelete(uploadData.tableName, uploadData.delData.record, in BatchDelete()
582 uploadData.delData.extend, deleteInfo); in BatchDelete()
941 uploadData = CloudSyncData(uploadData.tableName, uploadParam.mode); in HandleBatchUpload()
996 CloudSyncBatch &batchData = isInsert ? uploadData.insData : uploadData.updData; in UploadVersionRecordIfNeed()
[all …]
H A Dcloud_sync_utils.h65 …static int CheckCloudSyncDataValid(const CloudSyncData &uploadData, const std::string &tableName, …
67 static void ClearCloudSyncData(CloudSyncData &uploadData);
71 static bool CheckCloudSyncDataEmpty(const CloudSyncData &uploadData);
75 static int UpdateExtendTime(CloudSyncData &uploadData, const int64_t &count, uint64_t taskId,
96 static void UpdateAssetsFlag(CloudSyncData &uploadData);
H A Dcloud_syncer.h172 …int SaveUploadData(Info &insertInfo, Info &updateInfo, Info &deleteInfo, CloudSyncData &uploadData,
175 …int DoBatchUpload(CloudSyncData &uploadData, UploadParam &uploadParam, InnerProcessInfo &innerProc…
178 CloudSyncData &uploadData);
184 void SetUploadDataFlag(const TaskId taskId, CloudSyncData& uploadData);
262 void TagUploadAssets(CloudSyncData &uploadData);
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);
381 …void ChkIgnoredProcess(InnerProcessInfo &info, const CloudSyncData &uploadData, UploadParam &uploa…
411 … int HandleBatchUpload(UploadParam &uploadParam, InnerProcessInfo &info, CloudSyncData &uploadData,
H A Dcloud_syncer.cpp1199 if (!uploadData.delData.record.empty() && !uploadData.delData.extend.empty()) { in SaveUploadData()
1200 errCode = BatchDelete(deleteInfo, uploadData, innerProcessInfo); in SaveUploadData()
1206 if (!uploadData.updData.record.empty() && !uploadData.updData.extend.empty()) { in SaveUploadData()
1207 errCode = BatchUpdate(updateInfo, uploadData, innerProcessInfo); in SaveUploadData()
1213 if (!uploadData.insData.record.empty() && !uploadData.insData.extend.empty()) { in SaveUploadData()
1214 errCode = BatchInsert(insertInfo, uploadData, innerProcessInfo); in SaveUploadData()
1220 if (!uploadData.lockData.rowid.empty()) { in SaveUploadData()
1311 CloudSyncData &uploadData) in PreProcessBatchUpload() argument
1324 TagUploadAssets(uploadData); in PreProcessBatchUpload()
1325 CloudSyncUtils::UpdateAssetsFlag(uploadData); in PreProcessBatchUpload()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp410 cloudDataResult = uploadData; in __anon29de99fb0502()
582 cloudDataResult = uploadData; in __anon29de99fb0c02()
595 cloudDataResult = uploadData; in __anon29de99fb0d02()
683 cloudDataResult = uploadData; in __anon29de99fb1002()
904 CloudSyncData &uploadData) in SetFuncs015() argument
909 cloudDataResult = uploadData; in SetFuncs015()
919 extend = uploadData.insData.extend; in SetFuncs015()
927 record = uploadData.updData.record; in SetFuncs015()
928 extend = uploadData.updData.extend; in SetFuncs015()
933 record = uploadData.updData.record; in SetFuncs015()
[all …]
H A Dcloud_syncer_test.h162 void CallClearCloudSyncData(CloudSyncData& uploadData) in CallClearCloudSyncData() argument
164 CloudSyncUtils::ClearCloudSyncData(uploadData); in CallClearCloudSyncData()
198 void initFullCloudSyncData(CloudSyncData &uploadData, int size) in initFullCloudSyncData() argument
205 uploadData.insData.record = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
206 uploadData.insData.extend = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
207 uploadData.insData.assets = std::vector<VBucket>(size, asset); in initFullCloudSyncData()
208 uploadData.updData.record = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
209 uploadData.updData.extend = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
210 uploadData.updData.assets = std::vector<VBucket>(size, asset); in initFullCloudSyncData()
211 uploadData.delData.record = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
[all …]
H A Ddistributeddb_cloud_db_proxy_test.cpp897 CloudSyncData uploadData; variable
899 ret = utilsObj.UpdateExtendTime(uploadData, count, 0, timestamp);