Skip to content

Commit cb0dfd7

Browse files
lhotarieolivelli
authored andcommitted
[ML] Fix solution for preventing race conditions between timeout and completion (apache#10740)
- solution was added in apache#4455 (cherry picked from commit 4372b49)
1 parent 063040d commit cb0dfd7

File tree

1 file changed

+1
-1
lines changed
  • managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl

1 file changed

+1
-1
lines changed

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,7 @@ private void updateLatency() {
232232
*/
233233
private boolean checkAndCompleteOp(Object ctx) {
234234
long addOpCount = (ctx instanceof Long) ? (long) ctx : -1;
235-
if (addOpCount != -1 && ADD_OP_COUNT_UPDATER.compareAndSet(this, this.addOpCount, -1)) {
235+
if (addOpCount != -1 && ADD_OP_COUNT_UPDATER.compareAndSet(this, addOpCount, -1)) {
236236
return true;
237237
}
238238
log.info("Add-entry already completed for {}-{}", ledger != null ? ledger.getId() : -1, entryId);

0 commit comments

Comments
 (0)