org.apache.hadoop.hbase.io.hfile.bucket

Class TestBucketWriterThread

java.lang.Object

org.apache.hadoop.hbase.io.hfile.bucket.TestBucketWriterThread

public class TestBucketWriterThread
extends Object

Constructor Summary

Constructors

Constructor and Description
TestBucketWriterThread()

Method Summary

Modifier and Type	Method and Description
void	setUp() Set up variables and get BucketCache and WriterThread into state where tests can manually control the running of WriterThread and BucketCache is empty.
void	tearDown()
void	testCacheFullException() Do Cache full exception
void	testIOE() Do IOE.
void	testNonErrorCase() Test non-error case just works.
void	testTooBigEntry() Pass through a too big entry and ensure it is cleared from queues and ramCache.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestBucketWriterThread

public TestBucketWriterThread()

Method Detail

setUp

public void setUp()
           throws Exception

Set up variables and get BucketCache and WriterThread into state where tests can manually control the running of WriterThread and BucketCache is empty.

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testNonErrorCase

public void testNonErrorCase()
                      throws IOException,
                             InterruptedException

Test non-error case just works.

Throws:

FileNotFoundException

IOException

InterruptedException

testTooBigEntry

public void testTooBigEntry()
                     throws InterruptedException

Pass through a too big entry and ensure it is cleared from queues and ramCache. Manually run the WriterThread.

Throws:

InterruptedException

testIOE

public void testIOE()
             throws IOException,
                    InterruptedException

Do IOE. Take the RAMQueueEntry that was on the queue, doctor it to throw exception, then put it back and process it.

Throws:

IOException

InterruptedException

testCacheFullException

public void testCacheFullException()
                            throws IOException,
                                   InterruptedException

Do Cache full exception

Throws:

IOException

InterruptedException