org.apache.hadoop.hbase.procedure

Class TestProcedureCoordinator

java.lang.Object

org.apache.hadoop.hbase.procedure.TestProcedureCoordinator

public class TestProcedureCoordinator
extends Object

Test Procedure coordinator operation.

This only works correctly when we do class level parallelization of tests. If we do method level serialization this class will likely throw all kinds of errors.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TestProcedureCoordinator.AcquireBarrierAnswer Just tell the current coordinator that each of the nodes has prepared
private class	TestProcedureCoordinator.BarrierAnswer Just tell the current coordinator that each of the nodes has committed
private static class	TestProcedureCoordinator.OperationAnswer

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.procedure.ProcedureCoordinatorRpcs	controller
private org.apache.hadoop.hbase.procedure.ProcedureCoordinator	coordinator
private static List<String>	expected
private org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher	monitor
private static String	nodeName
private static long	POOL_KEEP_ALIVE
private static byte[]	procData
private static String	procName
private org.apache.hadoop.hbase.procedure.Procedure	task
private static long	TIMEOUT
private static long	WAKE_FREQUENCY

Constructor Summary

Constructors

Constructor and Description
TestProcedureCoordinator()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.procedure.ProcedureCoordinator	buildNewCoordinator()
void	resetTest()
void	runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy, TestProcedureCoordinator.AcquireBarrierAnswer prepare, String... cohort)
void	runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy, TestProcedureCoordinator.AcquireBarrierAnswer prepareOperation, TestProcedureCoordinator.BarrierAnswer commitOperation, String... cohort)
void	runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy, TestProcedureCoordinator.BarrierAnswer commit, String... cohort)
void	runCoordinatedProcedure(org.apache.hadoop.hbase.procedure.Procedure spy, String... cohort) Just run a procedure with the standard name and data, with not special task for the mock coordinator (it works just like a regular coordinator).
void	runSimpleProcedure(String... members)
void	testEarlyJoiningBarrier() Test that if nodes join the barrier early we still correctly handle the progress
void	testMultipleCohortOrchestration()
void	testNoCohort()
void	testSingleCohortOrchestration()
void	testThreadPoolSize() Currently we can only handle one procedure at a time.
void	testUnreachableControllerDuringCommit() Check handling a connection failure correctly if we get it during the barrier phase
void	testUnreachableControllerDuringPrepare() Check handling a connection failure correctly if we get it during the acquiring phase

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

WAKE_FREQUENCY

private static final long WAKE_FREQUENCY

See Also:

Constant Field Values

TIMEOUT

private static final long TIMEOUT

See Also:

Constant Field Values

POOL_KEEP_ALIVE

private static final long POOL_KEEP_ALIVE

See Also:

Constant Field Values

nodeName

private static final String nodeName

See Also:

Constant Field Values

procName

private static final String procName

See Also:

Constant Field Values

procData

private static final byte[] procData

expected

private static final List<String> expected

controller

private final org.apache.hadoop.hbase.procedure.ProcedureCoordinatorRpcs controller

task

private final org.apache.hadoop.hbase.procedure.Procedure task

monitor

private final org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher monitor

coordinator

private org.apache.hadoop.hbase.procedure.ProcedureCoordinator coordinator

Constructor Detail

TestProcedureCoordinator

public TestProcedureCoordinator()

Method Detail

resetTest

public void resetTest()
               throws IOException

Throws:

IOException

buildNewCoordinator

private org.apache.hadoop.hbase.procedure.ProcedureCoordinator buildNewCoordinator()

testThreadPoolSize

public void testThreadPoolSize()
                        throws Exception

Currently we can only handle one procedure at a time. This makes sure we handle that and reject submitting more.

Throws:

Exception

testUnreachableControllerDuringPrepare

public void testUnreachableControllerDuringPrepare()
                                            throws Exception

Check handling a connection failure correctly if we get it during the acquiring phase

Throws:

Exception

testUnreachableControllerDuringCommit

public void testUnreachableControllerDuringCommit()
                                           throws Exception

Check handling a connection failure correctly if we get it during the barrier phase

Throws:

Exception

testNoCohort

public void testNoCohort()
                  throws Exception

Throws:

Exception

testSingleCohortOrchestration

public void testSingleCohortOrchestration()
                                   throws Exception

Throws:

Exception

testMultipleCohortOrchestration

public void testMultipleCohortOrchestration()
                                     throws Exception

Throws:

Exception

runSimpleProcedure

public void runSimpleProcedure(String... members)
                        throws Exception

Throws:

Exception

testEarlyJoiningBarrier

public void testEarlyJoiningBarrier()
                             throws Exception

Test that if nodes join the barrier early we still correctly handle the progress

Throws:

Exception

runCoordinatedProcedure

public void runCoordinatedProcedure(org.apache.hadoop.hbase.procedure.Procedure spy,
                                    String... cohort)
                             throws Exception

Just run a procedure with the standard name and data, with not special task for the mock coordinator (it works just like a regular coordinator). For custom behavior see runCoordinatedOperation(Procedure, AcquireBarrierAnswer, BarrierAnswer, String[]) .

Parameters:

spy - Spy on a real Procedure

cohort - expected cohort members

Throws:

Exception - on failure

runCoordinatedOperation

public void runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy,
                                    TestProcedureCoordinator.AcquireBarrierAnswer prepare,
                                    String... cohort)
                             throws Exception

Throws:

Exception

runCoordinatedOperation

public void runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy,
                                    TestProcedureCoordinator.BarrierAnswer commit,
                                    String... cohort)
                             throws Exception

Throws:

Exception

runCoordinatedOperation

public void runCoordinatedOperation(org.apache.hadoop.hbase.procedure.Procedure spy,
                                    TestProcedureCoordinator.AcquireBarrierAnswer prepareOperation,
                                    TestProcedureCoordinator.BarrierAnswer commitOperation,
                                    String... cohort)
                             throws Exception

Throws:

Exception