X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=test%2Ftests%2Fmemcached%2Ferrors.cpp;h=377e14d1ba837f15c14a95cd799bc7341cc8160d;hb=0d7a3e0e040ddf840d656b61f41419c252debcde;hp=75ba019aba085c1adf457a64a715b3e29aa97888;hpb=2c43b7ea471c819c8e726eefccc39a469f6b9ae6;p=awesomized%2Flibmemcached diff --git a/test/tests/memcached/errors.cpp b/test/tests/memcached/errors.cpp index 75ba019a..377e14d1 100644 --- a/test/tests/memcached/errors.cpp +++ b/test/tests/memcached/errors.cpp @@ -17,7 +17,7 @@ TEST_CASE("memcached_errors") { } SECTION("dead servers") { - MemcachedCluster test{Cluster{vector{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)); @@ -41,10 +41,7 @@ TEST_CASE("memcached_errors") { REQUIRE_RC(MEMCACHED_SERVER_TEMPORARILY_DISABLED, memcached_set(memc, S("foo"), nullptr, 0, 0, 0)); REQUIRE(test.cluster.start()); - Retry cluster_is_listening{[&cluster = test.cluster] { - return cluster.isListening(); - }}; - REQUIRE(cluster_is_listening()); + REQUIRE(test.cluster.ensureListening()); Retry recovers{[memc]{ return MEMCACHED_SUCCESS == memcached_set(memc, S("foo"), nullptr, 0, 0, 0);