blob: 1c15ee931a741508fc6464283c6fe12818d42dcb (
plain) (
blame)
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/**
* Copyright 2018 VMware
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef _HOTSTUFF_CLIENT_H
#define _HOTSTUFF_CLIENT_H
#include "salticidae/msg.h"
#include "hotstuff/type.h"
#include "hotstuff/entity.h"
#include "hotstuff/consensus.h"
namespace hotstuff {
struct MsgReqCmd {
static const opcode_t opcode = 0x4;
DataStream serialized;
command_t cmd;
MsgReqCmd(const Command &cmd) { serialized << cmd; }
MsgReqCmd(DataStream &&s): serialized(std::move(s)) {}
};
struct MsgRespCmd {
static const opcode_t opcode = 0x5;
DataStream serialized;
#if HOTSTUFF_CMD_RESPSIZE > 0
uint8_t payload[HOTSTUFF_CMD_RESPSIZE];
#endif
Finality fin;
MsgRespCmd(const Finality &fin) {
serialized << fin;
#if HOTSTUFF_CMD_RESPSIZE > 0
serialized.put_data(payload, payload + sizeof(payload));
#endif
}
MsgRespCmd(DataStream &&s) {
s >> fin;
}
};
//#ifdef HOTSTUFF_AUTOCLI
//struct MsgDemandCmd {
// static const opcode_t opcode = 0x6;
// DataStream serialized;
// size_t ncmd;
// MsgDemandCmd(size_t ncmd) { serialized << ncmd; }
// MsgDemandCmd(DataStream &&s) { s >> ncmd; }
//};
//#endif
class CommandDummy: public Command {
uint32_t cid;
uint32_t n;
uint256_t hash;
#if HOTSTUFF_CMD_REQSIZE > 0
uint8_t payload[HOTSTUFF_CMD_REQSIZE];
#endif
public:
CommandDummy() {}
~CommandDummy() override {}
CommandDummy(uint32_t cid, uint32_t n):
cid(cid), n(n), hash(salticidae::get_hash(*this)) {}
void serialize(DataStream &s) const override {
s << cid << n;
#if HOTSTUFF_CMD_REQSIZE > 0
s.put_data(payload, payload + sizeof(payload));
#endif
}
void unserialize(DataStream &s) override {
s >> cid >> n;
#if HOTSTUFF_CMD_REQSIZE > 0
auto base = s.get_data_inplace(HOTSTUFF_CMD_REQSIZE);
memmove(payload, base, sizeof(payload));
#endif
hash = salticidae::get_hash(*this);
}
const uint256_t &get_hash() const override {
return hash;
}
bool verify() const override {
return true;
}
};
}
#endif
|