Package 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	Description
private org.apache.hadoop.hbase.client.locking.LockServiceClient	admin
static final HBaseClassTestRule	CLASS_RULE
private final org.apache.hadoop.conf.Configuration	conf
private static final 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 final org.slf4j.Logger	LOG
private final org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface	master
private long	procId
private static final org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockHeartbeatResponse	UNLOCKED_RESPONSE

Constructor Summary

Constructors

Constructor	Description
TestEntityLocks()

Method Summary

Modifier and Type	Method	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 Details

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 Details

TestEntityLocks

public TestEntityLocks()

Method Details

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