com.bigdata.journal

Class AbstractRestartSafeTestCase

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.rawstore.AbstractRawStoreTestCase

com.bigdata.journal.AbstractBufferStrategyTestCase

com.bigdata.journal.AbstractRestartSafeTestCase

All Implemented Interfaces:

junit.framework.Test

Direct Known Subclasses:

TestDirectJournal.TestRawStore, TestDiskJournal.TestRawStore, TestMappedJournal.TestRawStore, TestRWJournal.TestRawStore, TestWORMStrategy.TestRawStore, TestWORMStrategyNoCache.TestRawStore, TestWORMStrategyOneCacheBuffer.TestRawStore

public abstract class AbstractRestartSafeTestCase
extends AbstractBufferStrategyTestCase

Test suite for restart-safe (data survives commit and reopen of the store).

Version:

$Id$

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.rawstore.AbstractRawStoreTestCase

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
AbstractRestartSafeTestCase()
AbstractRestartSafeTestCase(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected IRawStore	reopenStore(IRawStore store) Re-open the same backing store.
void	test_abort() Test of abort semantics.
void	test_closeForWrites() Unit tests writes some data, commits, and closes the journal against future writes.
void	test_restartSafe_multipleWrites() Test writes a bunch of records and verifies that each can be read after it is written.
void	test_restartSafe_oneWrite() Writes a record, verifies the write then commits the store.
void	test_restartSafe_oneWriteNoCommit() Writes a record, verifies the write but does NOT commit the store.

Methods inherited from class com.bigdata.journal.AbstractBufferStrategyTestCase

getBufferMode, getProperties, getStore, test_overflow, test_writeNoExtend, test_writeWithExtend, writeRandomData

Methods inherited from class com.bigdata.rawstore.AbstractRawStoreTestCase

getRandomData, test_close, test_multipleWrites, test_read_correctRejection_0L, test_read_correctRejection_zeroLength, test_readImmutable, test_write_correctRejection_emptyRecord, test_write_correctRejection_null, test_writeImmutable, test_writeRead, test_writeReadRead, testBlobObjectStreams, testEmptyStream, testSimpleStringStream, testSimpleStringStreamFromStandardAllocation, testZipStreams

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

AbstractRestartSafeTestCase

public AbstractRestartSafeTestCase()

AbstractRestartSafeTestCase

public AbstractRestartSafeTestCase(String name)

Method Detail

reopenStore

protected IRawStore reopenStore(IRawStore store)

Re-open the same backing store.

Parameters:

store - the existing store.

Returns:

A new store.

Throws:

Throwable - if the existing store is not closed, e.g., from failure to obtain a file lock, etc.

test_restartSafe_oneWriteNoCommit

public void test_restartSafe_oneWriteNoCommit()

Writes a record, verifies the write but does NOT commit the store. Closes and reopens the store and finally verifies the write was lost.

test_restartSafe_oneWrite

public void test_restartSafe_oneWrite()

Writes a record, verifies the write then commits the store. Closes and reopens the store and finally verifies the write on the reopened store.

test_restartSafe_multipleWrites

public void test_restartSafe_multipleWrites()

Test writes a bunch of records and verifies that each can be read after it is written. The test then performs a random order read and verifies that each of the records can be read correctly.

test_abort

public void test_abort()

Test of abort semantics.

test_closeForWrites

public void test_closeForWrites()

Unit tests writes some data, commits, and closes the journal against future writes. The LRUNexus is then cleared and we verify that we can still read data back from the store. Finally, we close and then reopen the store in a read-only mode and verify that we can still read on the store.

This test was written to verify that closing the journal against future writes does not leave the write cache in an unusable state (e.g., if it is discarded, then we do not attempt to read against the write cache). Since AbstractJournal.closeForWrites(long) does not interfere with existing readers, care must be exercised if we are to release the write cache atomically.