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

Constructor Summary

Constructors

Constructor and Description
TestProcedureMember()

Method Summary

Modifier and Type	Method and Description
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

Constructor Detail

TestProcedureMember

public TestProcedureMember()

Method Detail

resetTest

public void resetTest()

Reset all the mock objects

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#prepare -- prepare needs to finish first, and the the abort is checked. Thus, the Subprocedure#prepare 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