When the leader gracefully closes, the follower can re-enter the elec…

…tion more quickly, instead of waiting to detect the RecordingSignal.STOP signal in the slowTickWork method.
aeron-io · Jun 4, 2024 · 752e54c · 752e54c
1 parent 57376c8
commit 752e54c
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java b/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java
@@ -2227,10 +2227,13 @@ private int consensusWork(final long timestamp, final long nowNs)
                 {
                     final long limit = null != appendPosition ? appendPosition.get() : logRecordingStopPosition;
                     final int count = logAdapter.poll(Math.min(notifiedCommitPosition, limit));
-                    if (0 == count && logAdapter.isImageClosed())
+                    if (0 == count)
                     {
                         final boolean isEos = logAdapter.isLogEndOfStream();
-                        enterElection(isEos, "log disconnected from leader: eos=" + isEos);
+                        if(isEos || logAdapter.isImageClosed())
+                        {
+                            enterElection(isEos, "log disconnected from leader: eos=" + isEos);
+                        }
                         return 1;
                     }