Package net.officefloor.server.http.mock

Class MockStreamBufferPool

java.lang.Object

net.officefloor.server.http.mock.MockStreamBufferPool

All Implemented Interfaces:

AutoCloseable, StreamBufferPool<ByteBuffer>

public class MockStreamBufferPool
extends Object
implements StreamBufferPool<ByteBuffer>

Mock StreamBufferPool.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
MockStreamBufferPool()	Instantiate with default buffer size for testing.
MockStreamBufferPool(ByteBufferFactory byteBufferFactory)	Instantiate.

Method Summary

Modifier and Type	Method	Description
void	assertAllBuffersReturned()	Asserts that all StreamBuffer instances have been released.
void	close()	Closes pool releasing all StreamBuffer instances.
static InputStream	createInputStream(StreamBuffer<ByteBuffer> headBuffer)	Creates an InputStream to the content of the StreamBuffer instances.
static String	getContent(StreamBuffer<ByteBuffer> headBuffer, Charset charset)	Convenience method to obtain the contents of the buffers as a string.
StreamBuffer<ByteBuffer>	getFileStreamBuffer(FileChannel file, long position, long count, FileCompleteCallback callback)	Obtains a StreamBuffer for the FileChannel content.
StreamBuffer<ByteBuffer>	getPooledStreamBuffer()	Obtains a StreamBuffer.
StreamBuffer<ByteBuffer>	getUnpooledStreamBuffer(ByteBuffer byteBuffer)	Obtains an StreamBuffer that is not pooled.
boolean	isActiveBuffers()	Indicates if there are active StreamBuffer instances.
static void	releaseStreamBuffers(StreamBuffer<ByteBuffer> headBuffer)	Releases the StreamBuffer instances.

Methods inherited from class java.lang.Object

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

Constructor Details

MockStreamBufferPool

public MockStreamBufferPool()

Instantiate with default buffer size for testing.

MockStreamBufferPool

public MockStreamBufferPool(ByteBufferFactory byteBufferFactory)

Instantiate.

Parameters:

byteBufferFactory - ByteBufferFactory.

Method Details

releaseStreamBuffers

public static void releaseStreamBuffers(StreamBuffer<ByteBuffer> headBuffer)

Releases the StreamBuffer instances.

Parameters:

headBuffer - Head StreamBuffer of linked list of StreamBuffer instances.

createInputStream

public static InputStream createInputStream(StreamBuffer<ByteBuffer> headBuffer)

Creates an InputStream to the content of the StreamBuffer instances.

Parameters:

headBuffer - Head StreamBuffer of linked list of StreamBuffer instances.

Returns:

InputStream to read the data from the StreamBuffer instances.

getContent

public static String getContent(StreamBuffer<ByteBuffer> headBuffer,
 Charset charset)

Convenience method to obtain the contents of the buffers as a string.

Parameters:

headBuffer - Head StreamBuffer of linked list of StreamBuffer instances.

charset - Charset of underlying data.

Returns:

Content of buffers as string.

isActiveBuffers

public boolean isActiveBuffers()

Indicates if there are active StreamBuffer instances.

Returns:

true if there are active StreamBuffer instances not released back to this StreamBufferPool.

assertAllBuffersReturned

public void assertAllBuffersReturned()

Asserts that all StreamBuffer instances have been released.

getPooledStreamBuffer

public StreamBuffer<ByteBuffer> getPooledStreamBuffer()

Description copied from interface: StreamBufferPool

Obtains a StreamBuffer.

Specified by:

getPooledStreamBuffer in interface StreamBufferPool<ByteBuffer>

Returns:

StreamBuffer.

getUnpooledStreamBuffer

public StreamBuffer<ByteBuffer> getUnpooledStreamBuffer(ByteBuffer byteBuffer)

Description copied from interface: StreamBufferPool

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.

Specified by:

getUnpooledStreamBuffer in interface StreamBufferPool<ByteBuffer>

Parameters:

byteBuffer - ByteBuffer.

Returns:

StreamBuffer for the unpooled ByteBuffer.

getFileStreamBuffer

public StreamBuffer<ByteBuffer> getFileStreamBuffer(FileChannel file,
 long position,
 long count,
 FileCompleteCallback callback)

Description copied from interface: StreamBufferPool

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.

Specified by:

getFileStreamBuffer in interface StreamBufferPool<ByteBuffer>

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.

close

public void close()

Description copied from interface: StreamBufferPool

Closes pool releasing all StreamBuffer instances.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface StreamBufferPool<ByteBuffer>