Package 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

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

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

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 Details

ZombieLastLogWriterRegionServer

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

Throws:

IOException

InterruptedException

Method Details

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)