From 2c42b045d1252cff94230d995615de4bad3b9d4f Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Tue, 09 Jan 2007 09:10:55 +0000
Subject: [PATCH] Use AtomicInteger instead of synchronized blocks in one case when incrementing a monitor counter.
---
opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java | 10 ++++------
1 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java b/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
index cb6440f..825ab82 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
@@ -40,6 +40,7 @@
import java.util.List;
import java.util.SortedMap;
import java.util.TreeMap;
+import java.util.concurrent.atomic.AtomicInteger;
import java.util.zip.DataFormatException;
import org.opends.server.api.ConfigurableComponent;
@@ -112,7 +113,7 @@
new TreeMap<ChangeNumber, UpdateMessage>();
private int numRcvdUpdates = 0;
private int numSentUpdates = 0;
- private int numProcessedUpdates = 0;
+ private AtomicInteger numProcessedUpdates = new AtomicInteger();
private int debugCount = 0;
private PersistentServerState state;
private int numReplayedPostOpCalled = 0;
@@ -921,10 +922,7 @@
*/
public void incProcessedUpdates()
{
- synchronized (this)
- {
- numProcessedUpdates++;
- }
+ numProcessedUpdates.incrementAndGet();
}
/**
@@ -934,7 +932,7 @@
*/
public int getNumProcessedUpdates()
{
- return numProcessedUpdates;
+ return numProcessedUpdates.get();
}
/**
--
Gitblit v1.10.0