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
Modifier and TypeFieldDescriptionprivate boolean
private final String
private AtomicBoolean
private boolean
private boolean
private boolean
Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
NO_PROC_ID, NO_TIMEOUT
-
Constructor Summary
ConstructorDescriptionTestLockProcedure
(AtomicBoolean lock, String key, boolean throwYield, boolean throwSuspend) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState
protected void
deserializeStateData
(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) protected org.apache.hadoop.hbase.procedure2.Procedure[]
protected boolean
protected void
protected void
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, isRollbackSupported, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, lockedWhenLoading, needPersistence, removeStackIndex, resetPersistence, restoreLock, setAbortFailure, setChildrenLatch, setExecuted, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringDetails, toStringSimpleSB, toStringState, tryRunnable, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted
-
Field Details
-
timestamps
-
key
-
triggerRollback
-
throwSuspend
-
throwYield
-
lock
-
hasLock
-
-
Constructor Details
-
TestLockProcedure
-
-
Method Details
-
setThrowYield
-
setThrowSuspend
-
setTriggerRollback
-
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 classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
- Throws:
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
-
rollback
- Specified by:
rollback
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
acquireLock
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(TestProcedureSuspended.TestProcEnv env) - Overrides:
acquireLock
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
releaseLock
- Overrides:
releaseLock
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
holdLock
- Overrides:
holdLock
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
getTimestamps
-
toStringClassDetails
- Overrides:
toStringClassDetails
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
abort
- Specified by:
abort
in classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
serializeStateData
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Specified by:
serializeStateData
in classorg.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 classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
- Throws:
IOException
-