public class TestProcedureCoordinator
extends java.lang.Object
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.
Constructor and Description |
---|
TestProcedureCoordinator() |
Modifier and Type | Method and Description |
---|---|
void |
resetTest() |
void |
runCoordinatedOperation(Procedure spy,
org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.AcquireBarrierAnswer prepare,
java.lang.String... cohort) |
void |
runCoordinatedOperation(Procedure spy,
org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.AcquireBarrierAnswer prepareOperation,
org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.BarrierAnswer commitOperation,
java.lang.String... cohort) |
void |
runCoordinatedOperation(Procedure spy,
org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.BarrierAnswer commit,
java.lang.String... cohort) |
void |
runCoordinatedProcedure(Procedure spy,
java.lang.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(java.lang.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
|
public void resetTest() throws java.io.IOException
java.io.IOException
public void testThreadPoolSize() throws java.lang.Exception
java.lang.Exception
public void testUnreachableControllerDuringPrepare() throws java.lang.Exception
java.lang.Exception
public void testUnreachableControllerDuringCommit() throws java.lang.Exception
java.lang.Exception
public void testNoCohort() throws java.lang.Exception
java.lang.Exception
public void testSingleCohortOrchestration() throws java.lang.Exception
java.lang.Exception
public void testMultipleCohortOrchestration() throws java.lang.Exception
java.lang.Exception
public void runSimpleProcedure(java.lang.String... members) throws java.lang.Exception
java.lang.Exception
public void testEarlyJoiningBarrier() throws java.lang.Exception
java.lang.Exception
public void runCoordinatedProcedure(Procedure spy, java.lang.String... cohort) throws java.lang.Exception
runCoordinatedOperation(Procedure, AcquireBarrierAnswer, BarrierAnswer, String[])
.spy
- Spy on a real Procedure
cohort
- expected cohort membersjava.lang.Exception
- on failurepublic void runCoordinatedOperation(Procedure spy, org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.AcquireBarrierAnswer prepare, java.lang.String... cohort) throws java.lang.Exception
java.lang.Exception
public void runCoordinatedOperation(Procedure spy, org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.BarrierAnswer commit, java.lang.String... cohort) throws java.lang.Exception
java.lang.Exception
public void runCoordinatedOperation(Procedure spy, org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.AcquireBarrierAnswer prepareOperation, org.apache.hadoop.hbase.procedure.TestProcedureCoordinator.BarrierAnswer commitOperation, java.lang.String... cohort) throws java.lang.Exception
java.lang.Exception