com.bigdata.ha.pipeline

Class TestSocketsDirect

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.ha.pipeline.TestSocketsDirect

All Implemented Interfaces:

junit.framework.Test

public class TestSocketsDirect
extends TestCase3

Test suite for basic socket behaviors.

Note: Tests in this suite should use direct byte buffers (non-heap NIO) buffers in order accurately model the conditions that bigdata uses for write replication. If you use heap byte[]s, then they are copied into an NIO direct buffer before they are transmitted over a socket. By using NIO direct buffers, we stay within the zero-copy pattern for sockets.

Note: Tests in this suite need to use ServerSocketChannel.open() to get access to the stream oriented listening interface for the server side of the socket. This is what is used by the HAReceiveService. It also sets up the ServerSocketChannel in a non-blocking mode and then uses the selectors to listen for available data. See HAReceiveService.

Author:

Martyn Cutcher, Bryan Thompson

Nested Class Summary

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

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.io.TestCase3

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestSocketsDirect()
TestSocketsDirect(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	testDirectSockets_exceptionIfPortNotOpen() Simple test of connecting to a server socket and the failure to connect to a port not associated with a server socket.
void	testDirectSockets_largeWrite_NotAccepted() Test of a large write on a socket to understand what happens when the write is greater than the combined size of the client send buffer and the server receive buffer and the server side of the socket is either not accepted or already shutdown.
void	testDirectSockets() The use of threaded tasks in the send/receive service makes it difficult to observer the socket state changes.
void	testMultipleClients() Confirms that multiple clients can communicate with same Server

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, assertCondition, assertEquals, assertEquals, getBytes, getPort, getRandomData, getRandomData, setUp, tearDown

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

TestSocketsDirect

public TestSocketsDirect()

TestSocketsDirect

public TestSocketsDirect(String name)

Method Detail

testDirectSockets_exceptionIfPortNotOpen

public void testDirectSockets_exceptionIfPortNotOpen()
                                              throws IOException

Simple test of connecting to a server socket and the failure to connect to a port not associated with a server socket.

Throws:

IOException

testDirectSockets_largeWrite_NotAccepted

public void testDirectSockets_largeWrite_NotAccepted()
                                              throws IOException,
                                                     InterruptedException

Test of a large write on a socket to understand what happens when the write is greater than the combined size of the client send buffer and the server receive buffer and the server side of the socket is either not accepted or already shutdown.

Throws:

IOException

InterruptedException

testDirectSockets

public void testDirectSockets()
                       throws IOException,
                              InterruptedException

The use of threaded tasks in the send/receive service makes it difficult to observer the socket state changes. So let's begin by writing some tests over the raw sockets. Note that connecting and then immediately closing the socket is perfectly okay. ...with an accept followed by a read() of -1 on the returned Socket stream.

Throws:

IOException

InterruptedException

testMultipleClients

public void testMultipleClients()
                         throws IOException

Confirms that multiple clients can communicate with same Server

Throws:

IOException