com.viaoa.remote.multiplexer.io

Class RemoteBufferedOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

com.viaoa.remote.multiplexer.io.RemoteBufferedOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class RemoteBufferedOutputStream
extends FilterOutputStream

Customized from BufferedOutputStream, but uses a shared pool of buffers so that it does not have to create a new one each time. Also removed sync on methods, since this is only used by one thread at a time.

Author:

vvia

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	bOwnedBuffer
protected byte[]	bsBuffer
protected int	count

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor and Description
RemoteBufferedOutputStream(OutputStream out) Creates a new buffered output stream to write data to the specified underlying output stream with the specified buffer size.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	finalize()
void	flush() Overwritten to include freeing the byte[] buffer from the shared pool.
protected byte[]	getBuffer()
protected static byte[]	getPoolBuffer()
protected static void	releasePoolBuffer(byte[] bs)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.io.FilterOutputStream

write

Methods inherited from class java.lang.Object

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

Field Detail

bsBuffer

protected byte[] bsBuffer

count

protected int count

bOwnedBuffer

protected boolean bOwnedBuffer

Constructor Detail

RemoteBufferedOutputStream

public RemoteBufferedOutputStream(OutputStream out)

Creates a new buffered output stream to write data to the specified underlying output stream with the specified buffer size.

Method Detail

getPoolBuffer

protected static byte[] getPoolBuffer()

releasePoolBuffer

protected static void releasePoolBuffer(byte[] bs)

getBuffer

protected byte[] getBuffer()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class FilterOutputStream

Throws:

IOException

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

write

public void write(int b)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Overwritten to include freeing the byte[] buffer from the shared pool.

Specified by:

flush in interface Flushable

Overrides:

flush in class FilterOutputStream

Throws:

IOException