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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include "msg/msg_types.h"
namespace ceph::net::test {
constexpr uint64_t CMD_CLI_NONCE = 1;
constexpr int64_t CMD_CLI_OSD = 1;
constexpr uint64_t TEST_NONCE = 2;
constexpr int64_t TEST_OSD = 2;
constexpr uint64_t CMD_SRV_NONCE = 3;
constexpr int64_t CMD_SRV_OSD = 3;
constexpr uint64_t TEST_PEER_NONCE = 2;
constexpr int64_t TEST_PEER_OSD = 4;
inline entity_addr_t get_test_peer_addr(
const entity_addr_t &cmd_peer_addr) {
entity_addr_t test_peer_addr = cmd_peer_addr;
test_peer_addr.set_port(cmd_peer_addr.get_port() + 1);
test_peer_addr.set_nonce(TEST_PEER_NONCE);
return test_peer_addr;
}
enum class cmd_t : char {
none = '\0',
shutdown,
suite_start,
suite_stop,
suite_connect_me,
suite_send_me,
suite_keepalive_me,
suite_markdown,
suite_recv_op
};
enum class policy_t : char {
none = '\0',
stateful_server,
stateless_server,
lossless_peer,
lossless_peer_reuse,
lossy_client,
lossless_client
};
inline std::ostream& operator<<(std::ostream& out, const cmd_t& cmd) {
switch(cmd) {
case cmd_t::none:
return out << "none";
case cmd_t::shutdown:
return out << "shutdown";
case cmd_t::suite_start:
return out << "suite_start";
case cmd_t::suite_stop:
return out << "suite_stop";
case cmd_t::suite_connect_me:
return out << "suite_connect_me";
case cmd_t::suite_send_me:
return out << "suite_send_me";
case cmd_t::suite_keepalive_me:
return out << "suite_keepalive_me";
case cmd_t::suite_markdown:
return out << "suite_markdown";
case cmd_t::suite_recv_op:
return out << "suite_recv_op";
default:
ceph_abort();
}
}
inline std::ostream& operator<<(std::ostream& out, const policy_t& policy) {
switch(policy) {
case policy_t::none:
return out << "none";
case policy_t::stateful_server:
return out << "stateful_server";
case policy_t::stateless_server:
return out << "stateless_server";
case policy_t::lossless_peer:
return out << "lossless_peer";
case policy_t::lossless_peer_reuse:
return out << "lossless_peer_reuse";
case policy_t::lossy_client:
return out << "lossy_client";
case policy_t::lossless_client:
return out << "lossless_client";
default:
ceph_abort();
}
}
} // namespace ceph::net::test
|
