From b48ce50fdf4d73e8be3799e3a7c6c2bf9d1b2965 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Sun, 02 Sep 2007 17:58:07 +0000
Subject: [PATCH] fix for #1733 & #845 - Initialization of replication
---
opends/src/server/org/opends/server/replication/protocol/SocketSession.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 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 91b8130..03fe632 100644
--- a/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
+++ b/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
@@ -37,6 +37,7 @@
import java.util.zip.DataFormatException;
import org.opends.server.loggers.debug.DebugTracer;
+import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
/**
* This class Implement a protocol session using a basic socket and relying on
@@ -91,7 +92,8 @@
{
if (debugEnabled())
{
- TRACER.debugVerbose("Closing SocketSession.");
+ TRACER.debugInfo("Closing SocketSession."
+ + stackTraceToSingleLineString(new Exception()));
}
socket.close();
}
@@ -104,6 +106,12 @@
{
byte[] buffer = msg.getBytes();
String str = String.format("%08x", buffer.length);
+
+ if (debugEnabled())
+ {
+ TRACER.debugInfo("SocketSession publish <" + str + ">");
+ }
+
byte[] sendLengthBuf = str.getBytes();
output.write(sendLengthBuf);
--
Gitblit v1.10.0