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

Jean-Noel Rouvignac
30.07.2014 5a0befe36d7b7e93a65bb19df19d667d413c7c89
opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -2495,11 +2495,29 @@
   * value received, and forwarding the message to the other RSes.
   * @param senderHandler The handler for the server that sent the heartbeat.
   * @param msg The message to process.
   * @throws DirectoryException
   *           if a problem occurs
   */
  void processChangeTimeHeartbeatMsg(ServerHandler senderHandler,
      ChangeTimeHeartbeatMsg msg)
      ChangeTimeHeartbeatMsg msg) throws DirectoryException
  {
    domainDB.replicaHeartbeat(baseDN, msg.getCSN());
    try
    {
      if (msg.isReplicaOfflineMsg())
      {
        domainDB.replicaOffline(baseDN, msg.getCSN());
      }
      else
      {
        domainDB.replicaHeartbeat(baseDN, msg.getCSN());
      }
    }
    catch (ChangelogException e)
    {
      throw new DirectoryException(ResultCode.OPERATIONS_ERROR, e
          .getMessageObject(), e);
    }
    if (senderHandler.isDataServer())
    {
      /*