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 25ca73c..4bcbed1 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 @@ -1461,7 +1461,9 @@ public class RpcServer implements RpcServerInterface { incRpcCount(); // Increment the rpc count } count = channelRead(channel, data); - if (data.remaining() == 0) { + if (count < 0) { + return count; + } else if (data.remaining() == 0) { dataLengthBuffer.clear(); data.flip(); if (skipInitialSaslHandshake) {