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:

java.lang.Runnable

public class GridFTPTransferSinkThread
extends TransferSinkThread

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

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

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

context, localControlChannel, reader, sink, socketBox

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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

Method Summary

Methods

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

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

copy, run

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

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 java.lang.Exception

Throws:

java.lang.Exception

Method Detail

startup

protected void startup()

Overrides:

startup in class TransferSinkThread

shutdown

protected void shutdown(java.lang.Object quitToken)
                 throws java.io.IOException

Overrides:

shutdown in class TransferSinkThread

Throws:

java.io.IOException