org.apache.hadoop.hbase

Class TestMetaTableAccessor.SpyingRpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcScheduler

org.apache.hadoop.hbase.ipc.DelegatingRpcScheduler

org.apache.hadoop.hbase.TestMetaTableAccessor.SpyingRpcScheduler

Enclosing class:

TestMetaTableAccessor

public static class TestMetaTableAccessor.SpyingRpcScheduler
extends DelegatingRpcScheduler

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
(package private) long	numPriorityCalls

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

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
SpyingRpcScheduler(org.apache.hadoop.hbase.ipc.RpcScheduler delegate)

Method Summary

Modifier and Type	Method and Description
boolean	dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)

Methods inherited from class org.apache.hadoop.hbase.ipc.DelegatingRpcScheduler

getActiveReadRpcHandlerCount, getActiveRpcHandlerCount, getActiveScanRpcHandlerCount, getActiveWriteRpcHandlerCount, getCallQueueInfo, getGeneralQueueLength, getMetaPriorityQueueLength, getNumGeneralCallsDropped, getNumLifoModeSwitches, getPriorityQueueLength, getReadQueueLength, getReplicationQueueLength, getScanQueueLength, getWriteQueueLength, init, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

numPriorityCalls

long numPriorityCalls

Constructor Detail

SpyingRpcScheduler

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

Method Detail

dispatch

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

Overrides:

dispatch in class DelegatingRpcScheduler

Throws:

IOException

InterruptedException