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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
/*
* Copyright (c) 2022 Cisco and/or its affiliates.
* 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.
*/
#include <core/memif_connector.h>
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <hicn/transport/core/global_object_pool.h>
#include <hicn/transport/utils/chrono_typedefs.h>
namespace transport {
namespace core {
namespace {
using namespace std::placeholders;
/**
* Master memif connector
*/
template <int Master>
class Memif {
static inline std::size_t counter = 256;
static inline std::size_t total_packets = counter * 4096;
static inline std::size_t packet_size = 64;
public:
Memif(asio::io_service &io_service)
: io_service_(io_service),
memif_connector_(std::make_shared<MemifConnector>(
std::bind(&Memif::onPacketReceived, this, _1, _2, _3),
std::bind(&Memif::onPacketSent, this, _1, _2),
std::bind(&Memif::onClose, this, _1),
std::bind(&Memif::onReconnect, this, _1, _2), io_service_,
Master ? "test_master" : "test_slave")),
recv_counter_(0),
sent_counter_(0) {
memif_connector_->connect(0 /* Memif ID */, Master /* Is Master */,
"@hicntransport/test/memif");
}
void setStart() { t0_ = utils::SteadyTime::now(); }
void startTest() {
if constexpr (!Master) {
auto &packet_manager = core::PacketManager<>::getInstance();
// Send in busrt of 256 packet per time
for (std::size_t i = 0; i < counter; i++) {
auto packet = packet_manager.getMemBuf();
packet->append(packet_size);
memif_connector_->send(packet);
sent_counter_++;
}
if (sent_counter_ < total_packets) {
asio::post(io_service_, std::bind(&Memif::startTest, this));
}
} else {
setStart();
}
}
auto getRecvCounter() { return recv_counter_; }
auto getSentCounter() { return sent_counter_; }
private:
void onPacketReceived(Connector *c,
const std::vector<utils::MemBuf::Ptr> &buffers,
const std::error_code &ec) {
if constexpr (Master) {
recv_counter_ += buffers.size();
if (recv_counter_ == total_packets) {
auto t1 = utils::SteadyTime::now();
auto delta = utils::SteadyTime::getDurationS(t0_, t1);
auto rate = recv_counter_ / delta.count();
LOG(INFO) << "rate: " << rate << " packets/s";
io_service_.stop();
}
} else {
FAIL() << "Slave should not receive packets";
}
}
void onPacketSent(Connector *c, const std::error_code &ec) {}
void onClose(Connector *c) {}
void onReconnect(Connector *c, const std::error_code &ec) {}
private:
asio::io_service &io_service_;
std::shared_ptr<MemifConnector> memif_connector_;
std::size_t recv_counter_;
std::size_t sent_counter_;
utils::SteadyTime::TimePoint t0_;
};
using MemifMaster = Memif<1>;
using MemifSlave = Memif<0>;
} // namespace
class MemifTest : public ::testing::Test {
protected:
MemifTest() : io_service_(), master_(io_service_), slave_(io_service_) {
// You can do set-up work for each test here.
}
void run() {
asio::post(io_service_, std::bind(&MemifSlave::startTest, &slave_));
master_.startTest();
io_service_.run();
EXPECT_THAT(master_.getRecvCounter(),
::testing::Eq(slave_.getSentCounter()));
}
virtual ~MemifTest() {
// You can do clean-up work that doesn't throw exceptions here.
}
// If the constructor and destructor are not enough for setting up
// and cleaning up each test, you can define the following methods:
virtual void SetUp() {
// Code here will be called immediately after the constructor (right
// before each test).
}
virtual void TearDown() {
// Code here will be called immediately after each test (right
// before the destructor).
}
protected:
asio::io_service io_service_;
MemifMaster master_;
MemifSlave slave_;
};
TEST_F(MemifTest, Test) { run(); }
} // namespace core
} // namespace transport
|
