oracle.ifs.utils.io

Class DataTransferThread

java.lang.Object

java.lang.Thread

oracle.ifs.utils.io.DataTransferThread

All Implemented Interfaces:

Runnable

public class DataTransferThread
extends Thread

The DataTransferThread.java class Thread for transfering from input stream to output stream in a thread.

Version:

1.0

Author:

Kevin Gillett

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected IOException	m_exception
protected InputStream	m_in
protected boolean	m_isBinaryTransfer
protected OutputStream	m_out

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
DataTransferThread()
DataTransferThread(InputStream in, OutputStream out, boolean isBinaryTransfer) Creates a DataTransferThread

Method Summary

Modifier and Type	Method and Description
protected byte[]	getByteBuffer() gets a bytes buffer
int	getBytesTransfered()
protected int	getDesiredBufferSize() determines the size of the byte buffer
IOException	getException() Returns an Exception if one exists usage -- call this method after the thread has run to get an Exception if one occured
void	reset(InputStream in, OutputStream out, boolean isBinaryTransfer)
void	run() Transfers the content from InputStream to OutputStream
void	throwException() Throws an Exception if one exists usage -- call this method after the thread has run to have exception thrown
protected int	transferAsciiData(InputStream in, OutputStream out) Transfer content from an inputstream to an outputstream, processing newlines.
protected int	transferBinaryData(InputStream in, OutputStream out) Transfer content from an inputstream to an outputstream, with no newline processing
protected int	transferData(InputStream in, OutputStream out, boolean isBinaryTransfer) Transfers content from inputstream to outputstream

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

m_in

protected InputStream m_in

m_out

protected OutputStream m_out

m_isBinaryTransfer

protected boolean m_isBinaryTransfer

m_exception

protected IOException m_exception

Constructor Detail

DataTransferThread

public DataTransferThread()

DataTransferThread

public DataTransferThread(InputStream in,
                          OutputStream out,
                          boolean isBinaryTransfer)

Creates a DataTransferThread

Parameters:

isBinaryTransfer - boolean to transfer in binary or ascii

Method Detail

reset

public void reset(InputStream in,
                  OutputStream out,
                  boolean isBinaryTransfer)

run

public void run()

Transfers the content from InputStream to OutputStream

Specified by:

run in interface Runnable

Overrides:

run in class Thread

throwException

public void throwException()
                    throws IOException

Throws an Exception if one exists usage -- call this method after the thread has run to have exception thrown

Throws:

IOException

getException

public IOException getException()

Returns an Exception if one exists usage -- call this method after the thread has run to get an Exception if one occured

getBytesTransfered

public int getBytesTransfered()

transferData

protected int transferData(InputStream in,
                           OutputStream out,
                           boolean isBinaryTransfer)
                    throws IOException

Transfers content from inputstream to outputstream

Parameters:

in - the input stream

out - the output stream

isBinaryTransfer - if true binary transfer, if false ascii transfer with bytes put on wire according to ftp rfc (no

Returns:

int the number of bytes transfered

Throws:

IOException

transferBinaryData

protected final int transferBinaryData(InputStream in,
                                       OutputStream out)
                                throws IOException

Transfer content from an inputstream to an outputstream, with no newline processing

Returns:

int the number of bytes transfered

Throws:

IOException

transferAsciiData

protected final int transferAsciiData(InputStream in,
                                      OutputStream out)
                               throws IOException

Transfer content from an inputstream to an outputstream, processing newlines. Warning this method does not work for 2 byte characters.

Returns:

int the number of bytes transfered

Throws:

IOException

getDesiredBufferSize

protected int getDesiredBufferSize()

determines the size of the byte buffer

getByteBuffer

protected byte[] getByteBuffer()

gets a bytes buffer