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

Class ModifyPeerProcedure

java.lang.Object

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

org.apache.hadoop.hbase.procedure2.StateMachineProcedure<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.PeerModificationState>

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

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, PeerProcedureInterface

Direct Known Subclasses:

AddPeerProcedure, DisablePeerProcedure, EnablePeerProcedure, RemovePeerProcedure, UpdatePeerConfigProcedure

@Private
public abstract class ModifyPeerProcedure
extends AbstractPeerProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

The base class for all replication peer related procedure except sync replication state transition.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

StateMachineProcedure.Flow

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure

Procedure.LockState

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

PeerProcedureInterface.PeerOperationType

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

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

Modifier	Constructor	Description
protected	ModifyPeerProcedure()
protected	ModifyPeerProcedure(String peerId)

Method Summary

Modifier and Type	Method	Description
protected boolean	enablePeerBeforeFinish()	The implementation class should override this method if the procedure may enter the serial related states.
protected StateMachineProcedure.Flow	executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)	called to perform a single step of the specified 'state' of the procedure
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState	getInitialState()	Return the initial state object that will be used for the first call to executeFromState().
protected ReplicationPeerConfig	getNewPeerConfig()
protected ReplicationPeerConfig	getOldPeerConfig()
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState	getState(int stateId)	Convert an ordinal (or state id) to an Enum (or more descriptive) state object.
protected int	getStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)	Convert the Enum (or more descriptive) state object to an ordinal (or state id).
private boolean	needReopen(TableStateManager tsm, TableName tn)
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState	nextStateAfterRefresh()	Implementation class can override this method.
protected abstract void	postPeerModification(MasterProcedureEnv env)	Called before we finish the procedure.
protected abstract void	prePeerModification(MasterProcedureEnv env)	Called before we start the actual processing.
protected void	releaseLatch(MasterProcedureEnv env)
protected void	reopenRegions(MasterProcedureEnv env)
private boolean	shouldFailForMigrating(MasterProcedureEnv env)
protected void	updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected abstract void	updatePeerStorage(MasterProcedureEnv env)

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

deserializeStateData, getPeerId, resetRetry, rollbackState, serializeStateData, setTimeoutFailure, suspend, waitInitialized

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

abort, addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, 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, 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, getPeerOperationType

Field Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

ModifyPeerProcedure

protected ModifyPeerProcedure()

ModifyPeerProcedure

protected ModifyPeerProcedure(String peerId)

Method Details

prePeerModification

protected abstract void prePeerModification(MasterProcedureEnv env)
                                     throws IOException,
ReplicationException,
ProcedureSuspendedException

Called before we start the actual processing. The implementation should call the pre CP hook, and also the pre-check for the peer modification.

If an IOException is thrown then we will give up and mark the procedure as failed directly. If all checks passes then the procedure can not be rolled back any more.

Throws:

IOException

ReplicationException

ProcedureSuspendedException

updatePeerStorage

protected abstract void updatePeerStorage(MasterProcedureEnv env)
                                   throws ReplicationException

Throws:

ReplicationException

postPeerModification

protected abstract void postPeerModification(MasterProcedureEnv env)
                                      throws IOException,
ReplicationException,
ProcedureSuspendedException

Called before we finish the procedure. The implementation can do some logging work, and also call the coprocessor hook if any.

Notice that, since we have already done the actual work, throwing IOException here will not fail this procedure, we will just ignore it and finish the procedure as suceeded. If ReplicationException is thrown we will retry since this usually means we fails to update the peer storage.

Throws:

IOException

ReplicationException

ProcedureSuspendedException

releaseLatch

protected void releaseLatch(MasterProcedureEnv env)

nextStateAfterRefresh

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

Implementation class can override this method. By default we will jump to POST_PEER_MODIFICATION and finish the procedure.

enablePeerBeforeFinish

protected boolean enablePeerBeforeFinish()

The implementation class should override this method if the procedure may enter the serial related states.

getOldPeerConfig

protected ReplicationPeerConfig getOldPeerConfig()

getNewPeerConfig

protected ReplicationPeerConfig getNewPeerConfig()

updateLastPushedSequenceIdForSerialPeer

protected void updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
                                                throws IOException,
ReplicationException

Throws:

IOException

ReplicationException

needReopen

private boolean needReopen(TableStateManager tsm,
 TableName tn)
                    throws IOException

Throws:

IOException

reopenRegions

protected void reopenRegions(MasterProcedureEnv env)
                      throws IOException

Throws:

IOException

shouldFailForMigrating

private boolean shouldFailForMigrating(MasterProcedureEnv env)
                                throws IOException

Throws:

IOException

executeFromState

protected StateMachineProcedure.Flow executeFromState(MasterProcedureEnv env,
 org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)
                                               throws ProcedureSuspendedException,
InterruptedException

Description copied from class: StateMachineProcedure

called to perform a single step of the specified 'state' of the procedure

Specified by:

executeFromState in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

state - state to execute

Returns:

Flow.NO_MORE_STATE if the procedure is completed, Flow.HAS_MORE_STATE if there is another step.

Throws:

ProcedureSuspendedException

InterruptedException

getState

protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState getState(int stateId)

Description copied from class: StateMachineProcedure

Convert an ordinal (or state id) to an Enum (or more descriptive) state object.

Specified by:

getState in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

Parameters:

stateId - the ordinal() of the state enum (or state id)

Returns:

the state enum object

getStateId

protected int getStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)

Description copied from class: StateMachineProcedure

Convert the Enum (or more descriptive) state object to an ordinal (or state id).

Specified by:

getStateId in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

Parameters:

state - the state enum object

Returns:

stateId the ordinal() of the state enum (or state id)

getInitialState

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

Description copied from class: StateMachineProcedure

Return the initial state object that will be used for the first call to executeFromState().

Specified by:

getInitialState in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

Returns:

the initial state enum object