public static class MultithreadedTestUtil.TestContext extends Object
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
private Throwable |
err |
private boolean |
stopped |
private Set<MultithreadedTestUtil.TestThread> |
testThreads |
private int |
threadDoneCount |
Constructor and Description |
---|
TestContext(org.apache.hadoop.conf.Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
addThread(MultithreadedTestUtil.TestThread t) |
private void |
checkException() |
protected org.apache.hadoop.conf.Configuration |
getConf() |
void |
setStopFlag(boolean s) |
boolean |
shouldRun() |
void |
startThreads() |
void |
stop() |
void |
threadDone() |
void |
threadFailed(Throwable t) |
void |
waitFor(long millis) |
private final org.apache.hadoop.conf.Configuration conf
private boolean stopped
private int threadDoneCount
private Set<MultithreadedTestUtil.TestThread> testThreads
public TestContext(org.apache.hadoop.conf.Configuration configuration)
protected org.apache.hadoop.conf.Configuration getConf()
public boolean shouldRun()
public void addThread(MultithreadedTestUtil.TestThread t)
public void startThreads()
private void checkException() throws Exception
Exception
public void threadFailed(Throwable t)
public void threadDone()
public void setStopFlag(boolean s) throws Exception
Exception
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.