Package org.apache.hadoop.hbase.master.locking

Class TestLockProcedure

java.lang.Object

org.apache.hadoop.hbase.master.locking.TestLockProcedure

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	HEARTBEAT_TIMEOUT
private static final int	LOCAL_LOCKS_TIMEOUT
private static final org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.master.MasterRpcServices	masterRpcService
private static String	namespace
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	procExec
private static org.apache.hadoop.hbase.TableName	tableName1
private static org.apache.hadoop.hbase.TableName	tableName2
private static List<org.apache.hadoop.hbase.client.RegionInfo>	tableRegions1
private static List<org.apache.hadoop.hbase.client.RegionInfo>	tableRegions2
private String	testMethodName
protected static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestLockProcedure()

Method Summary

Modifier and Type	Method	Description
private boolean	awaitForLocked(long procId, long timeoutInMs)	Returns immediately if the lock is acquired.
static void	cleanupTest()
private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest	getNamespaceLock(String namespace, String description)
private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest	getRegionLock(List<org.apache.hadoop.hbase.client.RegionInfo> regionInfos, String description)
private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest	getTableExclusiveLock(org.apache.hadoop.hbase.TableName tableName, String description)
private long	queueLock(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lockRequest)
private void	releaseLock(long procId)
private void	sendHeartbeatAndCheckLocked(long procId, boolean isLocked)
void	setup(org.junit.jupiter.api.TestInfo testInfo)
static void	setupCluster()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
void	testAbort()
void	testLatch()
void	testLocalLockTimeout()
void	testLocalMasterLockRecovery()
void	testLockRequestValidationEmptyDescription()
void	testLockRequestValidationEmptyNamespaceName()
void	testLockRequestValidationRegionsFromDifferentTable()
void	testMultipleLocks()
private void	testRemoteLockRecovery(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lock)
void	testRemoteNamespaceLockRecovery()
void	testRemoteRegionLockRecovery()
void	testRemoteTableLockRecovery()
void	testTimeout()
void	testUpdateHeartbeatAndUnlockForNamespace()
void	testUpdateHeartbeatAndUnlockForTable()
private void	validateLockRequestException(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lockRequest, String message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

HEARTBEAT_TIMEOUT

private static final int HEARTBEAT_TIMEOUT

See Also:

• Constant Field Values

LOCAL_LOCKS_TIMEOUT

private static final int LOCAL_LOCKS_TIMEOUT

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

UTIL

protected static final HBaseTestingUtil UTIL

masterRpcService

private static org.apache.hadoop.hbase.master.MasterRpcServices masterRpcService

procExec

private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> procExec

namespace

private static String namespace

tableName1

private static org.apache.hadoop.hbase.TableName tableName1

tableRegions1

private static List<org.apache.hadoop.hbase.client.RegionInfo> tableRegions1

tableName2

private static org.apache.hadoop.hbase.TableName tableName2

tableRegions2

private static List<org.apache.hadoop.hbase.client.RegionInfo> tableRegions2

testMethodName

private String testMethodName

Constructor Details

TestLockProcedure

public TestLockProcedure()

Method Details

setupConf

private static void setupConf(org.apache.hadoop.conf.Configuration conf)

setupCluster

@BeforeAll
public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

@AfterAll
public static void cleanupTest()
                        throws Exception

Throws:

Exception

setup

@BeforeEach
public void setup(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

getNamespaceLock

private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest getNamespaceLock(String namespace,
 String description)

getTableExclusiveLock

private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest getTableExclusiveLock(org.apache.hadoop.hbase.TableName tableName,
 String description)

getRegionLock

private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest getRegionLock(List<org.apache.hadoop.hbase.client.RegionInfo> regionInfos,
 String description)

validateLockRequestException

private void validateLockRequestException(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lockRequest,
 String message)
                                   throws Exception

Throws:

Exception

testLockRequestValidationEmptyDescription

@Test
public void testLockRequestValidationEmptyDescription()
                                               throws Exception

Throws:

Exception

testLockRequestValidationEmptyNamespaceName

@Test
public void testLockRequestValidationEmptyNamespaceName()
                                                 throws Exception

Throws:

Exception

testLockRequestValidationRegionsFromDifferentTable

@Test
public void testLockRequestValidationRegionsFromDifferentTable()
                                                        throws Exception

Throws:

Exception

awaitForLocked

private boolean awaitForLocked(long procId,
 long timeoutInMs)
                        throws Exception

Returns immediately if the lock is acquired.

Throws:

TimeoutException - if lock couldn't be acquired.

Exception

queueLock

private long queueLock(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lockRequest)
                throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

sendHeartbeatAndCheckLocked

private void sendHeartbeatAndCheckLocked(long procId,
 boolean isLocked)
                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

releaseLock

private void releaseLock(long procId)
                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testUpdateHeartbeatAndUnlockForTable

@Test
public void testUpdateHeartbeatAndUnlockForTable()
                                          throws Exception

Throws:

Exception

testAbort

@Test
public void testAbort()
               throws Exception

Throws:

Exception

testUpdateHeartbeatAndUnlockForNamespace

@Test
public void testUpdateHeartbeatAndUnlockForNamespace()
                                              throws Exception

Throws:

Exception

testTimeout

@Test
public void testTimeout()
                 throws Exception

Throws:

Exception

testMultipleLocks

@Test
public void testMultipleLocks()
                       throws Exception

Throws:

Exception

testLatch

@Test
public void testLatch()
               throws Exception

Throws:

Exception

testLocalLockTimeout

@Test
public void testLocalLockTimeout()
                          throws Exception

Throws:

Exception

testRemoteLockRecovery

private void testRemoteLockRecovery(org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest lock)
                             throws Exception

Throws:

Exception

testRemoteTableLockRecovery

@Test
public void testRemoteTableLockRecovery()
                                 throws Exception

Throws:

Exception

testRemoteNamespaceLockRecovery

@Test
public void testRemoteNamespaceLockRecovery()
                                     throws Exception

Throws:

Exception

testRemoteRegionLockRecovery

@Test
public void testRemoteRegionLockRecovery()
                                  throws Exception

Throws:

Exception

testLocalMasterLockRecovery

@Test
public void testLocalMasterLockRecovery()
                                 throws Exception

Throws:

Exception