Fix for 1561 : ReplicationDomain.disable() should wait for all threads to d...

gbellato

29.27.2007 a6be5db964ffa77a68b91966d99f6fa0b36b532e

 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();
  }