Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14120 ByteBufferUtils#compareTo small optimization.

This commit is contained in:
anoopsjohn 2015-07-20 16:49:51 +05:30
parent 338e39970b
commit 88038cf473
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
hbase-common/src/main/java/org/apache/hadoop/hbase/util/ByteBufferUtils.java
View File

@ -539,17 +539,17 @@ public final class ByteBufferUtils {
if (UnsafeAccess.isAvailable()) { if (UnsafeAccess.isAvailable()) {
long offset1Adj, offset2Adj; long offset1Adj, offset2Adj;
Object refObj1 = null, refObj2 = null; Object refObj1 = null, refObj2 = null;
if (buf1.hasArray()) { if (buf1.isDirect()) {
offset1Adj = o1 + ((DirectBuffer) buf1).address();
} else {
offset1Adj = o1 + buf1.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET; offset1Adj = o1 + buf1.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET;
refObj1 = buf1.array(); refObj1 = buf1.array();
} else {
offset1Adj = o1 + ((DirectBuffer) buf1).address();
} }
if (buf2.hasArray()) { if (buf2.isDirect()) {
offset2Adj = o2 + ((DirectBuffer) buf2).address();
} else {
offset2Adj = o2 + buf2.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET; offset2Adj = o2 + buf2.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET;
refObj2 = buf2.array(); refObj2 = buf2.array();
} else {
offset2Adj = o2 + ((DirectBuffer) buf2).address();
} }
return compareToUnsafe(refObj1, offset1Adj, l1, refObj2, offset2Adj, l2); return compareToUnsafe(refObj1, offset1Adj, l1, refObj2, offset2Adj, l2);
} }
@ -569,11 +569,11 @@ public final class ByteBufferUtils {
if (UnsafeAccess.isAvailable()) { if (UnsafeAccess.isAvailable()) {
long offset1Adj; long offset1Adj;
Object refObj1 = null; Object refObj1 = null;
if (buf1.hasArray()) { if (buf1.isDirect()) {
offset1Adj = o1 + ((DirectBuffer) buf1).address();
} else {
offset1Adj = o1 + buf1.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET; offset1Adj = o1 + buf1.arrayOffset() + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET;
refObj1 = buf1.array(); refObj1 = buf1.array();
} else {
offset1Adj = o1 + ((DirectBuffer) buf1).address();
} }
return compareToUnsafe(refObj1, offset1Adj, l1, buf2, o2 return compareToUnsafe(refObj1, offset1Adj, l1, buf2, o2
+ UnsafeAccess.BYTE_ARRAY_BASE_OFFSET, l2); + UnsafeAccess.BYTE_ARRAY_BASE_OFFSET, l2);