SECTION("starts and listens") {
REQUIRE(server.start().has_value());
-
- Retry server_is_listening{[&server] {
- return server.isListening();
- }};
- REQUIRE(server_is_listening());
+ REQUIRE(server.ensureListening());
+ REQUIRE(server.isListening());
+ REQUIRE(server.check());
SECTION("stops") {
SECTION("stopped") {
REQUIRE_FALSE(server.check());
+ REQUIRE_FALSE(server.isListening());
}
}
}
SECTION("starts and listens") {
REQUIRE(cluster.start());
-
- Retry cluster_is_listening{[&cluster] {
- return cluster.isListening();
- }};
- REQUIRE(cluster_is_listening());
+ REQUIRE(cluster.ensureListening());
+ REQUIRE(cluster.isListening());
SECTION("stops") {
SECTION("stopped") {
REQUIRE(cluster.isStopped());
+ REQUIRE_FALSE(cluster.isListening());
}
}
}
vector<Connection> conns;
conns.reserve(cluster.getServers().size());
for (const auto &server : cluster.getServers()) {
- REQUIRE(conns.emplace_back(Connection{server.getSocketOrPort()}).open());
+ CHECK_NOFAIL(conns.emplace_back(Connection{server.getSocketOrPort()}).open());
}
while (!conns.empty()) {
vector<Connection> again;