1 /*
2 * Copyright (c) 2021 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
16 #ifndef OMIT_MULTI_VER
17 #include "generic_multi_ver_kv_entry.h"
18
19 #include "multi_ver_value_object.h"
20 #include "parcel.h"
21
22 namespace DistributedDB {
GenericMultiVerKvEntry()23 GenericMultiVerKvEntry::GenericMultiVerKvEntry()
24 : operFlag_(0),
25 timestamp_(0),
26 oriTimestamp_(0)
27 {}
28
~GenericMultiVerKvEntry()29 GenericMultiVerKvEntry::~GenericMultiVerKvEntry()
30 {}
31
GetSerialData(std::vector<uint8_t> & data) const32 int GenericMultiVerKvEntry::GetSerialData(std::vector<uint8_t> &data) const
33 {
34 std::vector<uint8_t> valueObjectSerial;
35 int errCode = valueObject_.GetSerialData(valueObjectSerial);
36 if (errCode != E_OK) {
37 return errCode;
38 }
39
40 size_t totalLength = Parcel::GetVectorCharLen(key_) + Parcel::GetVectorCharLen(valueObjectSerial) +
41 Parcel::GetUInt64Len() * 3; // 3 means number of 3 uint64_t parameters: operFlag, timestamp and oriTimestamp.
42
43 data.resize(totalLength);
44 Parcel parcel(data.data(), data.size());
45
46 errCode = parcel.WriteVectorChar(key_);
47 if (errCode != E_OK) {
48 return errCode;
49 }
50
51 errCode = parcel.WriteVectorChar(valueObjectSerial);
52 if (errCode != E_OK) {
53 return errCode;
54 }
55
56 errCode = parcel.WriteUInt64(operFlag_);
57 if (errCode != E_OK) {
58 return errCode;
59 }
60
61 errCode = parcel.WriteUInt64(timestamp_);
62 if (errCode != E_OK) {
63 return errCode;
64 }
65
66 errCode = parcel.WriteUInt64(oriTimestamp_);
67 if (errCode != E_OK) {
68 return errCode;
69 }
70
71 return E_OK;
72 }
73
GetValueHash(std::vector<ValueSliceHash> & valueHashes) const74 int GenericMultiVerKvEntry::GetValueHash(std::vector<ValueSliceHash> &valueHashes) const
75 {
76 return valueObject_.GetValueHash(valueHashes);
77 }
78
DeSerialData(const std::vector<uint8_t> & data)79 int GenericMultiVerKvEntry::DeSerialData(const std::vector<uint8_t> &data)
80 {
81 Parcel parcel(const_cast<uint8_t *>(data.data()), data.size());
82 parcel.ReadVectorChar(key_);
83 std::vector<uint8_t> objectData;
84 parcel.ReadVectorChar(objectData);
85 parcel.ReadUInt64(operFlag_);
86 parcel.ReadUInt64(timestamp_);
87 parcel.ReadUInt64(oriTimestamp_);
88 if (parcel.IsError()) {
89 return -E_PARSE_FAIL;
90 }
91 return valueObject_.DeSerialData(objectData);
92 }
93
SetKey(const Key & key)94 int GenericMultiVerKvEntry::SetKey(const Key &key)
95 {
96 key_ = key;
97 return E_OK;
98 }
99
GetKey(Key & key) const100 int GenericMultiVerKvEntry::GetKey(Key &key) const
101 {
102 key = key_;
103 return E_OK;
104 }
105
SetValue(const Value & value)106 int GenericMultiVerKvEntry::SetValue(const Value &value)
107 {
108 return valueObject_.DeSerialData(value);
109 }
110
GetValue(Value & value) const111 int GenericMultiVerKvEntry::GetValue(Value &value)const
112 {
113 return valueObject_.GetSerialData(value);
114 }
115
SetOperFlag(uint64_t flag)116 void GenericMultiVerKvEntry::SetOperFlag(uint64_t flag)
117 {
118 operFlag_ = flag;
119 }
120
GetOperFlag(uint64_t & flag) const121 void GenericMultiVerKvEntry::GetOperFlag(uint64_t &flag) const
122 {
123 flag = operFlag_;
124 }
125
GetDataLength() const126 uint32_t GenericMultiVerKvEntry::GetDataLength() const
127 {
128 return valueObject_.GetDataLength();
129 }
130
SetDataLength(uint32_t length)131 void GenericMultiVerKvEntry::SetDataLength(uint32_t length)
132 {
133 valueObject_.SetDataLength(length);
134 }
135
SetTimestamp(uint64_t timestamp)136 void GenericMultiVerKvEntry::SetTimestamp(uint64_t timestamp)
137 {
138 timestamp_ = timestamp;
139 }
140
GetTimestamp(uint64_t & timestamp) const141 void GenericMultiVerKvEntry::GetTimestamp(uint64_t ×tamp) const
142 {
143 timestamp = timestamp_;
144 }
145
SetOriTimestamp(uint64_t oriTimestamp)146 void GenericMultiVerKvEntry::SetOriTimestamp(uint64_t oriTimestamp)
147 {
148 oriTimestamp_ = oriTimestamp;
149 }
150
GetOriTimestamp(uint64_t & oriTimestamp) const151 void GenericMultiVerKvEntry::GetOriTimestamp(uint64_t &oriTimestamp) const
152 {
153 oriTimestamp = oriTimestamp_;
154 }
155 } // namespace DistributedDB
156 #endif
157