org.apache.hadoop.hbase.master

Class TestSplitLogManager

java.lang.Object

org.apache.hadoop.hbase.master.TestSplitLogManager

public class TestSplitLogManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TestSplitLogManager.DummyMasterServices
private static interface	TestSplitLogManager.Expr

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static org.slf4j.Logger	LOG
private TestSplitLogManager.DummyMasterServices	master
private org.apache.hadoop.hbase.master.SplitLogManager	slm
private org.apache.hadoop.hbase.master.ServerManager	sm
private static HBaseTestingUtility	TEST_UTIL
private int	to
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
TestSplitLogManager()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.master.SplitLogManager.Task	findOrCreateOrphanTask(String path)
void	setup()
private String	submitTaskAndWait(org.apache.hadoop.hbase.master.SplitLogManager.TaskBatch batch, String name)
void	teardown()
void	testBatchWaitMillis()
void	testDeadWorker()
void	testEmptyLogDir()
void	testLogFilesAreArchived()
void	testMultipleResubmits()
void	testOrphanTaskAcquisition()
void	testRescanCleanup()
void	testTaskCreation() Test whether the splitlog correctly creates a task in zookeeper
void	testTaskDone()
void	testTaskErr()
void	testTaskResigned()
void	testUnassignedOrphan()
void	testUnassignedTimeout()
void	testWorkerCrash()
private void	waitForCounter(LongAdder ctr, long oldval, long newval, long timems)
private void	waitForCounter(TestSplitLogManager.Expr e, long oldval, long newval, long timems)

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

sm

private final org.apache.hadoop.hbase.master.ServerManager sm

zkw

private org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw

master

private TestSplitLogManager.DummyMasterServices master

slm

private org.apache.hadoop.hbase.master.SplitLogManager slm

conf

private org.apache.hadoop.conf.Configuration conf

to

private int to

TEST_UTIL

private static HBaseTestingUtility TEST_UTIL

Constructor Detail

TestSplitLogManager

public TestSplitLogManager()

Method Detail

setup

public void setup()
           throws Exception

Throws:

Exception

teardown

public void teardown()
              throws IOException,
                     org.apache.zookeeper.KeeperException

Throws:

IOException

org.apache.zookeeper.KeeperException

testBatchWaitMillis

public void testBatchWaitMillis()

waitForCounter

private void waitForCounter(LongAdder ctr,
                            long oldval,
                            long newval,
                            long timems)
                     throws Exception

Throws:

Exception

waitForCounter

private void waitForCounter(TestSplitLogManager.Expr e,
                            long oldval,
                            long newval,
                            long timems)
                     throws Exception

Throws:

Exception

findOrCreateOrphanTask

private org.apache.hadoop.hbase.master.SplitLogManager.Task findOrCreateOrphanTask(String path)

submitTaskAndWait

private String submitTaskAndWait(org.apache.hadoop.hbase.master.SplitLogManager.TaskBatch batch,
                                 String name)
                          throws org.apache.zookeeper.KeeperException,
                                 InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

testTaskCreation

public void testTaskCreation()
                      throws Exception

Test whether the splitlog correctly creates a task in zookeeper

Throws:

Exception

testOrphanTaskAcquisition

public void testOrphanTaskAcquisition()
                               throws Exception

Throws:

Exception

testUnassignedOrphan

public void testUnassignedOrphan()
                          throws Exception

Throws:

Exception

testMultipleResubmits

public void testMultipleResubmits()
                           throws Exception

Throws:

Exception

testRescanCleanup

public void testRescanCleanup()
                       throws Exception

Throws:

Exception

testTaskDone

public void testTaskDone()
                  throws Exception

Throws:

Exception

testTaskErr

public void testTaskErr()
                 throws Exception

Throws:

Exception

testTaskResigned

public void testTaskResigned()
                      throws Exception

Throws:

Exception

testUnassignedTimeout

public void testUnassignedTimeout()
                           throws Exception

Throws:

Exception

testDeadWorker

public void testDeadWorker()
                    throws Exception

Throws:

Exception

testWorkerCrash

public void testWorkerCrash()
                     throws Exception

Throws:

Exception

testEmptyLogDir

public void testEmptyLogDir()
                     throws Exception

Throws:

Exception

testLogFilesAreArchived

public void testLogFilesAreArchived()
                             throws Exception

Throws:

Exception