| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_types.h | 30 struct CloudSyncBatch { struct
41 CloudSyncBatch insData; argument
42 CloudSyncBatch updData;
43 CloudSyncBatch delData;
44 CloudSyncBatch lockData;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.h | 133 …static int FillCloudGid(const FillGidParam ¶m, const CloudSyncBatch &data, const std::string &…
161 static void MarkUploadSuccess(const FillGidParam ¶m, const CloudSyncBatch &data,
164 …static bool CheckDataChanged(const FillGidParam ¶m, const CloudSyncBatch &data, size_t dataInd…
166 …static bool CheckDataDelete(const FillGidParam ¶m, const CloudSyncBatch &data, size_t dataInde…
168 …static void MarkUploadSuccessInner(const FillGidParam ¶m, const CloudSyncBatch &data, const st…
|
| H A D | sqlite_cloud_kv_store.h | 110 …static void FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatc…
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 843 int SqliteCloudKvExecutorUtils::FillCloudGid(const FillGidParam ¶m, const CloudSyncBatch &data, in FillCloudGid()
1084 CloudSyncBatch syncBatch = isInsert ? data.insData : data.updData; in FillCloudVersionRecord()
1436 void SqliteCloudKvExecutorUtils::MarkUploadSuccess(const FillGidParam ¶m, const CloudSyncBatch … in MarkUploadSuccess()
1454 const CloudSyncBatch &data, size_t dataIndex) in CheckDataChanged()
1490 const CloudSyncBatch &data, size_t dataIndex) in CheckDataDelete()
1526 const CloudSyncBatch &data, const std::string &user, size_t dataIndex) in MarkUploadSuccessInner()
|
| H A D | sqlite_cloud_kv_store.cpp | 475 …udKvStore::FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatch) in FillTimestamp()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.h | 142 …int FillCloudAssetForUpload(OpType opType, const TableSchema &tableSchema, const CloudSyncBatch &d…
165 int GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch,
310 …FillUploadAssetStatement(OpType opType, const TableSchema &tableSchema, const CloudSyncBatch &data,
372 … const CloudSyncBatch &syncBatch, const std::vector<TableReferenceProperty> &targetTableReference,
375 int GetReferenceGidByStmt(sqlite3_stmt *statement, const CloudSyncBatch &syncBatch,
469 int FillCloudVersionForUpload(const std::string &tableName, const CloudSyncBatch &batchData);
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 192 const CloudSyncBatch &data) in FillCloudAssetForUpload()
287 …const TableSchema &tableSchema, const CloudSyncBatch &data, const int &index, sqlite3_stmt *&state… in InitFillUploadAssetStatement()
778 …const CloudSyncBatch &syncBatch, const std::map<std::string, std::vector<TableReferenceProperty>> … in GetReferenceGid()
793 const std::string &targetTable, const CloudSyncBatch &syncBatch, in GetReferenceGidInner()
862 …const CloudSyncBatch &syncBatch, const std::string &targetTable, std::map<int64_t, Entries> &refer… in GetReferenceGidByStmt()
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 1367 const CloudSyncBatch &batchData) in FillCloudVersionForUpload()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | mock_relational_sync_able_storage.h | 33 …MOCK_METHOD3(GetReferenceGid, int(const std::string &, const CloudSyncBatch &, std::map<int64_t, E…
|
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 1405 void CheckCloudBatchData(CloudSyncBatch &batchData, bool existRef) in CheckCloudBatchData()
1431 const CloudSyncBatch &syncBatch, std::map<int64_t, Entries> &referenceGid) { in __anon2ff534420802()
1467 const CloudSyncBatch &, std::map<int64_t, Entries> &referenceGid) { in __anon2ff534420902() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.h | 88 static int FillAssetIdToAssets(CloudSyncBatch &data, int errorCode, const CloudWaterType &type);
|
| H A D | cloud_sync_utils.cpp | 446 int CloudSyncUtils::FillAssetIdToAssets(CloudSyncBatch &data, int errorCode, const CloudWaterType &… in FillAssetIdToAssets()
|
| H A D | cloud_syncer_extend.cpp | 996 CloudSyncBatch &batchData = isInsert ? uploadData.insData : uploadData.updData; in UploadVersionRecordIfNeed()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 239 virtual int GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch,
246 const CloudSyncBatch &updateData, const CloudWaterType &type, bool isLock = false);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 112 static bool ChkFillCloudAssetParam(const CloudSyncBatch &data, int errCode);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 864 bool CloudStorageUtils::ChkFillCloudAssetParam(const CloudSyncBatch &data, int errCode) in ChkFillCloudAssetParam()
1317 CloudSyncBatch &opData = isInsert ? cloudSyncData.insData : cloudSyncData.updData; in IdentifyCloudTypeInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 901 CloudSyncBatch data;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1601 int RelationalSyncAbleStorage::GetReferenceGid(const std::string &tableName, const CloudSyncBatch &… in GetReferenceGid()
1887 …const std::string &tableName, const CloudSyncBatch &updateData, const CloudWaterType &type, bool i… in UpdateRecordFlagAfterUpload()
|