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
|
// This file is part of CAF, the C++ Actor Framework. See the file LICENSE in
// the main distribution directory for license terms and copyright or visit
// https://github.com/actor-framework/actor-framework/blob/master/LICENSE.
#define CAF_SUITE mailbox_element
#include "caf/mailbox_element.hpp"
#include "core-test.hpp"
#include <string>
#include <tuple>
#include <vector>
#include "caf/all.hpp"
using std::make_tuple;
using std::string;
using std::tuple;
using std::vector;
using namespace caf;
namespace {
template <class... Ts>
optional<tuple<Ts...>> fetch(const message& x) {
if (auto view = make_const_typed_message_view<Ts...>(x))
return to_tuple(view);
return none;
}
template <class... Ts>
optional<tuple<Ts...>> fetch(const mailbox_element& x) {
return fetch<Ts...>(x.content());
}
} // namespace
CAF_TEST(empty_message) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages,
make_message());
CHECK(m1->mid.is_async());
CHECK(m1->mid.category() == message_id::normal_message_category);
CHECK(m1->content().empty());
}
CAF_TEST(non_empty_message) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages,
make_message(1, 2, 3));
CHECK(m1->mid.is_async());
CHECK(m1->mid.category() == message_id::normal_message_category);
CHECK(!m1->content().empty());
CHECK_EQ((fetch<int, int>(*m1)), none);
CHECK_EQ((fetch<int, int, int>(*m1)), make_tuple(1, 2, 3));
}
CAF_TEST(tuple) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages, 1, 2,
3);
CHECK(m1->mid.is_async());
CHECK(m1->mid.category() == message_id::normal_message_category);
CHECK(!m1->content().empty());
CHECK_EQ((fetch<int, int>(*m1)), none);
CHECK_EQ((fetch<int, int, int>(*m1)), make_tuple(1, 2, 3));
}
CAF_TEST(high_priority) {
auto m1 = make_mailbox_element(nullptr,
make_message_id(message_priority::high),
no_stages, 42);
CHECK(m1->mid.category() == message_id::urgent_message_category);
}
CAF_TEST(upstream_msg_static) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages,
make<upstream_msg::drop>({0, 0}, nullptr));
CHECK(m1->mid.category() == message_id::upstream_message_category);
}
CAF_TEST(upstream_msg_dynamic) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages,
make_message(
make<upstream_msg::drop>({0, 0}, nullptr)));
CHECK(m1->mid.category() == message_id::upstream_message_category);
}
CAF_TEST(downstream_msg_static) {
auto m1 = make_mailbox_element(nullptr, make_message_id(), no_stages,
make<downstream_msg::close>({0, 0}, nullptr));
CHECK(m1->mid.category() == message_id::downstream_message_category);
}
CAF_TEST(downstream_msg_dynamic) {
auto m1 = make_mailbox_element(
nullptr, make_message_id(), no_stages,
make_message(make<downstream_msg::close>({0, 0}, nullptr)));
CHECK(m1->mid.category() == message_id::downstream_message_category);
}
|
