org.apache.hadoop.hbase.ipc

Class BufferChain

java.lang.Object

org.apache.hadoop.hbase.ipc.BufferChain

@InterfaceAudience.Private
class BufferChain
extends Object

Chain of ByteBuffers. Used writing out an array of byte buffers. Writes in chunks.

Field Summary

Fields

Modifier and Type	Field and Description
private int	bufferOffset
private ByteBuffer[]	buffers
private int	remaining
private int	size

Constructor Summary

Constructors

Constructor and Description
BufferChain(ByteBuffer... buffers)

Method Summary

Modifier and Type	Method and Description
(package private) ByteBuffer[]	getBuffers()
(package private) byte[]	getBytes() Expensive.
(package private) boolean	hasRemaining()
(package private) int	size()
(package private) long	write(GatheringByteChannel channel, int chunkSize) Write out our chain of buffers in chunks

Methods inherited from class java.lang.Object

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

Field Detail

buffers

private final ByteBuffer[] buffers

remaining

private int remaining

bufferOffset

private int bufferOffset

size

private int size

Constructor Detail

BufferChain

BufferChain(ByteBuffer... buffers)

Method Detail

getBytes

byte[] getBytes()

Expensive. Makes a new buffer to hold a copy of what is in contained ByteBuffers. This call drains this instance; it cannot be used subsequent to the call.

Returns:

A new byte buffer with the content of all contained ByteBuffers.

hasRemaining

boolean hasRemaining()

write

long write(GatheringByteChannel channel,
           int chunkSize)
    throws IOException

Write out our chain of buffers in chunks

Parameters:

channel - Where to write

chunkSize - Size of chunks to write.

Returns:

Amount written.

Throws:

IOException

size

int size()

getBuffers

ByteBuffer[] getBuffers()