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

Jean-Noël Rouvignac
30.12.2015 b0436a00587da6bdf8cd47a7ef94e4fe90aec71b
ByteSequenceReader.java: Added readCompactUnsignedInt() and used it
2 files modified
12 ■■■■ changed files
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java 6 ●●●● patch | view | raw | blame | history
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java 6 ●●●● patch | view | raw | blame | history
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java
@@ -517,7 +517,7 @@
        return newUndefinedSetWithKey(key);
      }
      final ByteSequenceReader reader = value.asReader();
      return newDefinedSet(decodeRaw(reader, (int) reader.readCompactUnsigned()));
      return newDefinedSet(decodeRaw(reader, reader.readCompactUnsignedInt()));
    }
    private static ByteStringBuilder append(ByteStringBuilder builder, EntryIDSet idSet)
@@ -557,9 +557,9 @@
        return EMPTY_LONG_ARRAY;
      }
      final long ids[] = new long[nbEntriesToDecode];
      ids[0] = reader.readCompactUnsigned();
      ids[0] = reader.readCompactUnsignedLong();
      for(int i = 1 ; i < nbEntriesToDecode ; i++) {
        ids[i] = ids[i-1] + reader.readCompactUnsigned();
        ids[i] = ids[i-1] + reader.readCompactUnsignedLong();
      }
      return ids;
    }
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java
@@ -66,7 +66,7 @@
          @Override
          public EntryID apply(ByteString value) throws Exception
          {
            return new EntryID(value.asReader().readCompactUnsigned());
            return new EntryID(value.asReader().readCompactUnsignedLong());
          }
        }, new CursorTransformer.ValueTransformer<ByteString, ByteString, Long, NeverThrowsException>()
        {
@@ -164,8 +164,8 @@
  public String keyToString(ByteString key)
  {
    ByteSequenceReader keyReader = key.asReader();
    long keyID = keyReader.readCompactUnsigned();
    long shardBucket = keyReader.readCompactUnsigned();
    long keyID = keyReader.readCompactUnsignedLong();
    long shardBucket = keyReader.readCompactUnsignedLong();
    return (keyID == TOTAL_COUNT_ENTRY_ID.longValue() ? "Total Children Count" : keyID) + "#" + shardBucket;
  }