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 10:39:37 UTC
(pulsar) 03/04: [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.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b940c0f78542a5ed64eb325d89d5c626cd02a832
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 ae844b57844..9e8483be1a7 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
@@ -553,8 +553,9 @@ public class PersistentDispatcherMultipleConsumers extends AbstractDispatcherMul
@Override
protected void cancelPendingRead() {
- if (havePendingRead && cursor.cancelPendingReadRequest()) {
+ if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) {
havePendingRead = false;
+ havePendingReplayRead = false;
}
}