Package org.apache.hadoop.hbase.procedure2

Class TestYieldProcedures.TestStateMachineProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>

org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

org.apache.hadoop.hbase.procedure2.TestYieldProcedures.TestStateMachineProcedure

All Implemented Interfaces:

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

Enclosing class:

TestYieldProcedures

public static class TestYieldProcedures.TestStateMachineProcedure
extends org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo
(package private) static enum	TestYieldProcedures.TestStateMachineProcedure.State

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

org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow

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	Description
private final AtomicBoolean	aborted
private final boolean	abortOnFinalStep
private final ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo>	executionInfo
private final boolean	throwInterruptOnceOnEachStep

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

stateCount

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

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TestStateMachineProcedure()
TestStateMachineProcedure(boolean abortOnFinalStep, boolean throwInterruptOnceOnEachStep)

Method Summary

Modifier and Type	Method	Description
protected boolean	abort(TestYieldProcedures.TestProcEnv env)
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow	executeFromState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state)
ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo>	getExecutionInfo()
protected TestYieldProcedures.TestStateMachineProcedure.State	getInitialState()
protected TestYieldProcedures.TestStateMachineProcedure.State	getState(int stateId)
protected int	getStateId(TestYieldProcedures.TestStateMachineProcedure.State state)
protected boolean	isRollbackSupported(TestYieldProcedures.TestStateMachineProcedure.State state)
protected boolean	isYieldBeforeExecuteFromState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state)
protected void	rollbackState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state)

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

addChildProcedure, deserializeStateData, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, rollback, serializeStateData, setNextState, toStringState

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

acquireLock, 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, holdLock, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, lockedWhenLoading, needPersistence, releaseLock, 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, toStringClassDetails, toStringDetails, toStringSimpleSB, tryRunnable, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted

Methods inherited from class java.lang.Object

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

Field Details

executionInfo

private final ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> executionInfo

aborted

private final AtomicBoolean aborted

throwInterruptOnceOnEachStep

private final boolean throwInterruptOnceOnEachStep

abortOnFinalStep

private final boolean abortOnFinalStep

Constructor Details

TestStateMachineProcedure

public TestStateMachineProcedure()

TestStateMachineProcedure

public TestStateMachineProcedure(boolean abortOnFinalStep,
 boolean throwInterruptOnceOnEachStep)

Method Details

getExecutionInfo

public ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> getExecutionInfo()

isRollbackSupported

protected boolean isRollbackSupported(TestYieldProcedures.TestStateMachineProcedure.State state)

Overrides:

isRollbackSupported in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

executeFromState

protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(TestYieldProcedures.TestProcEnv env,
 TestYieldProcedures.TestStateMachineProcedure.State state)
                                                                                  throws InterruptedException

Specified by:

executeFromState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

Throws:

InterruptedException

rollbackState

protected void rollbackState(TestYieldProcedures.TestProcEnv env,
 TestYieldProcedures.TestStateMachineProcedure.State state)
                      throws InterruptedException

Specified by:

rollbackState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

Throws:

InterruptedException

getState

protected TestYieldProcedures.TestStateMachineProcedure.State getState(int stateId)

Specified by:

getState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

getStateId

protected int getStateId(TestYieldProcedures.TestStateMachineProcedure.State state)

Specified by:

getStateId in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

getInitialState

protected TestYieldProcedures.TestStateMachineProcedure.State getInitialState()

Specified by:

getInitialState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

isYieldBeforeExecuteFromState

protected boolean isYieldBeforeExecuteFromState(TestYieldProcedures.TestProcEnv env,
 TestYieldProcedures.TestStateMachineProcedure.State state)

Overrides:

isYieldBeforeExecuteFromState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>

abort

protected boolean abort(TestYieldProcedures.TestProcEnv env)

Overrides:

abort in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>