org.apache.hadoop.hbase.regionserver.wal

Class TestAsyncFSWAL

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractTestFSWAL

org.apache.hadoop.hbase.regionserver.wal.TestAsyncFSWAL

public class TestAsyncFSWAL
extends AbstractTestFSWAL

Provides AsyncFSWAL test cases.

Field Summary

Fields

Modifier and Type	Field and Description
private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	CHANNEL_CLASS
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	GROUP

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractTestFSWAL

CONF, currentTest, DIR, FS, LOG, TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestAsyncFSWAL()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<?>	newSlowWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, String logDir, String archiveDir, org.apache.hadoop.conf.Configuration conf, List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners, boolean failIfWALExists, String prefix, String suffix, Runnable action)
protected org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<?>	newWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, String logDir, String archiveDir, org.apache.hadoop.conf.Configuration conf, List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners, boolean failIfWALExists, String prefix, String suffix)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testBrokenWriter()

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractTestFSWAL

addEdits, flushRegion, setUp, testFailedToCreateWALIfParentRenamed, testFindMemStoresEligibleForFlush, testFlushSequenceIdIsGreaterThanAllEditsInHFile, testSyncNoAppend, testWALComparator, testWALCoprocessorLoaded, testWriteEntryCanBeNull

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

GROUP

private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup GROUP

CHANNEL_CLASS

private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> CHANNEL_CLASS

Constructor Detail

TestAsyncFSWAL

public TestAsyncFSWAL()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

newWAL

protected org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<?> newWAL(org.apache.hadoop.fs.FileSystem fs,
                                                                           org.apache.hadoop.fs.Path rootDir,
                                                                           String logDir,
                                                                           String archiveDir,
                                                                           org.apache.hadoop.conf.Configuration conf,
                                                                           List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners,
                                                                           boolean failIfWALExists,
                                                                           String prefix,
                                                                           String suffix)
                                                                    throws IOException

Specified by:

newWAL in class AbstractTestFSWAL

Throws:

IOException

newSlowWAL

protected org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<?> newSlowWAL(org.apache.hadoop.fs.FileSystem fs,
                                                                               org.apache.hadoop.fs.Path rootDir,
                                                                               String logDir,
                                                                               String archiveDir,
                                                                               org.apache.hadoop.conf.Configuration conf,
                                                                               List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners,
                                                                               boolean failIfWALExists,
                                                                               String prefix,
                                                                               String suffix,
                                                                               Runnable action)
                                                                        throws IOException

Specified by:

newSlowWAL in class AbstractTestFSWAL

Throws:

IOException

testBrokenWriter

public void testBrokenWriter()
                      throws Exception

Throws:

Exception