org.wali

Class TestMinimalLockingWriteAheadLog

java.lang.Object

org.wali.TestMinimalLockingWriteAheadLog

public class TestMinimalLockingWriteAheadLog
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestMinimalLockingWriteAheadLog()

Method Summary

Modifier and Type	Method and Description
void	testCannotModifyLogAfterAllAreBlackListed()
void	testDecreaseNumberOfPartitions()
void	testRecoverAfterIOException()
void	testRecoverFileThatHasTrailingNULBytesAndTruncation()
void	testRecoverFileThatHasTrailingNULBytesNoTruncation()
void	testRepoDoesntContinuallyGrowOnOutOfMemoryError()
void	testShutdownWhileBlacklisted()
void	testStriping()
void	testTruncatedPartitionHeader()
void	testUpdatePerformance()
void	testWrite()
void	tryToCauseThreadingIssue() This test is intended to continually update the Write-ahead log using many threads, then stop and restore the repository to check for any corruption.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestMinimalLockingWriteAheadLog

public TestMinimalLockingWriteAheadLog()

Method Detail

testTruncatedPartitionHeader

public void testTruncatedPartitionHeader()
                                  throws java.io.IOException

Throws:

java.io.IOException

testUpdatePerformance

public void testUpdatePerformance()
                           throws java.io.IOException,
                                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testRepoDoesntContinuallyGrowOnOutOfMemoryError

public void testRepoDoesntContinuallyGrowOnOutOfMemoryError()
                                                     throws java.io.IOException,
                                                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

tryToCauseThreadingIssue

public void tryToCauseThreadingIssue()
                              throws java.io.IOException,
                                     java.lang.InterruptedException

This test is intended to continually update the Write-ahead log using many threads, then stop and restore the repository to check for any corruption. There were reports of potential threading issues leading to repository corruption. This was an attempt to replicate. It should not be run as a unit test, really, but will be left, as it can be valuable to exercise the implementation

Throws:

java.io.IOException - if unable to read from/write to the write-ahead log

java.lang.InterruptedException - if a thread is interrupted

testWrite

public void testWrite()
               throws java.io.IOException,
                      java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testRecoverAfterIOException

public void testRecoverAfterIOException()
                                 throws java.io.IOException

Throws:

java.io.IOException

testRecoverFileThatHasTrailingNULBytesAndTruncation

public void testRecoverFileThatHasTrailingNULBytesAndTruncation()
                                                         throws java.io.IOException

Throws:

java.io.IOException

testRecoverFileThatHasTrailingNULBytesNoTruncation

public void testRecoverFileThatHasTrailingNULBytesNoTruncation()
                                                        throws java.io.IOException

Throws:

java.io.IOException

testCannotModifyLogAfterAllAreBlackListed

public void testCannotModifyLogAfterAllAreBlackListed()
                                               throws java.io.IOException

Throws:

java.io.IOException

testStriping

public void testStriping()
                  throws java.io.IOException

Throws:

java.io.IOException

testShutdownWhileBlacklisted

public void testShutdownWhileBlacklisted()
                                  throws java.io.IOException

Throws:

java.io.IOException

testDecreaseNumberOfPartitions

public void testDecreaseNumberOfPartitions()
                                    throws java.io.IOException

Throws:

java.io.IOException