Package org.apache.maven.plugin.surefire.extensions

Class LegacyForkChannel

java.lang.Object

org.apache.maven.surefire.extensions.ForkChannel

org.apache.maven.plugin.surefire.extensions.LegacyForkChannel

All Implemented Interfaces:

Closeable, AutoCloseable

final class LegacyForkChannel
extends ForkChannel

The main purpose of this class is to bind the command reader reading the commands from CommandReader, serializing them and writing the stream to the sub-process. It binds the event handler deserializing a received event and sends the event object to the event handler.

Field Summary

Fields

Modifier and Type	Field	Description
private CloseableDaemonThread	commandReaderBindings
private CloseableDaemonThread	eventHandlerBindings

Constructor Summary

Constructors

Constructor	Description
LegacyForkChannel(ForkNodeArguments arguments)

Method Summary

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

Methods inherited from class org.apache.maven.surefire.extensions.ForkChannel

getArguments

Methods inherited from class java.lang.Object

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

Field Details

commandReaderBindings

private CloseableDaemonThread commandReaderBindings

eventHandlerBindings

private CloseableDaemonThread eventHandlerBindings

Constructor Details

LegacyForkChannel

LegacyForkChannel(@Nonnull
 ForkNodeArguments arguments)

Method Details

tryConnectToClient

public void tryConnectToClient()

Description copied from class: ForkChannel

Asynchronously connects to the client.

Specified by:

tryConnectToClient in class ForkChannel

getForkNodeConnectionString

public String getForkNodeConnectionString()

Description copied from class: ForkChannel

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

Specified by:

getForkNodeConnectionString in class ForkChannel

Returns:

a connection string utilized by the client in the fork JVM

getCountdownCloseablePermits

public int getCountdownCloseablePermits()

Description copied from class: ForkChannel

the permits in CountdownCloseable.

Specified by:

getCountdownCloseablePermits in class ForkChannel

bindCommandReader

public void bindCommandReader(@Nonnull
 CommandReader commands,
 WritableByteChannel stdIn)

Description copied from class: ForkChannel

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

Specified by:

bindCommandReader in class ForkChannel

Parameters:

commands - command reader, see CommandReader.readNextCommand()

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

bindEventHandler

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

Description copied from class: ForkChannel

Starts a Thread reading the events.

Specified by:

bindEventHandler in class ForkChannel

Parameters:

eventHandler - event eventHandler

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

stdOut - optional standard output stream of the JVM

disable

public void disable()

Specified by:

disable in class ForkChannel

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class ForkChannel