From 7486ef2bb077feb489a55db86707d96e69d12265 Mon Sep 17 00:00:00 2001
From: ludovicp <ludovicp@localhost>
Date: Fri, 30 Jul 2010 12:44:12 +0000
Subject: [PATCH] Implements a disk space thresholds feature, preventing the server from crashing or exiting of disks full.
---
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 39 ++++++++++++---------------------------
1 files changed, 12 insertions(+), 27 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
index e6200f6..848b5e6 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -199,8 +199,6 @@
public ReplicationServerDomain(
String baseDn, ReplicationServer replicationServer)
{
- super("Replication Server " + replicationServer.getReplicationPort() + " "
- + baseDn + " " + replicationServer.getServerId());
this.baseDn = baseDn;
this.replicationServer = replicationServer;
this.assuredTimeoutTimer = new Timer("Replication Assured Timer for " +
@@ -376,7 +374,9 @@
if ( (generationId>0) && (generationId != handler.getGenerationId()) )
{
if (debugEnabled())
- TRACER.debugInfo("In " + this.getName() +
+ TRACER.debugInfo("In " + "Replication Server " +
+ replicationServer.getReplicationPort() + " " +
+ baseDn + " " + replicationServer.getServerId() +
" for dn " + baseDn + ", update " +
update.getChangeNumber().toString() +
" will not be sent to replication server " +
@@ -3048,26 +3048,6 @@
* {@inheritDoc}
*/
@Override
- public long getUpdateInterval()
- {
- /* we don't wont to do polling on this monitor */
- return 0;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void updateMonitorData()
- {
- // As long as getUpdateInterval() returns 0, this will never get called
-
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
public ArrayList<Attribute> getMonitorData()
{
/*
@@ -3328,7 +3308,9 @@
if (!sidConnected)
{
if (debugEnabled())
- TRACER.debugInfo("In " + this.getName() +
+ TRACER.debugInfo("In " + "Replication Server " +
+ replicationServer.getReplicationPort() + " " +
+ baseDn + " " + replicationServer.getServerId() +
" Server " + sid
+ " is not considered for eligibility ... potentially down");
continue;
@@ -3352,8 +3334,9 @@
if (debugEnabled())
TRACER.debugInfo(
- "In " + this.getName() + " getEligibleCN() returns result ="
- + eligibleCN);
+ "In " + "Replication Server " + replicationServer.getReplicationPort() +
+ " " + baseDn + " " + replicationServer.getServerId() +
+ " getEligibleCN() returns result =" + eligibleCN);
return eligibleCN;
}
@@ -3396,7 +3379,9 @@
} catch (IOException e)
{
TRACER.debugCaught(DebugLogLevel.ERROR, e);
- logError(ERR_CHANGELOG_ERROR_SENDING_MSG.get(rsHandler.getName()));
+ logError(ERR_CHANGELOG_ERROR_SENDING_MSG.get(
+ "Replication Server " + replicationServer.getReplicationPort() +
+ " " + baseDn + " " + replicationServer.getServerId()));
stopServer(rsHandler, false);
}
}
--
Gitblit v1.10.0