freenet.support.compress

Class DecompressorThreadManager

java.lang.Object

freenet.support.compress.DecompressorThreadManager

public class DecompressorThreadManager
extends java.lang.Object

Creates and manages decompressor threads. This class is given all decompressors which should be applied to an InputStream via addDecompressor. The decompressors will be strung together and executed when the execute method is called. This class also stores any errors which may arise.

Constructor Summary

Constructors

Constructor and Description
DecompressorThreadManager(java.io.PipedInputStream inputStream, java.util.List<? extends Compressor> decompressors, long maxLen) Creates a new DecompressorThreadManager

Method Summary

Modifier and Type	Method and Description
java.io.PipedInputStream	execute() Creates and executes a new thread for each decompressor, chaining the output of the previous to the next.
java.lang.Throwable	getError() Returns an exception which was thrown during decompression
void	onFailure(java.lang.Throwable t) Informs the manager that a nonrecoverable exception has occured in the decompression threads
void	onFinish() Marks that the decompression of the stream has finished and wakes threads blocking on completion
void	waitFinished() Blocks until all threads have finished executing and cleaning up.

Methods inherited from class java.lang.Object

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

Constructor Detail

DecompressorThreadManager

public DecompressorThreadManager(java.io.PipedInputStream inputStream,
                                 java.util.List<? extends Compressor> decompressors,
                                 long maxLen)
                          throws java.io.IOException

Creates a new DecompressorThreadManager

Parameters:

inputStream - The stream that will be decompressed, if compressed

maxLen - The maximum number of bytes to extract

Throws:

java.io.IOException

Method Detail

execute

public java.io.PipedInputStream execute()
                                 throws java.lang.Throwable

Creates and executes a new thread for each decompressor, chaining the output of the previous to the next.

Returns:

An InputStream from which uncompressed data may be read from

Throws:

java.lang.Throwable

onFailure

public void onFailure(java.lang.Throwable t)

Informs the manager that a nonrecoverable exception has occured in the decompression threads

Parameters:

e - The thrown exception

onFinish

public void onFinish()

Marks that the decompression of the stream has finished and wakes threads blocking on completion

waitFinished

public void waitFinished()
                  throws java.lang.Throwable

Blocks until all threads have finished executing and cleaning up.

Throws:

java.lang.Throwable

getError

public java.lang.Throwable getError()

Returns an exception which was thrown during decompression

Returns:

Returns an exception which was caught during the decompression