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

Class TestBucketWriterThread

java.lang.Object

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

public class TestBucketWriterThread
extends java.lang.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 java.lang.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:

java.lang.Exception

tearDown

public void tearDown()
              throws java.lang.Exception

Throws:

java.lang.Exception

testNonErrorCase

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

Test non-error case just works.

Throws:

java.io.FileNotFoundException

java.io.IOException

java.lang.InterruptedException

testTooBigEntry

public void testTooBigEntry()
                     throws java.lang.InterruptedException

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

Throws:

java.lang.InterruptedException

testIOE

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

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

Throws:

java.io.IOException

java.lang.InterruptedException

testCacheFullException

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

Do Cache full exception

Throws:

java.io.IOException

java.lang.InterruptedException