hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [2/3] git commit: HBASE-11277 RpcServer threads can wedge under high load
Date Sat, 31 May 2014 22:26:14 GMT
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/7257dbc5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7257dbc5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7257dbc5

Branch: refs/heads/0.98
Commit: 7257dbc58fe27ec3b1b573707bb0a8f6fde3d462
Parents: f5338d7
Author: Andrew Purtell <apurtell@apache.org>
Authored: Sat May 31 15:24:06 2014 -0700
Committer: Andrew Purtell <apurtell@apache.org>
Committed: Sat May 31 15:24:16 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/7257dbc5/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 e79098e..1c12e2d 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
@@ -1506,8 +1506,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;
         }


Mime
View raw message