From 92a7350758362b7b90576a01fdf96417298e0a5c Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Mon, 09 Oct 2006 14:15:55 +0000
Subject: [PATCH] - Change the synchronization code so that the changelog server can now be used directly through the ChangelogBroker class as a client API.
---
opends/src/server/org/opends/server/changelog/ProtocolSession.java | 15 +++++++++++++++
1 files changed, 15 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/changelog/ProtocolSession.java b/opends/src/server/org/opends/server/changelog/ProtocolSession.java
index 177b974..1448e47 100644
--- a/opends/src/server/org/opends/server/changelog/ProtocolSession.java
+++ b/opends/src/server/org/opends/server/changelog/ProtocolSession.java
@@ -27,6 +27,7 @@
package org.opends.server.changelog;
import java.io.IOException;
+import java.net.SocketException;
import java.util.zip.DataFormatException;
import org.opends.server.synchronization.SynchronizationMessage;
@@ -90,4 +91,18 @@
* @return The IP address of the remote server.
*/
public abstract String getRemoteAddress();
+
+
+ /**
+ * Set a timeout value.
+ * With this option set to a non-zero value, calls to the receive() method
+ * block for only this amount of time after which a
+ * java.net.SocketTimeoutException is raised.
+ * The Broker is valid and useable even after such an Exception is raised.
+ *
+ * @param timeout the specified timeout, in milliseconds.
+ * @throws SocketException if there is an error in the underlying protocol,
+ * such as a TCP error.
+ */
+ public abstract void setSoTimeout(int timeout) throws SocketException;
}
--
Gitblit v1.10.0