com.bigdata.journal

Class TestConcurrentJournal

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.journal.AbstractIndexManagerTestCase<S>

com.bigdata.journal.ProxyTestCase<Journal>

com.bigdata.journal.TestConcurrentJournal

All Implemented Interfaces:

IProxyTest, junit.framework.Test

public class TestConcurrentJournal
extends ProxyTestCase<Journal>

Test suite for the IConcurrencyManager interface on the Journal.

Author:

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
TestConcurrentJournal()
TestConcurrentJournal(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_concurrentReadersAreOk() A stress test that runs concurrent ITx.READ_COMMITTED readers and ITx.UNISOLATED writers and verifies that readers are able to transparently continue to read against the named indices if the backing FileChannel is closed by an interrupt noticed during an IO on that FileChannel.
void	test_shutdown() Test ability to create a Journal and then shut it down (in particular this is testing shutdown of the thread pool on the ConcurrencyManager).
void	test_shutdownNow()
void	test_submit_interrupt01() Submits an unisolated task to the write service.
void	test_submit_interrupt02() Submits an unisolated task to the write service.
void	test_submit_readService_01() Submits an unisolated task to the read service and verifies that it executes.
void	test_submit_txService_readCommitted_01() Submits a read-committed task to the transaction service and verifies that it executes.
void	test_submit_txService_readOnly_01() Submits an read-only task to the transaction service and verifies that it executes.
void	test_submit_txService_readWrite_01() Submits a read-write task with an empty write set to the transaction service and verifies that it executes.
void	test_submit_writeService_01() Submits an unisolated task to the write service and verifies that it executes.
void	test_tasksAreNotThreadSafe() Verify that an AbstractTask correctly rejects an attempt to submit the same instance twice.
void	test_writeServiceCheckpointDirtyIndex() Test verifies that a write on an index will cause the index to be checkpointed when the task completes.

Methods inherited from class com.bigdata.journal.ProxyTestCase

getDelegate, getOurDelegate, getProperties, getStore, getStore, reopenStore, setDelegate, setUp, tearDown

Methods inherited from class com.bigdata.journal.AbstractIndexManagerTestCase

checkIfProxy, fail, getRandomData, setUp, tearDown

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

Methods inherited from interface junit.framework.Test

countTestCases, run

Constructor Detail

TestConcurrentJournal

public TestConcurrentJournal()

TestConcurrentJournal

public TestConcurrentJournal(String name)

Method Detail

test_shutdown

public void test_shutdown()

Test ability to create a Journal and then shut it down (in particular this is testing shutdown of the thread pool on the ConcurrencyManager).

test_shutdownNow

public void test_shutdownNow()

test_submit_readService_01

public void test_submit_readService_01()
                                throws InterruptedException,
                                       ExecutionException

Submits an unisolated task to the read service and verifies that it executes.

Throws:

InterruptedException

ExecutionException

test_submit_writeService_01

public void test_submit_writeService_01()
                                 throws InterruptedException,
                                        ExecutionException

Submits an unisolated task to the write service and verifies that it executes.

Throws:

InterruptedException

ExecutionException

test_submit_txService_readOnly_01

public void test_submit_txService_readOnly_01()
                                       throws InterruptedException,
                                              ExecutionException

Submits an read-only task to the transaction service and verifies that it executes.

Throws:

InterruptedException

ExecutionException

test_submit_txService_readCommitted_01

public void test_submit_txService_readCommitted_01()
                                            throws InterruptedException,
                                                   ExecutionException

Submits a read-committed task to the transaction service and verifies that it executes.

Throws:

InterruptedException

ExecutionException

test_submit_txService_readWrite_01

public void test_submit_txService_readWrite_01()
                                        throws InterruptedException,
                                               ExecutionException

Submits a read-write task with an empty write set to the transaction service and verifies that it executes.

Throws:

InterruptedException

ExecutionException

test_submit_interrupt01

public void test_submit_interrupt01()
                             throws InterruptedException,
                                    ExecutionException

Submits an unisolated task to the write service. The task just sleeps. We then verify that we can interrupt that task using Future.cancel(boolean) with mayInterruptWhileRunning := true and that an appropriate exception is thrown in the main thread.

Throws:

InterruptedException

ExecutionException

test_submit_interrupt02

public void test_submit_interrupt02()
                             throws InterruptedException,
                                    ExecutionException

Submits an unisolated task to the write service. The task just sleeps. We then verify that we can terminate that task using Future.cancel(boolean) with mayInterruptWhileRunning := false and that an appropriate exception is thrown in the main thread when we Future.get() the result of the task.

Note: FutureTask.cancel(boolean) is able to return control to the caller without being allowed to interrupt the task. However, it does NOT terminate the task - the worker thread is still running. Once the main thread reaches Journal.shutdown() it awaits the termination of the WriteExecutorService. However that service does NOT terminate because that worker thread is still running an infinite loop.

Eventually, we interrupt the thread directly using a reference to it we obtained when setting up the task. This allows the journal to terminate and the test to complete.

Throws:

InterruptedException

ExecutionException

test_tasksAreNotThreadSafe

public void test_tasksAreNotThreadSafe()
                                throws InterruptedException,
                                       ExecutionException

Verify that an AbstractTask correctly rejects an attempt to submit the same instance twice. This is important since the base class has various items of state that are not thread-safe and are not designed to be reusable.

Throws:

ExecutionException

InterruptedException

test_writeServiceCheckpointDirtyIndex

public void test_writeServiceCheckpointDirtyIndex()
                                           throws Exception

Test verifies that a write on an index will cause the index to be checkpointed when the task completes.

Throws:

Exception

test_concurrentReadersAreOk

public void test_concurrentReadersAreOk()
                                 throws Throwable

A stress test that runs concurrent ITx.READ_COMMITTED readers and ITx.UNISOLATED writers and verifies that readers are able to transparently continue to read against the named indices if the backing FileChannel is closed by an interrupt noticed during an IO on that FileChannel. In order for this test to succeed the backing FileChannel must be transparently re-opened in a thread-safe manner if it is closed asynchronously (i.e., closed while the buffer strategy is still open).

Throws:

Throwable