org.apache.hadoop.hbase.master.snapshot

Class TestAssignProcedure.TargetServerBeingNulledOnUsAssignProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>

org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure

org.apache.hadoop.hbase.master.assignment.AssignProcedure

org.apache.hadoop.hbase.master.snapshot.TestAssignProcedure.TargetServerBeingNulledOnUsAssignProcedure

All Implemented Interfaces:

Comparable<org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>>, org.apache.hadoop.hbase.master.procedure.TableProcedureInterface, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.ServerName>

Enclosing class:

TestAssignProcedure

public static class TestAssignProcedure.TargetServerBeingNulledOnUsAssignProcedure
extends org.apache.hadoop.hbase.master.assignment.AssignProcedure

An override that opens up the updateTransition method inside in AssignProcedure so can call it below directly in test and mess with targetServer. Used by test TestAssignProcedure.testTargetServerBeingNulledOnUs().

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.assignment.AssignProcedure

org.apache.hadoop.hbase.master.assignment.AssignProcedure.CompareAssignProcedure

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.TableProcedureInterface

org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType

Field Summary

Fields

Modifier and Type	Field and Description
AtomicBoolean	addToRemoteDispatcherWasCalled
AtomicBoolean	remoteCallFailedWasCalled
private org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode	rsn

Fields inherited from class org.apache.hadoop.hbase.master.assignment.AssignProcedure

COMPARATOR, targetServer

Fields inherited from class org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure

aborted

Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TargetServerBeingNulledOnUsAssignProcedure(org.apache.hadoop.hbase.client.RegionInfo regionInfo, org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode rsn)

Method Summary

Modifier and Type	Method and Description
protected boolean	addToRemoteDispatcher(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.ServerName targetServer)
org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode	getRegionState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
boolean	remoteCallFailed(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.ServerName serverName, IOException exception)
boolean	updateTransition(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode regionNode) Override so can change access from protected to public.

Methods inherited from class org.apache.hadoop.hbase.master.assignment.AssignProcedure

assign, assign, deserializeStateData, finishTransition, getProcedureMetrics, getServer, getTableOperationType, isRollbackSupported, remoteCallBuild, remoteCallFailed, reportTransition, serializeStateData, startTransition, toStringClassDetails

Methods inherited from class org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure

abort, acquireLock, bypass, execute, getAttempt, getRegionInfo, getTableName, getTransitionState, holdLock, isMeta, isServerOnline, isServerOnline, releaseLock, remoteOperationCompleted, remoteOperationFailed, reportTransition, rollback, setAttempt, setOverride, setRegionInfo, setTimeoutFailure, shouldWaitClientAck, storeInDispatchedQueue, toStringState, waitInitialized

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

addStackIndex, afterReplay, beforeReplay, compareTo, completionCleanup, doExecute, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, 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, isYieldAfterExecutionStep, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, skipPersistence, toString, toStringClass, toStringDetails, toStringSimpleSB, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

addToRemoteDispatcherWasCalled

public final AtomicBoolean addToRemoteDispatcherWasCalled

remoteCallFailedWasCalled

public final AtomicBoolean remoteCallFailedWasCalled

rsn

private final org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode rsn

Constructor Detail

TargetServerBeingNulledOnUsAssignProcedure

public TargetServerBeingNulledOnUsAssignProcedure(org.apache.hadoop.hbase.client.RegionInfo regionInfo,
                                                  org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode rsn)

Method Detail

updateTransition

public boolean updateTransition(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env,
                                org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode regionNode)
                         throws IOException,
                                org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

Override so can change access from protected to public.

Overrides:

updateTransition in class org.apache.hadoop.hbase.master.assignment.AssignProcedure

Throws:

IOException

org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

addToRemoteDispatcher

protected boolean addToRemoteDispatcher(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env,
                                        org.apache.hadoop.hbase.ServerName targetServer)

Overrides:

addToRemoteDispatcher in class org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure

getRegionState

public org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode getRegionState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)

Overrides:

getRegionState in class org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure

remoteCallFailed

public boolean remoteCallFailed(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env,
                                org.apache.hadoop.hbase.ServerName serverName,
                                IOException exception)

Specified by:

remoteCallFailed in interface org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.ServerName>

Overrides:

remoteCallFailed in class org.apache.hadoop.hbase.master.assignment.RegionTransitionProcedure