Package org.apache.hadoop.hbase.master.normalizer

Class TestRegionNormalizerWorkQueue

java.lang.Object

org.apache.hadoop.hbase.master.normalizer.TestRegionNormalizerWorkQueue

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestRegionNormalizerWorkQueue
extends Object

Tests that RegionNormalizerWorkQueue implements the contract described in its docstring.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	TestRegionNormalizerWorkQueue.Action

Constructor Summary

Constructors

Constructor	Description
TestRegionNormalizerWorkQueue()

Method Summary

Modifier and Type	Method	Description
private static <E> void	drainTo(org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<E> queue, Collection<E> dest)
void	testConcurrentPut()	Test that the uniqueness constraint is honored in the face of concurrent modification.
void	testElementUniquenessAndFIFO()
void	testPriorityAndFIFO()
void	testTake()	Test that calls to RegionNormalizerWorkQueue.take() block the requesting thread.

Methods inherited from class java.lang.Object

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

Constructor Details

TestRegionNormalizerWorkQueue

public TestRegionNormalizerWorkQueue()

Method Details

testElementUniquenessAndFIFO

@Test
public void testElementUniquenessAndFIFO()
                                  throws Exception

Throws:

Exception

testPriorityAndFIFO

@Test
public void testPriorityAndFIFO()
                         throws Exception

Throws:

Exception

testConcurrentPut

@Test
public void testConcurrentPut()
                       throws Exception

Test that the uniqueness constraint is honored in the face of concurrent modification.

Throws:

Exception

testTake

@Test
public void testTake()
              throws Exception

Test that calls to RegionNormalizerWorkQueue.take() block the requesting thread. The producing thread places new entries onto the queue following a known schedule. The consuming thread collects a time measurement between calls to take. Finally, the test makes coarse-grained assertions of the consumer's observations based on the producer's schedule.

Throws:

Exception

drainTo

private static <E> void drainTo(org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<E> queue,
 Collection<E> dest)
                         throws InterruptedException

Throws:

InterruptedException