Package org.globus.ftp.dc
Class TransferSinkThread
java.lang.Object
java.lang.Thread
org.globus.ftp.dc.TransferThread
org.globus.ftp.dc.TransferSinkThread
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
GridFTPTransferSinkThread
Implements incoming transfer.
While the transfer is in progress, replies are sent to the
local control channel. Also any failure messages go there
in the form of a negative reply.
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected TransferContext
protected BasicServerControlChannel
protected static org.apache.commons.logging.Log
protected DataChannelReader
protected DataSink
protected SocketBox
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
ConstructorsConstructorDescriptionTransferSinkThread
(AbstractDataChannel dataChannel, SocketBox socketBox, DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) -
Method Summary
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield
-
Field Details
-
logger
protected static org.apache.commons.logging.Log logger -
reader
-
sink
-
localControlChannel
-
context
-
socketBox
-
-
Constructor Details
-
TransferSinkThread
public TransferSinkThread(AbstractDataChannel dataChannel, SocketBox socketBox, DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) throws Exception - Throws:
Exception
-
-
Method Details