1 /*
2 * Copyright (c) 2024 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15 #include "cloud_sync_strategy.h"
16 #include "cloud/cloud_db_constant.h"
17
18 namespace DistributedDB {
CloudSyncStrategy()19 CloudSyncStrategy::CloudSyncStrategy() : policy_(SingleVerConflictResolvePolicy::DEFAULT_LAST_WIN)
20 {
21 }
22
SetConflictResolvePolicy(SingleVerConflictResolvePolicy policy)23 void CloudSyncStrategy::SetConflictResolvePolicy(SingleVerConflictResolvePolicy policy)
24 {
25 policy_ = policy;
26 }
27
TagSyncDataStatus(bool existInLocal,bool isCloudWin,const LogInfo & localInfo,const LogInfo & cloudInfo)28 OpType CloudSyncStrategy::TagSyncDataStatus([[gnu::unused]] bool existInLocal, [[gnu::unused]] bool isCloudWin,
29 [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo)
30 {
31 return OpType::NOT_HANDLE;
32 }
33
JudgeUpdateCursor()34 bool CloudSyncStrategy::JudgeUpdateCursor()
35 {
36 return false;
37 }
38
JudgeUpload()39 bool CloudSyncStrategy::JudgeUpload()
40 {
41 return false;
42 }
43
IsDelete(const LogInfo & info)44 bool CloudSyncStrategy::IsDelete(const LogInfo &info)
45 {
46 return (info.flag & static_cast<uint32_t>(LogInfoFlag::FLAG_DELETE)) ==
47 static_cast<uint32_t>(LogInfoFlag::FLAG_DELETE);
48 }
49
IsLogNeedUpdate(const LogInfo & cloudInfo,const LogInfo & localInfo)50 bool CloudSyncStrategy::IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo)
51 {
52 return (cloudInfo.sharingResource != localInfo.sharingResource) || (cloudInfo.version != localInfo.version);
53 }
54
IsSameVersion(const LogInfo & cloudInfo,const LogInfo & localInfo)55 bool CloudSyncStrategy::IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo)
56 {
57 if (cloudInfo.version.empty() || localInfo.version.empty()) {
58 return false;
59 }
60 return (cloudInfo.version == localInfo.version);
61 }
62
IsIgnoreUpdate(const LogInfo & localInfo) const63 bool CloudSyncStrategy::IsIgnoreUpdate(const LogInfo &localInfo) const
64 {
65 if (policy_ == SingleVerConflictResolvePolicy::DEFAULT_LAST_WIN) {
66 return false;
67 }
68 if ((localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) == 0 && IsDelete(localInfo)) {
69 LOGW("[CloudSyncStrategy] dont ignore %.6s", localInfo.cloudGid.c_str());
70 return false;
71 }
72 if (localInfo.originDev.empty() && localInfo.device.empty()) {
73 LOGW("[CloudSyncStrategy] %.6s was ignored override", localInfo.cloudGid.c_str());
74 return true;
75 }
76 return false;
77 }
78
TagUpdateLocal(const LogInfo & cloudInfo,const LogInfo & localInfo) const79 OpType CloudSyncStrategy::TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const
80 {
81 return IsIgnoreUpdate(localInfo) ? OpType::NOT_HANDLE : OpType::UPDATE;
82 }
83
IsSameRecord(const LogInfo & cloudInfo,const LogInfo & localInfo)84 bool CloudSyncStrategy::IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo)
85 {
86 // avoid compensated and unlock record miss update
87 return (localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_WAIT_COMPENSATED_SYNC)) == 0 &&
88 localInfo.status == static_cast<uint32_t>(LockStatus::UNLOCK) &&
89 !localInfo.version.empty() && localInfo.version == cloudInfo.version &&
90 std::abs(static_cast<int64_t>(cloudInfo.timestamp - localInfo.timestamp)) <
91 static_cast<int64_t>(CloudDbConstant::ONE_SECOND);
92 }
93 }