Repository: hbase Updated Branches: refs/heads/branch-1 c8d8499da -> 4666bf86a
HBASE-13496 Make Bytes::compareTo inlineable. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4666bf86 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4666bf86 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4666bf86 Branch: refs/heads/branch-1 Commit: 4666bf86a23f98d0989ec4e7b09fe729f654a65c Parents: c8d8499 Author: anoopsjohn <[email protected]> Authored: Thu Apr 23 10:36:08 2015 +0530 Committer: anoopsjohn <[email protected]> Committed: Thu Apr 23 10:40:56 2015 +0530 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/util/Bytes.java | 45 ++++++++++++-------- 1 file changed, 28 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/4666bf86/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Bytes.java ---------------------------------------------------------------------- diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Bytes.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Bytes.java index a3ebc63..5695b94 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Bytes.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Bytes.java @@ -1352,24 +1352,45 @@ public class Bytes { /** * Returns true if x1 is less than x2, when both values are treated as * unsigned long. + * Both values are passed as is read by Unsafe. When platform is Little Endian, have to + * convert to corresponding Big Endian value and then do compare. We do all writes in + * Big Endian format. */ static boolean lessThanUnsignedLong(long x1, long x2) { + if (littleEndian) { + x1 = Long.reverseBytes(x1); + x2 = Long.reverseBytes(x2); + } return (x1 + Long.MIN_VALUE) < (x2 + Long.MIN_VALUE); } /** * Returns true if x1 is less than x2, when both values are treated as * unsigned int. + * Both values are passed as is read by Unsafe. When platform is Little Endian, have to + * convert to corresponding Big Endian value and then do compare. We do all writes in + * Big Endian format. */ static boolean lessThanUnsignedInt(int x1, int x2) { + if (littleEndian) { + x1 = Integer.reverseBytes(x1); + x2 = Integer.reverseBytes(x2); + } return (x1 & 0xffffffffL) < (x2 & 0xffffffffL); } /** * Returns true if x1 is less than x2, when both values are treated as * unsigned short. + * Both values are passed as is read by Unsafe. When platform is Little Endian, have to + * convert to corresponding Big Endian value and then do compare. We do all writes in + * Big Endian format. */ static boolean lessThanUnsignedShort(short x1, short x2) { + if (littleEndian) { + x1 = Short.reverseBytes(x1); + x2 = Short.reverseBytes(x2); + } return (x1 & 0xffff) < (x2 & 0xffff); } @@ -1413,40 +1434,30 @@ public class Bytes { * time is no slower than comparing 4 bytes at a time even on 32-bit. * On the other hand, it is substantially faster on 64-bit. */ - for (int i = 0; i < minWords * SIZEOF_LONG; i += SIZEOF_LONG) { + // This is the end offset of long parts. + int j = minWords << 3; // Same as minWords * SIZEOF_LONG + for (int i = 0; i < j; i += SIZEOF_LONG) { long lw = theUnsafe.getLong(buffer1, offset1Adj + (long) i); long rw = theUnsafe.getLong(buffer2, offset2Adj + (long) i); long diff = lw ^ rw; - if(littleEndian){ - lw = Long.reverseBytes(lw); - rw = Long.reverseBytes(rw); - } if (diff != 0) { return lessThanUnsignedLong(lw, rw) ? -1 : 1; } } - int offset = minWords * SIZEOF_LONG; + int offset = j; if (minLength - offset >= SIZEOF_INT) { int il = theUnsafe.getInt(buffer1, offset1Adj + offset); int ir = theUnsafe.getInt(buffer2, offset2Adj + offset); - if(littleEndian){ - il = Integer.reverseBytes(il); - ir = Integer.reverseBytes(ir); - } - if(il != ir){ + if (il != ir) { return lessThanUnsignedInt(il, ir) ? -1: 1; } - offset += SIZEOF_INT; + offset += SIZEOF_INT; } if (minLength - offset >= SIZEOF_SHORT) { short sl = theUnsafe.getShort(buffer1, offset1Adj + offset); short sr = theUnsafe.getShort(buffer2, offset2Adj + offset); - if(littleEndian){ - sl = Short.reverseBytes(sl); - sr = Short.reverseBytes(sr); - } - if(sl != sr){ + if (sl != sr) { return lessThanUnsignedShort(sl, sr) ? -1: 1; } offset += SIZEOF_SHORT;
