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 ((localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) != 0 &&
38 localInfo.timestamp > cloudInfo.timestamp) {
39 return TagLocallyNewer(localInfo, cloudInfo, isCloudDelete, isLocalDelete);
40 }
41 if (isCloudDelete) {
42 return isLocalDelete ? OpType::UPDATE_TIMESTAMP : OpType::DELETE;
43 }
44 if (isLocalDelete) {
45 return OpType::INSERT;
46 }
47 // avoid local data insert to cloud success but return failed
48 // we just fill back gid here
49 bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo.wTimestamp == cloudInfo.wTimestamp);
50 if (isTimeSame && (localInfo.cloudGid.empty() || cloudInfo.sharingResource != localInfo.sharingResource)) {
51 return OpType::ONLY_UPDATE_GID;
52 }
53 if (!localInfo.isNeedUpdateAsset && IsSameRecord(cloudInfo, localInfo)) {
54 return OpType::NOT_HANDLE;
55 }
56 return TagUpdateLocal(cloudInfo, localInfo);
57 }
58
JudgeUpdateCursor()59 bool CloudMergeStrategy::JudgeUpdateCursor()
60 {
61 return true;
62 }
63
JudgeUpload()64 bool CloudMergeStrategy::JudgeUpload()
65 {
66 return true;
67 }
68
TagLocallyNewer(const LogInfo & localInfo,const LogInfo & cloudInfo,bool isCloudDelete,bool isLocalDelete)69 OpType CloudMergeStrategy::TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo,
70 bool isCloudDelete, bool isLocalDelete)
71 {
72 if (localInfo.cloudGid.empty()) {
73 return isCloudDelete ? OpType::NOT_HANDLE : (isLocalDelete ? 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 }