org.apache.hadoop.hbase.ipc

Class TestSimpleRpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.TestSimpleRpcScheduler

public class TestSimpleRpcScheduler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestSimpleRpcScheduler.CoDelEnvironmentEdge

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.ipc.RpcScheduler.Context	CONTEXT
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor and Description
TestSimpleRpcScheduler()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.ipc.CallRunner	createMockTask()
private org.apache.hadoop.hbase.ipc.RpcScheduler	disableHandlers(org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
private void	doAnswerTaskExecution(org.apache.hadoop.hbase.ipc.CallRunner callTask, ArrayList<Integer> results, int value, int sleepInterval)
private org.apache.hadoop.hbase.ipc.CallRunner	getMockedCallRunner(long timestamp, long sleepTime)
void	setUp()
void	testBasic()
void	testCallQueueInfo()
void	testCoDelScheduling()
void	testFastPathBalancedQueueRpcExecutorWithQueueLength0()
void	testHandlerIsolation()
void	testMetaRWScanQueues()
void	testPluggableRpcQueue()
void	testPluggableRpcQueueCanListenToConfigurationChanges()
void	testPluggableRpcQueueWireUpWithFastPathExecutor()
void	testPluggableRpcQueueWireUpWithoutFastPathExecutor()
void	testRpcScheduler()
private void	testRpcScheduler(String queueType)
private void	testRpcScheduler(String queueType, String pluggableQueueClass)
void	testScanQueues()
void	testScanQueueWithZeroScanRatio()
void	testSoftAndHardQueueLimits()
private static void	waitUntilQueueEmpty(org.apache.hadoop.hbase.ipc.SimpleRpcScheduler scheduler)

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testName

public org.junit.rules.TestName testName

LOG

private static final org.slf4j.Logger LOG

CONTEXT

private final org.apache.hadoop.hbase.ipc.RpcScheduler.Context CONTEXT

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Detail

TestSimpleRpcScheduler

public TestSimpleRpcScheduler()

Method Detail

setUp

public void setUp()

testBasic

public void testBasic()
               throws IOException,
                      InterruptedException

Throws:

IOException

InterruptedException

disableHandlers

private org.apache.hadoop.hbase.ipc.RpcScheduler disableHandlers(org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)

testCallQueueInfo

public void testCallQueueInfo()
                       throws IOException,
                              InterruptedException

Throws:

IOException

InterruptedException

testHandlerIsolation

public void testHandlerIsolation()
                          throws IOException,
                                 InterruptedException

Throws:

IOException

InterruptedException

createMockTask

private org.apache.hadoop.hbase.ipc.CallRunner createMockTask()

testRpcScheduler

public void testRpcScheduler()
                      throws Exception

Throws:

Exception

testPluggableRpcQueue

public void testPluggableRpcQueue()
                           throws Exception

Throws:

Exception

testPluggableRpcQueueWireUpWithFastPathExecutor

public void testPluggableRpcQueueWireUpWithFastPathExecutor()
                                                     throws Exception

Throws:

Exception

testPluggableRpcQueueWireUpWithoutFastPathExecutor

public void testPluggableRpcQueueWireUpWithoutFastPathExecutor()
                                                        throws Exception

Throws:

Exception

testPluggableRpcQueueCanListenToConfigurationChanges

public void testPluggableRpcQueueCanListenToConfigurationChanges()
                                                          throws Exception

Throws:

Exception

testRpcScheduler

private void testRpcScheduler(String queueType)
                       throws Exception

Throws:

Exception

testRpcScheduler

private void testRpcScheduler(String queueType,
                              String pluggableQueueClass)
                       throws Exception

Throws:

Exception

testScanQueueWithZeroScanRatio

public void testScanQueueWithZeroScanRatio()
                                    throws Exception

Throws:

Exception

testScanQueues

public void testScanQueues()
                    throws Exception

Throws:

Exception

doAnswerTaskExecution

private void doAnswerTaskExecution(org.apache.hadoop.hbase.ipc.CallRunner callTask,
                                   ArrayList<Integer> results,
                                   int value,
                                   int sleepInterval)

waitUntilQueueEmpty

private static void waitUntilQueueEmpty(org.apache.hadoop.hbase.ipc.SimpleRpcScheduler scheduler)
                                 throws InterruptedException

Throws:

InterruptedException

testSoftAndHardQueueLimits

public void testSoftAndHardQueueLimits()
                                throws Exception

Throws:

Exception

testCoDelScheduling

public void testCoDelScheduling()
                         throws Exception

Throws:

Exception

testFastPathBalancedQueueRpcExecutorWithQueueLength0

public void testFastPathBalancedQueueRpcExecutorWithQueueLength0()
                                                          throws Exception

Throws:

Exception

testMetaRWScanQueues

public void testMetaRWScanQueues()
                          throws Exception

Throws:

Exception

getMockedCallRunner

private org.apache.hadoop.hbase.ipc.CallRunner getMockedCallRunner(long timestamp,
                                                                   long sleepTime)
                                                            throws IOException

Throws:

IOException