fix: log appender force issue

dtprj · Jun 25, 2024 · 04ed1cd · 04ed1cd
1 parent fce07b0
commit 04ed1cd
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/store/LogAppender.java b/server/src/main/java/com/github/dtprj/dongting/raft/store/LogAppender.java
@@ -485,12 +485,11 @@ public SyncFrame(WriteTask task, long perfStartTime, int count, long bytes) {
         @Override
         protected FrameCallResult afterForce(Void unused) {
             perfCallback.fireTime(PerfConsts.RAFT_D_LOG_SYNC, perfStartTime, count, bytes);
-            WriteTask head = syncTaskQueueHead;
-            if (head != null && head.lastIndex <= task.lastIndex) {
-                syncTaskQueueHead = head.nextNeedSyncTask;
-                raftStatus.setLastForceLogIndex(head.lastIndex);
-                raftStatus.getLogForceFinishCondition().signalAll();
+            while (syncTaskQueueHead != null && syncTaskQueueHead.lastIndex <= task.lastIndex) {
+                raftStatus.setLastForceLogIndex(syncTaskQueueHead.lastIndex);
+                syncTaskQueueHead = syncTaskQueueHead.nextNeedSyncTask;
             }
+            raftStatus.getLogForceFinishCondition().signalAll();
             return Fiber.frameReturn();
         }
     }