org.apache.hadoop.hbase.master.locking

Class TestLockProcedure

java.lang.Object

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

public class TestLockProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
org.junit.rules.ExpectedException	exception
private static int	HEARTBEAT_TIMEOUT
private static int	LOCAL_LOCKS_TIMEOUT
private static 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
org.junit.rules.TestName	testName
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestLockProcedure()

Method Summary

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

exception

public final org.junit.rules.ExpectedException exception

testName

public org.junit.rules.TestName testName

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 HBaseTestingUtility 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 Detail

TestLockProcedure

public TestLockProcedure()

Method Detail

setupConf

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

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Throws:

Exception

tearDown

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

public void testLockRequestValidationEmptyDescription()
                                               throws Exception

Throws:

Exception

testLockRequestValidationEmptyNamespaceName

public void testLockRequestValidationEmptyNamespaceName()
                                                 throws Exception

Throws:

Exception

testLockRequestValidationRegionsFromDifferentTable

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

public void testUpdateHeartbeatAndUnlockForTable()
                                          throws Exception

Throws:

Exception

testAbort

public void testAbort()
               throws Exception

Throws:

Exception

testUpdateHeartbeatAndUnlockForNamespace

public void testUpdateHeartbeatAndUnlockForNamespace()
                                              throws Exception

Throws:

Exception

testTimeout

public void testTimeout()
                 throws Exception

Throws:

Exception

testMultipleLocks

public void testMultipleLocks()
                       throws Exception

Throws:

Exception

testLatch

public void testLatch()
               throws Exception

Throws:

Exception

testLocalLockTimeout

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

public void testRemoteTableLockRecovery()
                                 throws Exception

Throws:

Exception

testRemoteNamespaceLockRecovery

public void testRemoteNamespaceLockRecovery()
                                     throws Exception

Throws:

Exception

testRemoteRegionLockRecovery

public void testRemoteRegionLockRecovery()
                                  throws Exception

Throws:

Exception

testLocalMasterLockRecovery

public void testLocalMasterLockRecovery()
                                 throws Exception

Throws:

Exception