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

Jean-Noel Rouvignac
23.27.2014 bef73d94160ab49b47eed6d8fa17f0532d182b07
Code cleanup.

FileChangeNumberIndexDB.java, JEChangeNumberIndexDB.java:
Renamed DbMonitorProvider.getChangeNumber() to readChangeNumber() + reused getChangeNumber(Record) + used NO_KEY constant.
2 files modified
30 ■■■■■ changed files
opends/src/server/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDB.java 12 ●●●●● patch | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java 18 ●●●● patch | view | raw | blame | history
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} */