From 01eb7d07467b57c61868c73e9a94bff1d0b2dcd1 Mon Sep 17 00:00:00 2001
From: Nicolas Capponi <nicolas.capponi@forgerock.com>
Date: Wed, 21 May 2014 15:56:41 +0000
Subject: [PATCH] OPENDJ-1389 – Add support for replication changelog DB rotation
---
opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java b/opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
index e2b4f08..36e8a7a 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
@@ -49,13 +49,12 @@
import org.opends.server.types.DebugLogLevel;
import org.opends.server.util.StaticUtils;
import org.opends.server.util.TimeThread;
-
import com.forgerock.opendj.util.Pair;
-import static org.opends.messages.ReplicationMessages.*;
import static org.opends.server.loggers.ErrorLogger.*;
import static org.opends.server.loggers.debug.DebugLogger.*;
import static org.opends.server.util.StaticUtils.*;
+import static org.opends.messages.ReplicationMessages.*;
/**
* Log file implementation of the ChangelogDB interface.
@@ -106,10 +105,11 @@
/** The local replication server. */
private final ReplicationServer replicationServer;
+
private final AtomicBoolean shutdown = new AtomicBoolean();
static final DBCursor<UpdateMsg> EMPTY_CURSOR_REPLICA_DB =
- new FileReplicaDBCursor(new LogFile.EmptyLogCursor<CSN, UpdateMsg>(), null);
+ new FileReplicaDBCursor(new Log.EmptyLogCursor<CSN, UpdateMsg>(), null);
/**
* Creates a new changelog DB.
@@ -122,10 +122,10 @@
* if a problem occurs opening the supplied directory
*/
public FileChangelogDB(final ReplicationServer replicationServer, final ReplicationServerCfg config)
- throws ConfigException
+ throws ConfigException
{
- this.config = config;
this.replicationServer = replicationServer;
+ this.config = config;
this.dbDirectory = makeDir(config.getReplicationDBDirectory());
}
--
Gitblit v1.10.0