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

mrossign
24.28.2008 52635206c54376a391a2d9b55e37b89ce2d3edfa
opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationBroker.java
@@ -204,11 +204,7 @@
    HashMap<String, ServerState> rsStates = new HashMap<String, ServerState>();
    // Stop any existing heartbeat monitor from a previous session.
    if (heartbeatMonitor != null)
    {
      heartbeatMonitor.shutdown();
      heartbeatMonitor = null;
    }
    stopHeartBeat();
    synchronized (connectPhaseLock)
    {
@@ -753,6 +749,18 @@
  }
  /**
   * Stop the heartbeat monitor thread.
   */
  void stopHeartBeat()
  {
    if (heartbeatMonitor != null)
    {
      heartbeatMonitor.shutdown();
      heartbeatMonitor = null;
    }
  }
  /**
   * restart the ReplicationBroker.
   */
  public void reStart()
@@ -987,10 +995,6 @@
    replicationServer = "stopped";
    shutdown = true;
    connected = false;
    if (heartbeatMonitor != null)
    {
      heartbeatMonitor.shutdown();
    }
    try
    {
      if (debugEnabled())