org.apache.hadoop.hbase.client

Class TestAsyncClientPauseForCallQueueTooBig.CQTBERpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcScheduler

org.apache.hadoop.hbase.ipc.SimpleRpcScheduler

org.apache.hadoop.hbase.client.TestAsyncClientPauseForCallQueueTooBig.CQTBERpcScheduler

All Implemented Interfaces:

org.apache.hadoop.hbase.conf.ConfigurationObserver

Enclosing class:

TestAsyncClientPauseForCallQueueTooBig

public static final class TestAsyncClientPauseForCallQueueTooBig.CQTBERpcScheduler
extends org.apache.hadoop.hbase.ipc.SimpleRpcScheduler

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 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
CQTBERpcScheduler(org.apache.hadoop.conf.Configuration conf, int handlerCount, int priorityHandlerCount, int replicationHandlerCount, int metaTransitionHandler, org.apache.hadoop.hbase.ipc.PriorityFunction priority, org.apache.hadoop.hbase.Abortable server, int highPriorityLevel)

Method Summary

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

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

getActiveGeneralRpcHandlerCount, getActiveMetaPriorityRpcHandlerCount, getActivePriorityRpcHandlerCount, getActiveReadRpcHandlerCount, getActiveReplicationRpcHandlerCount, getActiveRpcHandlerCount, getActiveScanRpcHandlerCount, getActiveWriteRpcHandlerCount, getCallQueueInfo, getGeneralQueueLength, getMetaPriorityQueueLength, getNumGeneralCallsDropped, getNumLifoModeSwitches, getPriorityQueueLength, getReadQueueLength, getReplicationQueueLength, getScanQueueLength, getWriteQueueLength, init, onConfigurationChange, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CQTBERpcScheduler

public CQTBERpcScheduler(org.apache.hadoop.conf.Configuration conf,
                         int handlerCount,
                         int priorityHandlerCount,
                         int replicationHandlerCount,
                         int metaTransitionHandler,
                         org.apache.hadoop.hbase.ipc.PriorityFunction priority,
                         org.apache.hadoop.hbase.Abortable server,
                         int highPriorityLevel)

Method Detail

dispatch

public boolean dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
                 throws InterruptedException

Overrides:

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

Throws:

InterruptedException