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 and Description
CommandDecoder(ReadableByteChannel channel, ForkNodeArguments arguments)

Method Summary

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

CommandDecoder

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

Method Detail

decode

public Command decode(@Nonnull
                      AbstractStreamDecoder.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.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