From 9e64ce25287ad023bfa47b17cddd870f990d1eb8 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Tue, 19 Jun 2012 08:51:36 +0000
Subject: [PATCH] Initial cleanup for OPENDJ-506: NoSuchElementException thrown during replication in java.util.TreeMap.key(TreeMap.java:1221)
---
opends/src/server/org/opends/server/replication/server/ServerHandler.java | 39 ++-------------------------------------
1 files changed, 2 insertions(+), 37 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ServerHandler.java b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
index c3e2b86..0b58e05 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
@@ -23,7 +23,7 @@
*
*
* Copyright 2006-2010 Sun Microsystems, Inc.
- * Portions copyright 2011 ForgeRock AS
+ * Portions copyright 2011-2012 ForgeRock AS
*/
package org.opends.server.replication.server;
@@ -72,7 +72,6 @@
import org.opends.server.types.DirectoryException;
import org.opends.server.types.InitializationException;
import org.opends.server.types.ResultCode;
-import org.opends.server.util.TimeThread;
/**
* This class defines a server handler :
@@ -410,28 +409,6 @@
}
/**
- * Get an approximation of the delay by looking at the age of the oldest
- * message that has not been sent to this server.
- * This is an approximation because the age is calculated using the
- * clock of the server where the replicationServer is currently running
- * while it should be calculated using the clock of the server
- * that originally processed the change.
- *
- * The approximation error is therefore the time difference between
- *
- * @return the approximate delay for the connected server.
- */
- public long getApproxDelay()
- {
- long olderUpdateTime = getOlderUpdateTime();
- if (olderUpdateTime == 0)
- return 0;
-
- long currentTime = TimeThread.getTime();
- return ((currentTime - olderUpdateTime) / 1000);
- }
-
- /**
* Get the age of the older change that has not yet been replicated
* to the server handled by this ServerHandler.
* @return The age if the older change has not yet been replicated
@@ -661,18 +638,6 @@
public abstract String getMonitorInstanceName();
/**
- * Get the older update time for that server.
- * @return The older update time.
- */
- public long getOlderUpdateTime()
- {
- ChangeNumber olderUpdateCN = getOlderUpdateCN();
- if (olderUpdateCN == null)
- return 0;
- return olderUpdateCN.getTime();
- }
-
- /**
* Get the count of updates sent to this server.
* @return The count of update sent to this server.
*/
@@ -1144,7 +1109,7 @@
public UpdateMsg take()
{
boolean interrupted = true;
- UpdateMsg msg = getnextMessage(true); // synchronous:block until msg
+ UpdateMsg msg = getNextMessage(true); // synchronous:block until msg
boolean acquired = false;
do
--
Gitblit v1.10.0