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

Matthew Swift
13.23.2011 96eaa516a85e620a6b76a64ffbe71cdc6037e026
opends/src/server/org/opends/server/replication/server/ECLServerWriter.java
@@ -141,7 +141,6 @@
   */
  public void run()
  {
    Message errMessage = null;
    try
    {
      while (true)
@@ -170,16 +169,36 @@
    catch (SocketException e)
    {
      // Just ignore the exception and let the thread die as well
      errMessage = ERR_SERVER_BADLY_DISCONNECTED.get(handler.toString(),
          "for operation " + handler.getOperationId());
      logError(errMessage);
      if (session != null) // This will always be the case if a socket exception
                           // has occurred.
      {
        Message errMessage;
        if (handler.isDataServer())
        {
          errMessage = ERR_DS_BADLY_DISCONNECTED.get(
              handler.getReplicationServerId(),
              handler.getServerId(),
              session.getReadableRemoteAddress(),
              handler.getServiceId());
        }
        else
        {
          errMessage = ERR_RS_BADLY_DISCONNECTED.get(
              handler.getReplicationServerId(),
              handler.getServerId(),
              session.getReadableRemoteAddress(),
              handler.getServiceId());
        }
        logError(errMessage);
      }
    }
    catch (Exception e)
    {
      // An unexpected error happened.
      // Log an error and close the connection.
      errMessage = ERR_WRITER_UNEXPECTED_EXCEPTION.get(handler.toString() +
          " " +  stackTraceToSingleLineString(e));
      Message errMessage = ERR_WRITER_UNEXPECTED_EXCEPTION
          .get(handler.toString() + " "
              + stackTraceToSingleLineString(e));
      logError(errMessage);
    }
    finally