Package org.yamcs.tctm

Class CfdpPacketInputStream

java.lang.Object

org.yamcs.tctm.CfdpPacketInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, PacketInputStream

public class CfdpPacketInputStream
extends Object
implements PacketInputStream

CFDP packet reader that splits the stream into packets based on the length of the packet

Constructor Summary

Constructors

Constructor	Description
CfdpPacketInputStream()

Method Summary

Modifier and Type	Method	Description
void	close()
void	init(InputStream inputStream, YConfiguration config)	Called each time an input stream is opened to initialize the object
byte[]	readPacket()	read the next packet - blocking if necessary until all the data is available.

Methods inherited from class java.lang.Object

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

Constructor Detail

CfdpPacketInputStream

public CfdpPacketInputStream()

Method Detail

init

public void init(InputStream inputStream,
                 YConfiguration config)

Description copied from interface: PacketInputStream

Called each time an input stream is opened to initialize the object

Specified by:

init in interface PacketInputStream

readPacket

public byte[] readPacket()
                  throws IOException

Description copied from interface: PacketInputStream

read the next packet - blocking if necessary until all the data is available.

Specified by:

readPacket in interface PacketInputStream

Returns:

the next packet read from the input stream.

Throws:

EOFException - if this input stream reaches the end.

IOException - an I/O error has occurred

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException