Skip to content

Commit 9b562dc

Browse files
author
fanjianye
committed
change comment
1 parent ca48bb3 commit 9b562dc

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/InMemoryDeliveryTrackerTest.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,8 @@ public void testDelayedMessagesCountWithDuplicateEntryId(InMemoryDelayedDelivery
279279
assertFalse(tracker.hasMessageAvailable());
280280

281281
// case1: addMessage() with duplicate entryId,
282-
// getScheduledMessages() enter "cardinality <= n" and make tracker empty
282+
// getScheduledMessages() enter multiple timestamp and "cardinality <= n",
283+
// finally make tracker empty
283284
assertTrue(tracker.addMessage(1, 1, 10));
284285
assertTrue(tracker.addMessage(1, 2, 20));
285286
assertTrue(tracker.addMessage(1, 2, 20));
@@ -298,7 +299,8 @@ public void testDelayedMessagesCountWithDuplicateEntryId(InMemoryDelayedDelivery
298299

299300

300301
// case2: addMessage() with duplicate entryId,
301-
// getScheduledMessages() enter "cardinality > n" and make tracker empty
302+
// getScheduledMessages() enter one timestamp and "cardinality <= n",
303+
// finally make tracker empty
302304
clockTime.set(0);
303305
assertTrue(tracker.addMessage(1, 1, 10));
304306
assertTrue(tracker.addMessage(1, 2, 10));
@@ -318,7 +320,8 @@ public void testDelayedMessagesCountWithDuplicateEntryId(InMemoryDelayedDelivery
318320

319321

320322
// case3: addMessage() with duplicate entryId,
321-
// getScheduledMessages() make tracker remain half cardinality
323+
// getScheduledMessages() enter one timestamp and "cardinality > n",
324+
// finally make tracker remain half cardinality
322325
clockTime.set(0);
323326
assertTrue(tracker.addMessage(1, 1, 10));
324327
assertTrue(tracker.addMessage(1, 2, 10));

0 commit comments

Comments
 (0)