ds.funnel.data.buffer

Class BufferPoolImpl

java.lang.Object

ds.funnel.data.buffer.BufferPoolImpl

All Implemented Interfaces:

BufferPool

Direct Known Subclasses:

BufferPoolStriped

public class BufferPoolImpl
extends java.lang.Object
implements BufferPool

ChannelBuffers.java: A buffer pool to reuse allocated buffers.

Author:

Ryan Stern

Constructor Summary

Constructors

Constructor and Description
BufferPoolImpl(int inChunkSize, int inTotalChunks) Creates a new buffer pool.

Method Summary

Modifier and Type	Method and Description
java.nio.ByteBuffer	allocBuffer(int minSize) Returns an empty buffer with at least minSize capacity.
java.nio.ByteBuffer	allocBufferChunk() Returns an empty buffer with chunkSize capacity.
int	getChunkSize()
int	getNumChunks()
void	printAllocated() Print a list of buffers currently allocated.
void	returnBuffer(java.nio.ByteBuffer inBuffer) Return a buffer to the buffer pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferPoolImpl

public BufferPoolImpl(int inChunkSize,
                      int inTotalChunks)

Creates a new buffer pool. The pool will allocate a direct byte buffer with inChunkSize*inTotalChunks bytes.

Parameters:

inChunkSize - - Buffer chunks in increments of this size are allocated.

inTotalChunks - - The total number of direct byte buffer chunks.

Method Detail

getChunkSize

public int getChunkSize()

Specified by:

getChunkSize in interface BufferPool

Returns:

The size that allocated buffers are allocated in increments of.

getNumChunks

public int getNumChunks()

Specified by:

getNumChunks in interface BufferPool

Returns:

The total number of direct byte buffer chunks.

allocBuffer

public java.nio.ByteBuffer allocBuffer(int minSize)

Description copied from interface: BufferPool

Returns an empty buffer with at least minSize capacity.

Specified by:

allocBuffer in interface BufferPool

Parameters:

minSize - - The minimum size of the returned buffer.

Returns:

An empty ByteBuffer (may be new or reused).

allocBufferChunk

public java.nio.ByteBuffer allocBufferChunk()

Description copied from interface: BufferPool

Returns an empty buffer with chunkSize capacity.

Specified by:

allocBufferChunk in interface BufferPool

Returns:

An empty ByteBuffer (may be new or reused).

returnBuffer

public void returnBuffer(java.nio.ByteBuffer inBuffer)

Description copied from interface: BufferPool

Return a buffer to the buffer pool. It is no longer safe to read or write to the returned buffer, as it may be reallocated to a different thread.

Specified by:

returnBuffer in interface BufferPool

Parameters:

inBuffer - - The buffer to return to the pool.

printAllocated

public void printAllocated()

Print a list of buffers currently allocated. Used for debugging.

Specified by:

printAllocated in interface BufferPool