Package org.globus.ftp.dc

Class GridFTPTransferSinkThread

java.lang.Object

java.lang.Thread

org.globus.ftp.dc.TransferThread

org.globus.ftp.dc.TransferSinkThread

org.globus.ftp.dc.GridFTPTransferSinkThread

All Implemented Interfaces:

Runnable

public class GridFTPTransferSinkThread
extends TransferSinkThread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected EBlockParallelTransferContext	eContext
protected static org.apache.commons.logging.Log	logger

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields inherited from class org.globus.ftp.dc.TransferSinkThread

context, localControlChannel, reader, sink, socketBox

Constructor Summary

Constructors

Constructor	Description
GridFTPTransferSinkThread(AbstractDataChannel dataChannel, SocketBox socketBox, DataSink sink, BasicServerControlChannel localControlChannel, EBlockParallelTransferContext context)

Method Summary

Modifier and Type	Method	Description
protected void	shutdown(Object quitToken)
protected void	startup()

Methods inherited from class java.lang.Object

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

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, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class org.globus.ftp.dc.TransferSinkThread

copy, run

Field Detail

logger

protected static org.apache.commons.logging.Log logger

eContext

protected EBlockParallelTransferContext eContext

Constructor Detail

GridFTPTransferSinkThread

public GridFTPTransferSinkThread(AbstractDataChannel dataChannel,
                                 SocketBox socketBox,
                                 DataSink sink,
                                 BasicServerControlChannel localControlChannel,
                                 EBlockParallelTransferContext context)
                          throws Exception

Throws:

Exception

Method Detail

startup

protected void startup()

Overrides:

startup in class TransferSinkThread

shutdown

protected void shutdown(Object quitToken)
                 throws IOException

Overrides:

shutdown in class TransferSinkThread

Throws:

IOException