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

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, 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, 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)
void	setFailureType(FaultyFSLog.FailureType fType)
void	sync(long txid)
void	sync(long txid, boolean forceSync)

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

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

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

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

Methods inherited from class java.lang.Object

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

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)

sync

public void sync(long txid)
          throws IOException

Specified by:

sync in interface org.apache.hadoop.hbase.wal.WAL

Overrides:

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

Throws:

IOException

sync

public void sync(long txid,
                 boolean forceSync)
          throws IOException

Specified by:

sync in interface org.apache.hadoop.hbase.wal.WAL

Overrides:

sync 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