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
SetIsKvScene(bool isKvScene)23 void CloudSyncStrategy::SetIsKvScene(bool isKvScene)
24 {
25 isKvScene_ = isKvScene;
26 }
27
SetConflictResolvePolicy(SingleVerConflictResolvePolicy policy)28 void CloudSyncStrategy::SetConflictResolvePolicy(SingleVerConflictResolvePolicy policy)
29 {
30 policy_ = policy;
31 }
32
33 OpType CloudSyncStrategy::TagSyncDataStatus([[gnu::unused]] bool existInLocal, [[gnu::unused]] bool isCloudWin,
34 [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo)
35 {
36 return OpType::NOT_HANDLE;
37 }
38
JudgeUpdateCursor()39 bool CloudSyncStrategy::JudgeUpdateCursor()
40 {
41 return false;
42 }
43
JudgeUpload()44 bool CloudSyncStrategy::JudgeUpload()
45 {
46 return false;
47 }
48
JudgeKvScene()49 bool CloudSyncStrategy::JudgeKvScene()
50 {
51 return isKvScene_;
52 }
53
IsDelete(const LogInfo & info)54 bool CloudSyncStrategy::IsDelete(const LogInfo &info)
55 {
56 return (info.flag & static_cast<uint32_t>(LogInfoFlag::FLAG_DELETE)) ==
57 static_cast<uint32_t>(LogInfoFlag::FLAG_DELETE);
58 }
59
IsLogNeedUpdate(const LogInfo & cloudInfo,const LogInfo & localInfo)60 bool CloudSyncStrategy::IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo)
61 {
62 return (cloudInfo.sharingResource != localInfo.sharingResource) || (cloudInfo.version != localInfo.version);
63 }
64
IsSameVersion(const LogInfo & cloudInfo,const LogInfo & localInfo)65 bool CloudSyncStrategy::IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo)
66 {
67 if (cloudInfo.version.empty() || localInfo.version.empty()) {
68 return false;
69 }
70 return (cloudInfo.version == localInfo.version);
71 }
72
IsIgnoreUpdate(const LogInfo & localInfo) const73 bool CloudSyncStrategy::IsIgnoreUpdate(const LogInfo &localInfo) const
74 {
75 if (policy_ == SingleVerConflictResolvePolicy::DEFAULT_LAST_WIN) {
76 return false;
77 }
78 if ((localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) == 0 && IsDelete(localInfo)) {
79 LOGW("[CloudSyncStrategy] dont ignore %.6s", localInfo.cloudGid.c_str());
80 return false;
81 }
82 if (localInfo.originDev.empty() && localInfo.device.empty()) {
83 LOGW("[CloudSyncStrategy] %.6s was ignored override", localInfo.cloudGid.c_str());
84 return true;
85 }
86 return false;
87 }
88
TagUpdateLocal(const LogInfo & cloudInfo,const LogInfo & localInfo) const89 OpType CloudSyncStrategy::TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const
90 {
91 return IsIgnoreUpdate(localInfo) ? OpType::NOT_HANDLE : OpType::UPDATE;
92 }
93
IsSameRecord(const LogInfo & cloudInfo,const LogInfo & localInfo)94 bool CloudSyncStrategy::IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo)
95 {
96 // avoid compensated and unlock record miss update
97 return (localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_WAIT_COMPENSATED_SYNC)) == 0 &&
98 localInfo.status == static_cast<uint32_t>(LockStatus::UNLOCK) &&
99 !localInfo.version.empty() && localInfo.version == cloudInfo.version &&
100 std::abs(static_cast<int64_t>(cloudInfo.timestamp - localInfo.timestamp)) <
101 static_cast<int64_t>(CloudDbConstant::ONE_SECOND);
102 }
103 }