From a6be5db964ffa77a68b91966d99f6fa0b36b532e Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Tue, 29 May 2007 09:27:46 +0000
Subject: [PATCH] Fix for 1561 : ReplicationDomain.disable() should wait for all threads to die be fore returning
---
opends/src/server/org/opends/server/replication/protocol/SocketSession.java | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/SocketSession.java b/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
index 0c53005..7d0a90f 100644
--- a/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
+++ b/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
@@ -26,6 +26,9 @@
*/
package org.opends.server.replication.protocol;
+import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
+import static org.opends.server.loggers.debug.DebugLogger.getTracer;
+
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
@@ -33,6 +36,8 @@
import java.net.SocketException;
import java.util.zip.DataFormatException;
+import org.opends.server.loggers.debug.DebugTracer;
+
/**
* This class Implement a protocol session using a basic socket and relying on
* the innate encoding/decoding capabilities of the ReplicationMessage
@@ -44,6 +49,11 @@
*/
public class SocketSession implements ProtocolSession
{
+ /**
+ * The tracer object for the debug logger.
+ */
+ private static final DebugTracer TRACER = getTracer();
+
private Socket socket;
private InputStream input;
private OutputStream output;
@@ -83,6 +93,10 @@
*/
public void close() throws IOException
{
+ if (debugEnabled())
+ {
+ TRACER.debugVerbose("Closing SocketSession.");
+ }
socket.close();
}
--
Gitblit v1.10.0