Fix issue OpenDJ-95: Socket leak and constant disconnect/reconnect when a d...

Matthew Swift

23.27.2011 6ee1440f6f56ac066f97383315b2798287f0821a

 opends/src/server/org/opends/server/replication/server/ECLServerHandler.java

@@ -23,7 +23,7 @@
 *
 *
 *      Copyright 2009-2010 Sun Microsystems, Inc.
 *      Portions Copyright 2010 ForgeRock AS
 *      Portions Copyright 2010-2011 ForgeRock AS
 */
package org.opends.server.replication.server;

@@ -169,6 +169,7 @@
    }
    /**
     * Provide a string representation of this object for debug purpose..
     * @param buffer Append to this buffer.
     */
    public void toString(StringBuilder buffer)
    {
@@ -1550,9 +1551,10 @@
      // INIT_PHASE is done AND search is persistent => goto PERSISTENT_PHASE
      searchPhase = PERSISTENT_PHASE;

      if (writer ==null)
      final ProtocolSession localSession = session;
      if (writer ==null && localSession != null)
      {
        writer = new ECLServerWriter(session,this,replicationServerDomain);
        writer = new ECLServerWriter(localSession,this,replicationServerDomain);
        writer.start();  // start suspended
      }