1 /*
2 * Copyright (c) 2023 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/cloud_merge_strategy.h"
16 #include "cloud/cloud_storage_utils.h"
17
18 namespace DistributedDB {
19
TagSyncDataStatus(bool existInLocal,bool isCloudWin,const LogInfo & localInfo,const LogInfo & cloudInfo)20 OpType CloudMergeStrategy::TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
21 const LogInfo &cloudInfo)
22 {
23 bool isCloudDelete = IsDelete(cloudInfo);
24 bool isLocalDelete = IsDelete(localInfo);
25 if (isCloudWin) {
26 return TagCloudUpdateLocal(localInfo, cloudInfo, isCloudDelete, isLocalDelete);
27 }
28 if (CloudStorageUtils::IsDataLocked(localInfo.status)) {
29 return OpType::LOCKED_NOT_HANDLE;
30 }
31 if (!existInLocal) {
32 return TagLocalNotExist(isCloudDelete);
33 }
34 if (IsIgnoreUpdate(localInfo)) {
35 return OpType::NOT_HANDLE;
36 }
37 if (JudgeLocallyNewer(localInfo, cloudInfo)) {
38 return TagLocallyNewer(localInfo, cloudInfo, isCloudDelete, isLocalDelete);
39 }
40 if (isCloudDelete) {
41 return isLocalDelete ? OpType::UPDATE_TIMESTAMP : OpType::DELETE;
42 }
43 if (isLocalDelete) {
44 return OpType::INSERT;
45 }
46 // avoid local data insert to cloud success but return failed
47 // we just fill back gid here
48 bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo.wTimestamp == cloudInfo.wTimestamp);
49 if (isTimeSame && (localInfo.cloudGid.empty() || cloudInfo.sharingResource != localInfo.sharingResource)) {
50 return OpType::ONLY_UPDATE_GID;
51 }
52 if (!localInfo.isNeedUpdateAsset && IsSameRecord(cloudInfo, localInfo)) {
53 return OpType::NOT_HANDLE;
54 }
55 return TagUpdateLocal(cloudInfo, localInfo);
56 }
57
JudgeUpdateCursor()58 bool CloudMergeStrategy::JudgeUpdateCursor()
59 {
60 return true;
61 }
62
JudgeUpload()63 bool CloudMergeStrategy::JudgeUpload()
64 {
65 return true;
66 }
67
TagLocallyNewer(const LogInfo & localInfo,const LogInfo & cloudInfo,bool isCloudDelete,bool isLocalDelete)68 OpType CloudMergeStrategy::TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo,
69 bool isCloudDelete, bool isLocalDelete)
70 {
71 if (localInfo.cloudGid.empty()) {
72 return isCloudDelete ? OpType::NOT_HANDLE
73 : ((isLocalDelete && !JudgeKvScene()) ? OpType::INSERT : OpType::ONLY_UPDATE_GID);
74 }
75 if (isCloudDelete) {
76 return OpType::CLEAR_GID;
77 }
78 if (IsLogNeedUpdate(cloudInfo, localInfo)) {
79 return OpType::ONLY_UPDATE_GID;
80 }
81 return OpType::NOT_HANDLE;
82 }
83
TagCloudUpdateLocal(const LogInfo & localInfo,const LogInfo & cloudInfo,bool isCloudDelete,bool isLocalDelete)84 OpType CloudMergeStrategy::TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo,
85 bool isCloudDelete, bool isLocalDelete)
86 {
87 if (isCloudDelete) {
88 return isLocalDelete ? OpType::UPDATE_TIMESTAMP : OpType::DELETE;
89 }
90 if (isLocalDelete) {
91 return OpType::INSERT;
92 }
93 return TagUpdateLocal(cloudInfo, localInfo);
94 }
95
TagLocalNotExist(bool isCloudDelete)96 OpType CloudMergeStrategy::TagLocalNotExist(bool isCloudDelete)
97 {
98 // when cloud data is deleted, we think it is different data
99 if (isCloudDelete) {
100 return OpType::NOT_HANDLE;
101 }
102 return OpType::INSERT;
103 }
104
JudgeLocallyNewer(const LogInfo & localInfo,const LogInfo & cloudInfo)105 bool CloudMergeStrategy::JudgeLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo)
106 {
107 return (localInfo.timestamp > cloudInfo.timestamp) &&
108 ((JudgeKvScene() && (localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_CLOUD_WRITE)) == 0) ||
109 ((!JudgeKvScene()) && (localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) != 0));
110 }
111 }