org.apache.hadoop.hbase.procedure2

Class TestProcedureRecovery.TestStateMachineProcedure

java.lang.Object

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

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

org.apache.hadoop.hbase.procedure2.TestProcedureRecovery.TestStateMachineProcedure

All Implemented Interfaces:

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

Enclosing class:

TestProcedureRecovery

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestProcedureRecovery.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 int	iResult
private boolean	submitChildProc

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 testSubmitChildProc)

Method Summary

Modifier and Type	Method and Description
protected boolean	abort(TestProcedureRecovery.TestProcEnv env)
protected void	deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow	executeFromState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state)
protected TestProcedureRecovery.TestStateMachineProcedure.State	getInitialState()
protected TestProcedureRecovery.TestStateMachineProcedure.State	getState(int stateId)
protected int	getStateId(TestProcedureRecovery.TestStateMachineProcedure.State state)
protected void	rollbackState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state)
protected void	serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)

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

addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, 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

aborted

private AtomicBoolean aborted

iResult

private int iResult

submitChildProc

private boolean submitChildProc

Constructor Detail

TestStateMachineProcedure

public TestStateMachineProcedure()

TestStateMachineProcedure

public TestStateMachineProcedure(boolean testSubmitChildProc)

Method Detail

executeFromState

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

Specified by:

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

rollbackState

protected void rollbackState(TestProcedureRecovery.TestProcEnv env,
                             TestProcedureRecovery.TestStateMachineProcedure.State state)

Specified by:

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

getState

protected TestProcedureRecovery.TestStateMachineProcedure.State getState(int stateId)

Specified by:

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

getStateId

protected int getStateId(TestProcedureRecovery.TestStateMachineProcedure.State state)

Specified by:

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

getInitialState

protected TestProcedureRecovery.TestStateMachineProcedure.State getInitialState()

Specified by:

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

abort

protected boolean abort(TestProcedureRecovery.TestProcEnv env)

Overrides:

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

serializeStateData

protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
                           throws IOException

Overrides:

serializeStateData in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>

Throws:

IOException

deserializeStateData

protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer)
                             throws IOException

Overrides:

deserializeStateData in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>

Throws:

IOException