com.bigdata.io.writecache

Class TestWriteCacheServiceLifetime

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.io.writecache.TestWriteCacheServiceLifetime

All Implemented Interfaces:

junit.framework.Test

public class TestWriteCacheServiceLifetime
extends TestCase3

These tests exercise the lifetime semantics of a WriteCacheService. Specifically they stress the initialization and shutdown of services, and concurrent interactions.

Author:

Martyn Cutcher

Nested Class Summary

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

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields

Modifier and Type	Field and Description
protected Random	r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestWriteCacheServiceLifetime()
TestWriteCacheServiceLifetime(String name)

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	getRandomData() Returns random data that will fit in N bytes.
ByteBuffer	getRandomData(int nbytes) Returns random data that will fit in nbytes.
void	testSimpleStartStopRWService()
void	testSimpleStartStopRWService2() The first genuine lifetime test, sets 20 concurrent writer tasks to output to the service and a final task to close the service concurrently.

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, assertCondition, assertEquals, assertEquals, getBytes, getPort, 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

Field Detail

r

protected final Random r

Constructor Detail

TestWriteCacheServiceLifetime

public TestWriteCacheServiceLifetime()

TestWriteCacheServiceLifetime

public TestWriteCacheServiceLifetime(String name)

Method Detail

testSimpleStartStopRWService

public void testSimpleStartStopRWService()
                                  throws InterruptedException,
                                         IOException

Throws:

InterruptedException

IOException

testSimpleStartStopRWService2

public void testSimpleStartStopRWService2()
                                   throws InterruptedException,
                                          IOException

The first genuine lifetime test, sets 20 concurrent writer tasks to output to the service and a final task to close the service concurrently.

Throws:

InterruptedException

IOException

getRandomData

public ByteBuffer getRandomData()

Returns random data that will fit in N bytes. N is chosen randomly in 1:256.

Returns:

A new ByteBuffer wrapping a new byte[] of random length and having random contents.

getRandomData

public ByteBuffer getRandomData(int nbytes)

Returns random data that will fit in nbytes.

Overrides:

getRandomData in class TestCase3

Returns:

A new ByteBuffer wrapping a new byte[] having random contents.