org.apache.hadoop.hbase.master.procedure

Class TestServerCrashProcedure

java.lang.Object

org.apache.hadoop.hbase.master.procedure.TestServerCrashProcedure

Direct Known Subclasses:

TestServerCrashProcedureWithReplicas

public class TestServerCrashProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
private long	serverCrashFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	serverCrashProcMetrics
private long	serverCrashSubmittedCount
protected HBaseTestingUtility	util

Constructor Summary

Constructors

Constructor and Description
TestServerCrashProcedure()

Method Summary

Modifier and Type	Method and Description
private void	collectMasterMetrics()
protected org.apache.hadoop.hbase.client.Table	createTable(org.apache.hadoop.hbase.TableName tableName)
private long	getSCPProcId(org.apache.hadoop.hbase.procedure2.ProcedureExecutor<?> procExec)
void	setup()
private void	setupConf(org.apache.hadoop.conf.Configuration conf)
protected void	startMiniCluster()
void	tearDown()
void	testCrashTargetRs()
private void	testRecoveryAndDoubleExecution(boolean carryingMeta, boolean doubleExecution) Run server crash procedure steps twice to test idempotency and that we are persisting all needed state.
void	testRecoveryAndDoubleExecutionOnRsWithMeta()
void	testRecoveryAndDoubleExecutionOnRsWithoutMeta()

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

util

protected HBaseTestingUtility util

serverCrashProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics serverCrashProcMetrics

serverCrashSubmittedCount

private long serverCrashSubmittedCount

serverCrashFailedCount

private long serverCrashFailedCount

Constructor Detail

TestServerCrashProcedure

public TestServerCrashProcedure()

Method Detail

setupConf

private void setupConf(org.apache.hadoop.conf.Configuration conf)

setup

public void setup()
           throws Exception

Throws:

Exception

startMiniCluster

protected void startMiniCluster()
                         throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testCrashTargetRs

public void testCrashTargetRs()
                       throws Exception

Throws:

Exception

testRecoveryAndDoubleExecutionOnRsWithMeta

public void testRecoveryAndDoubleExecutionOnRsWithMeta()
                                                throws Exception

Throws:

Exception

testRecoveryAndDoubleExecutionOnRsWithoutMeta

public void testRecoveryAndDoubleExecutionOnRsWithoutMeta()
                                                   throws Exception

Throws:

Exception

getSCPProcId

private long getSCPProcId(org.apache.hadoop.hbase.procedure2.ProcedureExecutor<?> procExec)

testRecoveryAndDoubleExecution

private void testRecoveryAndDoubleExecution(boolean carryingMeta,
                                            boolean doubleExecution)
                                     throws Exception

Run server crash procedure steps twice to test idempotency and that we are persisting all needed state.

Throws:

Exception

createTable

protected org.apache.hadoop.hbase.client.Table createTable(org.apache.hadoop.hbase.TableName tableName)
                                                    throws IOException

Throws:

IOException

collectMasterMetrics

private void collectMasterMetrics()