org.apache.hadoop.hbase.procedure

Class TestZKProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure.TestZKProcedure

public class TestZKProcedure
extends Object

Cluster-wide testing of a distributed three-phase commit using a 'real' zookeeper cluster

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static String	COORDINATOR_NODE_NAME
private static byte[]	data
private static long	KEEP_ALIVE
private static org.slf4j.Logger	LOG
private static org.mockito.verification.VerificationMode	once
private static String	opName
private static int	POOL_SIZE
private static long	TIMEOUT
private static HBaseTestingUtility	UTIL
private static long	WAKE_FREQUENCY

Constructor Summary

Constructors

Constructor and Description
TestZKProcedure()

Method Summary

Modifier and Type	Method and Description
static void	cleanupTest()
private void	closeAll(org.apache.hadoop.hbase.procedure.ProcedureCoordinator coordinator, org.apache.hadoop.hbase.procedure.ZKProcedureCoordinator coordinatorController, List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.procedure.ProcedureMember,org.apache.hadoop.hbase.procedure.ZKProcedureMemberRpcs>> cohort)
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher	newZooKeeperWatcher()
private void	runCommit(String... members)
static void	setupTest()
void	testEmptyMemberSet()
void	testMultiCohortWithMemberTimeoutDuringPrepare() Test a distributed commit with multiple cohort members, where one of the cohort members has a timeout exception during the prepare stage.
void	testMultipleMembers()
void	testSingleMember()
private void	verifyCohortSuccessful(List<String> cohortNames, org.apache.hadoop.hbase.procedure.SubprocedureFactory subprocFactory, Iterable<org.apache.hadoop.hbase.procedure.Subprocedure> cohortTasks, org.mockito.verification.VerificationMode prepare, org.mockito.verification.VerificationMode commit, org.mockito.verification.VerificationMode cleanup, org.mockito.verification.VerificationMode finish, boolean opHasError)
private void	waitAndVerifyProc(org.apache.hadoop.hbase.procedure.Procedure proc, org.mockito.verification.VerificationMode prepare, org.mockito.verification.VerificationMode commit, org.mockito.verification.VerificationMode cleanup, org.mockito.verification.VerificationMode finish, boolean opHasError) Wait for the coordinator task to complete, and verify all the mocks
private void	waitAndVerifySubproc(org.apache.hadoop.hbase.procedure.Subprocedure op, org.mockito.verification.VerificationMode prepare, org.mockito.verification.VerificationMode commit, org.mockito.verification.VerificationMode cleanup, org.mockito.verification.VerificationMode finish, boolean opHasError) Wait for the coordinator task to complete, and verify all the mocks

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

UTIL

private static HBaseTestingUtility UTIL

COORDINATOR_NODE_NAME

private static final String COORDINATOR_NODE_NAME

See Also:

Constant Field Values

KEEP_ALIVE

private static final long KEEP_ALIVE

See Also:

Constant Field Values

POOL_SIZE

private static final int POOL_SIZE

See Also:

Constant Field Values

TIMEOUT

private static final long TIMEOUT

See Also:

Constant Field Values

WAKE_FREQUENCY

private static final long WAKE_FREQUENCY

See Also:

Constant Field Values

opName

private static final String opName

See Also:

Constant Field Values

data

private static final byte[] data

once

private static final org.mockito.verification.VerificationMode once

Constructor Detail

TestZKProcedure

public TestZKProcedure()

Method Detail

setupTest

public static void setupTest()
                      throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

newZooKeeperWatcher

private static org.apache.hadoop.hbase.zookeeper.ZKWatcher newZooKeeperWatcher()
                                                                        throws IOException

Throws:

IOException

testEmptyMemberSet

public void testEmptyMemberSet()
                        throws Exception

Throws:

Exception

testSingleMember

public void testSingleMember()
                      throws Exception

Throws:

Exception

testMultipleMembers

public void testMultipleMembers()
                         throws Exception

Throws:

Exception

runCommit

private void runCommit(String... members)
                throws Exception

Throws:

Exception

testMultiCohortWithMemberTimeoutDuringPrepare

public void testMultiCohortWithMemberTimeoutDuringPrepare()
                                                   throws Exception

Test a distributed commit with multiple cohort members, where one of the cohort members has a timeout exception during the prepare stage.

Throws:

Exception

waitAndVerifyProc

private void waitAndVerifyProc(org.apache.hadoop.hbase.procedure.Procedure proc,
                               org.mockito.verification.VerificationMode prepare,
                               org.mockito.verification.VerificationMode commit,
                               org.mockito.verification.VerificationMode cleanup,
                               org.mockito.verification.VerificationMode finish,
                               boolean opHasError)
                        throws Exception

Wait for the coordinator task to complete, and verify all the mocks

Parameters:

proc - the Procedure to execute

prepare - the mock prepare

commit - the mock commit

cleanup - the mock cleanup

finish - the mock finish

opHasError - the operation error state

Throws:

Exception - on unexpected failure

waitAndVerifySubproc

private void waitAndVerifySubproc(org.apache.hadoop.hbase.procedure.Subprocedure op,
                                  org.mockito.verification.VerificationMode prepare,
                                  org.mockito.verification.VerificationMode commit,
                                  org.mockito.verification.VerificationMode cleanup,
                                  org.mockito.verification.VerificationMode finish,
                                  boolean opHasError)
                           throws Exception

Wait for the coordinator task to complete, and verify all the mocks

Parameters:

op - the Subprocedure to use

prepare - the mock prepare

commit - the mock commit

cleanup - the mock cleanup

finish - the mock finish

opHasError - the operation error state

Throws:

Exception - on unexpected failure

verifyCohortSuccessful

private void verifyCohortSuccessful(List<String> cohortNames,
                                    org.apache.hadoop.hbase.procedure.SubprocedureFactory subprocFactory,
                                    Iterable<org.apache.hadoop.hbase.procedure.Subprocedure> cohortTasks,
                                    org.mockito.verification.VerificationMode prepare,
                                    org.mockito.verification.VerificationMode commit,
                                    org.mockito.verification.VerificationMode cleanup,
                                    org.mockito.verification.VerificationMode finish,
                                    boolean opHasError)
                             throws Exception

Throws:

Exception

closeAll

private void closeAll(org.apache.hadoop.hbase.procedure.ProcedureCoordinator coordinator,
                      org.apache.hadoop.hbase.procedure.ZKProcedureCoordinator coordinatorController,
                      List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.procedure.ProcedureMember,org.apache.hadoop.hbase.procedure.ZKProcedureMemberRpcs>> cohort)
               throws IOException

Throws:

IOException