From 0a51f5fbeb5e99c52f1be8973ae656de34fab75f Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 14 Aug 2013 09:30:53 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/LightweightServerHandler.java | 43 +++++++++++++++++--------------------------
1 files changed, 17 insertions(+), 26 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/LightweightServerHandler.java b/opends/src/server/org/opends/server/replication/server/LightweightServerHandler.java
index 0157f44..9107b2d 100644
--- a/opends/src/server/org/opends/server/replication/server/LightweightServerHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/LightweightServerHandler.java
@@ -27,14 +27,7 @@
*/
package org.opends.server.replication.server;
-import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
-import static org.opends.server.loggers.debug.DebugLogger.getTracer;
-
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Set;
+import java.util.*;
import org.opends.server.admin.std.server.MonitorProviderCfg;
import org.opends.server.api.MonitorProvider;
@@ -50,6 +43,8 @@
import org.opends.server.types.Attributes;
import org.opends.server.types.InitializationException;
+import static org.opends.server.loggers.debug.DebugLogger.*;
+
/**
* This class defines a server handler dedicated to the remote LDAP servers
* connected to a remote Replication Server.
@@ -142,13 +137,15 @@
this.protocolVersion = protocolVersion;
if (debugEnabled())
- TRACER.debugInfo(
- "In " +
- replServerHandler.getDomain().getReplicationServer().getMonitorInstanceName()+
- " LWSH for remote server " + this.serverId +
- " connected to:" + this.replServerHandler.getMonitorInstanceName() +
- " ()");
-}
+ TRACER.debugInfo("In " + getLocalRSMonitorInstanceName()
+ + " LWSH for remote server " + this.serverId + " connected to:"
+ + this.replServerHandler.getMonitorInstanceName() + " ()");
+ }
+
+ private String getLocalRSMonitorInstanceName()
+ {
+ return rsDomain.getReplicationServer().getMonitorInstanceName();
+ }
/**
* Creates a DSInfo structure representing this remote DS.
@@ -176,15 +173,11 @@
public void startHandler()
{
if (debugEnabled())
- TRACER.debugInfo(
- "In " +
-replServerHandler.getDomain().getReplicationServer().getMonitorInstanceName() +
- " LWSH for remote server " + this.serverId +
- " connected to:" + this.replServerHandler.getMonitorInstanceName() +
- " start");
+ TRACER.debugInfo("In " + getLocalRSMonitorInstanceName()
+ + " LWSH for remote server " + this.serverId + " connected to:"
+ + this.replServerHandler.getMonitorInstanceName() + " start");
DirectoryServer.deregisterMonitorProvider(this);
DirectoryServer.registerMonitorProvider(this);
-
}
/**
@@ -193,10 +186,8 @@
public void stopHandler()
{
if (debugEnabled())
- TRACER.debugInfo("In "
- + replServerHandler.getDomain().getReplicationServer()
- .getMonitorInstanceName() + " LWSH for remote server "
- + this.serverId + " connected to:"
+ TRACER.debugInfo("In " + getLocalRSMonitorInstanceName()
+ + " LWSH for remote server " + this.serverId + " connected to:"
+ this.replServerHandler.getMonitorInstanceName() + " stop");
DirectoryServer.deregisterMonitorProvider(this);
}
--
Gitblit v1.10.0