mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

pgamba
02.58.2007 b48ce50fdf4d73e8be3799e3a7c6c2bf9d1b2965
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);