Package org.yamcs.tctm

Class FixedPacketInputStream

java.lang.Object

org.yamcs.tctm.FixedPacketInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, PacketInputStream

public class FixedPacketInputStream
extends Object
implements PacketInputStream

This input stream reads packets of a configurable fixed packet size.

Field Summary

Fields

Modifier and Type	Field	Description
protected DataInputStream	dataInputStream

Constructor Summary

Constructors

Constructor	Description
FixedPacketInputStream()

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

Field Details

dataInputStream

protected DataInputStream dataInputStream

Constructor Details

FixedPacketInputStream

public FixedPacketInputStream()

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,
PacketTooLongException

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

PacketTooLongException - if a packet read is longer than a defined limit

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException