From 298372e2f7a605c4e8afe7cd6e7f61025b28db3e Mon Sep 17 00:00:00 2001
From: Jean-Noël Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 30 Nov 2015 16:48:55 +0000
Subject: [PATCH] FileChangelogDB.java: Renamed "changelog DB purger" thread to "Changelog DB purger" to get proper ordering in UIs.
---
opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java | 25 ++-----------------------
1 files changed, 2 insertions(+), 23 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
index e3f71df..e12c77e 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
@@ -69,12 +69,9 @@
import org.opends.server.util.StaticUtils;
import org.opends.server.util.TimeThread;
-/**
- * Log file implementation of the ChangelogDB interface.
- */
+/** Log file implementation of the ChangelogDB interface. */
public class FileChangelogDB implements ChangelogDB, ReplicationDomainDB
{
-
private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass();
/**
@@ -286,7 +283,6 @@
}
}
- /** {@inheritDoc} */
@Override
public void initializeDB()
{
@@ -336,7 +332,6 @@
}
}
- /** {@inheritDoc} */
@Override
public void shutdownDB() throws ChangelogException
{
@@ -479,7 +474,6 @@
}
}
- /** {@inheritDoc} */
@Override
public void removeDB() throws ChangelogException
{
@@ -487,7 +481,6 @@
StaticUtils.recursiveDelete(dbDirectory);
}
- /** {@inheritDoc} */
@Override
public ServerState getDomainOldestCSNs(DN baseDN)
{
@@ -499,7 +492,6 @@
return result;
}
- /** {@inheritDoc} */
@Override
public ServerState getDomainNewestCSNs(DN baseDN)
{
@@ -511,7 +503,6 @@
return result;
}
- /** {@inheritDoc} */
@Override
public void removeDomain(DN baseDN) throws ChangelogException
{
@@ -571,7 +562,6 @@
}
}
- /** {@inheritDoc} */
@Override
public void setPurgeDelay(final long purgeDelayInMillis)
{
@@ -614,7 +604,6 @@
}
}
- /** {@inheritDoc} */
@Override
public void setComputeChangeNumber(final boolean computeChangeNumber)
throws ChangelogException
@@ -692,14 +681,12 @@
}
}
- /** {@inheritDoc} */
@Override
public ReplicationDomainDB getReplicationDomainDB()
{
return this;
}
- /** {@inheritDoc} */
@Override
public MultiDomainDBCursor getCursorFrom(final MultiDomainServerState startState, CursorOptions options)
throws ChangelogException
@@ -708,7 +695,6 @@
return getCursorFrom(startState, options, excludedDomainDns);
}
- /** {@inheritDoc} */
@Override
public MultiDomainDBCursor getCursorFrom(final MultiDomainServerState startState,
CursorOptions options, final Set<DN> excludedDomainDns) throws ChangelogException
@@ -725,7 +711,6 @@
return cursor;
}
- /** {@inheritDoc} */
@Override
public DBCursor<UpdateMsg> getCursorFrom(final DN baseDN, final ServerState startState, CursorOptions options)
throws ChangelogException
@@ -796,7 +781,6 @@
cursors.add(cursor);
}
- /** {@inheritDoc} */
@Override
public void unregisterCursor(final DBCursor<?> cursor)
{
@@ -824,7 +808,6 @@
}
}
- /** {@inheritDoc} */
@Override
public boolean publishUpdateMsg(final DN baseDN, final UpdateMsg updateMsg) throws ChangelogException
{
@@ -845,7 +828,6 @@
return pair.getSecond(); // replica DB was created
}
- /** {@inheritDoc} */
@Override
public void replicaHeartbeat(final DN baseDN, final CSN heartbeatCSN) throws ChangelogException
{
@@ -867,7 +849,6 @@
updateCursorsWithOfflineCSN(baseDN, serverId, null);
}
- /** {@inheritDoc} */
@Override
public void notifyReplicaOffline(final DN baseDN, final CSN offlineCSN) throws ChangelogException
{
@@ -909,10 +890,9 @@
protected ChangelogDBPurger()
{
- super("changelog DB purger");
+ super("Changelog DB purger");
}
- /** {@inheritDoc} */
@Override
public void run()
{
@@ -1011,7 +991,6 @@
return DEFAULT_SLEEP;
}
- /** {@inheritDoc} */
@Override
public void initiateShutdown()
{
--
Gitblit v1.10.0