From bd2387a7deba42a7a5d039f833a4e70f42015ea1 Mon Sep 17 00:00:00 2001
From: lhsoft <liuhuwork@gmail.com>
Date: Wed, 21 Feb 2024 14:22:55 +0800
Subject: [PATCH] sync log immediately when there is configuration

---
 src/braft/log.cpp | 11 ++++++++---
 src/braft/log.h   |  2 +-
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/braft/log.cpp b/src/braft/log.cpp
index b58b04a9..f2b8c27e 100644
--- a/src/braft/log.cpp
+++ b/src/braft/log.cpp
@@ -436,7 +436,7 @@ int Segment::append(const LogEntry* entry) {
     return 0;
 }
 
-int Segment::sync(bool will_sync) {
+int Segment::sync(bool will_sync, bool has_conf) {
     if (_last_index < _first_index) {
         return 0;
     }
@@ -446,7 +446,8 @@ int Segment::sync(bool will_sync) {
             return 0;
         }
         if (FLAGS_raft_sync_policy == RaftSyncPolicy::RAFT_SYNC_BY_BYTES
-            && FLAGS_raft_sync_per_bytes > _unsynced_bytes) {
+            && FLAGS_raft_sync_per_bytes > _unsynced_bytes
+            && !has_conf) {
             return 0;
         }
         _unsynced_bytes = 0;
@@ -737,6 +738,7 @@ int SegmentLogStorage::append_entries(const std::vector<LogEntry*>& entries, IOM
     scoped_refptr<Segment> last_segment = NULL;
     int64_t now = 0;
     int64_t delta_time_us = 0;
+    bool has_conf = false;
     for (size_t i = 0; i < entries.size(); i++) {
         now = butil::cpuwide_time_us();
         LogEntry* entry = entries[i];
@@ -754,6 +756,9 @@ int SegmentLogStorage::append_entries(const std::vector<LogEntry*>& entries, IOM
         if (0 != ret) {
             return i;
         }
+        if (entry->type == ENTRY_TYPE_CONFIGURATION) {
+            has_conf = true;
+        }
         if (FLAGS_raft_trace_append_entry_latency && metric) {
             delta_time_us = butil::cpuwide_time_us() - now;
             metric->append_entry_time_us += delta_time_us;
@@ -763,7 +768,7 @@ int SegmentLogStorage::append_entries(const std::vector<LogEntry*>& entries, IOM
         last_segment = segment;
     }
     now = butil::cpuwide_time_us();
-    last_segment->sync(_enable_sync);
+    last_segment->sync(_enable_sync, has_conf);
     if (FLAGS_raft_trace_append_entry_latency && metric) {
         delta_time_us = butil::cpuwide_time_us() - now;
         metric->sync_segment_time_us += delta_time_us;
diff --git a/src/braft/log.h b/src/braft/log.h
index a74017d6..145785ad 100644
--- a/src/braft/log.h
+++ b/src/braft/log.h
@@ -70,7 +70,7 @@ class BAIDU_CACHELINE_ALIGNMENT Segment
     int close(bool will_sync = true);
 
     // sync open segment
-    int sync(bool will_sync);
+    int sync(bool will_sync, bool has_conf = false);
 
     // unlink segment
     int unlink();