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

Fabio Pistolesi
17.01.2015 89183d52637336618123b78c1410381b7780d977
opendj-server-legacy/src/main/java/org/opends/server/replication/service/ReplicationBroker.java
@@ -269,6 +269,10 @@
  {
    synchronized (startStopLock)
    {
      if (!shutdown)
      {
        return;
      }
      shutdown = false;
      this.rcvWindow = getMaxRcvWindow();
      connectAsDataServer();
@@ -2660,13 +2664,17 @@
  /** Stop the server. */
  public void stop()
  {
    if (logger.isTraceEnabled())
    if (logger.isTraceEnabled() && !shutdown)
    {
      debugInfo("is stopping and will close the connection to RS(" + getRsServerId() + ")");
    }
    synchronized (startStopLock)
    {
      if (shutdown)
      {
        return;
      }
      domain.publishReplicaOfflineMsg();
      shutdown = true;
      setConnectedRS(ConnectedRS.stopped());