Package 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.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
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.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
    TestModifyPeerProcedure()
     
    TestModifyPeerProcedure(String peerId)
     

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

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

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

  • Method Details

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