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

Jean-Noel Rouvignac
08.07.2013 3c062316441f2adb96afb6a6a98c09d91c27bd97
opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java
@@ -153,12 +153,17 @@
  /** {@inheritDoc} */
  @Override
  public void addRecord(CNIndexRecord record) throws ChangelogException
  public long addRecord(CNIndexRecord record) throws ChangelogException
  {
    db.addRecord(record);
    long changeNumber = nextChangeNumber();
    final CNIndexRecord newRecord =
        new CNIndexRecord(changeNumber, record.getPreviousCookie(), record
            .getBaseDN(), record.getCSN());
    db.addRecord(newRecord);
    if (debugEnabled())
      TRACER.debugInfo("In JEChangeNumberIndexDB.add, added: " + record);
      TRACER.debugInfo("In JEChangeNumberIndexDB.add, added: " + newRecord);
    return changeNumber;
  }
  /** {@inheritDoc} */
@@ -175,9 +180,7 @@
    return db.readLastRecord();
  }
  /** {@inheritDoc} */
  @Override
  public long nextChangeNumber()
  private long nextChangeNumber()
  {
    return lastGeneratedChangeNumber.incrementAndGet();
  }