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
FieldsModifier and TypeFieldDescriptionprivate booleanprivate final Stringprivate AtomicBooleanprivate booleanprivate booleanprivate booleanFields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
NO_PROC_ID, NO_TIMEOUT -
Constructor Summary
ConstructorsConstructorDescriptionTestLockProcedure(AtomicBoolean lock, String key, boolean throwYield, boolean throwSuspend) -
Method Summary
Modifier and TypeMethodDescriptionprotected booleanprotected org.apache.hadoop.hbase.procedure2.Procedure.LockStateprotected voiddeserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) protected org.apache.hadoop.hbase.procedure2.Procedure[]protected booleanprotected voidprotected voidprotected voidserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) voidsetThrowSuspend(boolean throwSuspend) voidsetThrowYield(boolean throwYield) voidsetTriggerRollback(boolean triggerRollback) protected voidtoStringClassDetails(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:
executein classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>- Throws:
org.apache.hadoop.hbase.procedure2.ProcedureYieldExceptionorg.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
-
rollback
- Specified by:
rollbackin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
acquireLock
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(TestProcedureSuspended.TestProcEnv env) - Overrides:
acquireLockin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
releaseLock
- Overrides:
releaseLockin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
holdLock
- Overrides:
holdLockin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
getTimestamps
-
toStringClassDetails
- Overrides:
toStringClassDetailsin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
abort
- Specified by:
abortin classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
-
serializeStateData
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Specified by:
serializeStateDatain 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:
deserializeStateDatain classorg.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>- Throws:
IOException
-