You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2014/06/01 00:26:15 UTC
[3/3] git commit: HBASE-11277 RpcServer threads can wedge under high
load
HBASE-11277 RpcServer threads can wedge under high load
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0c374cee
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0c374cee
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0c374cee
Branch: refs/heads/0.96
Commit: 0c374ceea9374c4743a427c7029335a975ad3f14
Parents: bba67cb
Author: Andrew Purtell <ap...@apache.org>
Authored: Sat May 31 15:24:06 2014 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Sat May 31 15:24:21 2014 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/0c374cee/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 0fccf6a..657dd1d 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
@@ -1517,8 +1517,8 @@ public class RpcServer implements RpcServerInterface {
if (!headerRead) {
continue;
}
- } else {
- // More to read still; go around again.
+ } else if (count > 0) {
+ // We got some data and there is more to read still; go around again.
if (LOG.isTraceEnabled()) LOG.trace("Continue to read rest of data " + data.remaining());
continue;
}