You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by an...@apache.org on 2015/10/13 04:28:14 UTC
hbase git commit: HBASE-13819 Make RPC layer CellBlock buffer a
DirectByteBuffer.
Repository: hbase
Updated Branches:
refs/heads/master ac82a8632 -> 6143b7694
HBASE-13819 Make RPC layer CellBlock buffer a DirectByteBuffer.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/6143b769
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/6143b769
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/6143b769
Branch: refs/heads/master
Commit: 6143b7694cc02e905b931de86462c6125ca8b3b6
Parents: ac82a86
Author: anoopsjohn <an...@gmail.com>
Authored: Tue Oct 13 07:57:53 2015 +0530
Committer: anoopsjohn <an...@gmail.com>
Committed: Tue Oct 13 07:57:53 2015 +0530
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/6143b769/hbase-common/src/main/java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java
----------------------------------------------------------------------
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java
index c685a92..aabbbc6 100644
--- a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java
+++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/BoundedByteBufferPool.java
@@ -43,6 +43,8 @@ import com.google.common.annotations.VisibleForTesting;
* achieve a particular 'run' size over time give or take a few extremes. Set TRACE level on this
* class for a couple of seconds to get reporting on how it is running when deployed.
*
+ * <p>This pool returns off heap ByteBuffers.
+ *
* <p>This class is thread safe.
*/
@InterfaceAudience.Private
@@ -94,7 +96,7 @@ public class BoundedByteBufferPool {
// Clear sets limit == capacity. Postion == 0.
bb.clear();
} else {
- bb = ByteBuffer.allocate(this.runningAverage);
+ bb = ByteBuffer.allocateDirect(this.runningAverage);
this.allocations.incrementAndGet();
}
if (LOG.isTraceEnabled()) {