| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 218 size_t insRecordLen = uploadData.insData.record.size(); in CheckCloudSyncDataValid()
219 size_t insExtendLen = uploadData.insData.extend.size(); in CheckCloudSyncDataValid()
246 std::vector<VBucket>().swap(uploadData.insData.record); in ClearCloudSyncData()
247 std::vector<VBucket>().swap(uploadData.insData.extend); in ClearCloudSyncData()
248 std::vector<int64_t>().swap(uploadData.insData.rowid); in ClearCloudSyncData()
287 return uploadData.insData.extend.empty() && uploadData.insData.record.empty() && in CheckCloudSyncDataEmpty()
311 if (!uploadData.insData.extend.empty()) { in UpdateExtendTime()
312 if (uploadData.insData.record.size() != uploadData.insData.extend.size()) { in UpdateExtendTime()
316 ret = CloudSyncUtils::GetWaterMarkAndUpdateTime(uploadData.insData.extend, waterMark); in UpdateExtendTime()
561 AssetOperationUtils::UpdateAssetsFlag(uploadData.insData.record, uploadData.insData.assets); in UpdateAssetsFlag()
|
| H A D | cloud_syncer_extend.cpp | 152 int errCode = cloudDB_.BatchInsert(uploadData.tableName, uploadData.insData.record, in BatchInsert()
153 uploadData.insData.extend, insertInfo); in BatchInsert()
170 … ret = CloudSyncUtils::FillAssetIdToAssets(uploadData.insData, errCode, CloudWaterType::INSERT); in BatchInsert()
177 bool isSkip = CloudSyncUtils::IsSkipAssetsMissingRecord(uploadData.insData.extend); in BatchInsert()
995 bool isInsert = !uploadData.insData.record.empty(); in UploadVersionRecordIfNeed()
996 CloudSyncBatch &batchData = isInsert ? uploadData.insData : uploadData.updData; in UploadVersionRecordIfNeed()
1033 for (size_t i = 0; i < uploadData.insData.extend.size(); i++) { in TagUploadAssets()
1035 (void)TagAssetsInSingleCol(assetField, true, uploadData.insData.record[i]); in TagUploadAssets()
|
| H A D | cloud_syncer.cpp | 1213 if (!uploadData.insData.record.empty() && !uploadData.insData.extend.empty()) { in SaveUploadData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_upload_test.cpp | 105 uploadData.insData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataInsData()
106 uploadData.insData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataInsData()
123 uploadData.insData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
124 uploadData.insData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
405 uploadData.insData.record = std::vector<VBucket>(1001, tmp);
406 uploadData.insData.extend = std::vector<VBucket>(1001, tmp);
527 uploadData2.insData.record = std::vector<VBucket>(100);
528 uploadData2.insData.extend = std::vector<VBucket>(100);
591 uploadData.insData.extend = std::vector<VBucket>(999, tmp);
875 extend = uploadData2.insData.extend; in __anon29de99fb1802()
[all …]
|
| H A D | cloud_syncer_test.h | 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()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 777 syncData.insData.rowid.push_back(1);
788 syncData.insData.extend.push_back(bucket1);
802 syncData.insData.extend.push_back(bucket2);
817 syncData.insData.extend.clear();
823 syncData.insData.extend.push_back(bucket1);
824 syncData.insData.extend.push_back(bucket2);
827 syncData.insData.extend.pop_back();
829 syncData.insData.extend.push_back(bucket2);
1206 syncData.insData.rowid.push_back(i);
1379 syncData.insData.extend.push_back(extend1);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_types.h | 41 CloudSyncBatch insData; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 248 … SQLiteSingleVerRelationalStorageExecutor::FillCloudVersionForUpload(data.tableName, data.insData); in FillCloudVersionForUpload()
930 for (size_t i = 0; i < cloudDataResult.insData.extend.size(); ++i) { in BindStmtWithCloudGid()
931 auto gidEntry = cloudDataResult.insData.extend[i].find(CloudDbConstant::GID_FIELD); in BindStmtWithCloudGid()
932 if (gidEntry == cloudDataResult.insData.extend[i].end()) { in BindStmtWithCloudGid()
934 if (DBCommon::IsRecordAssetsMissing(cloudDataResult.insData.extend[i])) { in BindStmtWithCloudGid()
945 bool containError = DBCommon::IsRecordError(cloudDataResult.insData.extend[i]); in BindStmtWithCloudGid()
951 cloudDataResult.insData.extend[i], val) != E_OK) { in BindStmtWithCloudGid()
961 … errCode = BindStmtWithCloudGidInner(val, cloudDataResult.insData.rowid[i], stmt, fillGidCount); in BindStmtWithCloudGid()
1344 errCode = FillCloudAssetForUpload(opType, tableSchema, data.insData); in FillHandleWithOpType()
1359 errCode = FillCloudAssetForUpload(opType, tableSchema, data.insData); in FillHandleWithOpType()
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 1474 if (cloudDataResult.insData.extend.empty() || cloudDataResult.insData.rowid.empty() || in UpdateCloudLogGid()
1475 cloudDataResult.insData.extend.size() != cloudDataResult.insData.rowid.size()) { in UpdateCloudLogGid()
|
| /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()
83 maxTimeStamp = GetMaxTimeStamp(data.insData.extend); in UpdateBeginTimeForMemoryDB()
788 return FillCloudGid(param, data.insData, user, CloudWaterType::INSERT, recorder); in FillCloudLog()
1084 CloudSyncBatch syncBatch = isInsert ? data.insData : data.updData; in FillCloudVersionRecord()
1202 syncData.insData.record.push_back(std::move(defaultRecord)); in InitDefaultCloudVersionRecord()
1205 syncData.insData.extend.push_back(std::move(defaultExtend)); in InitDefaultCloudVersionRecord()
1206 syncData.insData.assets.emplace_back(); in InitDefaultCloudVersionRecord()
1209 syncData.insData.hashKey.push_back(bytesHashKey); in InitDefaultCloudVersionRecord()
|
| H A D | sqlite_cloud_kv_store.cpp | 469 FillTimestamp(rawSysTime, currentTime, data.insData); in GetLocalCloudVersion()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 1441 syncData.insData.rowid.push_back(1); // rowid is 1
1442 syncData.insData.extend.resize(1); // has 1 record
1448 CheckCloudBatchData(syncData.insData, true);
1465 syncData.insData.rowid.push_back(1); // rowid is 1
1472 syncData.insData.extend.resize(1); // rowid is 1
|
| /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()
1545 int errCode = GetReferenceGid(syncData.tableName, syncData.insData, referenceGid); in FillReferenceData()
1550 …errCode = FillReferenceDataIntoExtend(syncData.insData.rowid, referenceGid, syncData.insData.exten… in FillReferenceData()
1875 …errCode = UpdateRecordFlagAfterUpload(handle, data.tableName, data.insData, CloudWaterType::INSERT… in FillCloudLogAndAssetInner()
|
| /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()
|