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, 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

  • Constructor Details

  • 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