org.apache.hadoop.hbase.procedure2

Class TestProcedureSuspended.TestLockProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

org.apache.hadoop.hbase.procedure2.TestProcedureSuspended.TestLockProcedure

All Implemented Interfaces:

Comparable<org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>>

Enclosing class:

TestProcedureSuspended

public static class TestProcedureSuspended.TestLockProcedure
extends org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure

org.apache.hadoop.hbase.procedure2.Procedure.LockState

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	hasLock
private String	key
private AtomicBoolean	lock
private boolean	throwSuspend
private boolean	throwYield
private ArrayList<Long>	timestamps
private boolean	triggerRollback

Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestLockProcedure(AtomicBoolean lock, String key, boolean throwYield, boolean throwSuspend)

Method Summary

Modifier and Type	Method and Description
protected boolean	abort(TestProcedureSuspended.TestProcEnv env)
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState	acquireLock(TestProcedureSuspended.TestProcEnv env)
protected void	deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
protected org.apache.hadoop.hbase.procedure2.Procedure[]	execute(TestProcedureSuspended.TestProcEnv env)
ArrayList<Long>	getTimestamps()
protected boolean	holdLock(TestProcedureSuspended.TestProcEnv env)
protected void	releaseLock(TestProcedureSuspended.TestProcEnv env)
protected void	rollback(TestProcedureSuspended.TestProcEnv env)
protected void	serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
void	setThrowSuspend(boolean throwSuspend)
void	setThrowYield(boolean throwYield)
void	setTriggerRollback(boolean triggerRollback)
protected void	toStringClassDetails(StringBuilder builder)

Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure

addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doAcquireLock, doExecute, doReleaseLock, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcedureMetrics, getProcId, getProcIdHashCode, getProcName, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, lockedWhenLoading, needPersistence, removeStackIndex, resetPersistence, restoreLock, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, toString, toStringClass, toStringDetails, toStringSimpleSB, toStringState, tryRunnable, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted

Methods inherited from class java.lang.Object

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

Field Detail

timestamps

private final ArrayList<Long> timestamps

key

private final String key

triggerRollback

private boolean triggerRollback

throwSuspend

private boolean throwSuspend

throwYield

private boolean throwYield

lock

private AtomicBoolean lock

hasLock

private boolean hasLock

Constructor Detail

TestLockProcedure

public TestLockProcedure(AtomicBoolean lock,
                         String key,
                         boolean throwYield,
                         boolean throwSuspend)

Method Detail

setThrowYield

public void setThrowYield(boolean throwYield)

setThrowSuspend

public void setThrowSuspend(boolean throwSuspend)

setTriggerRollback

public void setTriggerRollback(boolean triggerRollback)

execute

protected org.apache.hadoop.hbase.procedure2.Procedure[] execute(TestProcedureSuspended.TestProcEnv env)
                                                          throws org.apache.hadoop.hbase.procedure2.ProcedureYieldException,
                                                                 org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

Specified by:

execute in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

Throws:

org.apache.hadoop.hbase.procedure2.ProcedureYieldException

org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

rollback

protected void rollback(TestProcedureSuspended.TestProcEnv env)

Specified by:

rollback in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

acquireLock

protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(TestProcedureSuspended.TestProcEnv env)

Overrides:

acquireLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

releaseLock

protected void releaseLock(TestProcedureSuspended.TestProcEnv env)

Overrides:

releaseLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

holdLock

protected boolean holdLock(TestProcedureSuspended.TestProcEnv env)

Overrides:

holdLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

getTimestamps

public ArrayList<Long> getTimestamps()

toStringClassDetails

protected void toStringClassDetails(StringBuilder builder)

Overrides:

toStringClassDetails in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

abort

protected boolean abort(TestProcedureSuspended.TestProcEnv env)

Specified by:

abort in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

serializeStateData

protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
                           throws IOException

Specified by:

serializeStateData in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

Throws:

IOException

deserializeStateData

protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
                             throws IOException

Specified by:

deserializeStateData in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>

Throws:

IOException