org.apache.hadoop.hbase.io.hfile.bucket

Class BucketCache.WriterThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread

All Implemented Interfaces:

Runnable

Enclosing class:

BucketCache

class BucketCache.WriterThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private BlockingQueue<BucketCache.RAMQueueEntry>	inputQueue
private boolean	writerEnabled

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue)

Method Summary

Modifier and Type	Method and Description
(package private) void	disableWriter()
(package private) void	doDrain(List<BucketCache.RAMQueueEntry> entries) Flush the entries in ramCache to IOEngine and add bucket entry to backingMap.
private void	putIntoBackingMap(BlockCacheKey key, BucketEntry bucketEntry) Put the new bucket entry into backingMap.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

inputQueue

private final BlockingQueue<BucketCache.RAMQueueEntry> inputQueue

writerEnabled

private volatile boolean writerEnabled

Constructor Detail

WriterThread

WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue)

Method Detail

disableWriter

void disableWriter()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

putIntoBackingMap

private void putIntoBackingMap(BlockCacheKey key,
                               BucketEntry bucketEntry)

Put the new bucket entry into backingMap. Notice that we are allowed to replace the existing cache with a new block for the same cache key. there's a corner case: one thread cache a block in ramCache, copy to io-engine and add a bucket entry to backingMap. Caching another new block with the same cache key do the same thing for the same cache key, so if not evict the previous bucket entry, then memory leak happen because the previous bucketEntry is gone but the bucketAllocator do not free its memory.

Parameters:

key - Block cache key

bucketEntry - Bucket entry to put into backingMap.

See Also:

BlockCacheUtil.shouldReplaceExistingCacheBlock(BlockCache blockCache,BlockCacheKey cacheKey, Cacheable newBlock)

doDrain

void doDrain(List<BucketCache.RAMQueueEntry> entries)
      throws InterruptedException

Flush the entries in ramCache to IOEngine and add bucket entry to backingMap. Process all that are passed in even if failure being sure to remove from ramCache else we'll never undo the references and we'll OOME.

Parameters:

entries - Presumes list passed in here will be processed by this invocation only. No interference expected.

Throws:

InterruptedException