| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 220 size_t updRecordLen = uploadData.updData.record.size(); in CheckCloudSyncDataValid()
221 size_t updExtendLen = uploadData.updData.extend.size(); in CheckCloudSyncDataValid()
249 std::vector<VBucket>().swap(uploadData.updData.record); in ClearCloudSyncData()
250 std::vector<VBucket>().swap(uploadData.updData.extend); in ClearCloudSyncData()
288 uploadData.updData.extend.empty() && uploadData.updData.record.empty() && in CheckCloudSyncDataEmpty()
322 if (!uploadData.updData.extend.empty()) { in UpdateExtendTime()
323 if (uploadData.updData.record.size() != uploadData.updData.extend.size()) { in UpdateExtendTime()
327 ret = CloudSyncUtils::GetWaterMarkAndUpdateTime(uploadData.updData.extend, waterMark); in UpdateExtendTime()
562 AssetOperationUtils::UpdateAssetsFlag(uploadData.updData.record, uploadData.updData.assets); in UpdateAssetsFlag()
|
| H A D | cloud_syncer_extend.cpp | 197 int errCode = cloudDB_.BatchUpdate(uploadData.tableName, uploadData.updData.record, in BatchUpdate()
198 uploadData.updData.extend, updateInfo); in BatchUpdate()
215 … ret = CloudSyncUtils::FillAssetIdToAssets(uploadData.updData, errCode, CloudWaterType::UPDATE); in BatchUpdate()
222 bool isSkip = CloudSyncUtils::IsSkipAssetsMissingRecord(uploadData.updData.extend); in BatchUpdate()
996 CloudSyncBatch &batchData = isInsert ? uploadData.insData : uploadData.updData; in UploadVersionRecordIfNeed()
1038 for (size_t i = 0; i < uploadData.updData.extend.size(); i++) { in TagUploadAssets()
1040 (void)TagAssetsInSingleCol(assetField, false, uploadData.updData.record[i]); in TagUploadAssets()
|
| H A D | cloud_syncer.cpp | 1206 if (!uploadData.updData.record.empty() && !uploadData.updData.extend.empty()) { in SaveUploadData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 1096 syncData.updData.rowid.push_back(1L);
1110 syncData.updData.assets.push_back(bucket1);
1111 syncData.updData.extend.push_back(bucket1);
1153 syncData.updData.rowid.push_back(1L);
1154 syncData.updData.rowid.push_back(2L);
1165 syncData.updData.assets.push_back(bucket1);
1166 syncData.updData.assets.push_back(bucket2);
1167 syncData.updData.extend.push_back(bucket1);
1168 syncData.updData.extend.push_back(bucket2);
1171 syncData.updData.hashKey.push_back({ 1 });
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_syncer_test.h | 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()
|
| H A D | distributeddb_cloud_syncer_upload_test.cpp | 113 uploadData.updData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataUpdData()
114 uploadData.updData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataUpdData()
115 uploadData.updData.assets = std::vector<VBucket>(COUNT, assets); in PrepareUploadDataUpdData()
881 record = uploadData2.updData.record; in __anon29de99fb1902()
882 extend = uploadData2.updData.extend; in __anon29de99fb1902()
927 record = uploadData.updData.record; in SetFuncs015()
928 extend = uploadData.updData.extend; in SetFuncs015()
933 record = uploadData.updData.record; in SetFuncs015()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_types.h | 42 CloudSyncBatch updData; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1142 cloudDataResult.insData.extend.size(), cloudDataResult.updData.extend.size(), in GetCloudDataNext()
1555 errCode = GetReferenceGid(syncData.tableName, syncData.updData, referenceGid); in FillReferenceData()
1560 … return FillReferenceDataIntoExtend(syncData.updData.rowid, referenceGid, syncData.updData.extend); in FillReferenceData()
1877 …errCode = UpdateRecordFlagAfterUpload(handle, data.tableName, data.updData, CloudWaterType::UPDATE… in FillCloudLogAndAssetInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 1443 syncData.updData.rowid.push_back(2); // rowid is 2
1444 syncData.updData.extend.resize(1); // has 1 record
1449 CheckCloudBatchData(syncData.updData, true);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.cpp | 52 …data.insData.record.size(), data.updData.record.size(), data.delData.extend.size(), errCode, total… in GetCloudData()
80 maxTimeStamp = GetMaxTimeStamp(data.updData.extend); in UpdateBeginTimeForMemoryDB()
790 return FillCloudGid(param, data.updData, user, CloudWaterType::UPDATE, recorder); in FillCloudLog()
1084 CloudSyncBatch syncBatch = isInsert ? data.insData : data.updData; in FillCloudVersionRecord()
|
| H A D | sqlite_cloud_kv_store.cpp | 470 FillTimestamp(rawSysTime, currentTime, data.updData); in GetLocalCloudVersion()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 246 … SQLiteSingleVerRelationalStorageExecutor::FillCloudVersionForUpload(data.tableName, data.updData); in FillCloudVersionForUpload()
1349 errCode = FillCloudAssetForUpload(opType, tableSchema, data.updData); in FillHandleWithOpType()
1369 if (fillAsset && !data.updData.assets.empty()) { in FillHandleWithOpType()
1370 errCode = FillCloudAssetForUpload(opType, tableSchema, data.updData); in FillHandleWithOpType()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1317 CloudSyncBatch &opData = isInsert ? cloudSyncData.insData : cloudSyncData.updData; in IdentifyCloudTypeInner()
|