Module org.yamcs.core

Package org.yamcs.tctm

Class CcsdsPacketInputStream

java.lang.Object

org.yamcs.tctm.CcsdsPacketInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, PacketInputStream

public class CcsdsPacketInputStream
extends Object
implements PacketInputStream

Reads CCSDS packets from an input stream: first it reads 6 bytes primary header, it derives the length from the last two bytes and reads the remaining of the data. It also support a maxLength property to limit the size of the packet that is being read.

Constructor Summary

Constructors

Constructor	Description
CcsdsPacketInputStream()

Method Summary

Modifier and Type	Method	Description
void	close()
void	init(InputStream inputStream, YConfiguration args)	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 Details

CcsdsPacketInputStream

public CcsdsPacketInputStream()

Method Details

init

public void init(InputStream inputStream,
 YConfiguration args)

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