Package org.apache.hadoop.hbase.ipc

Class TestRWQueueRpcExecutor

java.lang.Object

org.apache.hadoop.hbase.ipc.TestRWQueueRpcExecutor

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

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private String	testMethodName

Constructor Summary

Constructors

Constructor	Description
TestRWQueueRpcExecutor()

Method Summary

Modifier and Type	Method	Description
void	itProvidesCorrectQueuesToBalancers()
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
private void	verifyDistinct(List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>> queues, List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>>... others)

Methods inherited from class java.lang.Object

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

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

testMethodName

private String testMethodName

Constructor Details

TestRWQueueRpcExecutor

public TestRWQueueRpcExecutor()

Method Details

setUp

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

itProvidesCorrectQueuesToBalancers

@Test
public void itProvidesCorrectQueuesToBalancers()
                                        throws InterruptedException

Throws:

InterruptedException

verifyDistinct

private void verifyDistinct(List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>> queues,
 List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>>... others)
                     throws InterruptedException

Throws:

InterruptedException