org.apache.hadoop.hbase.regionserver

Class TestRegionServerReportForDuty

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionServerReportForDuty

public class TestRegionServerReportForDuty
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestRegionServerReportForDuty.LogCapturer
static class	TestRegionServerReportForDuty.MyRegionServer
static class	TestRegionServerReportForDuty.NeverInitializedMaster This test HMaster class will always throw ServerNotRunningYetException if checked.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread	backupMaster
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.LocalHBaseCluster	cluster
private static org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread	master
private org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread	rs
private org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread	rs2
private static long	SLEEP_INTERVAL
private HBaseTestingUtility	testUtil

Constructor Summary

Constructors

Constructor and Description
TestRegionServerReportForDuty()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	tearDown()
void	testReportForDutyBackoff() Tests region server should backoff to report for duty if master is not ready.
void	testReportForDutyWithEnvironmentEdge() Tests region sever reportForDuty with a non-default environment edge
void	testReportForDutyWithMasterChange() Tests region sever reportForDuty with backup master becomes primary master after the first master goes away.
void	testReportForDutyWithRSRpcRetry() Tests region sever reportForDuty with RS RPC retry
private void	waitForClusterOnline(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread master)
private void	waitForSecondRsStarted()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

SLEEP_INTERVAL

private static final long SLEEP_INTERVAL

See Also:

Constant Field Values

testUtil

private HBaseTestingUtility testUtil

cluster

private org.apache.hadoop.hbase.LocalHBaseCluster cluster

rs

private org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread rs

rs2

private org.apache.hadoop.hbase.util.JVMClusterUtil.RegionServerThread rs2

master

private org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread master

backupMaster

private org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread backupMaster

Constructor Detail

TestRegionServerReportForDuty

public TestRegionServerReportForDuty()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testReportForDutyBackoff

public void testReportForDutyBackoff()
                              throws IOException,
                                     InterruptedException

Tests region server should backoff to report for duty if master is not ready.

Throws:

IOException

InterruptedException

testReportForDutyWithMasterChange

public void testReportForDutyWithMasterChange()
                                       throws Exception

Tests region sever reportForDuty with backup master becomes primary master after the first master goes away.

Throws:

Exception

testReportForDutyWithRSRpcRetry

public void testReportForDutyWithRSRpcRetry()
                                     throws Exception

Tests region sever reportForDuty with RS RPC retry

Throws:

Exception

testReportForDutyWithEnvironmentEdge

public void testReportForDutyWithEnvironmentEdge()
                                          throws Exception

Tests region sever reportForDuty with a non-default environment edge

Throws:

Exception

waitForClusterOnline

private void waitForClusterOnline(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread master)
                           throws InterruptedException

Throws:

InterruptedException

waitForSecondRsStarted

private void waitForSecondRsStarted()
                             throws InterruptedException

Throws:

InterruptedException