Package org.apache.hadoop.hbase.master.replication

Class TestTransitPeerSyncReplicationStateProcedureBackoff.TestTransitPeerSyncReplicationStateProcedure

java.lang.Object

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

org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,TState>

org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure<TState>

org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>

org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

org.apache.hadoop.hbase.master.replication.TestTransitPeerSyncReplicationStateProcedureBackoff.TestTransitPeerSyncReplicationStateProcedure

All Implemented Interfaces:

Comparable<org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>>, org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

Enclosing class:

TestTransitPeerSyncReplicationStateProcedureBackoff

public static class TestTransitPeerSyncReplicationStateProcedureBackoff.TestTransitPeerSyncReplicationStateProcedure
extends org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Nested Class Summary

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

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType

Field Summary

Fields inherited from class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

fromState

Fields inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure

latch, SLEEP_INTERVAL_MS, UPDATE_LAST_SEQ_ID_BATCH_SIZE

Fields inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure

peerId

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
TestTransitPeerSyncReplicationStateProcedure()
TestTransitPeerSyncReplicationStateProcedure(String peerId, org.apache.hadoop.hbase.replication.SyncReplicationState state)

Method Summary

Modifier and Type	Method	Description
protected <T extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>> void	addChildProcedure(T... subProcedure)
protected void	createDirForRemoteWAL(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	preTransit(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	removeAllReplicationQueues(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	reopenRegions(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	setPeerNewSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	transitPeerSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
private void	tryFail()

Methods inherited from class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

deserializeStateData, executeFromState, getInitialState, getPeerOperationType, getState, getStateId, serializeStateData

Methods inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure

acquireLock, checkPeerModificationEnabled, enablePeer, getLatch, holdLock, refreshPeer, releaseLock, setLastPushedSequenceId, setLastPushedSequenceIdForTable

Methods inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure

getPeerId, resetRetry, rollbackState, setTimeoutFailure, suspend, waitInitialized

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

abort, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState

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

addStackIndex, afterExec, afterReplay, beforeExec, beforeReplay, bypass, compareTo, completionCleanup, doExecute, 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, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, removeStackIndex, setAbortFailure, setChildrenLatch, setExecuted, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

getPeerId

Constructor Details

TestTransitPeerSyncReplicationStateProcedure

public TestTransitPeerSyncReplicationStateProcedure()

TestTransitPeerSyncReplicationStateProcedure

public TestTransitPeerSyncReplicationStateProcedure(String peerId,
 org.apache.hadoop.hbase.replication.SyncReplicationState state)

Method Details

tryFail

private void tryFail()
              throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

addChildProcedure

protected <T extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>>
void addChildProcedure(T... subProcedure)

Overrides:

addChildProcedure in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>

preTransit

protected void preTransit(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
                   throws IOException

Overrides:

preTransit in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Throws:

IOException

setPeerNewSyncReplicationState

protected void setPeerNewSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
                                       throws org.apache.hadoop.hbase.replication.ReplicationException

Overrides:

setPeerNewSyncReplicationState in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

removeAllReplicationQueues

protected void removeAllReplicationQueues(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
                                   throws org.apache.hadoop.hbase.replication.ReplicationException

Overrides:

removeAllReplicationQueues in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

reopenRegions

protected void reopenRegions(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)

Overrides:

reopenRegions in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

transitPeerSyncReplicationState

protected void transitPeerSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
                                        throws org.apache.hadoop.hbase.replication.ReplicationException

Overrides:

transitPeerSyncReplicationState in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

createDirForRemoteWAL

protected void createDirForRemoteWAL(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
                              throws IOException

Overrides:

createDirForRemoteWAL in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure

Throws:

IOException