Renamed MonitorData.java to ReplicationDomainMonitorData.java Renamed fmd f...

Jean-Noel Rouvignac

21.12.2013 207702a7577d969f685c9d2e9cf1b9a49e5a1daf

Renamed MonitorData.java to ReplicationDomainMonitorData.java
Renamed fmd field to firstMissingDates.
Obeyed java naming conventions.

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

@@ -249,7 +249,8 @@
    attributes.add(Attributes.create("connected-to",
        this.replicationServer.getMonitorInstanceName()));

    MonitorData md = replicationServerDomain.getDomainMonitorData();
    ReplicationDomainMonitorData md =
        replicationServerDomain.getDomainMonitorData();

    // Oldest missing update
    long approxFirstMissingDate = md.getApproxFirstMissingDate(serverId);

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

@@ -200,7 +200,7 @@
        replServerHandler.getMonitorInstanceName()));

    // Retrieves the topology counters
    MonitorData md = rsDomain.getDomainMonitorData();
    ReplicationDomainMonitorData md = rsDomain.getDomainMonitorData();

    ServerState remoteState = md.getLDAPServerState(serverId);
    if (remoteState == null)

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

@@ -53,7 +53,8 @@
  /**
   * The monitor data consolidated over the topology.
   */
  private volatile MonitorData monitorData = new MonitorData();
  private volatile ReplicationDomainMonitorData monitorData =
      new ReplicationDomainMonitorData();

  /**
   * This lock guards against multiple concurrent monitor data recalculation.
@@ -79,7 +80,7 @@
   * <p>
   * Guarded by pendingMonitorDataLock.
   */
  private MonitorData pendingMonitorData;
  private ReplicationDomainMonitorData pendingMonitorData;

  /**
   * A set containing the IDs of servers from which we are currently expecting
@@ -129,7 +130,7 @@
   * @return The latest monitor data available for this replication server
   *         domain, which is never {@code null}.
   */
  public MonitorData getMonitorData()
  public ReplicationDomainMonitorData getMonitorData()
  {
    return monitorData;
  }
