org.apache.hadoop.hbase.wal

Class FaultyFSLog

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.FaultyFSLog

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class FaultyFSLog
extends org.apache.hadoop.hbase.regionserver.wal.FSHLog

This is a utility class, used by tests, which fails operation specified by FailureType enum

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FaultyFSLog.FailureType

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
(package private) FaultyFSLog.FailureType	ft

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
FaultyFSLog(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, String logName, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected long	append(org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.hbase.wal.WALKeyImpl key, org.apache.hadoop.hbase.wal.WALEdit edits, boolean inMemstore)
protected void	doSync(long txid, boolean forceSync)
void	setFailureType(FaultyFSLog.FailureType fType)

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

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

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, 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

ft

FaultyFSLog.FailureType ft

Constructor Detail

FaultyFSLog

public FaultyFSLog(org.apache.hadoop.fs.FileSystem fs,
                   org.apache.hadoop.fs.Path rootDir,
                   String logName,
                   org.apache.hadoop.conf.Configuration conf)
            throws IOException

Throws:

IOException

Method Detail

setFailureType

public void setFailureType(FaultyFSLog.FailureType fType)

doSync

protected void doSync(long txid,
                      boolean forceSync)
               throws IOException

Overrides:

doSync in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

Throws:

IOException

append

protected long append(org.apache.hadoop.hbase.client.RegionInfo info,
                      org.apache.hadoop.hbase.wal.WALKeyImpl key,
                      org.apache.hadoop.hbase.wal.WALEdit edits,
                      boolean inMemstore)
               throws IOException

Overrides:

append in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

Throws:

IOException