[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-19 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r950585748 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -99,7 +100,7 @@ private long getCutoffTime() { }

[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-16 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r946806761 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -99,7 +100,7 @@ private long getCutoffTime() { }

[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-14 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo

[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-14 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo

[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-14 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo

[GitHub] [pulsar] coderzc commented on a diff in pull request #17092: [improve][broker]: DelayedDeliveryTracker init and addMessage

2022-08-14 Thread GitBox
coderzc commented on code in PR #17092: URL: https://github.com/apache/pulsar/pull/17092#discussion_r945407900 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java: ## @@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo