ds.funnel.data.buffer

Class BufferPoolStriped

java.lang.Object

ds.funnel.data.buffer.BufferPoolImpl

ds.funnel.data.buffer.BufferPoolStriped

All Implemented Interfaces:

BufferPool

public class BufferPoolStriped
extends BufferPoolImpl

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

Author:

Ryan Stern

Constructor Summary

Constructors

Constructor and Description
BufferPoolStriped(int inNumStripes, int inChunkSize, int inNumChunks)

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

BufferPoolStriped

public BufferPoolStriped(int inNumStripes,
                         int inChunkSize,
                         int inNumChunks)

Method Detail

getChunkSize

public int getChunkSize()

Specified by:

getChunkSize in interface BufferPool

Overrides:

getChunkSize in class BufferPoolImpl

Returns:

The size that allocated buffers are allocated in increments of.

getNumChunks

public int getNumChunks()

Specified by:

getNumChunks in interface BufferPool

Overrides:

getNumChunks in class BufferPoolImpl

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

Overrides:

allocBuffer in class BufferPoolImpl

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

Overrides:

allocBufferChunk in class BufferPoolImpl

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

Overrides:

returnBuffer in class BufferPoolImpl

Parameters:

inBuffer - - The buffer to return to the pool.

printAllocated

public void printAllocated()

Description copied from class: BufferPoolImpl

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

Specified by:

printAllocated in interface BufferPool

Overrides:

printAllocated in class BufferPoolImpl