fix: signal apply fiber to exit after mark install status

dtprj · Dec 6, 2024 · 235cc89 · 235cc89
1 parent 31c6c67
commit 235cc89
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/rpc/AppendProcessor.java b/server/src/main/java/com/github/dtprj/dongting/raft/rpc/AppendProcessor.java
@@ -490,6 +490,7 @@ private FrameCallResult startInstall(RaftStatusImpl raftStatus) {
         }
         log.info("start install snapshot, groupId={}", groupId);
         raftStatus.setInstallSnapshot(true);
+        gc.getApplyManager().apply(); // signal apply fiber to exit
         gc.getStatusManager().persistAsync(true);
         return gc.getStatusManager().waitUpdateFinish(this::afterStatusPersist);
     }