}
SECTION("dead servers") {
- MemcachedCluster test{Cluster{vector<Server>{Server{MEMCACHED_BINARY, {"-p", random_port_string("-p")}}}}};
+ MemcachedCluster test{Cluster{Server{MEMCACHED_BINARY, {"-p", random_port_string("-p")}}, 1}};
auto memc = &test.memc;
REQUIRE_SUCCESS(memcached_set(memc, S("foo"), nullptr, 0, 0, 0));
memcached_quit(memc);
- test.cluster.stop(
-#if __FreeBSD__
- true // graceful
-#endif
- );
+ test.cluster.stop();
Retry cluster_is_stopped{[&cluster = test.cluster]{
return cluster.isStopped();
}};
REQUIRE_RC(MEMCACHED_SERVER_TEMPORARILY_DISABLED, memcached_set(memc, S("foo"), nullptr, 0, 0, 0));
REQUIRE(test.cluster.start());
- REQUIRE(test.isListening());
+ REQUIRE(test.cluster.ensureListening());
Retry recovers{[memc]{
return MEMCACHED_SUCCESS == memcached_set(memc, S("foo"), nullptr, 0, 0, 0);