public class TestHASendAndReceive3Nodes extends AbstractHASendAndReceiveTestCase
HASendService and
HAReceiveService against a pipeline of 3 nodes.TestCase2.MyProperties, TestCase2.RandomTypechk_randomType, log| Constructor and Description |
|---|
TestHASendAndReceive3Nodes() |
TestHASendAndReceive3Nodes(String name) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
setUp() |
protected void |
tearDown() |
void |
testChecksumError() |
void |
testPipelineChange_largeMessage()
Variant test with a message size that we expect to be larger than will be
received by the OS before it hands control back to our code through the
Selector. |
void |
testPipelineChange_smallMessage()
Unit test verifies that we can reconfigure the downstream target in an
HA3 setting.
|
void |
testSimpleExchange() |
void |
testStressDirectBuffers()
Note: This appears to work now. This test has been observed to
deadlock CI and is disabled until we finish debugging the HA pipeline and
quorums.
|
newHAWriteMessage, newHAWriteMessageassertCondition, assertCondition, assertEquals, assertEquals, getBytes, getPort, getRandomData, getRandomDataassertEquals, 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, logPropertiesassertEquals, 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, toStringpublic TestHASendAndReceive3Nodes()
public TestHASendAndReceive3Nodes(String name)
protected void setUp()
throws Exception
Sets up an HA3 pipeline [A,B,C].
setUp in class AbstractHASendAndReceiveTestCaseExceptionprotected void tearDown()
throws Exception
tearDown in class AbstractHASendAndReceiveTestCaseExceptionpublic void testSimpleExchange()
throws InterruptedException,
ExecutionException,
TimeoutException,
ImmediateDownstreamReplicationException
public void testChecksumError()
throws InterruptedException,
ExecutionException,
ImmediateDownstreamReplicationException
public void testPipelineChange_smallMessage()
throws InterruptedException,
ExecutionException,
IOException,
TimeoutException
The test begins with 3 services [A,B,C] in the pipeline. Service A writes a message to ensure that the communications channels have been setup and we verify that the message is received by B and C.
We then remove (C) from the pipeline, leaving [A,B]. Another message is written on A and we verify that it is received by B.
We then add C to the pipeline, which gives us [A,B,C]. Another message is written on A and we verify that the message is received by both B and C.
Finally, we remove B from the pipeline, leaving [A,C]. Another message is written on A and we verify that the message is received by C.
public void testPipelineChange_largeMessage()
throws InterruptedException,
ExecutionException,
IOException,
TimeoutException
Selector.public void testStressDirectBuffers()
throws InterruptedException
InterruptedExceptionCopyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.