org.apache.hadoop.hbase.master.assignment

Class TestAssignmentManagerBase

java.lang.Object

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

Direct Known Subclasses:

TestAssignmentManager, TestHbckChore

public class TestAssignmentManagerBase
extends Object

Base class for AM test

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
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

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.master.assignment.AssignmentManager	am
protected long	assignFailedCount
protected org.apache.hadoop.hbase.procedure2.ProcedureMetrics	assignProcMetrics
protected long	assignSubmittedCount
org.junit.rules.ExpectedException	exception
protected ScheduledExecutorService	executor
private static org.slf4j.Logger	LOG
protected MockMasterServices	master
org.junit.rules.TestName	name
protected static int	NREGIONS
protected static int	NSERVERS
private static int	PROC_NTHREADS
protected NavigableMap<org.apache.hadoop.hbase.ServerName,SortedSet<byte[]>>	regionsToRegionServers
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 and Description
TestAssignmentManagerBase()

Method Summary

Modifier and Type	Method and Description
protected void	bulkSubmit(org.apache.hadoop.hbase.master.assignment.AssignProcedure[] procs)
protected void	collectAssignmentManagerMetrics()
private org.apache.hadoop.hbase.master.assignment.AssignProcedure	createAndSubmitAssign(org.apache.hadoop.hbase.TableName tableName, int regionId)
protected org.apache.hadoop.hbase.client.RegionInfo	createRegionInfo(org.apache.hadoop.hbase.TableName tableName, long regionId)
private void	doCrash(org.apache.hadoop.hbase.ServerName serverName)
private void	doRestart(org.apache.hadoop.hbase.ServerName serverName)
private 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)
void	setUp()
protected void	setupConfiguration(org.apache.hadoop.conf.Configuration conf)
private 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 Detail

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

exception

public final org.junit.rules.ExpectedException exception

PROC_NTHREADS

private 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

assignSubmittedCount

protected long assignSubmittedCount

assignFailedCount

protected long assignFailedCount

unassignSubmittedCount

protected long unassignSubmittedCount

unassignFailedCount

protected long unassignFailedCount

Constructor Detail

TestAssignmentManagerBase

public TestAssignmentManagerBase()

Method Detail

setupConfiguration

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

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUpMeta

private 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.AssignProcedure[] procs)
                   throws Exception

Throws:

Exception

createAndSubmitAssign

private org.apache.hadoop.hbase.master.assignment.AssignProcedure 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)

sendTransitionReport

private 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)
                           throws IOException

Throws:

IOException

doCrash

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

doRestart

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

collectAssignmentManagerMetrics

protected void collectAssignmentManagerMetrics()