Package org.apache.hadoop.hbase

Class TestChoreService

java.lang.Object

org.apache.hadoop.hbase.TestChoreService

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
private static final org.apache.hadoop.conf.Configuration	CONF
private int	initialCorePoolSize
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.ChoreService	service
private String	testName

Constructor Summary

Constructors

Constructor	Description
TestChoreService()

Method Summary

Modifier and Type	Method	Description
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	shutdownService(org.apache.hadoop.hbase.ChoreService service)
void	tearDown()
void	testCancelChore()
void	testChangingChoreServices(org.junit.jupiter.api.TestInfo testInfo)
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

LOG

private static final org.slf4j.Logger LOG

CONF

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

initialCorePoolSize

private int initialCorePoolSize

service

private org.apache.hadoop.hbase.ChoreService service

testName

private String testName

Constructor Details

TestChoreService

public TestChoreService()

Method Details

setUp

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

tearDown

@AfterEach
public void tearDown()

testInitialChorePrecedence

@Test
public void testInitialChorePrecedence()
                                throws InterruptedException

Throws:

InterruptedException

testCancelChore

@Test
public void testCancelChore()
                     throws InterruptedException

Throws:

InterruptedException

testScheduledChoreConstruction

@Test
public void testScheduledChoreConstruction()

testChoreServiceConstruction

@Test
public void testChoreServiceConstruction()
                                  throws InterruptedException

Throws:

InterruptedException

testFrequencyOfChores

@Test
public void testFrequencyOfChores()
                           throws InterruptedException

Throws:

InterruptedException

shutdownService

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

testForceTrigger

@Test
public void testForceTrigger()
                      throws InterruptedException

Throws:

InterruptedException

testCorePoolIncrease

@Test
public void testCorePoolIncrease()
                          throws InterruptedException

Throws:

InterruptedException

testCorePoolDecrease

@Test
public void testCorePoolDecrease()
                          throws InterruptedException

Throws:

InterruptedException

testNumberOfRunningChores

@Test
public void testNumberOfRunningChores()
                               throws InterruptedException

Throws:

InterruptedException

testNumberOfChoresMissingStartTime

@Test
public void testNumberOfChoresMissingStartTime()
                                        throws InterruptedException

Throws:

InterruptedException

testMaximumChoreServiceThreads

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

@Test
public void testChangingChoreServices(org.junit.jupiter.api.TestInfo testInfo)
                               throws InterruptedException

Throws:

InterruptedException

testStopperForScheduledChores

@Test
public void testStopperForScheduledChores()
                                   throws InterruptedException

Throws:

InterruptedException

testShutdownCancelsScheduledChores

@Test
public void testShutdownCancelsScheduledChores()
                                        throws InterruptedException

Throws:

InterruptedException

testShutdownWorksWhileChoresAreExecuting

@Test
public void testShutdownWorksWhileChoresAreExecuting()
                                              throws InterruptedException

Throws:

InterruptedException

testShutdownRejectsNewSchedules

@Test
public void testShutdownRejectsNewSchedules()
                                     throws InterruptedException

Throws:

InterruptedException

testInitialDelay

@Test
public void testInitialDelay()

for HBASE-25014

testCleanupWithStopper

@Test
public void testCleanupWithStopper()

testCleanupWithShutdown

@Test
public void testCleanupWithShutdown()