org.apache.hadoop.hbase.client.locking

Class TestEntityLocks

java.lang.Object

org.apache.hadoop.hbase.client.locking.TestEntityLocks

public class TestEntityLocks
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.locking.LockServiceClient	admin
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatResponse	LOCKED_RESPONSE
private org.mockito.ArgumentCaptor<org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatRequest>	lockHeartbeatReqArgCaptor
private org.mockito.ArgumentCaptor<org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest>	lockReqArgCaptor
private static org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface	master
private long	procId
private static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatResponse	UNLOCKED_RESPONSE

Constructor Summary

Constructors

Constructor and Description
TestEntityLocks()

Method Summary

Modifier and Type	Method and Description
(package private) org.apache.hadoop.hbase.client.locking.LockServiceClient	getAdmin()
void	setUp()
void	testEntityLock() Test basic lock function - requestLock, await, unlock.
void	testEntityLockTimeout() Test that abort is called when lock times out.
void	testHeartbeatException() Test that abort is called when lockHeartbeat fails with IOException.
private boolean	waitLockTimeOut(org.apache.hadoop.hbase.client.locking.EntityLock lock, long maxWaitTimeMillis)

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

conf

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

master

private final org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface master

admin

private org.apache.hadoop.hbase.client.locking.LockServiceClient admin

lockReqArgCaptor

private org.mockito.ArgumentCaptor<org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest> lockReqArgCaptor

lockHeartbeatReqArgCaptor

private org.mockito.ArgumentCaptor<org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatRequest> lockHeartbeatReqArgCaptor

UNLOCKED_RESPONSE

private static final org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatResponse UNLOCKED_RESPONSE

LOCKED_RESPONSE

private static final org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatResponse LOCKED_RESPONSE

procId

private long procId

Constructor Detail

TestEntityLocks

public TestEntityLocks()

Method Detail

getAdmin

org.apache.hadoop.hbase.client.locking.LockServiceClient getAdmin()
                                                           throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

waitLockTimeOut

private boolean waitLockTimeOut(org.apache.hadoop.hbase.client.locking.EntityLock lock,
                                long maxWaitTimeMillis)

testEntityLock

public void testEntityLock()
                    throws Exception

Test basic lock function - requestLock, await, unlock.

Throws:

Exception

testEntityLockTimeout

public void testEntityLockTimeout()
                           throws Exception

Test that abort is called when lock times out.

Throws:

Exception

testHeartbeatException

public void testHeartbeatException()
                            throws Exception

Test that abort is called when lockHeartbeat fails with IOException.

Throws:

Exception