org.apache.qpid.proton.engine.impl

Class ByteBufferUtils

java.lang.Object

org.apache.qpid.proton.engine.impl.ByteBufferUtils

public class ByteBufferUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ByteBufferUtils()

Method Summary

Modifier and Type	Method and Description
static java.nio.ByteBuffer	newReadableBuffer(int capacity)
static java.nio.ByteBuffer	newWriteableBuffer(int capacity)
static int	pour(java.nio.ByteBuffer source, java.nio.ByteBuffer destination)
static int	pourAll(java.nio.ByteBuffer source, TransportInput destinationTransportInput) Pours the contents of source into destinationTransportInput, calling the TransportInput many times if necessary.
static int	pourArrayToBuffer(byte[] source, int offset, int sizeRequested, java.nio.ByteBuffer destination) Assumes destination is ready to be written.
static int	pourBufferToArray(java.nio.ByteBuffer source, byte[] destination, int offset, int sizeRequested) Assumes source is ready to be read.

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteBufferUtils

public ByteBufferUtils()

Method Detail

pour

public static int pour(java.nio.ByteBuffer source,
                       java.nio.ByteBuffer destination)

Returns:

number of bytes poured

pourArrayToBuffer

public static int pourArrayToBuffer(byte[] source,
                                    int offset,
                                    int sizeRequested,
                                    java.nio.ByteBuffer destination)

Assumes destination is ready to be written.

Returns:

number of bytes poured which may be fewer than sizeRequested if destination has insufficient remaining

pourAll

public static int pourAll(java.nio.ByteBuffer source,
                          TransportInput destinationTransportInput)
                   throws TransportException

Pours the contents of source into destinationTransportInput, calling the TransportInput many times if necessary. If the TransportInput returns a TransportResult other than ok, data may remain in source.

Throws:

TransportException

pourBufferToArray

public static int pourBufferToArray(java.nio.ByteBuffer source,
                                    byte[] destination,
                                    int offset,
                                    int sizeRequested)

Assumes source is ready to be read.

Returns:

number of bytes poured which may be fewer than sizeRequested if source has insufficient remaining

newWriteableBuffer

public static java.nio.ByteBuffer newWriteableBuffer(int capacity)

newReadableBuffer

public static java.nio.ByteBuffer newReadableBuffer(int capacity)