org.apache.hadoop.hbase.procedure2

Class TestProcedureEvents

java.lang.Object

org.apache.hadoop.hbase.procedure2.TestProcedureEvents

public class TestProcedureEvents
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TestProcedureEvents.TestProcEnv
static class	TestProcedureEvents.TestTimeoutEventProcedure This Event+Procedure exhibits following behavior: On procedure execute() If had enough timeouts, abort the procedure.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.fs.FileSystem	fs
private HBaseCommonTestingUtility	htu
private static org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	logDir
private TestProcedureEvents.TestProcEnv	procEnv
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureEvents.TestProcEnv>	procExecutor
private org.apache.hadoop.hbase.procedure2.store.ProcedureStore	procStore

Constructor Summary

Constructors

Constructor and Description
TestProcedureEvents()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	tearDown()
void	testTimeoutEventProcedure() Tests being able to suspend a Procedure for N timeouts and then failing.s Resets the timeout after each elapses.
void	testTimeoutEventProcedureDoubleExecution()
private void	testTimeoutEventProcedureDoubleExecution(boolean killIfSuspended)
void	testTimeoutEventProcedureDoubleExecutionKillIfSuspended()

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

procEnv

private TestProcedureEvents.TestProcEnv procEnv

procStore

private org.apache.hadoop.hbase.procedure2.store.ProcedureStore procStore

procExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureEvents.TestProcEnv> procExecutor

htu

private HBaseCommonTestingUtility htu

fs

private org.apache.hadoop.fs.FileSystem fs

logDir

private org.apache.hadoop.fs.Path logDir

Constructor Detail

TestProcedureEvents

public TestProcedureEvents()

Method Detail

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

testTimeoutEventProcedure

public void testTimeoutEventProcedure()
                               throws Exception

Tests being able to suspend a Procedure for N timeouts and then failing.s Resets the timeout after each elapses. See TestProcedureEvents.TestTimeoutEventProcedure for example of how to do this sort of trickery with the ProcedureExecutor; i.e. suspend for a while, check for a condition and if not set, suspend again, etc., ultimately failing or succeeding eventually.

Throws:

Exception

testTimeoutEventProcedureDoubleExecution

public void testTimeoutEventProcedureDoubleExecution()
                                              throws Exception

Throws:

Exception

testTimeoutEventProcedureDoubleExecutionKillIfSuspended

public void testTimeoutEventProcedureDoubleExecutionKillIfSuspended()
                                                             throws Exception

Throws:

Exception

testTimeoutEventProcedureDoubleExecution

private void testTimeoutEventProcedureDoubleExecution(boolean killIfSuspended)
                                               throws Exception

Throws:

Exception