Package 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

@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	Description
static enum	FaultyFSLog.FailureType

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	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, closeExecutor, 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_AVOID_LOCAL_WRITES_DEFAULT, WAL_AVOID_LOCAL_WRITES_KEY, WAL_ROLL_MULTIPLIER, WAL_SHUTDOWN_WAIT_TIMEOUT_MS, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, walShutdownTimeout

Constructor Summary

Constructors

Constructor	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	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, getOldPath, getPreallocatedEventCount, getSyncFuture, getWALArchivePath, init, isLogRollRequested, logRollAndSetupWalProps, main, markClosedAndClean, 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 Details

ft

FaultyFSLog.FailureType ft

Constructor Details

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 Details

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