1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.hadoop.hbase.ipc;
21
22 public class MetricsHBaseServerWrapperImpl implements MetricsHBaseServerWrapper {
23
24 private RpcServer server;
25
26 MetricsHBaseServerWrapperImpl(RpcServer server) {
27 this.server = server;
28 }
29
30 @Override
31 public long getTotalQueueSize() {
32 if (this.server == null) {
33 return 0;
34 }
35 return server.callQueueSize.get();
36 }
37
38 @Override
39 public int getGeneralQueueLength() {
40 if (this.server == null || this.server.getScheduler() == null) {
41 return 0;
42 }
43 return server.getScheduler().getGeneralQueueLength();
44 }
45
46 @Override
47 public int getReplicationQueueLength() {
48 if (this.server == null || this.server.getScheduler() == null) {
49 return 0;
50 }
51 return server.getScheduler().getReplicationQueueLength();
52 }
53
54 @Override
55 public int getPriorityQueueLength() {
56 if (this.server == null || this.server.getScheduler() == null) {
57 return 0;
58 }
59 return server.getScheduler().getPriorityQueueLength();
60 }
61
62 @Override
63 public int getNumOpenConnections() {
64 if (this.server == null || this.server.connectionList == null) {
65 return 0;
66 }
67 return server.connectionList.size();
68 }
69
70 @Override
71 public int getActiveRpcHandlerCount() {
72 if (this.server == null || this.server.getScheduler() == null) {
73 return 0;
74 }
75 return server.getScheduler().getActiveRpcHandlerCount();
76 }
77 }