[Java] Lag the cleaning by a term + window to allow for greater NAK r…

…ange.
pinghe · Jul 9, 2016 · 5800f5f · 5800f5f
1 parent 3352811
commit 5800f5f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java b/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java
@@ -308,7 +308,7 @@ int updatePublishersLimit()
 
         if (publisherLimit.proposeMaxOrdered(candidatePublisherLimit))
         {
-            cleanBuffer(candidatePublisherLimit);
+            cleanBuffer(candidatePublisherLimit - termWindowLength);
 
             workCount = 1;
         }