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 and Description
static class	TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo
(package private) static class	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 and Description
private AtomicBoolean	aborted
private boolean	abortOnFinalStep
private ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo>	executionInfo
private 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 and Description
TestStateMachineProcedure()
TestStateMachineProcedure(boolean abortOnFinalStep, boolean throwInterruptOnceOnEachStep)

Method Summary

Modifier and Type	Method and 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	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, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, 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 Detail

executionInfo

private final ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> executionInfo

aborted

private final AtomicBoolean aborted

throwInterruptOnceOnEachStep

private final boolean throwInterruptOnceOnEachStep

abortOnFinalStep

private final boolean abortOnFinalStep

Constructor Detail

TestStateMachineProcedure

public TestStateMachineProcedure()

TestStateMachineProcedure

public TestStateMachineProcedure(boolean abortOnFinalStep,
                                 boolean throwInterruptOnceOnEachStep)

Method Detail

getExecutionInfo

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

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>