org.apache.hadoop.hbase.procedure

Class TestProcedureMember

java.lang.Object

org.apache.hadoop.hbase.procedure.TestProcedureMember

public class TestProcedureMember
extends Object

Test the procedure member, and it's error handling mechanisms.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TestProcedureMember.EmptySubprocedure Helper Procedure who's phase for each step is just empty

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private byte[]	data
private org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher	dispatcher
private org.apache.hadoop.hbase.procedure.ProcedureMember	member
private org.apache.hadoop.hbase.procedure.SubprocedureFactory	mockBuilder
private org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher	mockListener
private org.apache.hadoop.hbase.procedure.ProcedureMemberRpcs	mockMemberComms
private String	op
private static long	POOL_KEEP_ALIVE
(package private) org.apache.hadoop.hbase.procedure.Subprocedure	spySub
private static long	TIMEOUT
private static long	WAKE_FREQUENCY

Constructor Summary

Constructors

Constructor and Description
TestProcedureMember()

Method Summary

Modifier and Type	Method and Description
private void	addCommitAnswer() Add a 'in barrier phase' response to the mock controller when it gets a acquired notification
private org.apache.hadoop.hbase.procedure.ProcedureMember	buildCohortMember() Build a member using the class level mocks
private void	buildCohortMemberPair() Setup a procedure member that returns the spied-upon Subprocedure.
void	resetTest() Reset all the mock objects
void	testCoordinatorAbort() Fail correctly if coordinator aborts the procedure.
void	testMemberCommitCommsFailure() Handle Failures if a member's commit phase succeeds but notification to coordinator fails NOTE: This is the core difference that makes this different from traditional 2PC.
void	testMemberCommitException() Handle failures if a member's commit phase fails.
void	testMemberPrepareException() Make sure we call cleanup etc, when we have an exception during Subprocedure.acquireBarrier().
void	testNoTaskToBeRunFromRequest() Test that the cohort member correctly doesn't attempt to start a task when the builder cannot correctly build a new task for the requested operation
void	testPropagateConnectionErrorBackToManager() Fail correctly on getting an external error while waiting for the prepared latch
void	testSendMemberAcquiredCommsFailure() Make sure we call cleanup etc, when we have an exception during prepare.
void	testSimpleRun() Test the normal sub procedure execution case.

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

op

private final String op

See Also:

Constant Field Values

data

private final byte[] data

mockListener

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

mockBuilder

private final org.apache.hadoop.hbase.procedure.SubprocedureFactory mockBuilder

mockMemberComms

private final org.apache.hadoop.hbase.procedure.ProcedureMemberRpcs mockMemberComms

member

private org.apache.hadoop.hbase.procedure.ProcedureMember member

dispatcher

private org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher dispatcher

spySub

org.apache.hadoop.hbase.procedure.Subprocedure spySub

Constructor Detail

TestProcedureMember

public TestProcedureMember()

Method Detail

resetTest

public void resetTest()

Reset all the mock objects

buildCohortMember

private org.apache.hadoop.hbase.procedure.ProcedureMember buildCohortMember()

Build a member using the class level mocks

Returns:

member to use for tests

buildCohortMemberPair

private void buildCohortMemberPair()
                            throws IOException

Setup a procedure member that returns the spied-upon Subprocedure.

Throws:

IOException

addCommitAnswer

private void addCommitAnswer()
                      throws IOException

Add a 'in barrier phase' response to the mock controller when it gets a acquired notification

Throws:

IOException

testSimpleRun

public void testSimpleRun()
                   throws Exception

Test the normal sub procedure execution case.

Throws:

Exception

testMemberPrepareException

public void testMemberPrepareException()
                                throws Exception

Make sure we call cleanup etc, when we have an exception during Subprocedure.acquireBarrier().

Throws:

Exception

testSendMemberAcquiredCommsFailure

public void testSendMemberAcquiredCommsFailure()
                                        throws Exception

Make sure we call cleanup etc, when we have an exception during prepare.

Throws:

Exception

testCoordinatorAbort

public void testCoordinatorAbort()
                          throws Exception

Fail correctly if coordinator aborts the procedure. The subprocedure will not interrupt a running Subprocedure.acquireBarrier() -- prepare needs to finish first, and the the abort is checked. Thus, the Subprocedure.acquireBarrier() should succeed but later get rolled back via Subprocedure.cleanup(java.lang.Exception).

Throws:

Exception

testMemberCommitException

public void testMemberCommitException()
                               throws Exception

Handle failures if a member's commit phase fails. NOTE: This is the core difference that makes this different from traditional 2PC. In true 2PC the transaction is committed just before the coordinator sends commit messages to the member. Members are then responsible for reading its TX log. This implementation actually rolls back, and thus breaks the normal TX guarantees.

Throws:

Exception

testMemberCommitCommsFailure

public void testMemberCommitCommsFailure()
                                  throws Exception

Handle Failures if a member's commit phase succeeds but notification to coordinator fails NOTE: This is the core difference that makes this different from traditional 2PC. In true 2PC the transaction is committed just before the coordinator sends commit messages to the member. Members are then responsible for reading its TX log. This implementation actually rolls back, and thus breaks the normal TX guarantees.

Throws:

Exception

testPropagateConnectionErrorBackToManager

public void testPropagateConnectionErrorBackToManager()
                                               throws Exception

Fail correctly on getting an external error while waiting for the prepared latch

Throws:

Exception - on failure

testNoTaskToBeRunFromRequest

public void testNoTaskToBeRunFromRequest()
                                  throws Exception

Test that the cohort member correctly doesn't attempt to start a task when the builder cannot correctly build a new task for the requested operation

Throws:

Exception - on failure