com.bigdata.quorum

Class TestHA3QuorumSemantics

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.quorum.AbstractQuorumTestCase

com.bigdata.quorum.TestHA3QuorumSemantics

All Implemented Interfaces:

junit.framework.Test

public class TestHA3QuorumSemantics
extends AbstractQuorumTestCase

Test the quorum semantics for a highly available quorum of 3 services. The main points to test here are the particulars of events not observable with a singleton quorum, including that all events are perceived by all clients via the watcher for their quorum, that a service join which does not trigger a quorum meet, that a service leave which does not trigger a quorum break, a leader leave, etc.

These conditions arise because the quorum can meet with 2 out of 3 services forming a consensus. Even if the third service has the same lastCommitTime, if it votes after the other services, then it can be in the position of joining a quorum which has already met. This leads naturally into an exploration of the synchronization protocol for the persistent state of the services when joining a met quorum.

Author:

Bryan Thompson FIXME We must also test with k:=5 in order to see some situations which do not appear with k:=3 (not sure which ones off hand, but I remember noting that there are some). FIXME There will need to be unit tests for synchronization when a service wants to join a met quorum. Persistent services need to verify their root blocks in detail against the leader. If they are not identical, then the services need to synchronize rather than join. Also, services which attempt to join an already met quorum must synchronize before they can join. All of this needs to be tested, but we need to do those tests with live journals. FIXME There will need to be unit tests for hot spares.

Nested Class Summary

Nested classes/interfaces inherited from class junit.framework.TestCase2

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.quorum.AbstractQuorumTestCase

actors, clients, fixture, k, quorums

Fields inherited from class com.bigdata.io.TestCase3

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestHA3QuorumSemantics()
TestHA3QuorumSemantics(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	setUp()
void	test_memberAddRemove3() Unit test for quorum member add/remove.
void	test_pipelineAddRemove3() Unit test for write pipeline add/remove, including the PipelineState of the downstream service as maintained by the MockQuorumFixture.MockQuorumMember.
void	test_pipelineReorganization() Unit tests for pipeline reorganization when the leader is elected.
void	test_pipelineReorganization2() Variations on standard pipelineReorganization to test conditions that occasionally fail in TestHA3
void	test_serviceJoin3_simple() Unit test for service join/leave where services vote in the pipeline order so the leader does not need to reorganize the pipeline when the number of joined services reaches (k+1)/2.
void	test_serviceJoin3_simpleForceRemove()
void	test_voting3() Unit test for the voting protocol.

Methods inherited from class com.bigdata.quorum.AbstractQuorumTestCase

assertCondition, tearDown, toString

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, assertEquals, assertEquals, getBytes, getPort, getRandomData, getRandomData

Methods inherited from class junit.framework.TestCase2

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsWithinUlps, assertSameArray, assertSameArray, assertSameBigDecimal, assertSameBigDecimal, assertSameBigInteger, assertSameBigInteger, assertSameIterator, assertSameIterator, assertSameIteratorAnyOrder, assertSameIteratorAnyOrder, assertSameValue, assertSameValue, assertZeroUlps, assertZeroUlps, fail, getInnerCause, getNormalInt, getProjectBuildPath, getProperties, getRandomObject, getRandomObject, getRandomOrder, getRandomString, getTestInputStream, getTestResource, getTestResource, getUlps, getUlps, isDEBUG, isDEBUG, isINFO, isINFO, isInnerCause, logProperties

Methods inherited from class junit.framework.TestCase

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runBare, runTest, setName, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TestHA3QuorumSemantics

public TestHA3QuorumSemantics()

TestHA3QuorumSemantics

public TestHA3QuorumSemantics(String name)

Parameters:

name -

Method Detail

setUp

protected void setUp()
              throws Exception

Overrides:

setUp in class AbstractQuorumTestCase

Throws:

Exception

test_memberAddRemove3

public void test_memberAddRemove3()
                           throws InterruptedException

Unit test for quorum member add/remove.

Throws:

InterruptedException

test_pipelineAddRemove3

public void test_pipelineAddRemove3()
                             throws InterruptedException

Unit test for write pipeline add/remove, including the PipelineState of the downstream service as maintained by the MockQuorumFixture.MockQuorumMember.

Throws:

InterruptedException

test_voting3

public void test_voting3()
                  throws InterruptedException

Unit test for the voting protocol.

Throws:

InterruptedException

test_serviceJoin3_simple

public void test_serviceJoin3_simple()
                              throws InterruptedException

Unit test for service join/leave where services vote in the pipeline order so the leader does not need to reorganize the pipeline when the number of joined services reaches (k+1)/2. The quorum meets after two services cast their vote. When the third service casts its vote, it joins the met quorum.

Throws:

InterruptedException

test_serviceJoin3_simpleForceRemove

public void test_serviceJoin3_simpleForceRemove()
                                         throws InterruptedException

Throws:

InterruptedException

test_pipelineReorganization

public void test_pipelineReorganization()
                                 throws InterruptedException

Unit tests for pipeline reorganization when the leader is elected. This tests the automatic reorganization of the pipeline order where the service which will become the leader is not at the head of the pipeline. When the leader is elected, the leader must cause the pipeline to be reorganized such that the leader is at the head of the pipeline. In general, we can not control the pipeline order imposed by the leader when it reorganizes the pipeline and the leader that was aware of the network topology could chose to reorganize the pipeline in order to optimize it even though the leader was already at the head of the pipeline.

Throws:

InterruptedException

test_pipelineReorganization2

public void test_pipelineReorganization2()
                                  throws InterruptedException

Variations on standard pipelineReorganization to test conditions that occasionally fail in TestHA3

Throws:

InterruptedException