org.apache.hadoop.hbase.wal

Class TestFSHLogCorruptionWithMultiPutDueToDanglingByteBuffer.PauseWAL

java.lang.Object

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

org.apache.hadoop.hbase.regionserver.wal.FSHLog

org.apache.hadoop.hbase.wal.TestFSHLogCorruptionWithMultiPutDueToDanglingByteBuffer.PauseWAL

All Implemented Interfaces:

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

Enclosing class:

TestFSHLogCorruptionWithMultiPutDueToDanglingByteBuffer

public static final class TestFSHLogCorruptionWithMultiPutDueToDanglingByteBuffer.PauseWAL
extends org.apache.hadoop.hbase.regionserver.wal.FSHLog

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
private int	testTableWalAppendsCount

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

FIXED_OVERHEAD

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_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_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix

Constructor Summary

Constructors

Constructor and Description
PauseWAL(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)

Method Summary

Modifier and Type	Method and Description
protected void	atHeadOfRingBufferEventHandlerAppend()

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

afterCreatingZigZagLatch, append, beforeWaitOnSafePoint, createWriterInstance, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, doSync, doSync, getSequenceOnRingBuffer, publishSyncOnRingBuffer

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

abortCacheFlush, appendData, appendEntry, appendMarker, archive, archiveLogFile, blockOnSync, checkLogLowReplication, close, completeCacheFlush, computeFilename, doCheckSlowSync, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, 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

Methods inherited from interface org.apache.hadoop.hbase.wal.WAL

getTimestamp

Field Detail

testTableWalAppendsCount

private int testTableWalAppendsCount

Constructor Detail

PauseWAL

public PauseWAL(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

Throws:

IOException

Method Detail

atHeadOfRingBufferEventHandlerAppend

protected void atHeadOfRingBufferEventHandlerAppend()

Overrides:

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