Package org.apache.hadoop.hbase.master

Class TestRollingRestart

java.lang.Object

org.apache.hadoop.hbase.master.TestRollingRestart

public class TestRollingRestart
extends Object

Tests the restarting of everything as done during rolling restarts.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
boolean	splitWALCoordinatedByZK
private static HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestRollingRestart()

Method Summary

Modifier and Type	Method	Description
private void	assertRegionsAssigned(SingleProcessHBaseCluster cluster, Set<String> expectedRegions)
static Collection	coordinatedByZK()
private NavigableSet<String>	getDoubleAssignedRegions(SingleProcessHBaseCluster cluster)
private int	getNumberOfOnlineRegions(SingleProcessHBaseCluster cluster)
private boolean	isDeadServerSCPExecuted(org.apache.hadoop.hbase.ServerName serverName)	Checks if the SCP of specific dead server has been executed.
private void	log(String msg)
void	testBasicRollingRestart()
private void	waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster, org.apache.hadoop.hbase.ServerName serverName)

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static HBaseTestingUtil TEST_UTIL

name

public org.junit.rules.TestName name

splitWALCoordinatedByZK

public boolean splitWALCoordinatedByZK

Constructor Details

TestRollingRestart

public TestRollingRestart()

Method Details

testBasicRollingRestart

public void testBasicRollingRestart()
                             throws Exception

Throws:

Exception

isDeadServerSCPExecuted

private boolean isDeadServerSCPExecuted(org.apache.hadoop.hbase.ServerName serverName)
                                 throws IOException

Checks if the SCP of specific dead server has been executed.

Returns:

true if the SCP of specific serverName has been executed, false if not

Throws:

IOException

waitForRSShutdownToStartAndFinish

private void waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster,
 org.apache.hadoop.hbase.ServerName serverName)
                                        throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

log

private void log(String msg)

getNumberOfOnlineRegions

private int getNumberOfOnlineRegions(SingleProcessHBaseCluster cluster)

assertRegionsAssigned

private void assertRegionsAssigned(SingleProcessHBaseCluster cluster,
 Set<String> expectedRegions)
                            throws IOException

Throws:

IOException

getDoubleAssignedRegions

private NavigableSet<String> getDoubleAssignedRegions(SingleProcessHBaseCluster cluster)
                                               throws IOException

Throws:

IOException

coordinatedByZK

public static Collection coordinatedByZK()