[pulsar] branch branch-2.10 updated: [improve][broker] Added isActive in ManagedCursorImpl (#19341)

[xiangying]

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

xiangying pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new d1e4008ffc7 [improve][broker] Added isActive in ManagedCursorImpl 
(#19341)
d1e4008ffc7 is described below

commit d1e4008ffc7d11b4a4cebe6cc03a0b8b606336ac
Author: Heesung Sohn <103456639+heesung...@users.noreply.github.com>
AuthorDate: Sat Jan 28 08:37:13 2023 -0800

    [improve][broker] Added isActive in ManagedCursorImpl (#19341)
    
    (cherry picked from commit 96fb7dab7a1bc260d8ee3c9d5df15de6863ee15b)
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
 
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
index 409e273da46..09322382a46 100644
--- 
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
+++ 
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java
@@ -207,6 +207,9 @@ public class ManagedCursorImpl implements ManagedCursor {
     // active state cache in ManagedCursor. It should be in sync with the 
state in activeCursors in ManagedLedger.
     private volatile boolean isActive = false;
 
+    // active state cache in ManagedCursor. It should be in sync with the 
state in activeCursors in ManagedLedger.
+    private volatile boolean isActive = false;
+
     class MarkDeleteEntry {
         final PositionImpl newPosition;
         final MarkDeleteCallback callback;