Package org.apache.hadoop.hbase.master.procedure

Class TestProcedureWaitAndWake.MyPeerProcedure

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<Integer>
org.apache.hadoop.hbase.master.procedure.TestProcedureWaitAndWake.MyPeerProcedure
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:
TestProcedureWaitAndWake
public static final class TestProcedureWaitAndWake.MyPeerProcedure extends org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure<Integer>

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final class 
    TestProcedureWaitAndWake.MyPeerProcedure.MySubPeerProcedure
     

    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
    Modifier and Type
    Field
    Description
    private final CyclicBarrier
    barrier
     
    private boolean
    passedBarrier
     

    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
    MyPeerProcedure()
     
    MyPeerProcedure(CyclicBarrier barrier)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.apache.hadoop.hbase.procedure2.Procedure.LockState
    acquireLock(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
     
    protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
    executeFromState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, Integer state)
     
    protected Integer
    getInitialState()
     
    org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType
    getPeerOperationType()
     
    protected Integer
    getState(int stateId)
     
    protected int
    getStateId(Integer state)
     

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

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

  • Field Details

  • Constructor Details

  • Method Details

    • getPeerOperationType

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

    • acquireLock

      protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
      Overrides:
      acquireLock in class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure<Integer>

    • executeFromState

      protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, Integer state) throws org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException, org.apache.hadoop.hbase.procedure2.ProcedureYieldException, InterruptedException
      Specified by:
      executeFromState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>
      Throws:
      org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
      org.apache.hadoop.hbase.procedure2.ProcedureYieldException
      InterruptedException

    • getState

      protected Integer getState(int stateId)
      Specified by:
      getState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>

    • getStateId

      protected int getStateId(Integer state)
      Specified by:
      getStateId in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>

    • getInitialState

      protected Integer getInitialState()
      Specified by:
      getInitialState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>