org.apache.hadoop.hbase.master.procedure

Class TestMasterProcedureScheduler

java.lang.Object

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

public class TestMasterProcedureScheduler
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler	queue

Constructor Summary

Constructors

Constructor and Description
TestMasterProcedureScheduler()

Method Summary

Modifier and Type	Method and 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)
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 childProc)
void	testListLocksNamespace()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

queue

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

name

public org.junit.rules.TestName name

Constructor Detail

TestMasterProcedureScheduler

public TestMasterProcedureScheduler()

Method Detail

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

testSimpleTableOpsQueues

public void testSimpleTableOpsQueues()
                              throws Exception

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

Throws:

Exception

testCreateDeleteTableOperationsWithWriteLock

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

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

public void testVerifyRwLocks()
                       throws Exception

Verify the correct logic of RWLocks on the queue

Throws:

Exception

testVerifyNamespaceRwLocks

public void testVerifyNamespaceRwLocks()
                                throws Exception

Throws:

Exception

testVerifyNamespaceXLock

public void testVerifyNamespaceXLock()
                              throws Exception

Throws:

Exception

testXLockWaitingForExecutingSharedLockToRelease

public void testXLockWaitingForExecutingSharedLockToRelease()

testVerifyRegionLocks

public void testVerifyRegionLocks()
                           throws Exception

Throws:

Exception

testVerifySubProcRegionLocks

public void testVerifySubProcRegionLocks()
                                  throws Exception

Throws:

Exception

testInheritedRegionXLock

public void testInheritedRegionXLock()

testSuspendedProcedure

public void testSuspendedProcedure()
                            throws Exception

Throws:

Exception

generateRegionInfo

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

testParentXLockAndChildrenSharedLock

public void testParentXLockAndChildrenSharedLock()
                                          throws Exception

Throws:

Exception

testRootXLockAndChildrenSharedLock

public void testRootXLockAndChildrenSharedLock()
                                        throws Exception

Throws:

Exception

testInheritedXLockAndChildrenSharedLock

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

Throws:

Exception

testParentXLockAndChildrenXLock

public void testParentXLockAndChildrenXLock()
                                     throws Exception

Throws:

Exception

testRootXLockAndChildrenXLock

public void testRootXLockAndChildrenXLock()
                                   throws Exception

Throws:

Exception

testInheritedXLockAndChildrenXLock

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

Throws:

Exception

testYieldWithXLockHeld

public void testYieldWithXLockHeld()
                            throws Exception

Throws:

Exception

testYieldWithSharedLockHeld

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

public void testListLocksServer()
                         throws Exception

Throws:

Exception

testListLocksNamespace

public void testListLocksNamespace()
                            throws Exception

Throws:

Exception

testListLocksTable

public void testListLocksTable()
                        throws Exception

Throws:

Exception

testListLocksRegion

public void testListLocksRegion()
                         throws Exception

Throws:

Exception

testListLocksWaiting

public void testListLocksWaiting()
                          throws Exception

Throws:

Exception

testAcquireSharedLockWhileParentHoldingExclusiveLock

public void testAcquireSharedLockWhileParentHoldingExclusiveLock()