Improved handling coordinated omission

aeron-io · Jan 27, 2025 · 222569a · 222569a
1 parent 456fc19
commit 222569a
Showing 1 changed file with 14 additions and 7 deletions.
diff --git a/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/FailoverTestRig.java b/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/FailoverTestRig.java
@@ -237,17 +237,27 @@ private void runTest(final int durationSeconds, final int messageRate)
             }
 
             int workCount = 0;
+
             final long now = clock.nanoTime();
 
             if (moreToGenerate && now - nextMessageAt >= 0)
             {
                 generationTimestamps[freePosition++] = now;
 
-                workCount += trySend();
+                int trySend = trySend(nextMessageAt);
 
-                generatedMessages++;
-                nextMessageAt += periodNs;
+                if (trySend == 0)
+                {
+                    freePosition--;
+                }
+                else
+                {
+                    workCount += trySend;
+                    generatedMessages++;
+                    nextMessageAt += periodNs;
+                }
 
+                // todo: not sure what to do with this section.
                 if (now - nextMessageAt >= 0)
                 {
                     fallingBehindCount++;
@@ -256,8 +266,6 @@ private void runTest(final int durationSeconds, final int messageRate)
 
             workCount += transceiver.receive();
 
-            workCount += trySend();
-
             if (now - deadline >= 0)
             {
                 throw new RuntimeException("Timed out");
@@ -285,15 +293,14 @@ private void runTest(final int durationSeconds, final int messageRate)
         out.println("Stats: fallingBehindCount=" + fallingBehindCount);
     }
 
-    private int trySend()
+    private int trySend(final long timestamp)
     {
         if (!synced || sendPosition >= freePosition)
         {
             return 0;
         }
 
         final int sequence = sendPosition;
-        final long timestamp = generationTimestamps[sendPosition];
 
         if (transceiver.trySendEcho(sequence, timestamp))
         {