Package net.officefloor.server.stream.impl

Class BufferPoolServerOutputStream<B>

java.lang.Object

java.io.OutputStream

net.officefloor.server.stream.ServerOutputStream

net.officefloor.server.stream.impl.BufferPoolServerOutputStream<B>

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

public class BufferPoolServerOutputStream<B>
extends ServerOutputStream

ServerOutputStream that writes to StreamBuffer instances from a StreamBufferPool.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
BufferPoolServerOutputStream(StreamBufferPool<B> bufferPool)	Instantiate.
BufferPoolServerOutputStream(StreamBufferPool<B> bufferPool, CloseHandler closeHandler)	Instantiate.

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears this OutputStream and releases the StreamBuffer instances.
void	close()
void	flush()
StreamBuffer<B>	getBuffers()	Obtains the head StreamBuffer instances used by this ServerOutputStream.
long	getContentLength()	Obtains the content length of output data.
ServerWriter	getServerWriter(java.nio.charset.Charset charset)	Obtains the ServerWriter.
void	write(byte[] bytes, int off, int len)
void	write(int b)
void	write(java.nio.ByteBuffer buffer)	Writes a ByteBuffer.
void	write(java.nio.channels.FileChannel file, long position, long count, FileCompleteCallback callback)	Writes part of the FileChannel contents.
void	write(java.nio.channels.FileChannel file, FileCompleteCallback callback)	Writes the entire FileChannel contents.

Methods inherited from class java.io.OutputStream

nullOutputStream, write

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferPoolServerOutputStream

public BufferPoolServerOutputStream(StreamBufferPool<B> bufferPool,
                                    CloseHandler closeHandler)

Instantiate.

Parameters:

bufferPool - StreamBufferPool.

closeHandler - CloseHandler.

BufferPoolServerOutputStream

public BufferPoolServerOutputStream(StreamBufferPool<B> bufferPool)

Instantiate.

Parameters:

bufferPool - StreamBufferPool.

Method Detail

getServerWriter

public ServerWriter getServerWriter(java.nio.charset.Charset charset)
                             throws java.io.IOException

Obtains the ServerWriter.

Parameters:

charset - Charset for writing out String data.

Returns:

ServerWriter.

Throws:

java.io.IOException - Should ServerOutputStream be closed.

getContentLength

public long getContentLength()

Obtains the content length of output data.

Returns:

Content length of output data.

getBuffers

public StreamBuffer<B> getBuffers()

Obtains the head StreamBuffer instances used by this ServerOutputStream.

Returns:

StreamBuffer instances used by this ServerOutputStream.

clear

public void clear()
           throws java.io.IOException

Clears this OutputStream and releases the StreamBuffer instances.

Throws:

java.io.IOException - If failure in clearing OutputStream.

write

public void write(java.nio.ByteBuffer buffer)
           throws java.io.IOException

Description copied from class: ServerOutputStream

Writes a ByteBuffer.

This is to enable efficient I/O of writing content (typically cached).

Specified by:

write in class ServerOutputStream

Parameters:

buffer - ByteBuffer that should never change its content.

Throws:

java.io.IOException - If fails to write the ByteBuffer.

write

public void write(java.nio.channels.FileChannel file,
                  long position,
                  long count,
                  FileCompleteCallback callback)
           throws java.io.IOException

Description copied from class: ServerOutputStream

Writes part of the FileChannel contents.

This is to enable efficient I/O (ie DMA) of writing 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:

write in class ServerOutputStream

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 position.

callback - Optional FileCompleteCallback. May be null.

Throws:

java.io.IOException - If fails to write the FileChannel content.

write

public void write(java.nio.channels.FileChannel file,
                  FileCompleteCallback callback)
           throws java.io.IOException

Description copied from class: ServerOutputStream

Writes the entire FileChannel contents.

This is a convenience method for write(file, 0, -1).

Specified by:

write in class ServerOutputStream

Parameters:

file - FileChannel.

callback - Optional FileCompleteCallback. May be null.

Throws:

java.io.IOException - If fails to write the FileChannel content.

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

public void write(byte[] bytes,
                  int off,
                  int len)
           throws java.io.IOException

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException