Package org.apache.maven.plugin.surefire.booterclient.output

Class ForkClient

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.output.ForkClient

All Implemented Interfaces:

org.apache.maven.shared.utils.cli.StreamConsumer

public class ForkClient
extends Object
implements org.apache.maven.shared.utils.cli.StreamConsumer

Knows how to reconstruct *all* the state transmitted over stdout by the forked process.

Author:

Kristian Rosenvold

Constructor Summary

Constructors

Constructor	Description
ForkClient(DefaultReporterFactory defaultReporterFactory, NotifiableTestStream notifiableTestStream, org.apache.maven.plugin.surefire.log.api.ConsoleLogger log, AtomicBoolean printedErrorStream)

Method Summary

Modifier and Type	Method	Description
void	close(boolean hadTimeout)
final void	consumeLine(String s)
final void	consumeMultiLineContent(String s)
final DefaultReporterFactory	getDefaultReporterFactory()
final org.apache.maven.surefire.report.StackTraceWriter	getErrorInFork()
final org.apache.maven.surefire.report.RunListener	getReporter()	Used when getting reporters on the plugin side of a fork.
final Map<String,String>	getTestVmSystemProperties()
final boolean	hadTimeout()
boolean	hasTestsInProgress()
final boolean	isErrorInFork()
final boolean	isSaidGoodBye()
void	kill()
void	setForkNumber(int forkNumber)
protected void	stopOnNextTest()
Set<String>	testsInProgress()
final void	tryToTimeout(long currentTimeMillis, int forkedProcessTimeoutInSeconds)	Called in concurrent Thread.

Methods inherited from class java.lang.Object

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

Constructor Details

ForkClient

public ForkClient(DefaultReporterFactory defaultReporterFactory,
 NotifiableTestStream notifiableTestStream,
 org.apache.maven.plugin.surefire.log.api.ConsoleLogger log,
 AtomicBoolean printedErrorStream)

Method Details

stopOnNextTest

protected void stopOnNextTest()

kill

public void kill()

tryToTimeout

public final void tryToTimeout(long currentTimeMillis,
 int forkedProcessTimeoutInSeconds)

Called in concurrent Thread. Will shutdown if timeout was reached.

Parameters:

currentTimeMillis - current time in millis seconds

forkedProcessTimeoutInSeconds - timeout in seconds given by MOJO

getDefaultReporterFactory

public final DefaultReporterFactory getDefaultReporterFactory()

consumeLine

public final void consumeLine(String s)

Specified by:

consumeLine in interface org.apache.maven.shared.utils.cli.StreamConsumer

hadTimeout

public final boolean hadTimeout()

consumeMultiLineContent

public final void consumeMultiLineContent(String s)
                                   throws IOException

Throws:

IOException

getTestVmSystemProperties

public final Map<String,String> getTestVmSystemProperties()

getReporter

public final org.apache.maven.surefire.report.RunListener getReporter()

Used when getting reporters on the plugin side of a fork. Used by testing purposes only. May not be volatile variable.

Returns:

A mock provider reporter

close

public void close(boolean hadTimeout)

isSaidGoodBye

public final boolean isSaidGoodBye()

getErrorInFork

public final org.apache.maven.surefire.report.StackTraceWriter getErrorInFork()

isErrorInFork

public final boolean isErrorInFork()

testsInProgress

public Set<String> testsInProgress()

hasTestsInProgress

public boolean hasTestsInProgress()

setForkNumber

public void setForkNumber(int forkNumber)