[Broker] Make Persistent*DispatcherMultipleConsumers.readMoreEntries …

…synchronized (apache#10413)
m00119022 · Apr 28, 2021 · 55867f1 · 55867f1
1 parent 9e8949b
commit 55867f1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -216,7 +216,7 @@ public synchronized void consumerFlow(Consumer consumer, int additionalNumberOfM
         readMoreEntries();
     }
 
-    public void readMoreEntries() {
+    public synchronized void readMoreEntries() {
         // totalAvailablePermits may be updated by other threads
         int currentTotalAvailablePermits = totalAvailablePermits;
         if (currentTotalAvailablePermits > 0 && isAtleastOneConsumerAvailable()) {

diff --git a/...ache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java b/...ache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
@@ -135,7 +135,7 @@ protected void cancelPendingRead() {
     }
 
     @Override
-    public void readMoreEntries() {
+    public synchronized void readMoreEntries() {
         // totalAvailablePermits may be updated by other threads
         int currentTotalAvailablePermits = totalAvailablePermits;
         if (currentTotalAvailablePermits > 0 && isAtleastOneConsumerAvailable()) {