Skip to content
Snippets Groups Projects
Commit 19a4729b authored by Adrien Béraud's avatar Adrien Béraud
Browse files

test/dhtrunner: use random port, add more assertions

parent 405b8739
Branches
Tags
No related merge requests found
...@@ -36,8 +36,8 @@ DhtRunnerTester::setUp() { ...@@ -36,8 +36,8 @@ DhtRunnerTester::setUp() {
config.dht_config.node_config.max_peer_req_per_sec = -1; config.dht_config.node_config.max_peer_req_per_sec = -1;
config.dht_config.node_config.max_req_per_sec = -1; config.dht_config.node_config.max_req_per_sec = -1;
node1.run(42222, config); node1.run(0, config);
node2.run(42232, config); node2.run(0, config);
node2.bootstrap(node1.getBound()); node2.bootstrap(node1.getBound());
} }
...@@ -54,15 +54,17 @@ DhtRunnerTester::tearDown() { ...@@ -54,15 +54,17 @@ DhtRunnerTester::tearDown() {
node1.shutdown(shutdown); node1.shutdown(shutdown);
node2.shutdown(shutdown); node2.shutdown(shutdown);
std::unique_lock<std::mutex> lk(cv_m); std::unique_lock<std::mutex> lk(cv_m);
CPPUNIT_ASSERT(cv.wait_for(lk, 12s, [&]{ return done == 2; })); CPPUNIT_ASSERT(cv.wait_for(lk, 30s, [&]{ return done == 2u; }));
node1.join(); node1.join();
node2.join(); node2.join();
} }
void void
DhtRunnerTester::testConstructors() { DhtRunnerTester::testConstructors() {
CPPUNIT_ASSERT(node1.getBoundPort() == 42222); CPPUNIT_ASSERT(node1.getBoundPort());
CPPUNIT_ASSERT(node2.getBoundPort() == 42232); CPPUNIT_ASSERT_EQUAL(node1.getBoundPort(), node1.getBound().getPort());
CPPUNIT_ASSERT(node2.getBoundPort());
CPPUNIT_ASSERT_EQUAL(node2.getBoundPort(), node2.getBound().getPort());
dht::DhtRunner::Config config {}; dht::DhtRunner::Config config {};
dht::DhtRunner::Context context {}; dht::DhtRunner::Context context {};
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment