Package org.apache.maven.surefire.booter.stream

Class CommandDecoder

java.lang.Object

org.apache.maven.surefire.api.stream.AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

org.apache.maven.surefire.booter.stream.CommandDecoder

All Implemented Interfaces:

AutoCloseable

public class CommandDecoder
extends AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

AbstractStreamDecoder.BufferedStream, AbstractStreamDecoder.MalformedFrameException, AbstractStreamDecoder.Memento, AbstractStreamDecoder.Segment, AbstractStreamDecoder.StreamReadStatus

Field Summary

Fields inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
CommandDecoder(ReadableByteChannel channel, ForkNodeArguments arguments)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	debugStream(byte[] array, int position, int remaining)
Command	decode(AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>.Memento memento)
protected final byte[]	getEncodedMagicNumber()
protected SegmentType[]	nextSegmentType(MasterProcessCommand commandType)
protected Command	toMessage(MasterProcessCommand commandType, AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>.Memento memento)

Methods inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

checkArguments, checkDelimiter, checkHeader, getArguments, printRemainingStream, read, readByte, readCharset, readInt, readInteger, readLong, readLongPrivate, readMessageType, readSegment, readString

Methods inherited from class java.lang.Object

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

Constructor Details

CommandDecoder

public CommandDecoder(@Nonnull
 ReadableByteChannel channel,
 @Nonnull
 ForkNodeArguments arguments)

Method Details

decode

public Command decode(@Nonnull
 AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>.Memento memento)
               throws IOException,
MalformedChannelException

Specified by:

decode in class AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

Throws:

IOException

MalformedChannelException

getEncodedMagicNumber

@Nonnull
protected final byte[] getEncodedMagicNumber()

Specified by:

getEncodedMagicNumber in class AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

nextSegmentType

@Nonnull
protected SegmentType[] nextSegmentType(@Nonnull
 MasterProcessCommand commandType)

Specified by:

nextSegmentType in class AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

toMessage

@Nonnull
protected Command toMessage(@Nonnull
 MasterProcessCommand commandType,
 @Nonnull
 AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>.Memento memento)
                     throws AbstractStreamDecoder.MalformedFrameException

Specified by:

toMessage in class AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

Throws:

AbstractStreamDecoder.MalformedFrameException

debugStream

protected void debugStream(byte[] array,
 int position,
 int remaining)

Overrides:

debugStream in class AbstractStreamDecoder<Command,MasterProcessCommand,SegmentType>

close

public void close()
           throws IOException

Throws:

IOException