[pulsar] 02/03: [ML] Fix solution for preventing race conditions between timeout and completion (#10740)

[lh...@apache.org]

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

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

commit 4372b491c806b6dbd7b98b23ecaca1decfdac5f1
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Fri May 28 22:25:38 2021 +0300

    [ML] Fix solution for preventing race conditions between timeout and completion (#10740)
    
    - solution was added in #4455
---
 .../src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
index 78ad312..37e9f35 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
@@ -230,7 +230,7 @@ class OpAddEntry extends SafeRunnable implements AddCallback, CloseCallback {
      */
     private boolean checkAndCompleteOp(Object ctx) {
         long addOpCount = (ctx instanceof Long) ? (long) ctx : -1;
-        if (addOpCount != -1 && ADD_OP_COUNT_UPDATER.compareAndSet(this, this.addOpCount, -1)) {
+        if (addOpCount != -1 && ADD_OP_COUNT_UPDATER.compareAndSet(this, addOpCount, -1)) {
             return true;
         }
         log.info("Add-entry already completed for {}-{}", ledger != null ? ledger.getId() : -1, entryId);