com.bigdata.bfs

Class TestAppendBlock

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.btree.AbstractBTreeTestCase

com.bigdata.service.AbstractEmbeddedFederationTestCase

com.bigdata.bfs.AbstractRepositoryTestCase

com.bigdata.bfs.TestAppendBlock

All Implemented Interfaces:

junit.framework.Test

public class TestAppendBlock
extends AbstractRepositoryTestCase

Test atomic append operations on the file data index for the BigdataFileSystem. This also tests the correct assignment of block identifiers, the ability to count the #of blocks in a file version, the ability to visit the block identifiers for a file version, the ability to read a specific block for a file version, and the ability to read all data for a file version from an input stream. FIXME test where there is only a single index partition and where there are several. This will exercise both the logic that locates the index partition into which the atomic append will go and the logic that computes the next block identifer for the file version when entering a new partition. These tests can be run by establishing the appropriate partitions in the data index for the embedded federation.

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.bfs.AbstractRepositoryTestCase

BLOCK_SIZE, repo

Fields inherited from class com.bigdata.service.AbstractEmbeddedFederationTestCase

client, dataService0, dataService1, fed, metadataService

Fields inherited from class com.bigdata.btree.AbstractBTreeTestCase

keyBuilder, log, r

Fields inherited from class junit.framework.TestCase2

_randomType

Constructor Summary

Constructors

Constructor and Description
TestAppendBlock()
TestAppendBlock(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_atomicAppend2SmallBlocks() Test the ability to write two partial blocks in a row onto a file version and then read them back (test of append semantics).
void	test_atomicAppend3SmallBlocks() Test the ability to write three partial blocks in a row onto a file version and then read them back (test of append semantics).
void	test_atomicAppendCorrectRejection() Verify correct rejection: (a) writes that are larger than one block.
void	test_atomicAppendEmptyBlock() Atomic append of a zero length block.
void	test_atomicAppendFullBlock() Atomic append of a full block.
void	test_atomicAppendSmallBlock() Test the ability to write a byte[] onto the index and read it back.
void	test_atomicAppendStressTest() A stress test for writing a partial and full blocks on a file and reading back its data.

Methods inherited from class com.bigdata.bfs.AbstractRepositoryTestCase

getProperties, read, read, setUp, tearDown

Methods inherited from class com.bigdata.service.AbstractEmbeddedFederationTestCase

assertEquals, assertEquals, assertEquals, assertIndexRegistered, awaitAsynchronousOverflow, getPartitionCount

Methods inherited from class com.bigdata.btree.AbstractBTreeTestCase

assertChildKeys, assertEntryCounts, assertKeys, assertKeys, assertKeys, assertSameAbstractNodeData, assertSameBTree, assertSameEntryIterator, assertSameEntryIterator, assertSameIterator, assertSameIterator, assertSameLeaf, assertSameLeafData, assertSameNode, assertSameNodeData, assertSameNodeOrLeaf, assertSameRaba, assertValues, assertValues, doEntryIteratorTest, doInsertKeySequenceTest, doInsertLookupRemoveStressTest, doInsertRandomKeySequenceTest, doInsertRandomKeySequenceTest, doInsertRandomSparseKeySequenceTest, doKnownKeySequenceTest, doRandomIndexOfTest, doRandomKeyInsertTest, doRandomLookupTest, doRemoveStructureStressTest, doSplitTest, doSplitWithDecreasingKeySequence, doSplitWithIncreasingKeySequence, doSplitWithRandomDenseKeySequence, getBTree, getBTree, getKeysAndValues, getRandomKeys, getRandomKeyValues, i2k, nextLong, useRawRecords

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

TestAppendBlock

public TestAppendBlock()

TestAppendBlock

public TestAppendBlock(String arg0)

Parameters:

arg0 -

Method Detail

test_atomicAppendSmallBlock

public void test_atomicAppendSmallBlock()
                                 throws IOException

Test the ability to write a byte[] onto the index and read it back.

Throws:

IOException

test_atomicAppend2SmallBlocks

public void test_atomicAppend2SmallBlocks()
                                   throws IOException

Test the ability to write two partial blocks in a row onto a file version and then read them back (test of append semantics).

Throws:

IOException

test_atomicAppend3SmallBlocks

public void test_atomicAppend3SmallBlocks()
                                   throws IOException

Test the ability to write three partial blocks in a row onto a file version and then read them back (test of append semantics).

Throws:

IOException

test_atomicAppendEmptyBlock

public void test_atomicAppendEmptyBlock()
                                 throws IOException

Atomic append of a zero length block.

Throws:

IOException

test_atomicAppendFullBlock

public void test_atomicAppendFullBlock()
                                throws IOException

Atomic append of a full block.

Throws:

IOException

test_atomicAppendCorrectRejection

public void test_atomicAppendCorrectRejection()
                                       throws IOException

Verify correct rejection: (a) writes that are larger than one block.

Throws:

IOException

test_atomicAppendStressTest

public void test_atomicAppendStressTest()
                                 throws IOException

A stress test for writing a partial and full blocks on a file and reading back its data. Each pass writes on a different file.

Note: By virtue of how the file names are choosen this also tests atomic append of a file when there is an existing file and the new file would be (a) before; and (b) after the existing file in the index order.

Throws:

IOException