org.apache.hadoop.hbase.wal

Class TestWALSplit.ZombieLastLogWriterRegionServer

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.wal.TestWALSplit.ZombieLastLogWriterRegionServer

All Implemented Interfaces:

Runnable

Enclosing class:

TestWALSplit

class TestWALSplit.ZombieLastLogWriterRegionServer
extends Thread

This thread will keep writing to a 'wal' file even after the split process has started. It simulates a region server that was considered dead but woke up and wrote some more to the last log entry. Does its writing as an alternate user in another filesystem instance to simulate better it being a regionserver.

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
(package private) AtomicLong	editsCount
(package private) int	numOfWriters
(package private) String	region Region to write edits for.
(package private) AtomicBoolean	stop
(package private) org.apache.hadoop.hbase.security.User	user

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ZombieLastLogWriterRegionServer(AtomicLong counter, AtomicBoolean stop, String region, int writers)

Method Summary

Modifier and Type	Method and Description
private void	doWriting()
private void	loop(org.apache.hadoop.hbase.wal.WALProvider.Writer writer)
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

editsCount

final AtomicLong editsCount

stop

final AtomicBoolean stop

numOfWriters

final int numOfWriters

region

final String region

Region to write edits for.

user

final org.apache.hadoop.hbase.security.User user

Constructor Detail

ZombieLastLogWriterRegionServer

public ZombieLastLogWriterRegionServer(AtomicLong counter,
                                       AtomicBoolean stop,
                                       String region,
                                       int writers)
                                throws IOException,
                                       InterruptedException

Throws:

IOException

InterruptedException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

doWriting

private void doWriting()
                throws IOException,
                       InterruptedException

Throws:

IOException

InterruptedException

loop

private void loop(org.apache.hadoop.hbase.wal.WALProvider.Writer writer)