Package org.apache.maven.surefire.extensions

Class ForkChannel

java.lang.Object

org.apache.maven.surefire.extensions.ForkChannel

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class ForkChannel
extends Object
implements Closeable

It's a session object used only by a particular Thread in ForkStarter and communicates with a dedicated forked JVM. It represents a server.

It connects to a remote client by tryConnectToClient(), provides a connection string getForkNodeConnectionString() needed by the client in forked JVM, binds event handler and command reader. This object is called in one Thread.

Since:

3.0.0-M5

Author:

Tibor Digana (tibor17)

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForkChannel(ForkNodeArguments arguments)

Method Summary

Modifier and Type	Method	Description
abstract void	bindCommandReader(CommandReader commands, WritableByteChannel stdIn)	Binds command handler to the channel.
abstract void	bindEventHandler(EventHandler<Event> eventHandler, CountdownCloseable countdownCloseable, ReadableByteChannel stdOut)	Starts a Thread reading the events.
abstract void	close()
abstract void	disable()
protected ForkNodeArguments	getArguments()
abstract int	getCountdownCloseablePermits()	the permits in CountdownCloseable.
abstract String	getForkNodeConnectionString()	This is server related class, which if binds to a TCP port, determines the connection string for the client.
abstract void	tryConnectToClient()	Asynchronously connects to the client.

Methods inherited from class java.lang.Object

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

Constructor Details

ForkChannel

protected ForkChannel(@Nonnull
 ForkNodeArguments arguments)

Parameters:

arguments - data necessary for command reader and event handler.

Method Details

tryConnectToClient

public abstract void tryConnectToClient()
                                 throws IOException,
InterruptedException

Asynchronously connects to the client.

Throws:

IOException - if stream fails

InterruptedException - if interrupted thread

getForkNodeConnectionString

public abstract String getForkNodeConnectionString()

This is server related class, which if binds to a TCP port, determines the connection string for the client.

Returns:

a connection string utilized by the client in the fork JVM

getCountdownCloseablePermits

public abstract int getCountdownCloseablePermits()

the permits in CountdownCloseable.

bindCommandReader

public abstract void bindCommandReader(@Nonnull
 CommandReader commands,
 WritableByteChannel stdIn)
                                throws IOException,
InterruptedException

Binds command handler to the channel. Starts a Thread streaming out the commands.

Parameters:

commands - command reader, see CommandReader.readNextCommand()

stdIn - optional standard input stream of the JVM to write the encoded commands into it

Throws:

IOException - if an error in the fork channel

InterruptedException - channel interrupted

bindEventHandler

public abstract void bindEventHandler(@Nonnull
 EventHandler<Event> eventHandler,
 @Nonnull
 CountdownCloseable countdownCloseable,
 ReadableByteChannel stdOut)
                               throws IOException,
InterruptedException

Starts a Thread reading the events.

Parameters:

eventHandler - event eventHandler

countdownCloseable - count down of the final call of Closeable.close()

stdOut - optional standard output stream of the JVM

Throws:

IOException - if an error in the fork channel

InterruptedException - channel interrupted

getArguments

@Nonnull
protected ForkNodeArguments getArguments()

disable

public abstract void disable()

close

public abstract void close()
                    throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException