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

Class TestRegionNormalizerWorkQueue

java.lang.Object

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

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

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
org.junit.rules.TestName	testName

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testName

public org.junit.rules.TestName testName

Constructor Details

TestRegionNormalizerWorkQueue

public TestRegionNormalizerWorkQueue()

Method Details

testElementUniquenessAndFIFO

public void testElementUniquenessAndFIFO()
                                  throws Exception

Throws:

Exception

testPriorityAndFIFO

public void testPriorityAndFIFO()
                         throws Exception

Throws:

Exception

testConcurrentPut

public void testConcurrentPut()
                       throws Exception

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

Throws:

Exception

testTake

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