Package org.apache.hadoop.hbase.master.procedure

Class TestMasterProcedureScheduler

java.lang.Object

org.apache.hadoop.hbase.master.procedure.TestMasterProcedureScheduler

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestMasterProcedureScheduler.TestGlobalProcedure
static class	TestMasterProcedureScheduler.TestNamespaceProcedure
static class	TestMasterProcedureScheduler.TestPeerProcedure
static class	TestMasterProcedureScheduler.TestRegionProcedure
static class	TestMasterProcedureScheduler.TestTableProcedure
static class	TestMasterProcedureScheduler.TestTableProcedureWithEvent

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private Map<Long,org.apache.hadoop.hbase.procedure2.Procedure<?>>	procedures
private org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler	queue
private String	testMethodName

Constructor Summary

Constructors

Constructor	Description
TestMasterProcedureScheduler()

Method Summary

Modifier and Type	Method	Description
private static void	assertExclusiveLock(org.apache.hadoop.hbase.procedure2.LockedResource resource, org.apache.hadoop.hbase.procedure2.Procedure<?> procedure)
private static void	assertLockResource(org.apache.hadoop.hbase.procedure2.LockedResource resource, org.apache.hadoop.hbase.procedure2.LockedResourceType resourceType, String resourceName)
private static void	assertSharedLock(org.apache.hadoop.hbase.procedure2.LockedResource resource, int lockCount)
private static org.apache.hadoop.hbase.master.locking.LockProcedure	createExclusiveLockProcedure(long procId)
private static org.apache.hadoop.hbase.master.locking.LockProcedure	createLockProcedure(org.apache.hadoop.hbase.procedure2.LockType lockType, long procId)
private static org.apache.hadoop.hbase.master.locking.LockProcedure	createSharedLockProcedure(long procId)
private static org.apache.hadoop.hbase.client.RegionInfo[]	generateRegionInfo(org.apache.hadoop.hbase.TableName tableName)
private void	releaseTableExclusiveLockAndComplete(org.apache.hadoop.hbase.procedure2.Procedure<?> proc, org.apache.hadoop.hbase.TableName tableName)
void	setTestMethod(org.junit.jupiter.api.TestInfo testInfo)
void	setUp()
void	tearDown()
void	testAcquireSharedLockWhileParentHoldingExclusiveLock()
void	testCreateDeleteTableOperationsWithReadLock()	Check that the table queue is not deletable until every procedure in-progress is completed (this is a special case for read-locks).
void	testCreateDeleteTableOperationsWithWriteLock()	Check that the table queue is not deletable until every procedure in-progress is completed (this is a special case for write-locks).
void	testInheritedRegionXLock()
private void	testInheritedXLockAndChildrenSharedLock(org.apache.hadoop.hbase.TableName tableName, TestMasterProcedureScheduler.TestTableProcedure rootProc, TestMasterProcedureScheduler.TestRegionProcedure[] childProcs)
private void	testInheritedXLockAndChildrenXLock(org.apache.hadoop.hbase.TableName tableName, TestMasterProcedureScheduler.TestTableProcedure rootProc, TestMasterProcedureScheduler.TestTableProcedure... childProcs)
void	testListLocksGlobal()
void	testListLocksNamespace()
void	testListLocksPeer()
void	testListLocksRegion()
void	testListLocksServer()
void	testListLocksTable()
void	testListLocksWaiting()
void	testParentXLockAndChildrenSharedLock()
void	testParentXLockAndChildrenXLock()
void	testRootXLockAndChildrenSharedLock()
void	testRootXLockAndChildrenXLock()
void	testSimpleTableOpsQueues()	Verify simple create/insert/fetch/delete of the table queue.
void	testSuspendedProcedure()
void	testVerifyNamespaceRwLocks()
void	testVerifyNamespaceXLock()
void	testVerifyRegionLocks()
void	testVerifyRwLocks()	Verify the correct logic of RWLocks on the queue
void	testVerifySubProcRegionLocks()
void	testXLockWaitingForExecutingSharedLockToRelease()
void	testYieldWithSharedLockHeld()
void	testYieldWithXLockHeld()

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

queue

private org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler queue

procedures

private Map<Long,org.apache.hadoop.hbase.procedure2.Procedure<?>> procedures

testMethodName

private String testMethodName

Constructor Details

TestMasterProcedureScheduler

public TestMasterProcedureScheduler()

Method Details

setTestMethod

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

setUp

@BeforeEach
public void setUp()
           throws IOException

Throws:

IOException

tearDown

@AfterEach
public void tearDown()
              throws IOException

Throws:

IOException

testSimpleTableOpsQueues

@Test
public void testSimpleTableOpsQueues()
                              throws Exception

Verify simple create/insert/fetch/delete of the table queue.

Throws:

Exception

testCreateDeleteTableOperationsWithWriteLock

@Test
public void testCreateDeleteTableOperationsWithWriteLock()
                                                  throws Exception

Check that the table queue is not deletable until every procedure in-progress is completed (this is a special case for write-locks).

Throws:

Exception

testCreateDeleteTableOperationsWithReadLock

@Test
public void testCreateDeleteTableOperationsWithReadLock()
                                                 throws Exception

