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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestBucketWriterThread.MockBucketCache A BucketCache that does not start its writer threads.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache	bc
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.io.hfile.Cacheable	plainCacheable
private org.apache.hadoop.hbase.io.hfile.BlockCacheKey	plainKey
private BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry>	q
private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread	wt

Constructor Summary

Constructors

Constructor and Description
TestBucketWriterThread()

Method Summary

Modifier and Type	Method and Description
private static void	doDrainOfOneEntry(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bc, org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread wt, BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry> q)
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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

bc

private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bc

wt

private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread wt

q

private BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry> q

plainCacheable

private org.apache.hadoop.hbase.io.hfile.Cacheable plainCacheable

plainKey

private org.apache.hadoop.hbase.io.hfile.BlockCacheKey plainKey

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

doDrainOfOneEntry

private static void doDrainOfOneEntry(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bc,
                                      org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread wt,
                                      BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry> q)
                               throws InterruptedException

Throws:

InterruptedException