You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2018/12/21 00:35:46 UTC
hbase git commit: HBASE-21610,
numOpenConnections metric is set to -1 when zero server channel exist
Repository: hbase
Updated Branches:
refs/heads/branch-2.0 b07a28c56 -> 7e51e781f
HBASE-21610, numOpenConnections metric is set to -1 when zero server channel exist
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7e51e781
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7e51e781
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7e51e781
Branch: refs/heads/branch-2.0
Commit: 7e51e781f376a5229b9d4638724153840feec981
Parents: b07a28c
Author: Pankaj <pa...@huawei.com>
Authored: Tue Dec 18 01:31:55 2018 +0530
Committer: stack <st...@apache.org>
Committed: Thu Dec 20 16:35:34 2018 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/7e51e781/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
index 8ea2057..742a728 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
@@ -169,8 +169,9 @@ public class NettyRpcServer extends RpcServer {
@Override
public int getNumOpenConnections() {
+ int channelsCount = allChannels.size();
// allChannels also contains the server channel, so exclude that from the count.
- return allChannels.size() - 1;
+ return channelsCount > 0 ? channelsCount - 1 : channelsCount;
}
@Override