one place need to set bufferOverFlow_ = false

vesoft-inc · Apr 15, 2022 · b3f3779 · b3f3779
1 parent 1af0e37
commit b3f3779
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp
@@ -830,6 +830,7 @@ folly::Future<nebula::cpp2::ErrorCode> RaftPart::appendLogAsync(ClusterID source
   {
     std::lock_guard<std::mutex> lck(logsLock_);
     AppendLogsIteratorFactory::make(logs_, sendingLogs_);
+    bufferOverFlow_ = false;
     if (sendingLogs_.empty()) {
       replicatingLogs_ = false;
       return retFuture;