1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
// @author Vegard Sjonfjell
#include "protocolserialization5_2.h"
#include "storagecommand.h"
#include "serializationhelper.h"
namespace storage::mbusprot {
using documentapi::TestAndSetCondition;
void ProtocolSerialization5_2::onEncode(GBBuf & buf, const api::PutCommand & cmd) const
{
ProtocolSerialization5_0::onEncode(buf, cmd);
encodeTasCondition(buf, cmd);
}
api::StorageCommand::UP
ProtocolSerialization5_2::onDecodePutCommand(BBuf & buf) const
{
auto cmd = ProtocolSerialization5_0::onDecodePutCommand(buf);
decodeTasCondition(*cmd, buf);
return cmd;
}
void ProtocolSerialization5_2::onEncode(GBBuf & buf, const api::RemoveCommand & cmd) const
{
ProtocolSerialization4_2::onEncode(buf, cmd);
encodeTasCondition(buf, cmd);
}
api::StorageCommand::UP
ProtocolSerialization5_2::onDecodeRemoveCommand(BBuf & buf) const
{
auto cmd = ProtocolSerialization4_2::onDecodeRemoveCommand(buf);
decodeTasCondition(*cmd, buf);
return cmd;
}
void ProtocolSerialization5_2::onEncode(GBBuf & buf, const api::UpdateCommand & cmd) const
{
ProtocolSerialization5_0::onEncode(buf, cmd);
encodeTasCondition(buf, cmd);
}
api::StorageCommand::UP
ProtocolSerialization5_2::onDecodeUpdateCommand(BBuf & buf) const
{
auto cmd = ProtocolSerialization5_0::onDecodeUpdateCommand(buf);
decodeTasCondition(*cmd, buf);
return cmd;
}
void ProtocolSerialization5_2::decodeTasCondition(api::StorageCommand & storageCmd, BBuf & buf) {
auto & cmd = static_cast<api::TestAndSetCommand &>(storageCmd);
cmd.setCondition(TestAndSetCondition(SH::getString(buf)));
}
void ProtocolSerialization5_2::encodeTasCondition(GBBuf & buf, const api::StorageCommand & storageCmd) {
auto & cmd = static_cast<const api::TestAndSetCommand &>(storageCmd);
buf.putString(cmd.getCondition().getSelection());
}
}
|
