opends/src/server/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDB.java
@@ -265,19 +265,15 @@ private Attribute createChangeNumberAttribute(final boolean isFirst) { final String attributeName = isFirst ? "first-draft-changenumber" : "last-draft-changenumber"; final String changeNumber = String.valueOf(getChangeNumber(isFirst)); final String changeNumber = String.valueOf(readChangeNumber(isFirst)); return Attributes.create(attributeName, changeNumber); } private long getChangeNumber(final boolean isFirst) private long readChangeNumber(final boolean isFirst) { try { final ChangeNumberIndexRecord record = isFirst ? readFirstRecord() : readLastRecord(); if (record != null) { return record.getChangeNumber(); } return getChangeNumber(isFirst ? readFirstRecord() : readLastRecord()); } catch (ChangelogException e) { @@ -285,8 +281,8 @@ { TRACER.debugCaught(DebugLogLevel.WARNING, e); } return NO_KEY; } return 0; } /** {@inheritDoc} */ opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java
@@ -128,7 +128,9 @@ newestChangeNumber = changeNumber; if (debugEnabled()) { TRACER.debugInfo("In JEChangeNumberIndexDB.add, added: " + newRecord); } return changeNumber; } @@ -328,27 +330,25 @@ { final String attributeName = isFirst ? "first-draft-changenumber" : "last-draft-changenumber"; final String changeNumber = String.valueOf(getChangeNumber(isFirst)); final String changeNumber = String.valueOf(readChangeNumber(isFirst)); return Attributes.create(attributeName, changeNumber); } private long getChangeNumber(boolean isFirst) private long readChangeNumber(boolean isFirst) { try { final ChangeNumberIndexRecord record = isFirst ? db.readFirstRecord() : db.readLastRecord(); if (record != null) { return record.getChangeNumber(); } return getChangeNumber( isFirst ? db.readFirstRecord() : db.readLastRecord()); } catch (ChangelogException e) { if (debugEnabled()) { TRACER.debugCaught(DebugLogLevel.WARNING, e); } return 0; return NO_KEY; } } /** {@inheritDoc} */