Package org.apache.hadoop.hbase.ipc

Class TestSimpleRpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.TestSimpleRpcScheduler

@Tag("org.apache.hadoop.hbase.testclassification.RPCTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestSimpleRpcScheduler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	TestSimpleRpcScheduler.CoDelEnvironmentEdge

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private final org.apache.hadoop.hbase.ipc.RpcScheduler.Context	CONTEXT
private static final org.slf4j.Logger	LOG
private final AtomicInteger	requestProcessed
private String	testMethodName

Constructor Summary

Constructors

Constructor	Description
TestSimpleRpcScheduler()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.ipc.CallRunner	createMockTask(int priority)
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(org.junit.jupiter.api.TestInfo testInfo)
void	testBasic()
void	testCallQueueInfo()
void	testCoDelLifoWithRpcCalls()	Test LIFO switching behavior through actual RPC calls.
void	testCoDelQueueDrainAndFifoReturn()	Test that CoDel queue returns to FIFO mode after draining below threshold.
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 Details

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

testMethodName

private String testMethodName

requestProcessed

private final AtomicInteger requestProcessed

Constructor Details

TestSimpleRpcScheduler

public TestSimpleRpcScheduler()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)

testBasic

@Test
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

@Test
public void testCallQueueInfo()
                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHandlerIsolation

@Test
public void testHandlerIsolation()
                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

createMockTask

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

testRpcScheduler

@Test
public void testRpcScheduler()
                      throws Exception

Throws:

Exception

testPluggableRpcQueue

@Test
public void testPluggableRpcQueue()
                           throws Exception

Throws:

Exception

testPluggableRpcQueueWireUpWithFastPathExecutor

@Test
public void testPluggableRpcQueueWireUpWithFastPathExecutor()
                                                     throws Exception

Throws:

Exception

testPluggableRpcQueueWireUpWithoutFastPathExecutor

@Test
public void testPluggableRpcQueueWireUpWithoutFastPathExecutor()
                                                        throws Exception

Throws:

Exception

testPluggableRpcQueueCanListenToConfigurationChanges

@Test
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

@Test
public void testScanQueueWithZeroScanRatio()
                                    throws Exception

Throws:

Exception

testScanQueues

@Test
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

@Test
public void testSoftAndHardQueueLimits()
                                throws Exception

Throws:

Exception

testCoDelScheduling

@Test
public void testCoDelScheduling()
                         throws Exception

Throws:

Exception

testFastPathBalancedQueueRpcExecutorWithQueueLength0

@Test
public void testFastPathBalancedQueueRpcExecutorWithQueueLength0()
                                                          throws Exception

Throws:

Exception

testMetaRWScanQueues

@Test
public void testMetaRWScanQueues()
                          throws Exception

Throws:

Exception

getMockedCallRunner

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

Throws:

IOException

testCoDelLifoWithRpcCalls

@Test
public void testCoDelLifoWithRpcCalls()
                               throws Exception

Test LIFO switching behavior through actual RPC calls. This test verifies that when the queue fills beyond the LIFO threshold, newer calls are processed before older calls (LIFO mode).

Throws:

Exception

testCoDelQueueDrainAndFifoReturn

@Test
public void testCoDelQueueDrainAndFifoReturn()
                                      throws Exception

Test that CoDel queue returns to FIFO mode after draining below threshold.

Throws:

Exception