From 840c825261ce76e69fbffe437861b40984d30d35 Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Tue, 03 Oct 2006 13:47:20 +0000
Subject: [PATCH] At startup time, each changelog server establish a connection with each other changelog server.
---
opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java b/opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java
index fc482a8..d4cc9d6 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java
@@ -92,6 +92,7 @@
private boolean active = true;
private ServerWriter writer = null;
private DN baseDn = null;
+ private String serverAddressURL;
private static Map<ChangeNumber, ChangelogAckMessageList>
changelogsWaitingAcks = new HashMap<ChangeNumber, ChangelogAckMessageList>();
@@ -188,6 +189,8 @@
ChangelogStartMessage receivedMsg = (ChangelogStartMessage) msg;
serverId = receivedMsg.getServerId();
serverURL = receivedMsg.getServerURL();
+ String[] splittedURL = serverURL.split(":");
+ serverAddressURL = session.getRemoteAddress() + ":" + splittedURL[1];
serverIsLDAPserver = false;
this.baseDn = receivedMsg.getBaseDn();
if (baseDn == null)
@@ -262,6 +265,17 @@
}
/**
+ * Retrieves the Address URL for this server handler.
+ *
+ * @return The Address URL for this server handler,
+ * in the form of an IP address and port separated by a colon.
+ */
+ public String getServerAddressURL()
+ {
+ return serverAddressURL;
+ }
+
+ /**
* Retrieves the URL for this server handler.
*
* @return The URL for this server handler, in the form of an address and
--
Gitblit v1.10.0