From 430819a095e15f8d97c56e99762503f861e94354 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 30 Apr 2014 19:57:56 +0000
Subject: [PATCH] OPENDJ-1454 Remove all code supporting "dc=replicationChanges"
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java | 49 -------------------------------------------------
1 files changed, 0 insertions(+), 49 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
index e23f4cb..f3507e0 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -520,19 +520,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)
@@ -724,16 +711,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
{
@@ -767,32 +744,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