You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/10/04 11:28:39 UTC
(pulsar) 08/09: [fix][broker] Cancel possible pending replay read in cancelPendingRead (#23384)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0c6abe0f3233a8ca68d26e53c01ebe5f7b2931e2
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Tue Oct 1 22:54:32 2024 +0300
[fix][broker] Cancel possible pending replay read in cancelPendingRead (#23384)
(cherry picked from commit d2c91b1e1a8fc2fb233eb2856ddb6f53511ba201)
---
.../service/persistent/PersistentDispatcherMultipleConsumers.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
index 2983639c76a..07178cd9612 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -600,8 +600,9 @@ public class PersistentDispatcherMultipleConsumers extends AbstractDispatcherMul
@Override
protected void cancelPendingRead() {
- if (havePendingRead && cursor.cancelPendingReadRequest()) {
+ if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
havePendingRead = false;
+ havePendingReplayRead = false;
}
}