public static class TestProcedureSuspended.TestLockProcedure extends org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
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 |
Constructor and Description |
---|
TestLockProcedure(AtomicBoolean lock,
String key,
boolean throwYield,
boolean throwSuspend) |
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) |
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
private final ArrayList<Long> timestamps
private boolean triggerRollback
private boolean throwSuspend
private boolean throwYield
private AtomicBoolean lock
private boolean hasLock
public TestLockProcedure(AtomicBoolean lock, String key, boolean throwYield, boolean throwSuspend)
public void setThrowYield(boolean throwYield)
public void setThrowSuspend(boolean throwSuspend)
public void setTriggerRollback(boolean triggerRollback)
protected org.apache.hadoop.hbase.procedure2.Procedure[] execute(TestProcedureSuspended.TestProcEnv env) throws org.apache.hadoop.hbase.procedure2.ProcedureYieldException, org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
execute
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
protected void rollback(TestProcedureSuspended.TestProcEnv env)
rollback
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(TestProcedureSuspended.TestProcEnv env)
acquireLock
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
protected void releaseLock(TestProcedureSuspended.TestProcEnv env)
releaseLock
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
protected boolean holdLock(TestProcedureSuspended.TestProcEnv env)
holdLock
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
public ArrayList<Long> getTimestamps()
protected void toStringClassDetails(StringBuilder builder)
toStringClassDetails
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
protected boolean abort(TestProcedureSuspended.TestProcEnv env)
abort
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
serializeStateData
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
IOException
protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
deserializeStateData
in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureSuspended.TestProcEnv>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.