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.surefire.extensions.EventHandler<org.apache.maven.surefire.api.event.Event>

public final class ForkClient
extends Object
implements org.apache.maven.surefire.extensions.EventHandler<org.apache.maven.surefire.api.event.Event>

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, int forkNumber)

Method Summary

Modifier and Type	Method	Description
void	close(boolean hadTimeout)
org.apache.maven.surefire.api.report.TestOutputReceiver<org.apache.maven.surefire.api.report.TestOutputReportEntry>	getConsoleOutputReceiver()
DefaultReporterFactory	getDefaultReporterFactory()
org.apache.maven.surefire.api.report.StackTraceWriter	getErrorInFork()
org.apache.maven.surefire.api.report.RunListener	getReporter()	Used when getting reporters on the plugin side of a fork.
Map<String,String>	getTestVmSystemProperties()
boolean	hadTimeout()
void	handleEvent(org.apache.maven.surefire.api.event.Event event)
boolean	hasTestsInProgress()
boolean	isErrorInFork()
boolean	isSaidGoodBye()
void	kill()
void	setStopOnNextTestListener(ForkedProcessEventListener listener)
void	setTimeoutDetectedListener(Runnable listener)	Registers a one-shot callback invoked synchronously when the forked process timeout has been reached, immediately before the KILL command is sent.
Set<String>	testsInProgress()
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,
 int forkNumber)

Method Details

setStopOnNextTestListener

public void setStopOnNextTestListener(ForkedProcessEventListener listener)

setTimeoutDetectedListener

public void setTimeoutDetectedListener(Runnable listener)

Registers a one-shot callback invoked synchronously when the forked process timeout has been reached, immediately before the KILL command is sent. The forked JVM is still alive when the callback runs, so it may collect live diagnostics (for example a jstack dump).

Parameters:

listener - the callback to run, or null to clear; callback must not throw checked exceptions

kill

public void kill()

tryToTimeout

public void tryToTimeout(long currentTimeMillis,
 int forkedProcessTimeoutInSeconds)

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

Parameters:

currentTimeMillis - current time in milliseconds

forkedProcessTimeoutInSeconds - timeout in seconds given by MOJO

getDefaultReporterFactory

public DefaultReporterFactory getDefaultReporterFactory()

handleEvent

public void handleEvent(@Nonnull
 org.apache.maven.surefire.api.event.Event event)

Specified by:

handleEvent in interface org.apache.maven.surefire.extensions.EventHandler<org.apache.maven.surefire.api.event.Event>

hadTimeout

public boolean hadTimeout()

getTestVmSystemProperties

public Map<String,String> getTestVmSystemProperties()

getReporter

public org.apache.maven.surefire.api.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

getConsoleOutputReceiver

public org.apache.maven.surefire.api.report.TestOutputReceiver<org.apache.maven.surefire.api.report.TestOutputReportEntry> getConsoleOutputReceiver()

close

public void close(boolean hadTimeout)

isSaidGoodBye

public boolean isSaidGoodBye()

getErrorInFork

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

isErrorInFork

public boolean isErrorInFork()

testsInProgress

public Set<String> testsInProgress()

hasTestsInProgress

public boolean hasTestsInProgress()