org.apache.hadoop.hbase.master.replication

Class TestModifyPeerProcedureRetryBackoff.TestModifyPeerProcedure

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.AbstractPeerProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

org.apache.hadoop.hbase.master.replication.TestModifyPeerProcedureRetryBackoff.TestModifyPeerProcedure

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:

TestModifyPeerProcedureRetryBackoff

public static class TestModifyPeerProcedureRetryBackoff.TestModifyPeerProcedure
extends org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

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.ModifyPeerProcedure

SLEEP_INTERVAL_MS, UPDATE_LAST_SEQ_ID_BATCH_SIZE

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

latch, 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 and Description
TestModifyPeerProcedure()
TestModifyPeerProcedure(String peerId)

Method Summary

Modifier and Type	Method and Description
protected <T extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>> void	addChildProcedure(T... subProcedure)
protected void	enablePeer(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected boolean	enablePeerBeforeFinish()
org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType	getPeerOperationType()
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState	nextStateAfterRefresh()
protected void	postPeerModification(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	prePeerModification(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	reopenRegions(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
private void	tryFail()
protected void	updateLastPushedSequenceIdForSerialPeer(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
protected void	updatePeerStorage(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)

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

executeFromState, getInitialState, getNewPeerConfig, getOldPeerConfig, getState, getStateId, rollbackState, setLastPushedSequenceId, setLastPushedSequenceIdForTable, setTimeoutFailure

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

acquireLock, deserializeStateData, getLatch, getPeerId, holdLock, releaseLock, serializeStateData, waitInitialized

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

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

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

addStackIndex, afterReplay, 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, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, 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

Constructor Detail

TestModifyPeerProcedure

public TestModifyPeerProcedure()

TestModifyPeerProcedure

public TestModifyPeerProcedure(String peerId)

Method Detail

getPeerOperationType

public org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType getPeerOperationType()

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.PeerModificationState>

nextStateAfterRefresh

protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState nextStateAfterRefresh()

Overrides:

nextStateAfterRefresh in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

enablePeerBeforeFinish

protected boolean enablePeerBeforeFinish()

Overrides:

enablePeerBeforeFinish in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

updateLastPushedSequenceIdForSerialPeer

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

Overrides:

updateLastPushedSequenceIdForSerialPeer in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

reopenRegions

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

Overrides:

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

Throws:

IOException

enablePeer

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

Overrides:

enablePeer in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

prePeerModification

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

Specified by:

prePeerModification in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

updatePeerStorage

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

Specified by:

updatePeerStorage in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

postPeerModification

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

Specified by:

postPeerModification in class org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException