Home
last modified time | relevance | path

Searched refs:OpType (Results 1 – 25 of 41) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_merge_strategy.cpp35 return OpType::NOT_HANDLE; in TagSyncDataStatus()
41 return isLocalDelete ? OpType::UPDATE_TIMESTAMP : OpType::DELETE; in TagSyncDataStatus()
44 return OpType::INSERT; in TagSyncDataStatus()
53 return OpType::NOT_HANDLE; in TagSyncDataStatus()
73 : ((isLocalDelete && !JudgeKvScene()) ? OpType::INSERT : OpType::ONLY_UPDATE_GID); in TagLocallyNewer()
76 return OpType::CLEAR_GID; in TagLocallyNewer()
81 return OpType::NOT_HANDLE; in TagLocallyNewer()
88 return isLocalDelete ? OpType::UPDATE_TIMESTAMP : OpType::DELETE; in TagCloudUpdateLocal()
91 return OpType::INSERT; in TagCloudUpdateLocal()
100 return OpType::NOT_HANDLE; in TagLocalNotExist()
[all …]
H A Dcloud_force_push_strategy.cpp20 OpType CloudForcePushStrategy::TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo … in TagSyncDataStatus()
24 return OpType::LOCKED_NOT_HANDLE; in TagSyncDataStatus()
28 return OpType::NOT_HANDLE; in TagSyncDataStatus()
34 return isCloudDelete || isLocalDelete ? OpType::NOT_HANDLE : OpType::ONLY_UPDATE_GID; in TagSyncDataStatus()
38 return OpType::CLEAR_GID; in TagSyncDataStatus()
42 return OpType::SET_CLOUD_FORCE_PUSH_FLAG_ONE; in TagSyncDataStatus()
44 return OpType::SET_CLOUD_FORCE_PUSH_FLAG_ZERO; in TagSyncDataStatus()
48 return OpType::ONLY_UPDATE_GID; in TagSyncDataStatus()
50 return OpType::NOT_HANDLE; in TagSyncDataStatus()
H A Dcloud_force_pull_strategy.cpp20 OpType CloudForcePullStrategy::TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo … in TagSyncDataStatus()
24 return OpType::LOCKED_NOT_HANDLE; in TagSyncDataStatus()
28 return OpType::NOT_HANDLE; in TagSyncDataStatus()
31 return OpType::DELETE; in TagSyncDataStatus()
33 return OpType::UPDATE_TIMESTAMP; in TagSyncDataStatus()
36 return OpType::INSERT; in TagSyncDataStatus()
42 return gidEmpty ? OpType::NOT_HANDLE : OpType::DELETE; in TagSyncDataStatus()
45 return OpType::INSERT; in TagSyncDataStatus()
H A Dcloud_sync_utils.cpp52 case OpType::INSERT: in OpTypeToChangeType()
54 case OpType::DELETE: in OpTypeToChangeType()
56 case OpType::UPDATE: in OpTypeToChangeType()
353 case OpType::INSERT : in UpdateLocalCache()
354 case OpType::UPDATE : in UpdateLocalCache()
355 case OpType::DELETE: { in UpdateLocalCache()
406 case OpType::INSERT: in SaveChangedData()
410 case OpType::UPDATE: in SaveChangedData()
417 case OpType::DELETE: in SaveChangedData()
583 if (opType != OpType::INSERT && opType != OpType::UPDATE) { in CalOpType()
[all …]
H A Dcloud_merge_strategy.h26 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
33 …OpType TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, boo…
35 … OpType TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete,
38 OpType TagLocalNotExist(bool isCloudDelete);
H A Dcloud_sync_strategy.cpp33 OpType CloudSyncStrategy::TagSyncDataStatus([[gnu::unused]] bool existInLocal, [[gnu::unused]] bool…
36 return OpType::NOT_HANDLE;
89 OpType CloudSyncStrategy::TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const in TagUpdateLocal()
91 return IsIgnoreUpdate(localInfo) ? OpType::NOT_HANDLE : OpType::UPDATE; in TagUpdateLocal()
H A Dcloud_sync_utils.h38 static ChangeType OpTypeToChangeType(OpType strategy);
78 static void UpdateLocalCache(OpType opType, const LogInfo &cloudInfo,
98 static OpType CalOpType(ICloudSyncer::SyncParam &param, size_t dataIndex);
H A Dcloud_sync_strategy.h34 virtual OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
47 OpType TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const;
H A Dcloud_syncer.cpp667 if (downloadItem.strategy == OpType::DELETE) { in CloudDbDownloadAssets()
740 OpType strategyOpResult = OpType::NOT_HANDLE; in TagStatus()
760 OpType strategy = param.downloadData.opType[idx]; in TagDownloadAssets()
762 case OpType::INSERT: in TagDownloadAssets()
763 case OpType::UPDATE: in TagDownloadAssets()
764 case OpType::DELETE: in TagDownloadAssets()
767 case OpType::NOT_HANDLE: in TagDownloadAssets()
768 case OpType::ONLY_UPDATE_GID: in TagDownloadAssets()
787 OpType strategy = param.downloadData.opType[idx]; in HandleTagAssets()
1743 strategyOpResult = OpType::NOT_HANDLE; in TagStatusByStrategy()
[all …]
H A Dcloud_force_pull_strategy.h22 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
H A Dcloud_force_push_strategy.h22 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_strategy_test.cpp107 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT);
126 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE);
132 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::DELETE);
139 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::INSERT);
179 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE);
274 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::DELETE);
276 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::DELETE);
283 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE);
285 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE);
328 OpType result = OpType::INSERT;
[all …]
H A Ddistributeddb_cloud_kv_syncer_test.cpp61 void CheckUploadAbnormal(OpType opType, int64_t expCnt, bool isCompensated = false);
280 void DistributedDBCloudKvSyncerTest::CheckUploadAbnormal(OpType opType, int64_t expCnt, bool isComp… in CheckUploadAbnormal()
290 case OpType::INSERT: in CheckUploadAbnormal()
294 case OpType::UPDATE: in CheckUploadAbnormal()
298 case OpType::DELETE: in CheckUploadAbnormal()
347 CheckUploadAbnormal(OpType::UPDATE, 1L); // 1 is expected count in __anon644cd9970702()
349 CheckUploadAbnormal(OpType::UPDATE, 1L, true); // 1 is expected count in __anon644cd9970702()
404 CheckUploadAbnormal(OpType::INSERT, 1L); // 1 is expected count in __anon644cd9970a02()
406 CheckUploadAbnormal(OpType::INSERT, 2L, true); // 2 is expected count in __anon644cd9970a02()
461 CheckUploadAbnormal(OpType::DELETE, 1L); // 1 is expected count in __anon644cd9970d02()
[all …]
H A Ddistributeddb_cloud_db_proxy_test.cpp759 CloudSyncUtils::UpdateLocalCache(OpType::INSERT, cloudInfo, localInfo, localLogInfoCache);
766 CloudSyncUtils::UpdateLocalCache(OpType::DELETE, cloudInfo, localInfo, localLogInfoCache);
783 param.downloadData.opType.push_back(OpType::INSERT);
784 param.downloadData.opType.push_back(OpType::UPDATE);
796 EXPECT_EQ(CloudSyncUtils::CalOpType(param, i), OpType::INSERT);
804 param.downloadData.opType.push_back(OpType::UPDATE);
806 EXPECT_EQ(CloudSyncUtils::CalOpType(param, param.downloadData.data.size() - 1), OpType::UPDATE);
877 EXPECT_EQ(utilsObj.OpTypeToChangeType(OpType::ONLY_UPDATE_GID), ChangeType::OP_BUTT);
H A Dvirtual_cloud_syncer.h48 OpType &strategyOpResult);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_executor_utils.cpp464 case OpType::INSERT: in GetOperateDataSql()
467 case OpType::DELETE: in GetOperateDataSql()
484 case OpType::UPDATE: in GetOperateLogSql()
486 case OpType::DELETE: in GetOperateLogSql()
558 case OpType::INSERT: in BindStmt()
560 case OpType::UPDATE: in BindStmt()
562 case OpType::DELETE: in BindStmt()
787 case OpType::INSERT: in FillCloudLog()
789 case OpType::UPDATE: in FillCloudLog()
791 case OpType::DELETE: in FillCloudLog()
[all …]
H A Dsqlite_cloud_kv_executor_utils.h41 static int FillCloudLog(const FillGidParam &param, OpType opType, const CloudSyncData &data,
89 static int OperateCloudData(sqlite3 *db, bool isMemory, int index, OpType opType,
92 static std::string GetOperateDataSql(OpType opType);
94 static std::string GetOperateLogSql(OpType opType);
96 static OpType TransToOpType(const CloudWaterType type);
100 static int BindStmt(sqlite3_stmt *logStmt, sqlite3_stmt *dataStmt, int index, OpType opType,
125 …static int OnlyUpdateLogTable(sqlite3 *db, bool isMemory, int index, OpType op, DownloadData &down…
127 …static int OnlyUpdateSyncData(sqlite3 *db, bool isMemory, int index, OpType opType, DownloadData &…
129 …static int BindUpdateSyncDataStmt(sqlite3_stmt *dataStmt, int index, OpType opType, DownloadData &…
141 static int FillCloudVersionRecord(sqlite3 *db, OpType opType, const CloudSyncData &data);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp1047 std::vector<OpType> opTypes = { OpType::DELETE, OpType::INSERT, OpType::UPDATE,
1048 OpType::UPDATE, OpType::NOT_HANDLE };
1095 ASSERT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::UPDATE, syncData), E_OK);
1114 ASSERT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::UPDATE, syncData), E_OK);
1174 ASSERT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::UPDATE, syncData), E_OK);
1224 ASSERT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::INSERT, syncData), E_OK);
1362 EXPECT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::UPDATE_VERSION, syncData), E_OK);
1426 std::vector<OpType> opTypes = { OpType::INSERT, OpType::INSERT, OpType::DELETE, OpType::UPDATE,
1427 OpType::ONLY_UPDATE_GID, OpType::NOT_HANDLE };
1468 std::vector<OpType> opTypes = { OpType::INSERT, OpType::INSERT, OpType::INSERT };
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp259 case OpType::INSERT: in ExecutePutCloudData()
262 case OpType::UPDATE: in ExecutePutCloudData()
265 case OpType::DELETE: in ExecutePutCloudData()
268 case OpType::ONLY_UPDATE_GID: in ExecutePutCloudData()
271 case OpType::UPDATE_TIMESTAMP: in ExecutePutCloudData()
272 case OpType::CLEAR_GID: in ExecutePutCloudData()
276 case OpType::NOT_HANDLE: in ExecutePutCloudData()
997 …return (opType == OpType::DELETE || opType == OpType::UPDATE_TIMESTAMP || opType == OpType::CLEAR_… in IsAllowWithPrimaryKey()
998 opType == OpType::ONLY_UPDATE_GID || opType == OpType::LOCKED_NOT_HANDLE); in IsAllowWithPrimaryKey()
1002 OpType opType) in UpdateLogRecord()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.h142 …int FillCloudAssetForUpload(OpType opType, const TableSchema &tableSchema, const CloudSyncBatch &d…
143 int FillCloudVersionForUpload(const OpType opType, const CloudSyncData &data);
177 …int FillHandleWithOpType(const OpType opType, const CloudSyncData &data, bool fillAsset, bool igno…
310 …int InitFillUploadAssetStatement(OpType opType, const TableSchema &tableSchema, const CloudSyncBat…
348 …int GetUpdateLogRecordStatement(const TableSchema &tableSchema, const VBucket &vBucket, OpType opT…
353 int UpdateLogRecord(const VBucket &vBucket, const TableSchema &tableSchema, OpType opType);
366 int OnlyUpdateLogTable(const VBucket &vBucket, const TableSchema &tableSchema, OpType opType);
422 int64_t dataKey, OpType opType);
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp245 case OpType::UPDATE_VERSION: in FillCloudVersionForUpload()
247 case OpType::INSERT_VERSION: in FillCloudVersionForUpload()
1338 case OpType::UPDATE_VERSION: // fallthrough in FillHandleWithOpType()
1339 case OpType::INSERT_VERSION: { in FillHandleWithOpType()
1343 case OpType::SET_UPLOADING: { in FillHandleWithOpType()
1352 case OpType::INSERT: { in FillHandleWithOpType()
1365 errCode = FillCloudVersionForUpload(OpType::INSERT_VERSION, data); in FillHandleWithOpType()
1368 case OpType::UPDATE: { in FillHandleWithOpType()
1376 errCode = FillCloudVersionForUpload(OpType::UPDATE_VERSION, data); in FillHandleWithOpType()
1483 if (opType != OpType::ONLY_UPDATE_GID && opType != OpType::NOT_HANDLE && in OnlyUpdateAssetId()
[all …]
H A Dcloud_sync_log_table_manager.cpp116 insertTrigger += CloudStorageUtils::GetTableRefUpdateSql(table, OpType::INSERT); in GetInsertTrigger()
145 updateTrigger += CloudStorageUtils::GetTableRefUpdateSql(table, OpType::UPDATE); in GetUpdateTrigger()
181 deleteTrigger += CloudStorageUtils::GetTableRefUpdateSql(table, OpType::DELETE); in GetDeleteTrigger()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp823 … downloadData.opType = { OpType::UPDATE, OpType::DELETE, OpType::ONLY_UPDATE_GID, OpType::INSERT, in ConstructDownloadData()
824 …OpType::SET_CLOUD_FORCE_PUSH_FLAG_ZERO, OpType::SET_CLOUD_FORCE_PUSH_FLAG_ONE, OpType::NOT_HANDLE … in ConstructDownloadData()
849 if (downloadData.opType[i] == OpType::INSERT) { in SaveCloudDataTest()
1041 … downloadData.opType = { OpType::UPDATE, OpType::UPDATE_TIMESTAMP, OpType::INSERT, OpType::INSERT, in ConstructMultiDownloadData()
1042 OpType::INSERT, OpType::NOT_HANDLE }; in ConstructMultiDownloadData()
1159 downloadData.opType = { OpType::DELETE };
1195 downloadData.opType = { OpType::ONLY_UPDATE_GID, OpType::CLEAR_GID };
1259 downloadData.opType = { OpType::DELETE }; in DeleteWithPkTest()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dicloud_sync_storage_interface.h30 enum class OpType : uint8_t { enum
49 std::vector<OpType> opType;
150 …virtual int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data, bool fillAsset, bool ig…
H A Dstorage_proxy.h104 int FillCloudLogAndAsset(OpType opType, const CloudSyncData &data);
118 void FillCloudGidIfSuccess(const OpType opType, const CloudSyncData &data);

12