From f2279a32d3187f3903437f1d6fdd6639a0d13b2b Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 30 Apr 2014 12:43:41 +0000
Subject: [PATCH] OPENDJ-1430 Some changes are missing from the external changelog
---
opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 59 -----------------------------------------------------------
1 files changed, 0 insertions(+), 59 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java b/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
index 456f68c..1d68ab0 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -2461,65 +2461,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 (logger.isTraceEnabled())
- {
- debug("serverId=" + serverId
- + " is not considered for eligibility ... potentially down");
- }
- continue;
- }
-
- if (eligibleCSN == null || lastAliveCSN.isNewerThan(eligibleCSN))
- {
- eligibleCSN = lastAliveCSN;
- }
- }
-
- if (logger.isTraceEnabled())
- {
- 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