org.apache.hadoop.hbase.regionserver.wal

Class TestWALSyncTimeoutException.SlowAsyncFSWAL

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.TestWALSyncTimeoutException.SlowAsyncFSWAL

All Implemented Interfaces:

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

Enclosing class:

TestWALSyncTimeoutException

public static class TestWALSyncTimeoutException.SlowAsyncFSWAL
extends org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL

Nested Class Summary

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

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

Field Summary

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, closeExecutor, conf, consumeExecutor, consumer, 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, hasConsumerTask, highestProcessedAppendTxid, highestSyncedTxid, highestUnsyncedTxid, implClassName, inflightWALClosures, listeners, LOG_NAME_COMPARATOR, logrollsize, MAX_LOGS, maxLogs, numEntries, ourFiles, prefixPathStr, RING_BUFFER_SLOT_COUNT, ROLL_ON_SYNC_TIME_MS, rollOnSyncNs, rollRequested, rollWriterLock, sequenceIdAccounting, shouldShutDownConsumeExecutorWhenClose, shutdown, SLOW_SYNC_ROLL_INTERVAL_MS, SLOW_SYNC_ROLL_THRESHOLD, SLOW_SYNC_TIME_MS, slowSyncCheckInterval, slowSyncCount, slowSyncNs, slowSyncRollThreshold, syncFutureCache, syncFutures, totalLogSize, toWriteAppends, unackedAppends, useHsync, WAL_ROLL_MULTIPLIER, WAL_SHUTDOWN_WAIT_TIMEOUT_MS, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, walShutdownTimeout, writer

Constructor Summary

Constructors

Constructor and Description
SlowAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.Abortable abortable, 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, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
SlowAsyncFSWAL(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, 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 void	atHeadOfRingBufferEventHandlerAppend()

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

createAsyncWriter, createWriterInstance, doAppend, doCheckLogLowReplication, doWriterSync, getLogReplication, getPipeline, markerEditOnly, onWriterReplaced, preAppendAndSync, precheckBeforeAppendWALEdit

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

abortCacheFlush, append, appendData, appendEntry, appendMarker, archive, archiveLogFile, blockOnSync, checkLogLowReplication, checkSlowSyncCount, close, closeWriter, completeCacheFlush, computeFilename, createSingleThreadPoolConsumeExecutor, doCheckSlowSync, doCleanUpResources, doReplaceWriter, doShutdown, doSync, doSync, findRegionsToForceFlush, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getFiles, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSyncedTxid, getSyncFuture, getUnflushedEntriesCount, getWALArchivePath, init, isLogRollRequested, isUnflushedEntries, isWriterBroken, logRollAndSetupWalProps, main, markFutureDoneAndOffer, postSync, registerWALActionsListener, replaceWriter, requestLogRoll, requestLogRoll, rollWriter, rollWriter, setWaitOnShutdownInSeconds, shutdown, stampSequenceIdAndPublishToRingBuffer, startCacheFlush, startCacheFlush, sync, sync, sync, sync, toString, unregisterWALActionsListener, updateStore, waitForSafePoint

Methods inherited from class java.lang.Object

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

Constructor Detail

SlowAsyncFSWAL

public SlowAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs,
                      org.apache.hadoop.hbase.Abortable abortable,
                      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,
                      org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                      Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass,
                      org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor)
               throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException,
                      IOException

Throws:

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

IOException

SlowAsyncFSWAL

public SlowAsyncFSWAL(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,
                      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

atHeadOfRingBufferEventHandlerAppend

protected void atHeadOfRingBufferEventHandlerAppend()

Overrides:

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