Home
last modified time | relevance | path

Searched refs:CloudSyncData (Results 1 – 25 of 31) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_executor_utils.h34 SQLiteSingleVerContinueToken &token, CloudSyncData &data);
41 static int FillCloudLog(const FillGidParam &param, OpType opType, const CloudSyncData &data,
50 …static std::pair<int, CloudSyncData> GetLocalCloudVersion(sqlite3 *db, bool isMemory, const std::s…
67 sqlite3_stmt *statement, CloudSyncData &cloudDataResult, UploadDetail &detail);
141 static int FillCloudVersionRecord(sqlite3 *db, OpType opType, const CloudSyncData &data);
143 static std::pair<int, CloudSyncData> GetLocalCloudVersionInner(sqlite3 *db, bool isMemory,
146 static int GetCloudVersionRecord(bool isMemory, sqlite3_stmt *stmt, CloudSyncData &syncData);
148 …DefaultCloudVersionRecord(const std::string &key, const std::string &dev, CloudSyncData &syncData);
156 … static bool UpdateBeginTimeForMemoryDB(SQLiteSingleVerContinueToken &token, CloudSyncData &data);
H A Dsqlite_cloud_kv_store.h53 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
55 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
74 …int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data, bool fillAsset, bool ignoreEmpt…
92 std::pair<int, CloudSyncData> GetLocalCloudVersion() override;
H A Dsqlite_cloud_kv_store.cpp180 const Timestamp &beginTime, ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData()
197 int SqliteCloudKvStore::GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudData… in GetCloudDataNext()
263 int SqliteCloudKvStore::FillCloudLogAndAsset(OpType opType, const CloudSyncData &data, bool fillAss… in FillCloudLogAndAsset()
451 std::pair<int, CloudSyncData> SqliteCloudKvStore::GetLocalCloudVersion() in GetLocalCloudVersion()
453 std::pair<int, CloudSyncData> res; in GetLocalCloudVersion()
H A Dsqlite_cloud_kv_executor_utils.cpp28 const CloudUploadRecorder &recorder, SQLiteSingleVerContinueToken &token, CloudSyncData &data) in GetCloudData()
72 …ExecutorUtils::UpdateBeginTimeForMemoryDB(SQLiteSingleVerContinueToken &token, CloudSyncData &data) in UpdateBeginTimeForMemoryDB()
98 sqlite3_stmt *statement, CloudSyncData &cloudDataResult, UploadDetail &detail) in GetCloudDataForSync()
773 …dKvExecutorUtils::FillCloudLog(const FillGidParam &param, OpType opType, const CloudSyncData &data, in FillCloudLog()
1078 …CloudKvExecutorUtils::FillCloudVersionRecord(sqlite3 *db, OpType opType, const CloudSyncData &data) in FillCloudVersionRecord()
1118 std::pair<int, CloudSyncData> SqliteCloudKvExecutorUtils::GetLocalCloudVersion(sqlite3 *db, bool is… in GetLocalCloudVersion()
1128 std::pair<int, CloudSyncData> SqliteCloudKvExecutorUtils::GetLocalCloudVersionInner(sqlite3 *db, bo… in GetLocalCloudVersionInner()
1131 std::pair<int, CloudSyncData> res; in GetLocalCloudVersionInner()
1173 …dKvExecutorUtils::GetCloudVersionRecord(bool isMemory, sqlite3_stmt *stmt, CloudSyncData &syncData) in GetCloudVersionRecord()
1193 CloudSyncData &syncData) in InitDefaultCloudVersionRecord()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
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_extend.cpp150 int CloudSyncer::BatchInsert(Info &insertInfo, CloudSyncData &uploadData, InnerProcessInfo &innerPr… in BatchInsert()
195 int CloudSyncer::BatchUpdate(Info &updateInfo, CloudSyncData &uploadData, InnerProcessInfo &innerPr… in BatchUpdate()
484 void CloudSyncer::ChkIgnoredProcess(InnerProcessInfo &info, const CloudSyncData &uploadData, Upload… in ChkIgnoredProcess()
579 int CloudSyncer::BatchDelete(Info &deleteInfo, CloudSyncData &uploadData, InnerProcessInfo &innerPr… in BatchDelete()
919 CloudSyncData &uploadData, ContinueToken &continueStmtToken) in HandleBatchUpload()
941 uploadData = CloudSyncData(uploadData.tableName, uploadParam.mode); in HandleBatchUpload()
1022 void CloudSyncer::TagUploadAssets(CloudSyncData &uploadData) in TagUploadAssets()
1112 CloudSyncData uploadData(tableName, uploadParam.mode); in DoUploadByMode()
H A Dcloud_sync_utils.cpp215 int CloudSyncUtils::CheckCloudSyncDataValid(const CloudSyncData &uploadData, const std::string &tab… in CheckCloudSyncDataValid()
244 void CloudSyncUtils::ClearCloudSyncData(CloudSyncData &uploadData) in ClearCloudSyncData()
285 bool CloudSyncUtils::CheckCloudSyncDataEmpty(const CloudSyncData &uploadData) in CheckCloudSyncDataEmpty()
303 int CloudSyncUtils::UpdateExtendTime(CloudSyncData &uploadData, const int64_t &count, uint64_t task… in UpdateExtendTime()
559 void CloudSyncUtils::UpdateAssetsFlag(CloudSyncData &uploadData) in UpdateAssetsFlag()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp71 void PrepareUploadDataForUploadModeCheck012(CloudSyncData &uploadData);
103 const VBucket &assets, CloudSyncData &uploadData) in PrepareUploadDataInsData()
111 const VBucket &assets, CloudSyncData &uploadData) in PrepareUploadDataUpdData()
402 CloudSyncData uploadData(cloudSyncer->GetCurrentContextTableName());
409 CloudSyncData &cloudDataResult) { in __anon29de99fb0502()
577 CloudSyncData uploadData(cloudSyncer->GetCurrentContextTableName());
677 CloudSyncData uploadData(cloudSyncer->GetCurrentContextTableName());
865 CloudSyncData &cloudDataResult) { in __anon29de99fb1602()
904 CloudSyncData &uploadData) in SetFuncs015()
908 CloudSyncData &cloudDataResult) { in SetFuncs015()
[all …]
H A Dmock_icloud_sync_storage_interface.h37 CloudSyncData &));
38 MOCK_METHOD2(GetCloudDataNext, int(ContinueToken &, CloudSyncData &));
49 MOCK_METHOD4(FillCloudLogAndAsset, int(OpType, const CloudSyncData &, bool, bool));
H A Dcloud_syncer_test.h162 void CallClearCloudSyncData(CloudSyncData& uploadData) in CallClearCloudSyncData()
198 void initFullCloudSyncData(CloudSyncData &uploadData, int size) in initFullCloudSyncData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h70 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult);
73 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult);
75 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) const;
104 int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data);
118 void FillCloudGidIfSuccess(const OpType opType, const CloudSyncData &data);
148 std::pair<int, CloudSyncData> GetLocalCloudVersion();
H A Dicloud_sync_storage_interface.h119 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) = 0;
121 …virtual int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) = 0;
150 …virtual int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data, bool fillAsset, bool ig…
215 virtual std::pair<int, CloudSyncData> GetLocalCloudVersion() in GetLocalCloudVersion()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dcloud_db_types.h39 struct CloudSyncData { struct
51 CloudSyncData() = default; argument
52 CloudSyncData(const std::string &_tableName) : tableName(_tableName) {}; in CloudSyncData() argument
53 …CloudSyncData(const std::string &_tableName, CloudWaterType _mode) : tableName(_tableName), mode(_… in CloudSyncData() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h150 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
152 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
182 …int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data, bool fillAsset, bool ignoreEmpt…
231 int FillReferenceData(CloudSyncData &syncData);
243 const CloudSyncData &data, bool fillAsset, bool ignoreEmptyGid);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_meta_data_test.cpp229 CloudSyncData cloudDataResult;
251 std::pair<int, CloudSyncData> ver = proxyObj.GetLocalCloudVersion();
283 CloudSyncData data;
336 CloudSyncData data;
372 CloudSyncData cloudDataResult;
H A Dmock_relational_sync_able_storage.h28 int CallFillReferenceData(CloudSyncData &syncData) in CallFillReferenceData()
H A Ddistributeddb_cloud_save_cloud_data_test.cpp1395 CloudSyncData data(g_assetTableName);
1429 CloudSyncData syncData("FillReferenceGid001");
1464 CloudSyncData syncData("FillReferenceGid002");
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp223 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData()
231 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData()
249 int StorageProxy::GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult… in GetCloudDataNext()
437 int StorageProxy::FillCloudLogAndAsset(OpType opType, const CloudSyncData &data) in FillCloudLogAndAsset()
524 void StorageProxy::FillCloudGidIfSuccess(const OpType opType, const CloudSyncData &data) in FillCloudGidIfSuccess()
649 std::pair<int, CloudSyncData> StorageProxy::GetLocalCloudVersion() in GetLocalCloudVersion()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.h121 int UpdateCloudLogGid(const CloudSyncData &cloudDataResult, bool ignoreEmptyGid);
123 int GetSyncCloudData(const CloudUploadRecorder &uploadRecorder, CloudSyncData &cloudDataResult,
143 int FillCloudVersionForUpload(const OpType opType, const CloudSyncData &data);
177 …int FillHandleWithOpType(const OpType opType, const CloudSyncData &data, bool fillAsset, bool igno…
286 CloudSyncData &cloudDataResult, uint32_t &stepNum, uint32_t &totalSize);
384 …int BindStmtWithCloudGid(const CloudSyncData &cloudDataResult, bool ignoreEmptyGid, sqlite3_stmt *…
H A Dsqlite_single_ver_relational_continue_token.h43 …int GetCloudStatement(sqlite3 *db, CloudSyncData &cloudDataResult, sqlite3_stmt *&queryStmt, bool …
H A Dsqlite_single_ver_relational_continue_token.cpp176 int SQLiteSingleVerRelationalContinueToken::GetCloudStatement(sqlite3 *db, CloudSyncData &cloudData… in GetCloudStatement()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp769 CloudSyncData syncData(g_tableName);
859 CloudSyncData cloudSyncData(g_tableName);
895 CloudSyncData cloudSyncData(g_tableName);
927 CloudSyncData cloudSyncData(g_tableName);
968 CloudSyncData cloudSyncData;
1053 CloudSyncData cloudSyncData;
1093 CloudSyncData syncData(g_tableName);
1152 CloudSyncData syncData(g_tableName);
1204 CloudSyncData syncData(g_tableName);
1360 CloudSyncData syncData(g_tableName);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_storage_utils.h174 …static int IdentifyCloudType(const CloudUploadRecorder &recorder, CloudSyncData &cloudSyncData, VB…
198 …static int IdentifyCloudTypeInner(CloudSyncData &cloudSyncData, VBucket &data, VBucket &log, VBuck…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1103 const Timestamp &beginTime, ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData()
1123 CloudSyncData &cloudDataResult) in GetCloudDataNext()
1392 int RelationalSyncAbleStorage::FillCloudLogAndAsset(const OpType opType, const CloudSyncData &data,… in FillCloudLogAndAsset()
1542 int RelationalSyncAbleStorage::FillReferenceData(CloudSyncData &syncData) in FillReferenceData()
1862 OpType opType, const CloudSyncData &data, bool fillAsset, bool ignoreEmptyGid) in FillCloudLogAndAssetInner()

12