[pulsar] 42/46: [Broker] Make Persistent*DispatcherMultipleConsumers.readMoreEntries synchronized (#10413)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch 2.7.2_ds_tmp
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 83d10a140f220626eaa5360a62d4b78bacb63e1c
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Wed Apr 28 19:57:54 2021 +0300

    [Broker] Make Persistent*DispatcherMultipleConsumers.readMoreEntries 
synchronized (#10413)
    
    (cherry picked from commit 55867f1ea3e3288b8f43c8c5b35418a545b16b29)
---
 .../persistent/PersistentStreamingDispatcherMultipleConsumers.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
index 9340e17..a080e62 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
@@ -135,7 +135,7 @@ public class PersistentStreamingDispatcherMultipleConsumers 
extends PersistentDi
     }
 
     @Override
-    public void readMoreEntries() {
+    public synchronized void readMoreEntries() {
         // totalAvailablePermits may be updated by other threads
         int currentTotalAvailablePermits = totalAvailablePermits;
         if (currentTotalAvailablePermits > 0 && 
isAtleastOneConsumerAvailable()) {