com.bigdata.io

Class TestFileChannelUtility

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

com.bigdata.io.TestFileChannelUtility

All Implemented Interfaces:

junit.framework.Test

public class TestFileChannelUtility
extends junit.framework.TestCase

Test suite for FileChannelUtility.

Version:

$Id$

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
TestFileChannelUtility()
TestFileChannelUtility(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	assertSameData(byte[] expected, byte[] actual)
protected void	doReadTest(int ntrials, byte[] expected, RandomAccessFile raf) Verify FileChannelUtility.readAll(FileChannel, ByteBuffer, long) using a file that the caller has pre-written and a byte[] containing the ground truth data for that file.
protected int	getRandomLength(RandomAccessFile raf, long pos) Choose #of bytes for the an operation which is no more bytes than exist from that position to the end of the file but up to 4 times the capacity of the direct buffers in use by the pool (and no more than Integer.MAX_VALUE bytes regardless).
protected long	getRandomPosition(RandomAccessFile raf) Start at any position in the source file (up to int32 offset).
void	no_testAsyncReadersCancelled()
void	no_testAsyncReadersCloseChannel()
protected void	setUp()
protected void	tearDown()
void	test_oneTrial_readAll_writeAll() A single trial testing the behavior of readAll() and writeAll()
void	test_readAll_writeAll() A sequence of trials testing the behavior of readAll() and writeAll().
void	test_transferAllFrom() Test of FileChannelUtility#transferAll(FileChannel, long, long, RandomAccessFile) on 20M of random data using a bunch of transfer of different sizes from different positions in the source file.
void	testReopenerInputStream()

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

TestFileChannelUtility

public TestFileChannelUtility()

TestFileChannelUtility

public TestFileChannelUtility(String arg0)

Parameters:

arg0 -

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

getRandomPosition

protected long getRandomPosition(RandomAccessFile raf)
                          throws IOException

Start at any position in the source file (up to int32 offset).

Throws:

IOException

getRandomLength

protected int getRandomLength(RandomAccessFile raf,
                  long pos)
                       throws IOException

Choose #of bytes for the an operation which is no more bytes than exist from that position to the end of the file but up to 4 times the capacity of the direct buffers in use by the pool (and no more than Integer.MAX_VALUE bytes regardless).

Parameters:

pos - A position within that file.

Throws:

IOException

assertSameData

protected void assertSameData(byte[] expected,
                  byte[] actual)

test_oneTrial_readAll_writeAll

public void test_oneTrial_readAll_writeAll()
                                    throws IOException

A single trial testing the behavior of readAll() and writeAll()

Throws:

IOException

test_readAll_writeAll

public void test_readAll_writeAll()
                           throws IOException

A sequence of trials testing the behavior of readAll() and writeAll(). The ground truth data is changed periodically and updated on the source file and continued testing is performed.

Throws:

IOException

doReadTest

protected void doReadTest(int ntrials,
              byte[] expected,
              RandomAccessFile raf)
                   throws IOException

Verify FileChannelUtility.readAll(FileChannel, ByteBuffer, long) using a file that the caller has pre-written and a byte[] containing the ground truth data for that file.

Parameters:

expected - The ground truth data.

raf - A file pre-written with that ground truth data.

Throws:

IOException

test_transferAllFrom

public void test_transferAllFrom()
                          throws IOException

Test of FileChannelUtility#transferAll(FileChannel, long, long, RandomAccessFile) on 20M of random data using a bunch of transfer of different sizes from different positions in the source file.

Throws:

IOException

testReopenerInputStream

public void testReopenerInputStream()
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

no_testAsyncReadersCancelled

public void no_testAsyncReadersCancelled()
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

no_testAsyncReadersCloseChannel

public void no_testAsyncReadersCloseChannel()
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException