org.apache.hadoop.hbase.ipc

Class DelegatingRpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcScheduler

org.apache.hadoop.hbase.ipc.DelegatingRpcScheduler

Direct Known Subclasses:

TestMetaTableAccessor.SpyingRpcScheduler

public class DelegatingRpcScheduler
extends org.apache.hadoop.hbase.ipc.RpcScheduler

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.RpcScheduler

org.apache.hadoop.hbase.ipc.RpcScheduler.Context

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.ipc.RpcScheduler	delegate

Fields inherited from class org.apache.hadoop.hbase.ipc.RpcScheduler

IPC_SERVER_MAX_CALLQUEUE_LENGTH, IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH

Constructor Summary

Constructors

Constructor and Description
DelegatingRpcScheduler(org.apache.hadoop.hbase.ipc.RpcScheduler delegate)

Method Summary

Modifier and Type	Method and Description
boolean	dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
int	getActiveReadRpcHandlerCount()
int	getActiveRpcHandlerCount()
int	getActiveScanRpcHandlerCount()
int	getActiveWriteRpcHandlerCount()
org.apache.hadoop.hbase.ipc.CallQueueInfo	getCallQueueInfo()
int	getGeneralQueueLength()
int	getMetaPriorityQueueLength()
long	getNumGeneralCallsDropped()
long	getNumLifoModeSwitches()
int	getPriorityQueueLength()
int	getReadQueueLength()
int	getReplicationQueueLength()
int	getScanQueueLength()
int	getWriteQueueLength()
void	init(org.apache.hadoop.hbase.ipc.RpcScheduler.Context context)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

delegate

protected org.apache.hadoop.hbase.ipc.RpcScheduler delegate

Constructor Detail

DelegatingRpcScheduler

public DelegatingRpcScheduler(org.apache.hadoop.hbase.ipc.RpcScheduler delegate)

Method Detail

stop

public void stop()

Specified by:

stop in class org.apache.hadoop.hbase.ipc.RpcScheduler

start

public void start()

Specified by:

start in class org.apache.hadoop.hbase.ipc.RpcScheduler

init

public void init(org.apache.hadoop.hbase.ipc.RpcScheduler.Context context)

Specified by:

init in class org.apache.hadoop.hbase.ipc.RpcScheduler

getReplicationQueueLength

public int getReplicationQueueLength()

Specified by:

getReplicationQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getPriorityQueueLength

public int getPriorityQueueLength()

Specified by:

getPriorityQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getGeneralQueueLength

public int getGeneralQueueLength()

Specified by:

getGeneralQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getActiveRpcHandlerCount

public int getActiveRpcHandlerCount()

Specified by:

getActiveRpcHandlerCount in class org.apache.hadoop.hbase.ipc.RpcScheduler

dispatch

public boolean dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
                 throws IOException,
                        InterruptedException

Specified by:

dispatch in class org.apache.hadoop.hbase.ipc.RpcScheduler

Throws:

IOException

InterruptedException

getMetaPriorityQueueLength

public int getMetaPriorityQueueLength()

Specified by:

getMetaPriorityQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getNumGeneralCallsDropped

public long getNumGeneralCallsDropped()

Specified by:

getNumGeneralCallsDropped in class org.apache.hadoop.hbase.ipc.RpcScheduler

getNumLifoModeSwitches

public long getNumLifoModeSwitches()

Specified by:

getNumLifoModeSwitches in class org.apache.hadoop.hbase.ipc.RpcScheduler

getWriteQueueLength

public int getWriteQueueLength()

Specified by:

getWriteQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getReadQueueLength

public int getReadQueueLength()

Specified by:

getReadQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getScanQueueLength

public int getScanQueueLength()

Specified by:

getScanQueueLength in class org.apache.hadoop.hbase.ipc.RpcScheduler

getActiveWriteRpcHandlerCount

public int getActiveWriteRpcHandlerCount()

Specified by:

getActiveWriteRpcHandlerCount in class org.apache.hadoop.hbase.ipc.RpcScheduler

getActiveReadRpcHandlerCount

public int getActiveReadRpcHandlerCount()

Specified by:

getActiveReadRpcHandlerCount in class org.apache.hadoop.hbase.ipc.RpcScheduler

getActiveScanRpcHandlerCount

public int getActiveScanRpcHandlerCount()

Specified by:

getActiveScanRpcHandlerCount in class org.apache.hadoop.hbase.ipc.RpcScheduler

getCallQueueInfo

public org.apache.hadoop.hbase.ipc.CallQueueInfo getCallQueueInfo()

Specified by:

getCallQueueInfo in class org.apache.hadoop.hbase.ipc.RpcScheduler