pgamba

29.53.2007 40cef7d36084fbe86d34cfa497628d8972c4c9e7

 opends/src/server/org/opends/server/synchronization/plugin/HeartbeatMonitor.java

@@ -27,12 +27,14 @@

package org.opends.server.synchronization.plugin;

import org.opends.server.api.DirectoryThread;
import org.opends.server.synchronization.protocol.ProtocolSession;
import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
import static org.opends.server.loggers.debug.DebugLogger.debugInfo;

import java.io.IOException;

import org.opends.server.api.DirectoryThread;
import org.opends.server.synchronization.protocol.ProtocolSession;

/**
 * This class implements a thread to monitor heartbeat messages from the
 * synchronization server.  Each broker runs one of these threads.
@@ -103,6 +105,9 @@
        long lastReceiveTime = session.getLastReceiveTime();
        if (now > lastReceiveTime + 2 * heartbeatInterval)
        {
          debugInfo("Heartbeat monitor is closing the broker session " +
          "because it could not detect a heartbeat.");

          // Heartbeat is well overdue so the server is assumed to be dead.
          if (debugEnabled())
          {