com.groupon.lex.metrics.history.xdr.support.reader

Class XdrDecodingFileReader

java.lang.Object

org.acplt.oncrpc.XdrDecodingStream

com.groupon.lex.metrics.history.xdr.support.reader.XdrDecodingFileReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class XdrDecodingFileReader
extends org.acplt.oncrpc.XdrDecodingStream
implements Closeable

Constructor Summary

Constructors

Constructor and Description
XdrDecodingFileReader(FileReader in)
XdrDecodingFileReader(FileReader in, ByteBuffer useBuffer)
XdrDecodingFileReader(FileReader in, int bufSiz)

Method Summary

Modifier and Type	Method and Description
void	beginDecoding()
void	close()
void	endDecoding()
InetAddress	getSenderAddress()
int	getSenderPort()
int	xdrDecodeInt()
void	xdrDecodeOpaque(byte[] opaque, int offset, int length)
byte[]	xdrDecodeOpaque(int length)

Methods inherited from class org.acplt.oncrpc.XdrDecodingStream

getCharacterEncoding, setCharacterEncoding, xdrDecodeBoolean, xdrDecodeBooleanFixedVector, xdrDecodeBooleanVector, xdrDecodeByte, xdrDecodeByteFixedVector, xdrDecodeByteVector, xdrDecodeDouble, xdrDecodeDoubleFixedVector, xdrDecodeDoubleVector, xdrDecodeDynamicOpaque, xdrDecodeFloat, xdrDecodeFloatFixedVector, xdrDecodeFloatVector, xdrDecodeIntFixedVector, xdrDecodeIntVector, xdrDecodeLong, xdrDecodeLongFixedVector, xdrDecodeLongVector, xdrDecodeOpaque, xdrDecodeShort, xdrDecodeShortFixedVector, xdrDecodeShortVector, xdrDecodeString, xdrDecodeStringFixedVector, xdrDecodeStringVector

Methods inherited from class java.lang.Object

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

Constructor Detail

XdrDecodingFileReader

public XdrDecodingFileReader(@NonNull
                             FileReader in,
                             int bufSiz)

XdrDecodingFileReader

public XdrDecodingFileReader(@NonNull
                             FileReader in)

XdrDecodingFileReader

public XdrDecodingFileReader(@NonNull
                             FileReader in,
                             @NonNull
                             ByteBuffer useBuffer)

Method Detail

beginDecoding

public void beginDecoding()

Specified by:

beginDecoding in class org.acplt.oncrpc.XdrDecodingStream

endDecoding

public void endDecoding()

Overrides:

endDecoding in class org.acplt.oncrpc.XdrDecodingStream

getSenderAddress

public InetAddress getSenderAddress()

Specified by:

getSenderAddress in class org.acplt.oncrpc.XdrDecodingStream

getSenderPort

public int getSenderPort()

Specified by:

getSenderPort in class org.acplt.oncrpc.XdrDecodingStream

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.acplt.oncrpc.XdrDecodingStream

Throws:

IOException

xdrDecodeInt

public int xdrDecodeInt()
                 throws org.acplt.oncrpc.OncRpcException,
                        IOException

Specified by:

xdrDecodeInt in class org.acplt.oncrpc.XdrDecodingStream

Throws:

org.acplt.oncrpc.OncRpcException

IOException

xdrDecodeOpaque

public byte[] xdrDecodeOpaque(int length)
                       throws org.acplt.oncrpc.OncRpcException,
                              IOException

Specified by:

xdrDecodeOpaque in class org.acplt.oncrpc.XdrDecodingStream

Throws:

org.acplt.oncrpc.OncRpcException

IOException

xdrDecodeOpaque

public void xdrDecodeOpaque(byte[] opaque,
                            int offset,
                            int length)
                     throws org.acplt.oncrpc.OncRpcException,
                            IOException

Specified by:

xdrDecodeOpaque in class org.acplt.oncrpc.XdrDecodingStream

Throws:

org.acplt.oncrpc.OncRpcException

IOException