From 13819a2e81db0422a7c8c186f838c7b243173170 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 03 Sep 2014 06:30:37 +0000
Subject: [PATCH] OPENDJ-1205 (CR-4428) Remove network layer from External ChangeLog implementation
---
opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java | 24 +-----------------------
1 files changed, 1 insertions(+), 23 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 aea82ec..6458bac 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
@@ -120,13 +120,12 @@
*/
private long purgeDelayInMillis;
private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>();
- private volatile long latestPurgeDate;
/** The local replication server. */
private final ReplicationServer replicationServer;
private final AtomicBoolean shutdown = new AtomicBoolean();
- static final DBCursor<UpdateMsg> EMPTY_CURSOR_REPLICA_DB =
+ private static final DBCursor<UpdateMsg> EMPTY_CURSOR_REPLICA_DB =
new FileReplicaDBCursor(new Log.EmptyLogCursor<CSN, UpdateMsg>(), null, AFTER_MATCHING_KEY);
/**
@@ -486,18 +485,6 @@
/** {@inheritDoc} */
@Override
- public ServerState getDomainOldestCSNs(DN baseDN)
- {
- final ServerState result = new ServerState();
- for (FileReplicaDB replicaDB : getDomainMap(baseDN).values())
- {
- result.update(replicaDB.getOldestCSN());
- }
- return result;
- }
-
- /** {@inheritDoc} */
- @Override
public ServerState getDomainNewestCSNs(DN baseDN)
{
final ServerState result = new ServerState();
@@ -622,13 +609,6 @@
/** {@inheritDoc} */
@Override
- public long getDomainLatestTrimDate(final DN baseDN)
- {
- return latestPurgeDate;
- }
-
- /** {@inheritDoc} */
- @Override
public ChangeNumberIndexDB getChangeNumberIndexDB()
{
synchronized (cnIndexDBLock)
@@ -927,8 +907,6 @@
}
}
- latestPurgeDate = purgeTimestamp;
-
jeFriendlySleep(computeSleepTimeUntilNextPurge(oldestNotPurgedCSN));
}
catch (InterruptedException e)
--
Gitblit v1.10.0