OPENDJ-1116 Introduce abstraction for the changelog DB

Matthew Swift

07.53.2013 984ba7b145520f02414eedf36b88946172ef4dd3

 opends/src/server/org/opends/server/replication/plugin/AttrHistoricalMultiple.java

@@ -135,17 +135,17 @@
     while (it.hasNext())
     {
       AttrValueHistorical info = it.next();
       if (csn.newerOrEquals(info.getValueUpdateTime()) &&
           csn.newerOrEquals(info.getValueDeleteTime()))
       if (csn.isNewerThanOrEqualTo(info.getValueUpdateTime()) &&
           csn.isNewerThanOrEqualTo(info.getValueDeleteTime()))
         it.remove();
     }

     if (csn.newer(deleteTime))
     if (csn.isNewerThan(deleteTime))
     {
       deleteTime = csn;
     }

     if (csn.newer(lastUpdateTime))
     if (csn.isNewerThan(lastUpdateTime))
     {
       lastUpdateTime = csn;
     }
@@ -162,7 +162,7 @@
     AttrValueHistorical info = new AttrValueHistorical(val, null, csn);
     valuesHist.remove(info);
     valuesHist.put(info, info);
     if (csn.newer(lastUpdateTime))
     if (csn.isNewerThan(lastUpdateTime))
     {
       lastUpdateTime = csn;
     }
@@ -184,7 +184,7 @@
      AttrValueHistorical info = new AttrValueHistorical(val, null, csn);
      valuesHist.remove(info);
      valuesHist.put(info, info);
      if (csn.newer(lastUpdateTime))
      if (csn.isNewerThan(lastUpdateTime))
      {
        lastUpdateTime = csn;
      }
@@ -204,7 +204,7 @@
     AttrValueHistorical info = new AttrValueHistorical(addedValue, csn, null);
     valuesHist.remove(info);
     valuesHist.put(info, info);
     if (csn.newer(lastUpdateTime))
     if (csn.isNewerThan(lastUpdateTime))
     {
       lastUpdateTime = csn;
     }
@@ -225,7 +225,7 @@
      AttrValueHistorical info = new AttrValueHistorical(val, csn, null);
      valuesHist.remove(info);
      valuesHist.put(info, info);
      if (csn.newer(lastUpdateTime))
      if (csn.isNewerThan(lastUpdateTime))
      {
        lastUpdateTime = csn;
      }
@@ -262,7 +262,7 @@
      switch (m.getModificationType())
      {
      case DELETE:
        if (csn.older(getDeleteTime()))
        if (csn.isOlderThan(getDeleteTime()))
        {
          /* this delete is already obsoleted by a more recent delete
           * skip this mod
@@ -282,7 +282,7 @@
        break;

      case REPLACE:
        if (csn.older(getDeleteTime()))
        if (csn.isOlderThan(getDeleteTime()))
        {
          /* this replace is already obsoleted by a more recent delete
           * skip this mod
@@ -428,7 +428,7 @@
      {
        AttrValueHistorical valInfo = it.next();

        if (csn.older(valInfo.getValueUpdateTime()))
        if (csn.isOlderThan(valInfo.getValueUpdateTime()))
        {
          /*
           * this value has been updated after this delete, therefore
@@ -443,7 +443,7 @@
           * information unless it is a Deleted attribute value that is
           * more recent than this DELETE
           */
          if (csn.newerOrEquals(valInfo.getValueDeleteTime()))
          if (csn.isNewerThanOrEqualTo(valInfo.getValueDeleteTime()))
          {
            it.remove();
          }
@@ -452,11 +452,11 @@

      m.setAttribute(builder.toAttribute());

      if (csn.newer(getDeleteTime()))
      if (csn.isNewerThan(getDeleteTime()))
      {
        deleteTime = csn;
      }
      if (csn.newer(getLastUpdateTime()))
      if (csn.isNewerThan(getLastUpdateTime()))
      {
        lastUpdateTime = csn;
      }
@@ -484,8 +484,8 @@
            // we need to keep the delete.
            addedInCurrentOp = true;
          }
          if (csn.newerOrEquals(oldValInfo.getValueDeleteTime()) &&
              csn.newerOrEquals(oldValInfo.getValueUpdateTime()))
          if (csn.isNewerThanOrEqualTo(oldValInfo.getValueDeleteTime()) &&
              csn.isNewerThanOrEqualTo(oldValInfo.getValueUpdateTime()))
          {
            valuesHist.remove(oldValInfo);
            valuesHist.put(valInfo, valInfo);
@@ -523,7 +523,7 @@

      m.setAttribute(builder.toAttribute());

      if (csn.newer(getLastUpdateTime()))
      if (csn.isNewerThan(getLastUpdateTime()))
      {
        lastUpdateTime = csn;
      }
@@ -554,7 +554,7 @@
     * real entry
     */

    if (csn.older(getDeleteTime()))
    if (csn.isOlderThan(getDeleteTime()))
    {
      /* A delete has been done more recently than this add
       * forget this MOD ADD
@@ -586,7 +586,7 @@
           * in all cases suppress this value from the value list
           * as it is already present in the entry
           */
          if (csn.newer(oldValInfo.getValueUpdateTime()))
          if (csn.isNewerThan(oldValInfo.getValueUpdateTime()))
          {
            valuesHist.remove(oldValInfo);
            valuesHist.put(valInfo, valInfo);
@@ -598,7 +598,7 @@
          /* this value is marked as a deleted value
           * check if this mod is more recent the this delete
           */
          if (csn.newerOrEquals(oldValInfo.getValueDeleteTime()))
          if (csn.isNewerThanOrEqualTo(oldValInfo.getValueDeleteTime()))
          {
            /* this add is more recent,
             * remove the old delete historical information
@@ -629,7 +629,7 @@
      modsIterator.remove();
    }

    if (csn.newer(getLastUpdateTime()))
    if (csn.isNewerThan(getLastUpdateTime()))
    {
      lastUpdateTime = csn;
    }