org.theta4j.ptpip.io

Class PtpIpInputStream

java.lang.Object

org.theta4j.ptpip.io.PtpIpInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public final class PtpIpInputStream
extends java.lang.Object
implements java.io.Closeable

InputStream of PTP-IP.

Constructor Summary

Constructors

Constructor and Description
PtpIpInputStream(java.io.InputStream is) Wrap InputStream by PtpIpInputStream.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
PtpIpPacket.Type	nextType() Get type of next PTP-IP Packet.
CancelPacket	readCancelPacket() Read CancelPacket from the stream.
byte[]	readData() Process Data Phase (StartData -> [Data] -> EndData) and returns all data as byte array.
void	readData(java.io.OutputStream dst) Process Data Phase (StartData -> [Data] -> EndData) and writes all data to dst.
DataPacket	readDataPacket() Read DataPacket from the stream.
EndDataPacket	readEndDataPacket() Read EndDataPacket from the stream.
EventPacket	readEventPacket() Read EventPacket from the stream.
InitCommandAckPacket	readInitCommandAckPacket() Read InitCommandAckPacket from the stream.
InitCommandRequestPacket	readInitCommandRequestPacket() Read InitCommandRequestPacket from the stream.
InitEventAckPacket	readInitEventAckPacket() Read InitEventAckPacket from the stream.
InitEventRequestPacket	readInitEventRequestPacket() Read InitEventRequestPacket from the stream.
InitFailPacket	readInitFailPacket() Read InitFailPacket from the stream.
OperationRequestPacket	readOperationRequestPacket() Read OperationRequestPacket from the stream.
OperationResponsePacket	readOperationResponsePacket() Read OperationResponsePacket from the stream.
ProbeRequestPacket	readProbeRequestPacket() Read ProbeRequestPacket from the stream.
ProbeResponsePacket	readProbeResponsePacket() Read ProbeResponsePacket from the stream.
StartDataPacket	readStartDataPacket() Read StartDataPacket from the stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

PtpIpInputStream

public PtpIpInputStream(java.io.InputStream is)

Wrap InputStream by PtpIpInputStream.

Parameters:

is -

Method Detail

nextType

public PtpIpPacket.Type nextType()
                          throws java.io.IOException

Get type of next PTP-IP Packet. This method does not change the position of stream.

Throws:

java.io.IOException

readInitCommandRequestPacket

public InitCommandRequestPacket readInitCommandRequestPacket()
                                                      throws java.io.IOException

Read InitCommandRequestPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not InitCommandRequestPacket.

java.io.IOException

readInitCommandAckPacket

public InitCommandAckPacket readInitCommandAckPacket()
                                              throws java.io.IOException

Read InitCommandAckPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not InitCommandAckPacket.

java.io.IOException

readInitEventRequestPacket

public InitEventRequestPacket readInitEventRequestPacket()
                                                  throws java.io.IOException

Read InitEventRequestPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not InitEventRequestPacket.

java.io.IOException

readInitEventAckPacket

public InitEventAckPacket readInitEventAckPacket()
                                          throws java.io.IOException

Read InitEventAckPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not InitEventAckPacket.

java.io.IOException

readInitFailPacket

public InitFailPacket readInitFailPacket()
                                  throws java.io.IOException

Read InitFailPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not InitFailPacket.

java.io.IOException

readOperationRequestPacket

public OperationRequestPacket readOperationRequestPacket()
                                                  throws java.io.IOException

Read OperationRequestPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not OperationRequestPacket.

java.io.IOException

readOperationResponsePacket

public OperationResponsePacket readOperationResponsePacket()
                                                    throws java.io.IOException

Read OperationResponsePacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not OperationResponsePacket.

java.io.IOException

readEventPacket

public EventPacket readEventPacket()
                            throws java.io.IOException

Read EventPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not EventPacket.

java.io.IOException

readStartDataPacket

public StartDataPacket readStartDataPacket()
                                    throws java.io.IOException

Read StartDataPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not StartDataPacket.

java.io.IOException

readDataPacket

public DataPacket readDataPacket()
                          throws java.io.IOException

Read DataPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not DataPacket.

java.io.IOException

readEndDataPacket

public EndDataPacket readEndDataPacket()
                                throws java.io.IOException

Read EndDataPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not EndDataPacket.

java.io.IOException

readCancelPacket

public CancelPacket readCancelPacket()
                              throws java.io.IOException

Read CancelPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not CancelPacket.

java.io.IOException

readProbeRequestPacket

public ProbeRequestPacket readProbeRequestPacket()
                                          throws java.io.IOException

Read ProbeRequestPacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not ProbeRequestPacket.

java.io.IOException

readProbeResponsePacket

public ProbeResponsePacket readProbeResponsePacket()
                                            throws java.io.IOException

Read ProbeResponsePacket from the stream.

Throws:

java.lang.RuntimeException - if next packet is not ProbeResponsePacket.

java.io.IOException

readData

public byte[] readData()
                throws java.io.IOException,
                       PtpException

Process Data Phase (StartData -> [Data] -> EndData) and returns all data as byte array.

Throws:

java.io.IOException

PtpException

readData

public void readData(java.io.OutputStream dst)
              throws java.io.IOException,
                     PtpException

Process Data Phase (StartData -> [Data] -> EndData) and writes all data to dst.

Parameters:

dst -

Throws:

java.lang.RuntimeException - if it is not Data Phase.

java.io.IOException

PtpException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException