From 57a633bda328d5618bdf4fc58dde73083f61e2c4 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 10 Jul 2014 15:29:00 +0000
Subject: [PATCH] FileChangelogDB.java, JEChangelogDB.java: Synchronized the two files for easier code identification. Code is really too much duplicated between the two implementations.
---
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java | 78 +++++++++++++++++---------------------
1 files changed, 35 insertions(+), 43 deletions(-)
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
index 32c0c08..0d98801 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
+++ b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -75,8 +75,7 @@
* concurrent shutdown.
*/
private final ConcurrentMap<DN, ConcurrentMap<Integer, JEReplicaDB>>
- domainToReplicaDBs =
- new ConcurrentHashMap<DN, ConcurrentMap<Integer, JEReplicaDB>>();
+ domainToReplicaDBs = new ConcurrentHashMap<DN, ConcurrentMap<Integer, JEReplicaDB>>();
private ReplicationDbEnv dbEnv;
private ReplicationServerCfg config;
private final File dbDirectory;
@@ -88,8 +87,7 @@
* @GuardedBy("cnIndexDBLock")
*/
private JEChangeNumberIndexDB cnIndexDB;
- private final AtomicReference<ChangeNumberIndexer> cnIndexer =
- new AtomicReference<ChangeNumberIndexer>();
+ private final AtomicReference<ChangeNumberIndexer> cnIndexer = new AtomicReference<ChangeNumberIndexer>();
/** Used for protecting {@link ChangeNumberIndexDB} related state. */
private final Object cnIndexDBLock = new Object();
@@ -99,8 +97,7 @@
* older than this delay might be removed.
*/
private long purgeDelayInMillis;
- private final AtomicReference<ChangelogDBPurger> cnPurger =
- new AtomicReference<ChangelogDBPurger>();
+ private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>();
private volatile long latestPurgeDate;
/** The local replication server. */
@@ -157,7 +154,7 @@
private File makeDir(String dbDirName) throws ConfigException
{
// Check that this path exists or create it.
- File dbDirectory = getFileForPath(dbDirName);
+ final File dbDirectory = getFileForPath(dbDirName);
try
{
if (!dbDirectory.exists())
@@ -217,7 +214,7 @@
* the baseDN for which to create a ReplicaDB
* @param serverId
* the serverId for which to create a ReplicaDB
- * @param rs
+ * @param server
* the ReplicationServer
* @return a Pair with the JEReplicaDB and a boolean indicating whether it had
* to be created
@@ -225,14 +222,14 @@
* if a problem occurred with the database
*/
Pair<JEReplicaDB, Boolean> getOrCreateReplicaDB(DN baseDN,
- int serverId, ReplicationServer rs) throws ChangelogException
+ int serverId, ReplicationServer server) throws ChangelogException
{
while (!shutdown.get())
{
final ConcurrentMap<Integer, JEReplicaDB> domainMap =
getExistingOrNewDomainMap(baseDN);
final Pair<JEReplicaDB, Boolean> result =
- getExistingOrNewReplicaDB(domainMap, serverId, baseDN, rs);
+ getExistingOrNewReplicaDB(domainMap, serverId, baseDN, server);
if (result != null)
{
return result;
@@ -270,7 +267,7 @@
private Pair<JEReplicaDB, Boolean> getExistingOrNewReplicaDB(
final ConcurrentMap<Integer, JEReplicaDB> domainMap, int serverId,
- DN baseDN, ReplicationServer rs) throws ChangelogException
+ DN baseDN, ReplicationServer server) throws ChangelogException
{
// happy path: the JEReplicaDB already exists
JEReplicaDB currentValue = domainMap.get(serverId);
@@ -292,16 +289,16 @@
if (domainToReplicaDBs.get(baseDN) != domainMap)
{
- // the domainMap could have been concurrently removed because
+ // The domainMap could have been concurrently removed because
// 1) a shutdown was initiated or 2) an initialize was called.
// Return will allow the code to:
// 1) shutdown properly or 2) lazily recreate the JEReplicaDB
return null;
}
- final JEReplicaDB newValue = new JEReplicaDB(serverId, baseDN, rs, dbEnv);
- domainMap.put(serverId, newValue);
- return Pair.of(newValue, true);
+ final JEReplicaDB newDB = new JEReplicaDB(serverId, baseDN, server, dbEnv);
+ domainMap.put(serverId, newDB);
+ return Pair.of(newDB, true);
}
}
@@ -314,7 +311,7 @@
final File dbDir = getFileForPath(config.getReplicationDBDirectory());
dbEnv = new ReplicationDbEnv(dbDir.getAbsolutePath(), replicationServer);
final ChangelogState changelogState = dbEnv.readChangelogState();
- initializeChangelogState(changelogState);
+ initializeToChangelogState(changelogState);
if (config.isComputeChangeNumber())
{
startIndexer(changelogState);
@@ -329,17 +326,14 @@
}
}
- private void initializeChangelogState(final ChangelogState changelogState)
+ private void initializeToChangelogState(final ChangelogState changelogState)
throws ChangelogException
{
- for (Map.Entry<DN, Long> entry :
- changelogState.getDomainToGenerationId().entrySet())
+ for (Map.Entry<DN, Long> entry : changelogState.getDomainToGenerationId().entrySet())
{
- replicationServer.getReplicationServerDomain(entry.getKey(), true)
- .initGenerationID(entry.getValue());
+ replicationServer.getReplicationServerDomain(entry.getKey(), true).initGenerationID(entry.getValue());
}
- for (Map.Entry<DN, List<Integer>> entry :
- changelogState.getDomainToServerIds().entrySet())
+ for (Map.Entry<DN, List<Integer>> entry : changelogState.getDomainToServerIds().entrySet())
{
for (int serverId : entry.getValue())
{
@@ -482,7 +476,10 @@
{
firstException = e;
}
- else logger.traceException(e);
+ else
+ {
+ logger.traceException(e);
+ }
}
cnIndexDB = null;
@@ -608,7 +605,7 @@
/** {@inheritDoc} */
@Override
- public void setPurgeDelay(long purgeDelayInMillis)
+ public void setPurgeDelay(final long purgeDelayInMillis)
{
this.purgeDelayInMillis = purgeDelayInMillis;
final ChangelogDBPurger purger;
@@ -632,7 +629,7 @@
/** {@inheritDoc} */
@Override
- public void setComputeChangeNumber(boolean computeChangeNumber)
+ public void setComputeChangeNumber(final boolean computeChangeNumber)
throws ChangelogException
{
if (computeChangeNumber)
@@ -651,8 +648,7 @@
private void startIndexer(final ChangelogState changelogState)
{
- final ChangeNumberIndexer indexer =
- new ChangeNumberIndexer(this, changelogState);
+ final ChangeNumberIndexer indexer = new ChangeNumberIndexer(this, changelogState);
if (cnIndexer.compareAndSet(null, indexer))
{
indexer.start();
@@ -661,7 +657,7 @@
/** {@inheritDoc} */
@Override
- public long getDomainLatestTrimDate(DN baseDN)
+ public long getDomainLatestTrimDate(final DN baseDN)
{
return latestPurgeDate;
}
@@ -697,17 +693,15 @@
/** {@inheritDoc} */
@Override
- public DBCursor<UpdateMsg> getCursorFrom(DN baseDN,
- ServerState startAfterServerState) throws ChangelogException
+ public DBCursor<UpdateMsg> getCursorFrom(final DN baseDN, final ServerState startAfterServerState)
+ throws ChangelogException
{
final Set<Integer> serverIds = getDomainMap(baseDN).keySet();
- final Map<DBCursor<UpdateMsg>, Void> cursors =
- new HashMap<DBCursor<UpdateMsg>, Void>(serverIds.size());
+ final Map<DBCursor<UpdateMsg>, Void> cursors = new HashMap<DBCursor<UpdateMsg>, Void>(serverIds.size());
for (int serverId : serverIds)
{
// get the last already sent CSN from that server to get a cursor
- final CSN lastCSN = startAfterServerState != null ?
- startAfterServerState.getCSN(serverId) : null;
+ final CSN lastCSN = startAfterServerState != null ? startAfterServerState.getCSN(serverId) : null;
cursors.put(getCursorFrom(baseDN, serverId, lastCSN), null);
}
// recycle exhausted cursors,
@@ -717,8 +711,8 @@
/** {@inheritDoc} */
@Override
- public DBCursor<UpdateMsg> getCursorFrom(DN baseDN, int serverId,
- CSN startAfterCSN) throws ChangelogException
+ public DBCursor<UpdateMsg> getCursorFrom(final DN baseDN, final int serverId, final CSN startAfterCSN)
+ throws ChangelogException
{
JEReplicaDB replicaDB = getReplicaDB(baseDN, serverId);
if (replicaDB != null)
@@ -751,7 +745,7 @@
/** {@inheritDoc} */
@Override
- public void replicaHeartbeat(DN baseDN, CSN heartbeatCSN)
+ public void replicaHeartbeat(final DN baseDN, final CSN heartbeatCSN) throws ChangelogException
{
final ChangeNumberIndexer indexer = cnIndexer.get();
if (indexer != null)
@@ -762,8 +756,7 @@
/** {@inheritDoc} */
@Override
- public void replicaOffline(DN baseDN, CSN offlineCSN)
- throws ChangelogException
+ public void replicaOffline(final DN baseDN, final CSN offlineCSN) throws ChangelogException
{
dbEnv.addOfflineReplica(baseDN, offlineCSN);
final ChangeNumberIndexer indexer = cnIndexer.get();
@@ -775,7 +768,7 @@
/**
* The thread purging the changelogDB on a regular interval. Records are
- * purged from the changelogDB is they are older than a delay specified in
+ * purged from the changelogDB if they are older than a delay specified in
* seconds. The purge process works in two steps:
* <ol>
* <li>first purge the changeNumberIndexDB and retrieve information to drive
@@ -836,8 +829,7 @@
}
}
- for (final Map<Integer, JEReplicaDB> domainMap
- : domainToReplicaDBs.values())
+ for (final Map<Integer, JEReplicaDB> domainMap : domainToReplicaDBs.values())
{
for (final JEReplicaDB replicaDB : domainMap.values())
{
--
Gitblit v1.10.0