- Retry cluster_is_listening([this]() {
- return cluster.isListening();
- });
- while (!cluster_is_listening()) {
- cluster.stop();
- cluster.wait();
- cluster.start();
+ while (!cluster.ensureListening()) {
+ cluster.restart();
+ }
+
+ if (auto br = getenv_else("MEMCACHED_BREAK", "0")) {
+ if (*br && *br != '0') {
+ string in;
+
+ cout << "Started servers:\n";
+ for (const auto &server : cluster.getServers()) {
+ cout << server.getPid() << " ";
+ }
+ cout << "\nPress ENTER to continue... " << ::flush;
+ cin.get();
+ }