Package org.apache.hadoop.hbase.regionserver

Class TestFailedAppendAndSync.DodgyFSLog

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.regionserver.TestFailedAppendAndSync.DodgyFSLog
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider, org.apache.hadoop.hbase.wal.WAL
Enclosing class:
TestFailedAppendAndSync
class TestFailedAppendAndSync.DodgyFSLog 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

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) final AtomicLong
    rolls
     
    (package private) boolean
    throwAppendException
     
    (package private) boolean
    throwArchiveException
     
    (package private) boolean
    throwSyncException
     

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

  • Constructor Summary

    Constructors
    Constructor
    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)
     

  • Method Summary

    Modifier and Type
    Method
    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)
     

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

    checkSlowSyncCount, createCombinedWriter, doAppend, doCheckLogLowReplication, doCleanUpResources, doWriterSync, init, onWriterReplaced

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

    abortCacheFlush, append, appendData, appendEntry, appendMarker, atHeadOfRingBufferEventHandlerAppend, blockOnSync, checkLogLowReplication, close, closeWriter, completeCacheFlush, computeFilename, createSingleThreadPoolConsumeExecutor, doCheckSlowSync, doReplaceWriter, doShutdown, doSync, doSync, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSequenceIdAccounting, 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

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • DodgyFSLog

      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
      Throws:
      IOException

  • Method Details

    • rollWriter

      public Map<byte[],List<byte[]>> rollWriter(boolean force) throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException, IOException
      Specified by:
      rollWriter in interface org.apache.hadoop.hbase.wal.WAL
      Overrides:
      rollWriter in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>
      Throws:
      org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException
      IOException

    • archiveLogFile

      protected void archiveLogFile(org.apache.hadoop.fs.Path p) throws IOException
      Overrides:
      archiveLogFile in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>
      Throws:
      IOException

    • archive

      protected void archive(org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,Long> localLogsToArchive)
      Overrides:
      archive in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>

    • createWriterInstance

      protected org.apache.hadoop.hbase.wal.WALProvider.Writer createWriterInstance(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
      Overrides:
      createWriterInstance in class org.apache.hadoop.hbase.regionserver.wal.FSHLog
      Throws:
      IOException