Package org.apache.hadoop.hbase.master.assignment

Class TestAssignmentManagerBase

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase

Direct Known Subclasses:

TestAMAssignWithRandExec, TestAMServerFailedOpen, TestAssignmentManager, TestHbckChore

public abstract class TestAssignmentManagerBase
extends Object

Base class for AM test.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	TestAssignmentManagerBase.CallQueueTooBigOnceRsExecutor
protected static class	TestAssignmentManagerBase.FaultyRsExecutor
protected class	TestAssignmentManagerBase.GoodRsExecutor
protected class	TestAssignmentManagerBase.HangOnCloseThenRSCrashExecutor
protected class	TestAssignmentManagerBase.HangThenRSCrashExecutor	Takes open request and then returns nothing so acts like a RS that went zombie.
protected class	TestAssignmentManagerBase.HangThenRSRestartExecutor	Takes open request and then returns nothing so acts like a RS that went zombie.
protected static interface	TestAssignmentManagerBase.MockRSExecutor
protected class	TestAssignmentManagerBase.MockRSProcedureDispatcher
protected class	TestAssignmentManagerBase.NoopRsExecutor
protected class	TestAssignmentManagerBase.RandRsExecutor
protected static class	TestAssignmentManagerBase.ServerNotYetRunningRsExecutor
protected class	TestAssignmentManagerBase.SocketTimeoutRsExecutor
protected class	TestAssignmentManagerBase.TimeoutThenCallQueueTooBigRsExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hadoop.hbase.master.assignment.AssignmentManager	am
protected long	assignFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	assignProcMetrics
protected long	assignSubmittedCount
protected long	closeFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	closeProcMetrics
protected long	closeSubmittedCount
protected ScheduledExecutorService	executor
private static final org.slf4j.Logger	LOG
protected MockMasterServices	master
protected long	moveFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	moveProcMetrics
protected long	moveSubmittedCount
org.junit.rules.TestName	name
protected int	newRsAdded
protected static final int	NREGIONS
protected static final int	NSERVERS
protected long	openFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	openProcMetrics
protected long	openSubmittedCount
protected static final int	PROC_NTHREADS
protected NavigableMap<org.apache.hadoop.hbase.ServerName,SortedSet<byte[]>>	regionsToRegionServers
protected long	reopenFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	reopenProcMetrics
protected long	reopenSubmittedCount
protected TestAssignmentManagerBase.MockRSProcedureDispatcher	rsDispatcher
protected long	unassignFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	unassignProcMetrics
protected long	unassignSubmittedCount
protected HBaseTestingUtility	util

Constructor Summary

Constructors

Constructor	Description
TestAssignmentManagerBase()

Method Summary

Modifier and Type	Method	Description
protected void	bulkSubmit(org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure[] procs)
protected final void	collectAssignmentManagerMetrics()
protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure	createAndSubmitAssign(org.apache.hadoop.hbase.TableName tableName, int regionId)
protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure	createAssignProcedure(org.apache.hadoop.hbase.client.RegionInfo hri)
protected org.apache.hadoop.hbase.client.RegionInfo	createRegionInfo(org.apache.hadoop.hbase.TableName tableName, long regionId)
protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure	createUnassignProcedure(org.apache.hadoop.hbase.client.RegionInfo hri)
protected void	doCrash(org.apache.hadoop.hbase.ServerName serverName)
protected void	doRestart(org.apache.hadoop.hbase.ServerName serverName)
protected int	getAssignMaxAttempts()
protected void	sendTransitionReport(org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionInfo regionInfo, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode state, long seqId)
void	setUp()
protected void	setupConfiguration(org.apache.hadoop.conf.Configuration conf)
protected void	setUpMeta()
protected Future<byte[]>	submitProcedure(org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> proc)
void	tearDown()
protected byte[]	waitOnFuture(Future<byte[]> future)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

PROC_NTHREADS

protected static final int PROC_NTHREADS

See Also:

• Constant Field Values

NREGIONS

protected static final int NREGIONS

See Also:

• Constant Field Values

NSERVERS

protected static final int NSERVERS

util

protected HBaseTestingUtility util

rsDispatcher

protected TestAssignmentManagerBase.MockRSProcedureDispatcher rsDispatcher

master

protected MockMasterServices master

am

protected org.apache.hadoop.hbase.master.assignment.AssignmentManager am

regionsToRegionServers

protected NavigableMap<org.apache.hadoop.hbase.ServerName,SortedSet<byte[]>> regionsToRegionServers

executor

protected ScheduledExecutorService executor

assignProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics assignProcMetrics

unassignProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics unassignProcMetrics

moveProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics moveProcMetrics

reopenProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics reopenProcMetrics

openProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics openProcMetrics

closeProcMetrics

protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics closeProcMetrics

assignSubmittedCount

protected long assignSubmittedCount

assignFailedCount

protected long assignFailedCount

unassignSubmittedCount

protected long unassignSubmittedCount

unassignFailedCount

protected long unassignFailedCount

moveSubmittedCount

protected long moveSubmittedCount

moveFailedCount

protected long moveFailedCount

reopenSubmittedCount

protected long reopenSubmittedCount

reopenFailedCount

protected long reopenFailedCount

openSubmittedCount

protected long openSubmittedCount

openFailedCount

protected long openFailedCount

closeSubmittedCount

protected long closeSubmittedCount

closeFailedCount

protected long closeFailedCount

newRsAdded

protected int newRsAdded

Constructor Details

TestAssignmentManagerBase

public TestAssignmentManagerBase()

Method Details

getAssignMaxAttempts

protected int getAssignMaxAttempts()

setupConfiguration

protected void setupConfiguration(org.apache.hadoop.conf.Configuration conf)
                           throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUpMeta

protected void setUpMeta()
                  throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

submitProcedure

protected Future<byte[]> submitProcedure(org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> proc)

waitOnFuture

protected byte[] waitOnFuture(Future<byte[]> future)
                       throws Exception

Throws:

Exception

bulkSubmit

protected void bulkSubmit(org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure[] procs)
                   throws Exception

Throws:

Exception

createAndSubmitAssign

protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure createAndSubmitAssign(org.apache.hadoop.hbase.TableName tableName,
 int regionId)

createRegionInfo

protected org.apache.hadoop.hbase.client.RegionInfo createRegionInfo(org.apache.hadoop.hbase.TableName tableName,
 long regionId)

createAssignProcedure

protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure createAssignProcedure(org.apache.hadoop.hbase.client.RegionInfo hri)

createUnassignProcedure

protected org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure createUnassignProcedure(org.apache.hadoop.hbase.client.RegionInfo hri)

sendTransitionReport

protected void sendTransitionReport(org.apache.hadoop.hbase.ServerName serverName,
 org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionInfo regionInfo,
 org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode state,
 long seqId)
                             throws IOException

Throws:

IOException

doCrash

protected void doCrash(org.apache.hadoop.hbase.ServerName serverName)

doRestart

protected void doRestart(org.apache.hadoop.hbase.ServerName serverName)

collectAssignmentManagerMetrics

protected final void collectAssignmentManagerMetrics()