election don't wait forever

vesoft-inc · Oct 29, 2021 · 65c2997 · 65c2997
1 parent 925a2b1
commit 65c2997
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp
@@ -1111,7 +1111,11 @@ bool RaftPart::leaderElection() {
     VLOG(2) << idStr_
             << "AskForVoteRequest has been sent to all peers"
                ", waiting for responses";
-    futures.wait();
+    futures.wait(std::chrono::seconds(FLAGS_raft_heartbeat_interval_secs));
+    if (futures.hasException()) {
+      LOG(INFO) << idStr_ << "Election timeout";
+      return false;
+    }
     CHECK(!futures.hasException())
         << "Got exception -- " << futures.result().exception().what().toStdString();
     VLOG(2) << idStr_ << "Got AskForVote response back";