diff --git a/src/v/raft/prevote_stm.cc b/src/v/raft/prevote_stm.cc index 896c34dea253..a0d13e123d46 100644 --- a/src/v/raft/prevote_stm.cc +++ b/src/v/raft/prevote_stm.cc @@ -163,13 +163,8 @@ ss::future prevote_stm::do_prevote() { // dispatch requests to all voters _config->for_each_voter([this](vnode id) { (void)dispatch_prevote(id); }); - // wait until majority - const size_t majority = (_config->unique_voter_count() / 2) + 1; - - return _sem.wait(majority) - .then([this] { return process_replies(); }) - // process results - .then([this]() { return _success; }); + // process results + return process_replies().then([this]() { return _success; }); } ss::future<> prevote_stm::process_replies() { diff --git a/src/v/raft/vote_stm.cc b/src/v/raft/vote_stm.cc index 8c6511fc7e30..7052bd098823 100644 --- a/src/v/raft/vote_stm.cc +++ b/src/v/raft/vote_stm.cc @@ -144,18 +144,11 @@ ss::future<> vote_stm::do_vote() { // dispatch requests to all voters _config->for_each_voter([this](vnode id) { (void)dispatch_one(id); }); - // wait until majority - const size_t majority = (_config->unique_voter_count() / 2) + 1; - - return _sem.wait(majority) - .then([this] { return process_replies(); }) - // porcess results - .then([this]() { - return _ptr->_op_lock.get_units().then( - [this](ss::semaphore_units<> u) { - return update_vote_state(std::move(u)); - }); - }); + return process_replies().then([this]() { + return _ptr->_op_lock.get_units().then([this](ss::semaphore_units<> u) { + return update_vote_state(std::move(u)); + }); + }); } ss::future<> vote_stm::process_replies() {