@@ -141,7 +142,8 @@
   * @throws InterruptedException
   *           If this thread is interrupted while waiting for a response.
   */
  public MonitorData computeDomainMonitorData() throws InterruptedException
  public ReplicationDomainMonitorData computeDomainMonitorData()
      throws InterruptedException
  {
    // Only allow monitor recalculation at a time.
    synchronized (pendingMonitorLock)
@@ -157,7 +159,7 @@
          {
            // Clear the pending monitor data.
            pendingMonitorDataServerIDs.clear();
            pendingMonitorData = new MonitorData();
            pendingMonitorData = new ReplicationDomainMonitorData();

            initializePendingMonitorData();


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

File was renamed from opends/src/server/org/opends/server/replication/server/MonitorData.java
@@ -28,6 +28,7 @@
package org.opends.server.replication.server;

import java.util.Iterator;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

@@ -39,10 +40,10 @@
import static org.opends.server.loggers.debug.DebugLogger.*;

/**
 * This class defines the Monitor Data that are consolidated across the
 * whole replication topology.
 * This class defines the Monitor Data that are consolidated across a
 * replication domain.
 */
public class MonitorData
class ReplicationDomainMonitorData
{
  /**
   * The tracer object for the debug logger.
@@ -65,11 +66,11 @@


  /** For each LDAP server, its server state. */
  private ConcurrentMap<Integer, ServerState> LDAPStates =
  private ConcurrentMap<Integer, ServerState> ldapStates =
    new ConcurrentHashMap<Integer, ServerState>();

  /** A Map containing the ServerStates of each RS. */
  private ConcurrentMap<Integer, ServerState> RSStates =
  private ConcurrentMap<Integer, ServerState> rsStates =
    new ConcurrentHashMap<Integer, ServerState>();

  /** For each LDAP server, the last(max) CN it published. */
@@ -80,7 +81,7 @@
   * For each LDAP server, an approximation of the date of the first missing
   * change.
   */
  private ConcurrentMap<Integer, Long> fmd =
  private ConcurrentMap<Integer, Long> firstMissingDates =
    new ConcurrentHashMap<Integer, Long>();

  private ConcurrentMap<Integer, Long> missingChanges =
@@ -97,7 +98,7 @@
   */
  public long getApproxDelay(int serverId)
  {
    Long afmd = fmd.get(serverId);
    Long afmd = firstMissingDates.get(serverId);
    if (afmd != null && afmd > 0)
      return (TimeThread.getTime() - afmd) / 1000;
    return 0;
@@ -110,7 +111,7 @@
   */
  public long getApproxFirstMissingDate(int serverId)
  {
    Long res = fmd.get(serverId);
    Long res = firstMissingDates.get(serverId);
    if (res != null)
      return res;
    return 0;
@@ -124,9 +125,9 @@
  public long getMissingChanges(int serverId)
  {
    Long res = missingChanges.get(serverId);
    if (res == null)
      return 0;
    if (res != null)
    return res;
    return 0;
  }

  /**
@@ -139,9 +140,9 @@
  public long getMissingChangesRS(int serverId)
  {
    Long res = missingChangesRS.get(serverId);
    if (res == null)
      return 0;
    if (res != null)
    return res;
    return 0;
  }

  /**
@@ -156,13 +157,18 @@
    //   Regarding each other LSj
    //    Sum the difference : max(LSj) - state(LSi)

    for (Integer lsiSid : this.LDAPStates.keySet()) {
      ServerState lsiState = this.LDAPStates.get(lsiSid);
      Long lsiMissingChanges = (long) 0;
    for (Entry<Integer, ServerState> entry : ldapStates.entrySet())
    {
      final Integer lsiServerId = entry.getKey();
      final ServerState lsiState = entry.getValue();

      long lsiMissingChanges = 0;
      if (lsiState != null) {
        for (Integer lsjSid : this.maxCNs.keySet()) {
          ChangeNumber lsjMaxCN = this.maxCNs.get(lsjSid);
          ChangeNumber lsiLastCN = lsiState.getChangeNumber(lsjSid);
        for (Entry<Integer, ChangeNumber> entry2 : maxCNs.entrySet())
        {
          final Integer lsjServerId = entry2.getKey();
          final ChangeNumber lsjMaxCN = entry2.getValue();
          ChangeNumber lsiLastCN = lsiState.getChangeNumber(lsjServerId);

          int missingChangesLsiLsj =
              ChangeNumber.diffSeqNum(lsjMaxCN, lsiLastCN);
@@ -183,10 +189,12 @@
          when it is recovering from an old snapshot and the local RS is
          sending him the changes it is missing.
          */
          if (lsjSid.equals(lsiSid) && missingChangesLsiLsj <= 50) {
          if (lsjServerId.equals(lsiServerId) && missingChangesLsiLsj <= 50)
          {
            missingChangesLsiLsj = 0;
            if (debugEnabled()) {
              mds += " (diff replaced by 0 as for server id " + lsiSid + ")";
              mds +=
                  " (diff replaced by 0 as for server id " + lsiServerId + ")";
            }
          }

@@ -196,21 +204,25 @@
      if (debugEnabled()) {
        mds += "=" + lsiMissingChanges;
      }
      this.missingChanges.put(lsiSid, lsiMissingChanges);
      this.missingChanges.put(lsiServerId, lsiMissingChanges);
    }

    // Computes the missing changes counters for RS :
    // Sum the difference of sequence numbers for each element in the States.

    for (int lsiSid : RSStates.keySet())
    for (Entry<Integer, ServerState> entry : rsStates.entrySet())
    {
      ServerState lsiState = this.RSStates.get(lsiSid);
      Long lsiMissingChanges = (long)0;
      final Integer lsiServerId = entry.getKey();
      final ServerState lsiState = entry.getValue();

      long lsiMissingChanges = 0;
      if (lsiState != null)
      {
        for (Integer lsjSid : this.maxCNs.keySet()) {
          ChangeNumber lsjMaxCN = this.maxCNs.get(lsjSid);
          ChangeNumber lsiLastCN = lsiState.getChangeNumber(lsjSid);
        for (Entry<Integer, ChangeNumber> entry2 : maxCNs.entrySet())
        {
          final Integer lsjServerId = entry2.getKey();
          final ChangeNumber lsjMaxCN = entry2.getValue();
          ChangeNumber lsiLastCN = lsiState.getChangeNumber(lsjServerId);

          int missingChangesLsiLsj =
              ChangeNumber.diffSeqNum(lsjMaxCN, lsiLastCN);
@@ -226,12 +238,12 @@
      {
        mds += "=" + lsiMissingChanges;
      }
      this.missingChangesRS.put(lsiSid,lsiMissingChanges);
      this.missingChangesRS.put(lsiServerId,lsiMissingChanges);

      if (debugEnabled())
      {
        TRACER.debugInfo(
          "Complete monitor data : Missing changes ("+ lsiSid +")=" + mds);
          "Complete monitor data : Missing changes ("+ lsiServerId +")=" + mds);
      }
    }
  }
@@ -247,25 +259,31 @@
    String mds = "Monitor data=\n";

    // maxCNs
    for (Integer sid : maxCNs.keySet()) {
      ChangeNumber cn = maxCNs.get(sid);
      mds += "\nmaxCNs(" + sid + ")= " + cn.toStringUI();
    for (Entry<Integer, ChangeNumber> entry : maxCNs.entrySet())
    {
      final Integer serverId = entry.getKey();
      final ChangeNumber cn = entry.getValue();
      mds += "\nmaxCNs(" + serverId + ")= " + cn.toStringUI();
    }

    // LDAP data
    for (Integer sid : LDAPStates.keySet()) {
      ServerState ss = LDAPStates.get(sid);
      mds += "\nLSData(" + sid + ")=\t"
          + "state=[" + ss + "] afmd=" + getApproxFirstMissingDate(sid)
          + " missingDelay=" + getApproxDelay(sid)
          + " missingCount=" + missingChanges.get(sid);
    for (Entry<Integer, ServerState> entry : ldapStates.entrySet())
    {
      final Integer serverId = entry.getKey();
      final ServerState ss = entry.getValue();
      mds += "\nLSData(" + serverId + ")=\t"
          + "state=[" + ss + "] afmd=" + getApproxFirstMissingDate(serverId)
          + " missingDelay=" + getApproxDelay(serverId)
          + " missingCount=" + missingChanges.get(serverId);
    }

    // RS data
    for (Integer sid : RSStates.keySet()) {
      ServerState ss = RSStates.get(sid);
      mds += "\nRSData(" + sid + ")=\t" + "state=[" + ss
          + "] missingCount=" + missingChangesRS.get(sid);
    for (Entry<Integer, ServerState> entry : rsStates.entrySet())
    {
      final Integer serverId = entry.getKey();
      final ServerState ss = entry.getValue();
      mds += "\nRSData(" + serverId + ")=\t" + "state=[" + ss
          + "] missingCount=" + missingChangesRS.get(serverId);
    }

    mds += "\n--";
@@ -278,9 +296,9 @@
   */
  public void setMaxCNs(ServerState state)
  {
    for (Integer sid : state) {
      ChangeNumber newCN = state.getChangeNumber(sid);
      setMaxCN(sid, newCN);
    for (Integer serverId : state) {
      ChangeNumber newCN = state.getChangeNumber(serverId);
      setMaxCN(serverId, newCN);
    }
  }

@@ -293,6 +311,7 @@
  public void setMaxCN(int serverId, ChangeNumber newCN)
  {
    if (newCN==null) return;

    ChangeNumber currentMaxCN = maxCNs.get(serverId);
    if (currentMaxCN == null)
    {
@@ -311,7 +330,7 @@
   */
  public ServerState getLDAPServerState(int serverId)
  {
    return LDAPStates.get(serverId);
    return ldapStates.get(serverId);
  }

  /**
@@ -321,7 +340,7 @@
   */
  public void setLDAPServerState(int serverId, ServerState state)
  {
    LDAPStates.put(serverId, state);
    ldapStates.put(serverId, state);
  }

  /**
@@ -332,7 +351,7 @@
   */
  public void setRSState(int serverId, ServerState state)
  {
    RSStates.put(serverId, state);
    rsStates.put(serverId, state);
  }

  /**
@@ -342,14 +361,14 @@
   */
  public void setFirstMissingDate(int serverId, long newFmd)
  {
    Long currentFmd = fmd.get(serverId);
    Long currentFmd = firstMissingDates.get(serverId);
    if (currentFmd == null)
    {
      fmd.put(serverId, newFmd);
      firstMissingDates.put(serverId, newFmd);
    }
    else if (newFmd != 0 && (newFmd < currentFmd || currentFmd == 0))
    {
      fmd.replace(serverId, newFmd);
      firstMissingDates.replace(serverId, newFmd);
    }
  }

@@ -361,7 +380,7 @@
   */
  public Iterator<Integer> ldapIterator()
  {
    return LDAPStates.keySet().iterator();
    return ldapStates.keySet().iterator();
  }

  /**
@@ -372,7 +391,7 @@
   */
  public Iterator<Integer> rsIterator()
  {
    return RSStates.keySet().iterator();
    return rsStates.keySet().iterator();
  }

  /**
@@ -383,7 +402,7 @@
   */
  public ServerState getRSStates(int serverId)
  {
    return RSStates.get(serverId);
    return rsStates.get(serverId);
  }

  /**

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

@@ -1655,7 +1655,7 @@
    returnMsg.setReplServerDbState(getDbServerState());

    // Add the server state for each DS and RS currently in the topology.
    final MonitorData monitorData = getDomainMonitorData();
    final ReplicationDomainMonitorData monitorData = getDomainMonitorData();
    for (int replicaId : toIterable(monitorData.ldapIterator()))
    {
      returnMsg.setServerState(replicaId,
@@ -2416,7 +2416,7 @@
   * @return The latest monitor data available for this replication server
   *         domain, which is never {@code null}.
   */
  MonitorData getDomainMonitorData()
  ReplicationDomainMonitorData getDomainMonitorData()
  {
    return domainMonitor.getMonitorData();
  }

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

@@ -715,7 +715,8 @@
    // Add the specific RS ones
    attributes.add(Attributes.create("Replication-Server", serverURL));

    MonitorData md = replicationServerDomain.getDomainMonitorData();
    ReplicationDomainMonitorData md =
        replicationServerDomain.getDomainMonitorData();

    // Missing changes
    attributes.add(Attributes.create("missing-changes",