org.dcm4che3.net

Class PDUDecoder

java.lang.Object

java.io.InputStream

org.dcm4che3.net.PDVInputStream

org.dcm4che3.net.PDUDecoder

All Implemented Interfaces:

Closeable, AutoCloseable

class PDUDecoder
extends PDVInputStream

Author:

Gunter Zeilinger

Field Summary

Fields

Modifier and Type	Field and Description
private Association	as
private byte[]	buf
private InputStream	in
private static String	INVALID_COMMON_EXTENDED_NEGOTIATION
private static String	INVALID_PDU_LENGTH
private static String	INVALID_PDV
private static String	INVALID_USER_IDENTITY
private static int	MAX_PDU_LEN
private int	pcid
private int	pdulen
private int	pdutype
private int	pdvend
private int	pdvmch
private int	pos
private Thread	th
private static String	UNEXPECTED_PDV_PCID
private static String	UNEXPECTED_PDV_TYPE
private static String	UNRECOGNIZED_PDU

Constructor Summary

Constructors

Constructor and Description
PDUDecoder(Association as, InputStream in)

Method Summary

Modifier and Type	Method and Description
private void	abort(int reason, String logmsg)
int	available()
private void	checkPDULength(int len)
private void	checkThread()
void	close()
void	copyTo(OutputStream out)
void	copyTo(OutputStream out, int length)
private AAssociateRQAC	decode(AAssociateRQAC rqac)
private byte[]	decodeBytes()
private CommonExtendedNegotiation	decodeCommonExtNeg(int itemLen)
void	decodeDIMSE()
private ExtendedNegotiation	decodeExtNeg(int itemLen)
private void	decodeItem(AAssociateRQAC rqac)
private PresentationContext	decodePC(int itemLen)
private RoleSelection	decodeRoleSelection(int itemLen)
private String	decodeString()
private UserIdentityAC	decodeUserIdentityAC(int itemLen)
private UserIdentityRQ	decodeUserIdentityRQ(int itemLen)
private void	decodeUserInfo(int itemLength, AAssociateRQAC rqac)
private void	decodeUserInfoSubItem(AAssociateRQAC rqac)
private Dimse	dimseOf(Attributes cmd)
private int	get()
private void	get(byte[] b, int off, int len)
private byte[]	getBytes(int len)
private int	getInt()
private String	getString(int len)
private int	getUnsignedShort()
private boolean	hasRemaining()
private boolean	isLastPDV()
void	nextPDU()
private void	nextPDV(int expectedPDVType, int expectedPCID)
int	read()
int	read(byte[] b, int off, int len)
private Attributes	readCommand()
Attributes	readDataset(String tsuid)
private void	readFully(int off, int len)
private void	readPDU()
private int	remaining()
private void	skip(int len)
long	skip(long n)
long	skipAll()

Methods inherited from class java.io.InputStream

mark, markSupported, read, reset

Methods inherited from class java.lang.Object

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

Field Detail

UNRECOGNIZED_PDU

private static final String UNRECOGNIZED_PDU

See Also:

Constant Field Values

INVALID_PDU_LENGTH

private static final String INVALID_PDU_LENGTH

See Also:

Constant Field Values

INVALID_COMMON_EXTENDED_NEGOTIATION

private static final String INVALID_COMMON_EXTENDED_NEGOTIATION

See Also:

Constant Field Values

INVALID_USER_IDENTITY

private static final String INVALID_USER_IDENTITY

See Also:

Constant Field Values

INVALID_PDV

private static final String INVALID_PDV

See Also:

Constant Field Values

UNEXPECTED_PDV_TYPE

private static final String UNEXPECTED_PDV_TYPE

See Also:

Constant Field Values

UNEXPECTED_PDV_PCID

private static final String UNEXPECTED_PDV_PCID

See Also:

Constant Field Values

MAX_PDU_LEN

private static final int MAX_PDU_LEN

See Also:

Constant Field Values

as

private final Association as

in

private final InputStream in

th

private final Thread th

buf

private byte[] buf

pos

private int pos

pdutype

private int pdutype

pdulen

private int pdulen

pcid

private int pcid

pdvmch

private int pdvmch

pdvend

private int pdvend

Constructor Detail

PDUDecoder

public PDUDecoder(Association as,
                  InputStream in)

Method Detail

remaining

private int remaining()

hasRemaining

private boolean hasRemaining()

get

private int get()

get

private void get(byte[] b,
                 int off,
                 int len)

skip

private void skip(int len)

getUnsignedShort

private int getUnsignedShort()

getInt

private int getInt()

getBytes

private byte[] getBytes(int len)

decodeBytes

private byte[] decodeBytes()

nextPDU

public void nextPDU()
             throws IOException

Throws:

IOException

checkThread

private void checkThread()

checkPDULength

private void checkPDULength(int len)
                     throws AAbort

Throws:

AAbort

readPDU

private void readPDU()
              throws IOException

Throws:

IOException

readFully

private void readFully(int off,
                       int len)
                throws IOException

Throws:

IOException

abort

private void abort(int reason,
                   String logmsg)
            throws AAbort

Throws:

AAbort

getString

private String getString(int len)

decodeString

private String decodeString()

decode

private AAssociateRQAC decode(AAssociateRQAC rqac)
                       throws AAbort

Throws:

AAbort

decodeItem

private void decodeItem(AAssociateRQAC rqac)
                 throws AAbort

Throws:

AAbort

decodePC

private PresentationContext decodePC(int itemLen)

decodeUserInfo

private void decodeUserInfo(int itemLength,
                            AAssociateRQAC rqac)
                     throws AAbort

Throws:

AAbort

decodeUserInfoSubItem

private void decodeUserInfoSubItem(AAssociateRQAC rqac)
                            throws AAbort

Throws:

AAbort

decodeRoleSelection

private RoleSelection decodeRoleSelection(int itemLen)

decodeExtNeg

private ExtendedNegotiation decodeExtNeg(int itemLen)

decodeCommonExtNeg

private CommonExtendedNegotiation decodeCommonExtNeg(int itemLen)
                                              throws AAbort

Throws:

AAbort

decodeUserIdentityRQ

private UserIdentityRQ decodeUserIdentityRQ(int itemLen)
                                     throws AAbort

Throws:

AAbort

decodeUserIdentityAC

private UserIdentityAC decodeUserIdentityAC(int itemLen)
                                     throws AAbort

Throws:

AAbort

decodeDIMSE

public void decodeDIMSE()
                 throws IOException

Throws:

IOException

dimseOf

private Dimse dimseOf(Attributes cmd)
               throws AAbort

Throws:

AAbort

readCommand

private Attributes readCommand()
                        throws IOException

Throws:

IOException

readDataset

public Attributes readDataset(String tsuid)
                       throws IOException

Specified by:

readDataset in class PDVInputStream

Throws:

IOException

nextPDV

private void nextPDV(int expectedPDVType,
                     int expectedPCID)
              throws IOException

Throws:

IOException

isLastPDV

private boolean isLastPDV()
                   throws IOException

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

available

public final int available()

Overrides:

available in class InputStream

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

skipAll

public long skipAll()
             throws IOException

Specified by:

skipAll in class PDVInputStream

Throws:

IOException

copyTo

public void copyTo(OutputStream out,
                   int length)
            throws IOException

Specified by:

copyTo in class PDVInputStream

Throws:

IOException

copyTo

public void copyTo(OutputStream out)
            throws IOException

Specified by:

copyTo in class PDVInputStream

Throws:

IOException