public class ForkClient
extends java.lang.Object
implements org.apache.maven.shared.utils.cli.StreamConsumer
Modifier and Type | Field and Description |
---|---|
private DefaultReporterFactory |
defaultReporterFactory |
private StackTraceWriter |
errorInFork |
private NotifiableTestStream |
notifiableTestStream |
private boolean |
saidGoodBye |
private static long |
START_TIME_NEGATIVE_TIMEOUT |
private static long |
START_TIME_ZERO |
private java.util.Map<java.lang.Integer,RunListener> |
testSetReporters |
private java.util.concurrent.atomic.AtomicLong |
testSetStartedAt
test-set . |
private java.util.Properties |
testVmSystemProperties |
Constructor and Description |
---|
ForkClient(DefaultReporterFactory defaultReporterFactory,
java.util.Properties testVmSystemProperties,
NotifiableTestStream notifiableTestStream) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean hadTimeout) |
void |
consumeLine(java.lang.String s) |
void |
consumeMultiLineContent(java.lang.String s) |
private java.lang.String |
createConsoleMessage(java.lang.String remaining) |
private ReportEntry |
createReportEntry(java.lang.String untokenized) |
private StackTraceWriter |
deserializeStackTraceWriter(java.util.StringTokenizer tokens) |
DefaultReporterFactory |
getDefaultReporterFactory() |
StackTraceWriter |
getErrorInFork() |
private ConsoleLogger |
getOrCreateConsoleLogger(int channelNumber) |
private ConsoleOutputReceiver |
getOrCreateConsoleOutputReceiver(int channelNumber) |
private RunListener |
getOrCreateReporter(int channelNumber) |
RunListener |
getReporter(int channelNumber)
Used when getting reporters on the plugin side of a fork.
|
boolean |
hadTimeout() |
boolean |
isErrorInFork() |
boolean |
isSaidGoodBye() |
private java.lang.String |
nullableCsv(java.lang.String source) |
private void |
processLine(java.lang.String s) |
private void |
setCurrentStartTime() |
protected void |
stopOnNextTest() |
void |
tryToTimeout(long currentTimeMillis,
int forkedProcessTimeoutInSeconds)
Called in concurrent Thread.
|
private java.lang.String |
unescape(java.lang.String source) |
private void |
writeTestOutput(int channelNumber,
java.lang.String remaining,
boolean isStdout) |
private static final long START_TIME_ZERO
private static final long START_TIME_NEGATIVE_TIMEOUT
private final DefaultReporterFactory defaultReporterFactory
private final NotifiableTestStream notifiableTestStream
private final java.util.Map<java.lang.Integer,RunListener> testSetReporters
private final java.util.Properties testVmSystemProperties
private final java.util.concurrent.atomic.AtomicLong testSetStartedAt
test-set
.private volatile boolean saidGoodBye
private volatile StackTraceWriter errorInFork
public ForkClient(DefaultReporterFactory defaultReporterFactory, java.util.Properties testVmSystemProperties, NotifiableTestStream notifiableTestStream)
protected void stopOnNextTest()
public final void tryToTimeout(long currentTimeMillis, int forkedProcessTimeoutInSeconds)
public final DefaultReporterFactory getDefaultReporterFactory()
public final void consumeLine(java.lang.String s)
consumeLine
in interface org.apache.maven.shared.utils.cli.StreamConsumer
private void setCurrentStartTime()
public final boolean hadTimeout()
private void processLine(java.lang.String s)
private void writeTestOutput(int channelNumber, java.lang.String remaining, boolean isStdout)
public final void consumeMultiLineContent(java.lang.String s) throws java.io.IOException
java.io.IOException
private java.lang.String createConsoleMessage(java.lang.String remaining)
private ReportEntry createReportEntry(java.lang.String untokenized)
private StackTraceWriter deserializeStackTraceWriter(java.util.StringTokenizer tokens)
private java.lang.String nullableCsv(java.lang.String source)
private java.lang.String unescape(java.lang.String source)
public final RunListener getReporter(int channelNumber)
channelNumber
- The logical channel numberprivate RunListener getOrCreateReporter(int channelNumber)
private ConsoleOutputReceiver getOrCreateConsoleOutputReceiver(int channelNumber)
private ConsoleLogger getOrCreateConsoleLogger(int channelNumber)
public void close(boolean hadTimeout)
public final boolean isSaidGoodBye()
public final StackTraceWriter getErrorInFork()
public final boolean isErrorInFork()