@InterfaceAudience.Private public class TransitPeerSyncReplicationStateProcedure extends AbstractPeerProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
StateMachineProcedure.Flow
Procedure.LockState
PeerProcedureInterface.PeerOperationType
Modifier and Type | Field and Description |
---|---|
private boolean |
enabled |
protected SyncReplicationState |
fromState |
private static org.slf4j.Logger |
LOG |
private boolean |
serial |
private SyncReplicationState |
toState |
latch, SLEEP_INTERVAL_MS, UPDATE_LAST_SEQ_ID_BATCH_SIZE
peerId
stateCount
NO_PROC_ID, NO_TIMEOUT
Constructor and Description |
---|
TransitPeerSyncReplicationStateProcedure() |
TransitPeerSyncReplicationStateProcedure(String peerId,
SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
protected void |
createDirForRemoteWAL(MasterProcedureEnv env) |
protected void |
deserializeStateData(ProcedureStateSerializer serializer)
Called on store load to allow the user to decode the previously serialized state.
|
protected StateMachineProcedure.Flow |
executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state)
called to perform a single step of the specified 'state' of the procedure
|
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState |
getInitialState()
Return the initial state object that will be used for the first call to executeFromState().
|
PeerProcedureInterface.PeerOperationType |
getPeerOperationType() |
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState |
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.PeerSyncReplicationStateTransitionState state)
Convert the Enum (or more descriptive) state object to an ordinal (or state id).
|
private void |
postTransit(MasterProcedureEnv env) |
protected void |
preTransit(MasterProcedureEnv env) |
protected void |
removeAllReplicationQueues(MasterProcedureEnv env) |
protected void |
reopenRegions(MasterProcedureEnv env) |
private void |
replayRemoteWAL(boolean serial) |
protected void |
serializeStateData(ProcedureStateSerializer serializer)
The user-level code of the procedure may have some state to persist (e.g.
|
private void |
setNextStateAfterRefreshBegin() |
private void |
setNextStateAfterRefreshEnd() |
protected void |
setPeerNewSyncReplicationState(MasterProcedureEnv env) |
protected void |
transitPeerSyncReplicationState(MasterProcedureEnv env) |
acquireLock, checkPeerModificationEnabled, enablePeer, getLatch, holdLock, refreshPeer, releaseLock, setLastPushedSequenceId, setLastPushedSequenceIdForTable
getPeerId, resetRetry, rollbackState, setTimeoutFailure, suspend, waitInitialized
abort, addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPeerId
private static final org.slf4j.Logger LOG
protected SyncReplicationState fromState
private SyncReplicationState toState
private boolean enabled
private boolean serial
public TransitPeerSyncReplicationStateProcedure()
public TransitPeerSyncReplicationStateProcedure(String peerId, SyncReplicationState state)
public PeerProcedureInterface.PeerOperationType getPeerOperationType()
protected void serializeStateData(ProcedureStateSerializer serializer) throws IOException
Procedure
serializeStateData
in class AbstractPeerNoLockProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
serializer
- stores the serializable stateIOException
protected void deserializeStateData(ProcedureStateSerializer serializer) throws IOException
Procedure
deserializeStateData
in class AbstractPeerNoLockProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
serializer
- contains the serialized stateIOException
protected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState getState(int stateId)
StateMachineProcedure
getState
in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
stateId
- the ordinal() of the state enum (or state id)protected int getStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state)
StateMachineProcedure
getStateId
in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
state
- the state enum objectprotected org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState getInitialState()
StateMachineProcedure
getInitialState
in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
protected void preTransit(MasterProcedureEnv env) throws IOException
IOException
private void postTransit(MasterProcedureEnv env) throws IOException
IOException
protected void reopenRegions(MasterProcedureEnv env)
protected void createDirForRemoteWAL(MasterProcedureEnv env) throws IOException
IOException
private void setNextStateAfterRefreshBegin()
private void setNextStateAfterRefreshEnd()
private void replayRemoteWAL(boolean serial)
protected void setPeerNewSyncReplicationState(MasterProcedureEnv env) throws ReplicationException
ReplicationException
protected void removeAllReplicationQueues(MasterProcedureEnv env) throws ReplicationException
ReplicationException
protected void transitPeerSyncReplicationState(MasterProcedureEnv env) throws ReplicationException
ReplicationException
protected StateMachineProcedure.Flow executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state) throws ProcedureSuspendedException
StateMachineProcedure
executeFromState
in class StateMachineProcedure<MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
state
- state to executeProcedureSuspendedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.