ibis.io
Class DataOutputStreamSplitter

java.lang.Object
  java.io.OutputStream
      ibis.io.DataOutputStream
          ibis.io.DataOutputStreamSplitter

All Implemented Interfaces:

DataOutput, Closeable, Flushable

public final class DataOutputStreamSplitter
extends DataOutputStream

Contract: write to multiple outputstreams. when an exception occurs, store it and continue. when the data is written to all streams, throw one large exception that contains all previous exceptions. This way, even when one of the streams dies, the rest will receive the data.

Constructor Summary

DataOutputStreamSplitter()

DataOutputStreamSplitter(boolean removeOnException)

Method Summary

void	add(DataOutputStream s)
int	bufferSize()
long	bytesWritten() Returns the number of bytes that was written to the stream, in the stream dependant format.
void	close()
void	finish() Blocks until the data is written.
boolean	finished() Checks whether all data has been written after a flush.
void	flush()
void	remove(DataOutputStream s)
void	resetBytesWritten() Resets the counter for the number of bytes written.
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)
void	writeArray(boolean[] source, int offset, int length) Writes (a slice of) an array of booleans.
void	writeArray(byte[] source, int offset, int length) Writes (a slice of) an array of bytes.
void	writeArray(char[] source, int offset, int length) Writes (a slice of) an array of characters.
void	writeArray(double[] source, int offset, int length) Writes (a slice of) an array of doubles.
void	writeArray(float[] source, int offset, int length) Writes (a slice of) an array of floats.
void	writeArray(int[] source, int offset, int length) Writes (a slice of) an array of integers.
void	writeArray(long[] source, int offset, int length) Writes (a slice of) an array of longs.
void	writeArray(short[] source, int offset, int length) Writes (a slice of) an array of shorts.
void	writeBoolean(boolean value) Writes a boolean value.
void	writeByte(byte value) Writes a byte value.
void	writeByteBuffer(ByteBuffer b) Writes the contents of the byte buffer (between its current position and its limit).
void	writeChar(char value) Writes a char value.
void	writeDouble(double value) Writes a double value.
void	writeFloat(float value) Writes a float value.
void	writeInt(int value) Writes a int value.
void	writeLong(long value) Writes a long value.
void	writeShort(short value) Writes a short value.

Methods inherited from class ibis.io.DataOutputStream

writeArray, writeArray, writeArray, writeArray, writeArray, writeArray, writeArray, writeArray

Methods inherited from class java.lang.Object

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

Constructor Detail

DataOutputStreamSplitter

public DataOutputStreamSplitter()

DataOutputStreamSplitter

public DataOutputStreamSplitter(boolean removeOnException)

Method Detail

add

public void add(DataOutputStream s)

remove

public void remove(DataOutputStream s)

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

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

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Specified by:

flush in class DataOutputStream

Throws:

IOException

finish

public void finish()
            throws IOException

Description copied from class: DataOutputStream

Blocks until the data is written.

Overrides:

finish in class DataOutputStream

Throws:

IOException - on IO error.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in class DataOutputStream

Throws:

IOException

finished

public boolean finished()
                 throws IOException

Description copied from class: DataOutputStream

Checks whether all data has been written after a flush.

Overrides:

finished in class DataOutputStream

Returns:

true if all data has been written after a flush.

Throws:

IOException

bytesWritten

public long bytesWritten()

Description copied from class: DataOutputStream

Returns the number of bytes that was written to the stream, in the stream dependant format. This is the number of bytes that will be sent over the network.

Specified by:

bytesWritten in class DataOutputStream

resetBytesWritten

public void resetBytesWritten()

Description copied from class: DataOutputStream

Resets the counter for the number of bytes written.

Specified by:

resetBytesWritten in class DataOutputStream

writeArray

public void writeArray(boolean[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of booleans.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeByteBuffer

public void writeByteBuffer(ByteBuffer b)
                     throws IOException

Description copied from interface: DataOutput

Writes the contents of the byte buffer (between its current position and its limit).

Parameters:

b - the byte buffer from which data is to be written

Throws:

IOException - an error occurred

writeArray

public void writeArray(byte[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of bytes.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(char[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of characters.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(double[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of doubles.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(float[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of floats.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(int[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of integers.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(long[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of longs.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeArray

public void writeArray(short[] source,
                       int offset,
                       int length)
                throws IOException

Description copied from interface: DataOutput

Writes (a slice of) an array of shorts.

Parameters:

source - the array to write

offset - the offset at which to start

length - the number of elements to be copied

Throws:

IOException - on an IO error

writeBoolean

public void writeBoolean(boolean value)
                  throws IOException

Description copied from interface: DataOutput

Writes a boolean value.

Parameters:

value - the boolean value to write

Throws:

IOException - on an IO error

writeByte

public void writeByte(byte value)
               throws IOException

Description copied from interface: DataOutput

Writes a byte value.

Parameters:

value - the byte value to write

Throws:

IOException - on an IO error

writeChar

public void writeChar(char value)
               throws IOException

Description copied from interface: DataOutput

Writes a char value.

Parameters:

value - the char value to write

Throws:

IOException - on an IO error

writeDouble

public void writeDouble(double value)
                 throws IOException

Description copied from interface: DataOutput

Writes a double value.

Parameters:

value - the double value to write

Throws:

IOException - on an IO error

writeFloat

public void writeFloat(float value)
                throws IOException

Description copied from interface: DataOutput

Writes a float value.

Parameters:

value - the float value to write

Throws:

IOException - on an IO error

writeInt

public void writeInt(int value)
              throws IOException

Description copied from interface: DataOutput

Writes a int value.

Parameters:

value - the int value to write

Throws:

IOException - on an IO error

writeLong

public void writeLong(long value)
               throws IOException

Description copied from interface: DataOutput

Writes a long value.

Parameters:

value - the long value to write

Throws:

IOException - on an IO error

writeShort

public void writeShort(short value)
                throws IOException

Description copied from interface: DataOutput

Writes a short value.

Parameters:

value - the short value to write

Throws:

IOException - on an IO error

bufferSize

public int bufferSize()

Specified by:

bufferSize in class DataOutputStream