org.apache.hadoop.hbase.replication

Class DualAsyncFSWALForTest

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter>

org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL

org.apache.hadoop.hbase.regionserver.wal.DualAsyncFSWAL

org.apache.hadoop.hbase.replication.DualAsyncFSWALForTest

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider, org.apache.hadoop.hbase.wal.WAL

class DualAsyncFSWALForTest
extends org.apache.hadoop.hbase.regionserver.wal.DualAsyncFSWAL

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DualAsyncFSWALForTest.MyCombinedAsyncWriter

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.wal.WAL

org.apache.hadoop.hbase.wal.WAL.Entry

Field Summary

Fields

Modifier and Type	Field and Description
private CountDownLatch	arrive
private boolean	localBroken
private boolean	remoteBroken
private CountDownLatch	resume

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

ASYNC_WAL_USE_SHARED_EVENT_LOOP, ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS, DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP, DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS, DEFAULT_WAL_BATCH_SIZE, WAL_BATCH_SIZE

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

abortable, blocksize, closed, conf, coprocessorHost, DEFAULT_ROLL_ON_SYNC_TIME_MS, DEFAULT_SLOW_SYNC_ROLL_INTERVAL_MS, DEFAULT_SLOW_SYNC_ROLL_THRESHOLD, DEFAULT_SLOW_SYNC_TIME_MS, DEFAULT_WAL_SHUTDOWN_WAIT_TIMEOUT_MS, DEFAULT_WAL_SYNC_TIMEOUT_MS, filenum, fs, highestSyncedTxid, highestUnsyncedTxid, implClassName, inflightWALClosures, listeners, logrollsize, MAX_LOGS, maxLogs, numEntries, ourFiles, prefixPathStr, RING_BUFFER_SLOT_COUNT, ROLL_ON_SYNC_TIME_MS, rollOnSyncNs, rollRequested, rollWriterLock, sequenceIdAccounting, shutdown, SLOW_SYNC_ROLL_INTERVAL_MS, SLOW_SYNC_ROLL_THRESHOLD, SLOW_SYNC_TIME_MS, slowSyncCheckInterval, slowSyncCount, slowSyncNs, slowSyncRollThreshold, syncFutureCache, totalLogSize, useHsync, WAL_ROLL_MULTIPLIER, WAL_SHUTDOWN_WAIT_TIMEOUT_MS, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, walShutdownTimeout

Constructor Summary

Constructors

Constructor and Description

DualAsyncFSWALForTest(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.Path remoteWALDir, 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, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter	createCombinedAsyncWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter localWriter, org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter remoteWriter)
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter	createWriterInstance(org.apache.hadoop.fs.Path path)
void	resumeLogRoll()
void	setLocalBroken()
void	setRemoteBroken()
void	suspendLogRoll()
void	waitUntilArrive()

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

markerEditOnly, skipRemoteWAL

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

append, closeWriter, createAsyncWriter, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, doSync, doSync

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

abortCacheFlush, appendData, appendEntry, appendMarker, archive, archiveLogFile, atHeadOfRingBufferEventHandlerAppend, blockOnSync, checkLogLowReplication, close, completeCacheFlush, computeFilename, doCheckSlowSync, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSyncFuture, getWALArchivePath, init, isLogRollRequested, logRollAndSetupWalProps, main, postSync, registerWALActionsListener, requestLogRoll, requestLogRoll, rollWriter, rollWriter, shutdown, stampSequenceIdAndPublishToRingBuffer, startCacheFlush, startCacheFlush, sync, sync, sync, sync, toString, unregisterWALActionsListener, updateStore

Methods inherited from class java.lang.Object

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

Field Detail

localBroken

private boolean localBroken

remoteBroken

private boolean remoteBroken

arrive

private CountDownLatch arrive

resume

private CountDownLatch resume

Constructor Detail

DualAsyncFSWALForTest

public DualAsyncFSWALForTest(org.apache.hadoop.fs.FileSystem fs,
                             org.apache.hadoop.fs.FileSystem remoteFs,
                             org.apache.hadoop.fs.Path rootDir,
                             org.apache.hadoop.fs.Path remoteWALDir,
                             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,
                             org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                             Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
                      throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException,
                             IOException

Throws:

org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException

IOException

Method Detail

createCombinedAsyncWriter

protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter createCombinedAsyncWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter localWriter,
                                                                                        org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter remoteWriter)

Overrides:

createCombinedAsyncWriter in class org.apache.hadoop.hbase.regionserver.wal.DualAsyncFSWAL

createWriterInstance

protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter createWriterInstance(org.apache.hadoop.fs.Path path)
                                                                            throws IOException

Overrides:

createWriterInstance in class org.apache.hadoop.hbase.regionserver.wal.DualAsyncFSWAL

Throws:

IOException

setLocalBroken

public void setLocalBroken()

setRemoteBroken

public void setRemoteBroken()

suspendLogRoll

public void suspendLogRoll()

waitUntilArrive

public void waitUntilArrive()
                     throws InterruptedException

Throws:

InterruptedException

resumeLogRoll

public void resumeLogRoll()