[Java] Poll Archive only if NULL_VALUE == liveLogReplaySessionId.

nbradac · Aug 23, 2024 · 7f66094 · 7f66094
1 parent 0970140
commit 7f66094
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackupAgent.java b/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackupAgent.java
@@ -841,10 +841,13 @@ private int liveLogReplay(final long nowMs)
                     workCount++;
                 }
             }
-            else if (pollForResponse(clusterArchive, correlationId))
+            else if (NULL_VALUE == liveLogReplaySessionId)
             {
-                liveLogReplaySessionId = clusterArchive.controlResponsePoller().relevantId();
-                timeOfLastProgressMs = nowMs;
+                if (pollForResponse(clusterArchive, correlationId))
+                {
+                    liveLogReplaySessionId = clusterArchive.controlResponsePoller().relevantId();
+                    timeOfLastProgressMs = nowMs;
+                }
             }
             else if (NULL_COUNTER_ID == liveLogRecCounterId)
             {
@@ -858,7 +861,6 @@ else if (NULL_COUNTER_ID == liveLogRecCounterId)
                     liveLogRecordingId = RecordingPos.getRecordingId(countersReader, liveLogRecCounterId);
                     timeOfLastBackupQueryMs = nowMs;
                     timeOfLastProgressMs = nowMs;
-
                     state(UPDATE_RECORDING_LOG, nowMs);
                 }
             }