public static class TestProcedureRecovery.TestStateMachineProcedure extends org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
Modifier and Type | Class and Description |
---|---|
(package private) static class |
TestProcedureRecovery.TestStateMachineProcedure.State |
Modifier and Type | Field and Description |
---|---|
private AtomicBoolean |
aborted |
private int |
iResult |
private boolean |
submitChildProc |
Constructor and Description |
---|
TestStateMachineProcedure() |
TestStateMachineProcedure(boolean testSubmitChildProc) |
addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
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
private AtomicBoolean aborted
private int iResult
private boolean submitChildProc
public TestStateMachineProcedure()
public TestStateMachineProcedure(boolean testSubmitChildProc)
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state)
executeFromState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected boolean isRollbackSupported(TestProcedureRecovery.TestStateMachineProcedure.State state)
isRollbackSupported
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected void rollbackState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state)
rollbackState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected TestProcedureRecovery.TestStateMachineProcedure.State getState(int stateId)
getState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected int getStateId(TestProcedureRecovery.TestStateMachineProcedure.State state)
getStateId
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected TestProcedureRecovery.TestStateMachineProcedure.State getInitialState()
getInitialState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected boolean abort(TestProcedureRecovery.TestProcEnv env)
abort
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
serializeStateData
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
IOException
protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
deserializeStateData
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.