From 473e684067fcf03dd99666e033f61541fa8c5e62 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 30 Apr 2014 20:38:20 +0000
Subject: [PATCH] OPENDJ-1454 Remove all code supporting "dc=replicationChanges"
---
opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java | 49 -------------------------------------------------
1 files changed, 0 insertions(+), 49 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java b/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
index 73813d7..6a5a11b 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -511,19 +511,6 @@
StaticUtils.recursiveDelete(dbDirectory);
}
-
- /** {@inheritDoc} */
- @Override
- public long getDomainChangesCount(DN baseDN)
- {
- long entryCount = 0;
- for (JEReplicaDB replicaDB : getDomainMap(baseDN).values())
- {
- entryCount += replicaDB.getChangesCount();
- }
- return entryCount;
- }
-
/** {@inheritDoc} */
@Override
public ServerState getDomainOldestCSNs(DN baseDN)
@@ -713,16 +700,6 @@
/** {@inheritDoc} */
@Override
- public DBCursor<UpdateMsg> getCursorFrom(DN baseDN, CSN startAfterCSN)
- throws ChangelogException
- {
- // Builds a new serverState for all the serverIds in the replication domain
- // to ensure we get cursors starting after the provided CSN.
- return getCursorFrom(baseDN, buildServerState(baseDN, startAfterCSN));
- }
-
- /** {@inheritDoc} */
- @Override
public DBCursor<UpdateMsg> getCursorFrom(DN baseDN,
ServerState startAfterServerState) throws ChangelogException
{
@@ -756,32 +733,6 @@
return EMPTY_CURSOR;
}
- private ServerState buildServerState(DN baseDN, CSN startAfterCSN)
- {
- final ServerState result = new ServerState();
- if (startAfterCSN == null)
- {
- return result;
- }
-
- for (int serverId : getDomainMap(baseDN).keySet())
- {
- if (serverId == startAfterCSN.getServerId())
- {
- // reuse the provided CSN one as it is the most accurate
- result.update(startAfterCSN);
- }
- else
- {
- // build a new CSN, ignoring the seqNum since it is irrelevant for
- // a different serverId
- final CSN csn = startAfterCSN; // only used for increased readability
- result.update(new CSN(csn.getTime(), 0, serverId));
- }
- }
- return result;
- }
-
/** {@inheritDoc} */
@Override
public boolean publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)
--
Gitblit v1.10.0