You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by yo...@apache.org on 2021/03/01 11:08:00 UTC
[pulsar] 04/08: BugFix : Use Atomic Field Updater to increment
volatile messagesConsumedCounter (#9656)
This is an automated email from the ASF dual-hosted git repository.
yong pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 08fbbcce600ee7fa8d1dfd025f3d837ef6c13204
Author: Ali Ahmed <al...@gmail.com>
AuthorDate: Mon Feb 22 04:41:12 2021 -0800
BugFix : Use Atomic Field Updater to increment volatile messagesConsumedCounter (#9656)
(cherry picked from commit 0e1ba28c77c0051fff340328e5adc4d8b1c101fa)
---
.../main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 3bfe45f..8e02b89 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
@@ -1895,7 +1895,7 @@ public class ManagedCursorImpl implements ManagedCursor {
PositionImpl previousPosition = ledger.getPreviousPosition(position);
individualDeletedMessages.addOpenClosed(previousPosition.getLedgerId(), previousPosition.getEntryId(),
position.getLedgerId(), position.getEntryId());
- ++messagesConsumedCounter;
+ MSG_CONSUMED_COUNTER_UPDATER.incrementAndGet(this);
BitSetRecyclable bitSetRecyclable = batchDeletedIndexes.remove(position);
if (bitSetRecyclable != null) {
bitSetRecyclable.recycle();