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 DataInputStreamdataInputStream
-
Constructor Summary
Constructors Constructor Description FixedPacketInputStream()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidinit(InputStream inputStream, YConfiguration args)Called each time an input stream is opened to initialize the objectbyte[]readPacket()read the next packet - blocking if necessary until all the data is available.
-
-
-
Field Detail
-
dataInputStream
protected DataInputStream dataInputStream
-
-
Method Detail
-
init
public void init(InputStream inputStream, YConfiguration args)
Description copied from interface:PacketInputStreamCalled each time an input stream is opened to initialize the object- Specified by:
initin interfacePacketInputStream
-
readPacket
public byte[] readPacket() throws IOException, PacketTooLongExceptionDescription copied from interface:PacketInputStreamread the next packet - blocking if necessary until all the data is available.- Specified by:
readPacketin interfacePacketInputStream- Returns:
- the next packet read from the input stream.
- Throws:
EOFException- if this input stream reaches the end.IOException- an I/O error has occurredPacketTooLongException- if a packet read is longer than a defined limit
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
-