diff --git a/test/raft/replication_test.cc b/test/raft/replication_test.cc index 4fa3da4094..cfaad5516b 100644 --- a/test/raft/replication_test.cc +++ b/test/raft/replication_test.cc @@ -130,9 +130,10 @@ public: virtual future<> abort() { return make_ready_future<>(); } }; +std::unordered_set SERVER_DISCONNECTED; class failure_detector : public raft::failure_detector { bool is_alive(raft::server_id server) override { - return true; + return SERVER_DISCONNECTED.find(server) == SERVER_DISCONNECTED.end(); } };