From 4ef1bf3f0289cb7a361407a09db7b696393cd371 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 14 Apr 2014 13:57:14 +0000
Subject: [PATCH] OPENDJ-1430 - Some changes are missing from the external changelog
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 59 -----------------------------------------------------------
1 files changed, 0 insertions(+), 59 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
index 67ffa6c..e2fddc1 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -2496,65 +2496,6 @@
return domainDB.getDomainOldestCSNs(baseDN);
}
- /**
- * Returns the eligible CSN for that domain - relies on the
- * ChangeTimeHeartbeat state.
- * <p>
- * For each DS, take the oldest CSN from the changetime heartbeat state and
- * from the changelog db last CSN. Can be null.
- *
- * @return the eligible CSN.
- */
- CSN getEligibleCSN()
- {
- CSN eligibleCSN = null;
- for (final CSN lastAliveCSN : domainDB.getDomainLastAliveCSNs(baseDN))
- {
- // Should it be considered for eligibility ?
- final int serverId = lastAliveCSN.getServerId();
- if (!isServerConnected(serverId))
- {
- if (debugEnabled())
- {
- debug("serverId=" + serverId
- + " is not considered for eligibility ... potentially down");
- }
- continue;
- }
-
- if (eligibleCSN == null || lastAliveCSN.isNewerThan(eligibleCSN))
- {
- eligibleCSN = lastAliveCSN;
- }
- }
-
- if (debugEnabled())
- {
- debug("getEligibleCSN() returns result =" + eligibleCSN);
- }
- return eligibleCSN;
- }
-
- private boolean isServerConnected(int serverId)
- {
- if (connectedDSs.containsKey(serverId))
- {
- return true;
- }
-
- // not directly connected
- for (ReplicationServerHandler rsHandler : connectedRSs.values())
- {
- if (rsHandler.isRemoteLDAPServer(serverId))
- {
- return true;
- }
- }
- return false;
- }
-
-
-
private void sendTopologyMsg(String type, ServerHandler handler,
TopologyMsg msg)
{
--
Gitblit v1.10.0