Package org.apache.hadoop.hbase.regionserver

Class TestWALLockup.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.TestWALLockup.DodgyFSLog
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider, org.apache.hadoop.hbase.wal.WAL
Enclosing class:
TestWALLockup
private static final class TestWALLockup.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) CountDownLatch
    latch
     
    (package private) boolean
    throwException
     

    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
    DodgyFSLog(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    afterCreatingZigZagLatch()
     
    protected void
    beforeWaitOnSafePoint()
     
    protected org.apache.hadoop.hbase.wal.WALProvider.Writer
    createWriterInstance(org.apache.hadoop.fs.Path path)
     

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

    append, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, doSync, 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

  • Constructor Details

    • DodgyFSLog

      public DodgyFSLog(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf) throws IOException
      Throws:
      IOException

  • Method Details

    • afterCreatingZigZagLatch

      protected void afterCreatingZigZagLatch()
      Overrides:
      afterCreatingZigZagLatch in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

    • beforeWaitOnSafePoint

      protected void beforeWaitOnSafePoint()
      Overrides:
      beforeWaitOnSafePoint in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

    • createWriterInstance

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