class TestFailedAppendAndSync.DodgyFSLog extends org.apache.hadoop.hbase.regionserver.wal.FSHLog
Modifier and Type | Field and Description |
---|---|
(package private) AtomicLong |
rolls |
(package private) boolean |
throwAppendException |
(package private) boolean |
throwArchiveException |
(package private) boolean |
throwSyncException |
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_BATCH_SIZE, DEFAULT_WAL_SHUTDOWN_WAIT_TIMEOUT_MS, DEFAULT_WAL_SYNC_TIMEOUT_MS, filenum, fs, hasConsumerTask, highestProcessedAppendTxid, 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, 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_BATCH_SIZE, WAL_ROLL_MULTIPLIER, WAL_SHUTDOWN_WAIT_TIMEOUT_MS, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, walShutdownTimeout
Constructor and Description |
---|
DodgyFSLog(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.hbase.Server server,
org.apache.hadoop.fs.Path root,
String logDir,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
archive(org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,Long> localLogsToArchive) |
protected void |
archiveLogFile(org.apache.hadoop.fs.Path p) |
protected org.apache.hadoop.hbase.wal.WALProvider.Writer |
createWriterInstance(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
Map<byte[],List<byte[]>> |
rollWriter(boolean force) |
checkSlowSyncCount, createCombinedWriter, doAppend, doCheckLogLowReplication, doCleanUpResources, doWriterSync, init, onWriterReplaced
abortCacheFlush, append, appendData, appendEntry, appendMarker, atHeadOfRingBufferEventHandlerAppend, blockOnSync, checkLogLowReplication, close, closeWriter, completeCacheFlush, computeFilename, createSingleThreadPoolConsumeExecutor, doCheckSlowSync, doReplaceWriter, doShutdown, doSync, doSync, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSyncedTxid, getSyncFuture, getWALArchivePath, isLogRollRequested, isWriterBroken, logRollAndSetupWalProps, main, markFutureDoneAndOffer, postSync, registerWALActionsListener, requestLogRoll, requestLogRoll, rollWriter, setWaitOnShutdownInSeconds, shutdown, skipRemoteWAL, stampSequenceIdAndPublishToRingBuffer, startCacheFlush, startCacheFlush, sync, sync, sync, sync, toString, unregisterWALActionsListener, updateStore, waitForSafePoint
volatile boolean throwSyncException
volatile boolean throwAppendException
volatile boolean throwArchiveException
final AtomicLong rolls
public DodgyFSLog(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.Server server, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public Map<byte[],List<byte[]>> rollWriter(boolean force) throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException, IOException
rollWriter
in interface org.apache.hadoop.hbase.wal.WAL
rollWriter
in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>
org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException
IOException
protected void archiveLogFile(org.apache.hadoop.fs.Path p) throws IOException
archiveLogFile
in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>
IOException
protected void archive(org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,Long> localLogsToArchive)
archive
in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>
protected org.apache.hadoop.hbase.wal.WALProvider.Writer createWriterInstance(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
createWriterInstance
in class org.apache.hadoop.hbase.regionserver.wal.FSHLog
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.