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

Jean-Noel Rouvignac
09.57.2013 abbdffd7e86953f89c3469bcfc659d842fb785f6
opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
@@ -94,7 +94,7 @@
  /** {@inheritDoc} */
  @Override
  public boolean next()
  public boolean next() throws ChangelogException
  {
    currentChange = cursor.next();
@@ -112,18 +112,11 @@
          cursor = null;
        }
        replicaDB.flush();
        try
        cursor = db.openReadCursor(lastNonNullCurrentCSN);
        currentChange = cursor.next();
        if (currentChange != null)
        {
          cursor = db.openReadCursor(lastNonNullCurrentCSN);
          currentChange = cursor.next();
          if (currentChange != null)
          {
            lastNonNullCurrentCSN = currentChange.getCSN();
          }
        }
        catch(Exception e)
        {
          currentChange = null;
          lastNonNullCurrentCSN = currentChange.getCSN();
        }
      }
    }