From b0436a00587da6bdf8cd47a7ef94e4fe90aec71b Mon Sep 17 00:00:00 2001
From: Jean-Noël Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 05 Nov 2015 12:25:29 +0000
Subject: [PATCH] ByteSequenceReader.java: Added readCompactUnsignedInt() and used it
---
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java | 6 +++---
opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java b/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java
index 4fad6d3..8e56910 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/EntryIDSet.java
+++ b/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;
}
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java b/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java
index cd21d18..7cd6766 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ID2Count.java
+++ b/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;
}
--
Gitblit v1.10.0