1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.ipc;
20
21 import java.io.IOException;
22
23 public class DelegatingRpcScheduler extends RpcScheduler {
24 protected RpcScheduler delegate;
25
26 public DelegatingRpcScheduler(RpcScheduler delegate) {
27 this.delegate = delegate;
28 }
29
30 @Override
31 public void stop() {
32 delegate.stop();
33 }
34 @Override
35 public void start() {
36 delegate.start();
37 }
38 @Override
39 public void init(Context context) {
40 delegate.init(context);
41 }
42 @Override
43 public int getReplicationQueueLength() {
44 return delegate.getReplicationQueueLength();
45 }
46
47 @Override
48 public int getPriorityQueueLength() {
49 return delegate.getPriorityQueueLength();
50 }
51
52 @Override
53 public int getGeneralQueueLength() {
54 return delegate.getGeneralQueueLength();
55 }
56
57 @Override
58 public int getActiveRpcHandlerCount() {
59 return delegate.getActiveRpcHandlerCount();
60 }
61
62 @Override
63 public boolean dispatch(CallRunner task) throws IOException, InterruptedException {
64 return delegate.dispatch(task);
65 }
66
67 @Override
68 public long getNumGeneralCallsDropped() {
69 return delegate.getNumGeneralCallsDropped();
70 }
71
72 @Override
73 public long getNumLifoModeSwitches() {
74 return delegate.getNumLifoModeSwitches();
75 }
76
77 @Override
78 public int getWriteQueueLength() {
79 return 0;
80 }
81
82 @Override
83 public int getReadQueueLength() {
84 return 0;
85 }
86
87 @Override
88 public int getScanQueueLength() {
89 return 0;
90 }
91
92 @Override
93 public int getActiveWriteRpcHandlerCount() {
94 return 0;
95 }
96
97 @Override
98 public int getActiveReadRpcHandlerCount() {
99 return 0;
100 }
101
102 @Override
103 public int getActiveScanRpcHandlerCount() {
104 return 0;
105 }
106 }