Package org.apache.hadoop.hbase

Class TestChoreService

java.lang.Object

org.apache.hadoop.hbase.TestChoreService

public class TestChoreService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestChoreService.CountingChore
private static class	TestChoreService.DoNothingChore	Lightweight ScheduledChore used primarily to fill the scheduling queue in tests
static class	TestChoreService.FailInitialChore	A Chore that will try to execute the initial chore a few times before succeeding.
private static class	TestChoreService.SampleStopper	Straight forward stopper implementation that is used by default when one is not provided
private static class	TestChoreService.SleepingChore
private static class	TestChoreService.SlowChore	Sleeps for longer than the scheduled period.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.apache.hadoop.conf.Configuration	CONF
private int	initialCorePoolSize
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private org.apache.hadoop.hbase.ChoreService	service

Constructor Summary

Constructors

Constructor	Description
TestChoreService()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	shutdownService(org.apache.hadoop.hbase.ChoreService service)
void	tearDown()
void	testCancelChore()
void	testChangingChoreServices()
void	testChoreServiceConstruction()
void	testCleanupWithShutdown()
void	testCleanupWithStopper()
void	testCorePoolDecrease()
void	testCorePoolIncrease()
void	testForceTrigger()
void	testFrequencyOfChores()
void	testInitialChorePrecedence()
void	testInitialDelay()	for HBASE-25014
void	testMaximumChoreServiceThreads()	ChoreServices should never have a core pool size that exceeds the number of chores that have been scheduled with the service.
void	testNumberOfChoresMissingStartTime()
void	testNumberOfRunningChores()
void	testScheduledChoreConstruction()
void	testShutdownCancelsScheduledChores()
void	testShutdownRejectsNewSchedules()
void	testShutdownWorksWhileChoresAreExecuting()
void	testStopperForScheduledChores()

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

LOG

private static final org.slf4j.Logger LOG

CONF

private static final org.apache.hadoop.conf.Configuration CONF

name

public org.junit.rules.TestName name

initialCorePoolSize

private int initialCorePoolSize

service

private org.apache.hadoop.hbase.ChoreService service

Constructor Details

TestChoreService

public TestChoreService()

Method Details

setUp

public void setUp()

tearDown

public void tearDown()

testInitialChorePrecedence

public void testInitialChorePrecedence()
                                throws InterruptedException

Throws:

InterruptedException

testCancelChore

public void testCancelChore()
                     throws InterruptedException

Throws:

InterruptedException

testScheduledChoreConstruction

public void testScheduledChoreConstruction()

testChoreServiceConstruction

public void testChoreServiceConstruction()
                                  throws InterruptedException

Throws:

InterruptedException

testFrequencyOfChores

public void testFrequencyOfChores()
                           throws InterruptedException

Throws:

InterruptedException

shutdownService

public void shutdownService(org.apache.hadoop.hbase.ChoreService service)

testForceTrigger

public void testForceTrigger()
                      throws InterruptedException

Throws:

InterruptedException

testCorePoolIncrease

public void testCorePoolIncrease()
                          throws InterruptedException

Throws:

InterruptedException

testCorePoolDecrease

public void testCorePoolDecrease()
                          throws InterruptedException

Throws:

InterruptedException

testNumberOfRunningChores

public void testNumberOfRunningChores()
                               throws InterruptedException

Throws:

InterruptedException

testNumberOfChoresMissingStartTime

public void testNumberOfChoresMissingStartTime()
                                        throws InterruptedException

Throws:

InterruptedException

testMaximumChoreServiceThreads

public void testMaximumChoreServiceThreads()
                                    throws InterruptedException

ChoreServices should never have a core pool size that exceeds the number of chores that have been scheduled with the service. For example, if 4 ScheduledChores are scheduled with a ChoreService, the number of threads in the ChoreService's core pool should never exceed 4

Throws:

InterruptedException

testChangingChoreServices

public void testChangingChoreServices()
                               throws InterruptedException

Throws:

InterruptedException

testStopperForScheduledChores

public void testStopperForScheduledChores()
                                   throws InterruptedException

Throws:

InterruptedException

testShutdownCancelsScheduledChores

public void testShutdownCancelsScheduledChores()
                                        throws InterruptedException

Throws:

InterruptedException

testShutdownWorksWhileChoresAreExecuting

public void testShutdownWorksWhileChoresAreExecuting()
                                              throws InterruptedException

Throws:

InterruptedException

testShutdownRejectsNewSchedules

public void testShutdownRejectsNewSchedules()
                                     throws InterruptedException

Throws:

InterruptedException

testInitialDelay

public void testInitialDelay()

for HBASE-25014

testCleanupWithStopper

public void testCleanupWithStopper()

testCleanupWithShutdown

public void testCleanupWithShutdown()