com.bigdata.ha.halog

Class TestHALogWriter

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.ha.halog.TestHALogWriter

All Implemented Interfaces:

junit.framework.Test

public class TestHALogWriter
extends TestCase2

Test suite for HALogWriter and HALogReader.

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 junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestHALogWriter()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	setUp()
protected void	tearDown()
void	test_closeLiveLogWithOpenReader() A unit test where the reader is blocked awaiting more input in IHALogReader.hasMoreBuffers() on the live HALog.
void	test_disableLiveLogWithOpenReader() A unit test where the reader is blocked awaiting more input in IHALogReader.hasMoreBuffers() on the live HALog.
void	test_doubleOpen_close_historicalHALog() Unit test verifies that each open of an IHALogReader is distinct and the an IHALogReader.close() will not close the backing channel for a different reader instance that is reading from the same HALog file.
void	test_fileLeak_historicalHALog() Unit test for an open file leak for a historical log reader.
void	testConcurrentRWWriterReader() While a writer thread writes a number of HALogs, readers are opened to process them.
void	testSimpleRWWriter() Simple writelog test, open file, write data and commit.
void	testSimpleRWWriterReader() Simple WriteReader, no concurrency, confirms non-delayed responses.

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

TestHALogWriter

public TestHALogWriter()

Method Detail

setUp

protected void setUp()
              throws Exception

Overrides:

setUp in class junit.framework.TestCase

Throws:

Exception

tearDown

protected void tearDown()
                 throws Exception

Overrides:

tearDown in class junit.framework.TestCase

Throws:

Exception

testSimpleRWWriter

public void testSimpleRWWriter()
                        throws FileNotFoundException,
                               IOException,
                               InterruptedException

Simple writelog test, open file, write data and commit.

Throws:

FileNotFoundException

IOException

InterruptedException

testSimpleRWWriterReader

public void testSimpleRWWriterReader()
                              throws FileNotFoundException,
                                     IOException,
                                     InterruptedException

Simple WriteReader, no concurrency, confirms non-delayed responses.

Throws:

FileNotFoundException

IOException

InterruptedException

testConcurrentRWWriterReader

public void testConcurrentRWWriterReader()
                                  throws Exception

While a writer thread writes a number of HALogs, readers are opened to process them.

Throws:

Exception

test_closeLiveLogWithOpenReader

public void test_closeLiveLogWithOpenReader()
                                     throws IOException,
                                            InterruptedException,
                                            ExecutionException

A unit test where the reader is blocked awaiting more input in IHALogReader.hasMoreBuffers() on the live HALog. The writer is closed. The reader should immediately notice this event and return false.

Throws:

IOException

InterruptedException

ExecutionException

test_disableLiveLogWithOpenReader

public void test_disableLiveLogWithOpenReader()
                                       throws IOException,
                                              InterruptedException,
                                              ExecutionException

A unit test where the reader is blocked awaiting more input in IHALogReader.hasMoreBuffers() on the live HALog. The writer is disabled. The reader should immediately notice this event and return false.

Throws:

IOException

InterruptedException

ExecutionException

test_doubleOpen_close_historicalHALog

public void test_doubleOpen_close_historicalHALog()
                                           throws Exception

Unit test verifies that each open of an IHALogReader is distinct and the an IHALogReader.close() will not close the backing channel for a different reader instance that is reading from the same HALog file. This version of the test is for a historical (non-live) HALog file. The case for the live HALog file is tested by testSimpleRWWriterReader().

Throws:

Exception

test_fileLeak_historicalHALog

public void test_fileLeak_historicalHALog()
                                   throws Exception

Unit test for an open file leak for a historical log reader.

Throws:

Exception

See Also:

DGC Thread Leak: sendHALogForWriteSet()