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

Jean-Noel Rouvignac
03.04.2014 fe6d85f3d071138359165eca4e5b67d3f651cebe
opends/src/server/org/opends/server/replication/server/ServerReader.java
@@ -22,11 +22,11 @@
 *
 *
 *      Copyright 2006-2010 Sun Microsystems, Inc.
 *      Portions Copyright 2011-2013 ForgeRock AS
 *      Portions Copyright 2011-2014 ForgeRock AS
 */
package org.opends.server.replication.server;
import java.io.IOException;
import java.net.SocketException;
import org.opends.messages.Message;
import org.opends.server.api.DirectoryThread;
@@ -59,9 +59,6 @@
  private static final DebugTracer TRACER = getTracer();
  private final Session session;
  private final ServerHandler handler;
  private final String remoteAddress;
  /**
   * Constructor for the LDAP server reader part of the replicationServer.
@@ -78,7 +75,6 @@
        + session.getReadableRemoteAddress());
    this.session = session;
    this.handler = handler;
    this.remoteAddress = session.getReadableRemoteAddress();
  }
  /**
@@ -247,7 +243,7 @@
        }
      }
    }
    catch (IOException e)
    catch (SocketException e)
    {
      /*
       * The connection has been broken
@@ -257,18 +253,7 @@
      logException(e);
      if (!handler.shuttingDown())
      {
        if (handler.isDataServer())
        {
          errMessage = ERR_DS_BADLY_DISCONNECTED.get(
              handler.getReplicationServerId(), handler.getServerId(),
              remoteAddress, handler.getBaseDNString());
        }
        else
        {
          errMessage = ERR_RS_BADLY_DISCONNECTED.get(
              handler.getReplicationServerId(), handler.getServerId(),
              remoteAddress, handler.getBaseDNString());
        }
        errMessage = handler.getBadlyDisconnectedErrorMessage();
        logError(errMessage);
      }
    }