org.apache.hadoop.hbase.procedure2

Class TestProcedureRecovery.BaseTestStepProcedure

java.lang.Object

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

org.apache.hadoop.hbase.procedure2.SequentialProcedure<TestProcedureRecovery.TestProcEnv>

org.apache.hadoop.hbase.procedure2.TestProcedureRecovery.BaseTestStepProcedure

All Implemented Interfaces:

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

Direct Known Subclasses:

TestProcedureRecovery.TestMultiStepProcedure, TestProcedureRecovery.TestMultiStepProcedure.Step1Procedure, TestProcedureRecovery.TestMultiStepProcedure.Step2Procedure

Enclosing class:

TestProcedureRecovery

public static class TestProcedureRecovery.BaseTestStepProcedure
extends org.apache.hadoop.hbase.procedure2.SequentialProcedure<TestProcedureRecovery.TestProcEnv>

Nested Class Summary

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	abort
private int	step

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

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
BaseTestStepProcedure()

Method Summary

Modifier and Type	Method and Description
protected boolean	abort(TestProcedureRecovery.TestProcEnv env)
protected org.apache.hadoop.hbase.procedure2.Procedure[]	execute(TestProcedureRecovery.TestProcEnv env)
private boolean	isAborted()
protected void	rollback(TestProcedureRecovery.TestProcEnv env)

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

deserializeStateData, doExecute, doRollback, serializeStateData

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

acquireLock, addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doAcquireLock, doReleaseLock, 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, isYieldAfterExecutionStep, 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, toStringState, 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

abort

private AtomicBoolean abort

step

private int step

Constructor Detail

BaseTestStepProcedure

public BaseTestStepProcedure()

Method Detail

execute

protected org.apache.hadoop.hbase.procedure2.Procedure[] execute(TestProcedureRecovery.TestProcEnv env)
                                                          throws InterruptedException

Specified by:

execute in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureRecovery.TestProcEnv>

Throws:

InterruptedException

rollback

protected void rollback(TestProcedureRecovery.TestProcEnv env)

Specified by:

rollback in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureRecovery.TestProcEnv>

abort

protected boolean abort(TestProcedureRecovery.TestProcEnv env)

Specified by:

abort in class org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureRecovery.TestProcEnv>

isAborted

private boolean isAborted()