com.bigdata.ha.pipeline

Class TestHASendAndReceive

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.ha.pipeline.AbstractHASendAndReceiveTestCase

com.bigdata.ha.pipeline.TestHASendAndReceive

All Implemented Interfaces:

junit.framework.Test

public class TestHASendAndReceive
extends AbstractHASendAndReceiveTestCase

Test the raw socket protocol implemented by HASendService and HAReceiveService.

Author:

martyn Cutcher

Nested Class Summary

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

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.ha.pipeline.AbstractHASendAndReceiveTestCase

chk

Fields inherited from class com.bigdata.io.TestCase3

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestHASendAndReceive()
TestHASendAndReceive(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	setUp()
protected void	tearDown()
void	testSimpleExchange() Should we expect concurrency of the Socket send and RMI? It seems that we should be able to handle it whatever the logical argument.
void	testStress() Sends a large number of random buffers, confirming successful transmission.
void	testStressDirectBuffers() Sends a large number of random buffers, confirming successful transmission.

Methods inherited from class com.bigdata.ha.pipeline.AbstractHASendAndReceiveTestCase

newHAWriteMessage, newHAWriteMessage

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, 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

TestHASendAndReceive

public TestHASendAndReceive()

TestHASendAndReceive

public TestHASendAndReceive(String name)

Method Detail

setUp

protected void setUp()
              throws Exception

Overrides:

setUp in class AbstractHASendAndReceiveTestCase

Throws:

Exception

tearDown

protected void tearDown()
                 throws Exception

Overrides:

tearDown in class AbstractHASendAndReceiveTestCase

Throws:

Exception

testSimpleExchange

public void testSimpleExchange()
                        throws InterruptedException,
                               ExecutionException,
                               TimeoutException,
                               ImmediateDownstreamReplicationException

Should we expect concurrency of the Socket send and RMI? It seems that we should be able to handle it whatever the logical argument. The only constraint should be on the processing of each pair of socket/RMI interactions. OTOH, if we are intending to process the OP_ACCEPT and OP_READ within the ReadTask that can only be processed AFTER the RMI is received, then we should not sen the socket until we have a returned FutureTask.

Throws:

ExecutionException

InterruptedException

TimeoutException

ImmediateDownstreamReplicationException

testStress

public void testStress()
                throws TimeoutException,
                       InterruptedException,
                       ExecutionException,
                       ImmediateDownstreamReplicationException

Sends a large number of random buffers, confirming successful transmission.

Throws:

TimeoutException

ExecutionException

InterruptedException

ImmediateDownstreamReplicationException

testStressDirectBuffers

public void testStressDirectBuffers()
                             throws InterruptedException

Sends a large number of random buffers, confirming successful transmission.

Throws:

InterruptedException