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

Class XdrBufferDecodingStream

java.lang.Object

org.acplt.oncrpc.XdrDecodingStream

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

public class XdrBufferDecodingStream
extends org.acplt.oncrpc.XdrDecodingStream

Author:

ariane

Constructor Summary

Constructors

Constructor and Description
XdrBufferDecodingStream(BufferSupplier buf_supplier)
XdrBufferDecodingStream(ByteBuffer buf)
XdrBufferDecodingStream(ByteBuffer buf, BufferSupplier buf_supplier)
XdrBufferDecodingStream(int bufsize, BufferSupplier buf_supplier)

Method Summary

Modifier and Type	Method and Description
boolean	atEof()
long	avail()
void	beginDecoding()
void	endDecoding()
InetAddress	getSenderAddress()
int	getSenderPort()
long	readBytes()
int	xdrDecodeInt()
void	xdrDecodeOpaque(byte[] opaque, int offset, int length)
byte[]	xdrDecodeOpaque(int length)

Methods inherited from class org.acplt.oncrpc.XdrDecodingStream

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

XdrBufferDecodingStream

public XdrBufferDecodingStream(ByteBuffer buf,
                               BufferSupplier buf_supplier)
                        throws IOException

Throws:

IOException

XdrBufferDecodingStream

public XdrBufferDecodingStream(BufferSupplier buf_supplier)
                        throws IOException

Throws:

IOException

XdrBufferDecodingStream

public XdrBufferDecodingStream(int bufsize,
                               BufferSupplier buf_supplier)
                        throws IOException

Throws:

IOException

XdrBufferDecodingStream

public XdrBufferDecodingStream(ByteBuffer buf)

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

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

readBytes

public long readBytes()

avail

public long avail()

atEof

public boolean atEof()
              throws IOException

Throws:

IOException