From 6041a9d09480ec1eca6ff9b68776094f33742e98 Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Wed, 23 Sep 2020 11:21:16 -0400 Subject: [PATCH] Make exit conditions slightly more conservative. --- .../whispersystems/textsecuregcm/storage/MessagePersister.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java index 8f48bb476..369967cdb 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java @@ -92,7 +92,7 @@ public class MessagePersister implements Managed { } queuesPersisted += queuesToPersist.size(); - } while (queuesToPersist.size() == QUEUE_BATCH_LIMIT); + } while (queuesToPersist.size() >= QUEUE_BATCH_LIMIT); queueCountHistogram.update(queuesPersisted); }