Check that the table queue is not deletable until every procedure in-progress is completed (this is a special case for read-locks).

Throws:

Exception

testVerifyRwLocks

@Test
public void testVerifyRwLocks()
                       throws Exception

Verify the correct logic of RWLocks on the queue

Throws:

Exception

testVerifyNamespaceRwLocks

@Test
public void testVerifyNamespaceRwLocks()
                                throws Exception

Throws:

Exception

testVerifyNamespaceXLock

@Test
public void testVerifyNamespaceXLock()
                              throws Exception

Throws:

Exception

testXLockWaitingForExecutingSharedLockToRelease

@Test
public void testXLockWaitingForExecutingSharedLockToRelease()

testVerifyRegionLocks

@Test
public void testVerifyRegionLocks()
                           throws Exception

Throws:

Exception

testVerifySubProcRegionLocks

@Test
public void testVerifySubProcRegionLocks()
                                  throws Exception

Throws:

Exception

testInheritedRegionXLock

@Test
public void testInheritedRegionXLock()

testSuspendedProcedure

@Test
public void testSuspendedProcedure()
                            throws Exception

Throws:

Exception

generateRegionInfo

private static org.apache.hadoop.hbase.client.RegionInfo[] generateRegionInfo(org.apache.hadoop.hbase.TableName tableName)

testParentXLockAndChildrenSharedLock

@Test
public void testParentXLockAndChildrenSharedLock()
                                          throws Exception

Throws:

Exception

testRootXLockAndChildrenSharedLock

@Test
public void testRootXLockAndChildrenSharedLock()
                                        throws Exception

Throws:

Exception

releaseTableExclusiveLockAndComplete

private void releaseTableExclusiveLockAndComplete(org.apache.hadoop.hbase.procedure2.Procedure<?> proc,
 org.apache.hadoop.hbase.TableName tableName)

testInheritedXLockAndChildrenSharedLock

private void testInheritedXLockAndChildrenSharedLock(org.apache.hadoop.hbase.TableName tableName,
 TestMasterProcedureScheduler.TestTableProcedure rootProc,
 TestMasterProcedureScheduler.TestRegionProcedure[] childProcs)
                                              throws Exception

Throws:

Exception

testParentXLockAndChildrenXLock

@Test
public void testParentXLockAndChildrenXLock()
                                     throws Exception

Throws:

Exception

testRootXLockAndChildrenXLock

@Test
public void testRootXLockAndChildrenXLock()
                                   throws Exception

Throws:

Exception

testInheritedXLockAndChildrenXLock

private void testInheritedXLockAndChildrenXLock(org.apache.hadoop.hbase.TableName tableName,
 TestMasterProcedureScheduler.TestTableProcedure rootProc,
 TestMasterProcedureScheduler.TestTableProcedure... childProcs)
                                         throws Exception

Throws:

Exception

testYieldWithXLockHeld

@Test
public void testYieldWithXLockHeld()
                            throws Exception

Throws:

Exception

testYieldWithSharedLockHeld

@Test
public void testYieldWithSharedLockHeld()
                                 throws Exception

Throws:

Exception

createLockProcedure

private static org.apache.hadoop.hbase.master.locking.LockProcedure createLockProcedure(org.apache.hadoop.hbase.procedure2.LockType lockType,
 long procId)
                                                                                 throws Exception

Throws:

Exception

createExclusiveLockProcedure

private static org.apache.hadoop.hbase.master.locking.LockProcedure createExclusiveLockProcedure(long procId)
                                                                                          throws Exception

Throws:

Exception

createSharedLockProcedure

private static org.apache.hadoop.hbase.master.locking.LockProcedure createSharedLockProcedure(long procId)
                                                                                       throws Exception

Throws:

Exception

assertLockResource

private static void assertLockResource(org.apache.hadoop.hbase.procedure2.LockedResource resource,
 org.apache.hadoop.hbase.procedure2.LockedResourceType resourceType,
 String resourceName)

assertExclusiveLock

private static void assertExclusiveLock(org.apache.hadoop.hbase.procedure2.LockedResource resource,
 org.apache.hadoop.hbase.procedure2.Procedure<?> procedure)

assertSharedLock

private static void assertSharedLock(org.apache.hadoop.hbase.procedure2.LockedResource resource,
 int lockCount)

testListLocksServer

@Test
public void testListLocksServer()
                         throws Exception

Throws:

Exception

testListLocksNamespace

@Test
public void testListLocksNamespace()
                            throws Exception

Throws:

Exception

testListLocksTable

@Test
public void testListLocksTable()
                        throws Exception

Throws:

Exception

testListLocksRegion

@Test
public void testListLocksRegion()
                         throws Exception

Throws:

Exception

testListLocksPeer

@Test
public void testListLocksPeer()
                       throws Exception

Throws:

Exception

testListLocksGlobal

@Test
public void testListLocksGlobal()
                         throws Exception

Throws:

Exception

testListLocksWaiting

@Test
public void testListLocksWaiting()
                          throws Exception

Throws:

Exception

testAcquireSharedLockWhileParentHoldingExclusiveLock

@Test
public void testAcquireSharedLockWhileParentHoldingExclusiveLock()