hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [1/3] git commit: HBASE-11277 RpcServer threads can wedge under high load
Date Sat, 31 May 2014 22:26:13 GMT
Repository: hbase
Updated Branches:
  refs/heads/0.96 bba67cb91 -> 0c374ceea
  refs/heads/0.98 f5338d7e0 -> 7257dbc58
  refs/heads/master af63fba39 -> 7f2f7c23a


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/7f2f7c23
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7f2f7c23
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7f2f7c23

Branch: refs/heads/master
Commit: 7f2f7c23a7bd274925f6438d316d8e2e8d8709d6
Parents: af63fba
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:06 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/7f2f7c23/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 5c21ec1..0e2a025 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;
         }


Mime
View raw message