Repository: hbase Updated Branches: refs/heads/master 3b72b69d0 -> cb5c4c146
HBASE-17235 Improvement in creation of CIS for onheap buffer cases (Ram) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cb5c4c14 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cb5c4c14 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cb5c4c14 Branch: refs/heads/master Commit: cb5c4c146f50da6ba75368c2d3fd7ca2d47a532a Parents: 3b72b69 Author: Ramkrishna <[email protected]> Authored: Fri Dec 2 14:07:16 2016 +0530 Committer: Ramkrishna <[email protected]> Committed: Fri Dec 2 14:07:16 2016 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/cb5c4c14/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java index a17310c..0c8f34f 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java @@ -156,6 +156,7 @@ import org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDesc import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; +import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; /** * An RPC server that hosts protobuf described Services. @@ -2148,11 +2149,11 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver { // do its default 4k allocation for CodedInputStream. We force it to use backing array. CodedInputStream cis; if (buf.hasArray()) { - cis = CodedInputStream.newInstance(buf.array(), offset, buf.limit()); + cis = UnsafeByteOperations.unsafeWrap(buf.array(), 0, buf.limit()).newCodedInput(); } else { cis = CodedInputStream.newInstance(new ByteBuffByteInput(buf, 0, buf.limit()), true); - cis.enableAliasing(true); } + cis.enableAliasing(true); int headerSize = cis.readRawVarint32(); offset = cis.getTotalBytesRead(); Message.Builder builder = RequestHeader.newBuilder();
