This code allows the replication code to replay operation in the correct or...

gbellato

11.19.2007 a714dc56fbe8419a6f0e4e8ffd36384009a89557

 opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java

@@ -238,10 +238,13 @@
      {}
    }

    if ( (recentChangeNumber != null) &&
         (recentChangeNumber.getTimeSec() - changeNumber.getTimeSec() < 2))
    if ( (recentChangeNumber != null) && (changeNumber != null))
    {
      flush();
      if (((recentChangeNumber.getTimeSec() - changeNumber.getTimeSec()) < 2) ||
         ((recentChangeNumber.getSeqnum() - changeNumber.getSeqnum()) < 20))
      {
        flush();
      }
    }

    return new ReplicationIterator(serverId, db, changeNumber);