Package net.officefloor.server.stream

Interface StreamBufferPool<B>

Type Parameters:

B - Type of buffer being pooled.

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

AbstractStreamBufferPool, MockStreamBufferPool, NettyBufferPool, ThreadLocalStreamBufferPool, VertxBufferPool

public interface StreamBufferPool<B>
extends AutoCloseable

Provides interface to wrap buffer pooling implementations.

Author:

Daniel Sagenschneider

Method Summary

Modifier and Type	Method	Description
void	close()	Closes pool releasing all StreamBuffer instances.
StreamBuffer<B>	getFileStreamBuffer(FileChannel file, long position, long count, FileCompleteCallback callback)	Obtains a StreamBuffer for the FileChannel content.
StreamBuffer<B>	getPooledStreamBuffer()	Obtains a StreamBuffer.
StreamBuffer<B>	getUnpooledStreamBuffer(ByteBuffer buffer)	Obtains an StreamBuffer that is not pooled.

Method Details

getPooledStreamBuffer

StreamBuffer<B> getPooledStreamBuffer()

Obtains a StreamBuffer.

Returns:

StreamBuffer.

getUnpooledStreamBuffer

StreamBuffer<B> getUnpooledStreamBuffer(ByteBuffer buffer)

Obtains an StreamBuffer that is not pooled. This is for ByteBuffer instances that are managed outside the BufferPool.

Typical use is to create StreamBuffer for some read-only cached content within a ByteBuffer.

Parameters:

buffer - ByteBuffer.

Returns:

StreamBuffer for the unpooled ByteBuffer.

getFileStreamBuffer

StreamBuffer<B> getFileStreamBuffer(FileChannel file,
 long position,
 long count,
 FileCompleteCallback callback)
                             throws IOException

Obtains a StreamBuffer for the FileChannel content.

This enables efficient writing (ie DMA) of FileChannel content.

To write the entire FileChannel contents, invoke write(file, 0, -1).

Note that the underlying implementation will need to support FileChannel efficiencies.

Parameters:

file - FileChannel.

position - Position within the FileChannel to start writing content. Must be non-negative number.

count - Count of bytes to write from the FileChannel. A negative value (typically -1) indicates to write the remaining FileChannel content from the position.

callback - Optional FileCompleteCallback. May be null.

Returns:

StreamBuffer for the FileChannel.

Throws:

IOException - If fails to create the StreamBuffer for the FileChannel. Typically, this is because the underlying implementation does not support DMA and copies the data from the FileChannel.

close

void close()

Closes pool releasing all StreamBuffer instances.

Specified by:

close in interface AutoCloseable