|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.globus.ftp.dc.TransferThread
org.globus.ftp.dc.TransferSinkThread
public class TransferSinkThread
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 |
---|
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
protected TransferContext |
context
|
protected BasicServerControlChannel |
localControlChannel
|
protected static org.apache.commons.logging.Log |
logger
|
protected DataChannelReader |
reader
|
protected DataSink |
sink
|
protected SocketBox |
socketBox
|
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
TransferSinkThread(AbstractDataChannel dataChannel,
SocketBox socketBox,
DataSink sink,
BasicServerControlChannel localControlChannel,
TransferContext context)
|
Method Summary | |
---|---|
protected void |
copy()
|
void |
run()
|
protected void |
shutdown(java.lang.Object quitToken)
|
protected void |
startup()
|
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 |
---|
protected static org.apache.commons.logging.Log logger
protected DataChannelReader reader
protected DataSink sink
protected BasicServerControlChannel localControlChannel
protected TransferContext context
protected SocketBox socketBox
Constructor Detail |
---|
public TransferSinkThread(AbstractDataChannel dataChannel, SocketBox socketBox, DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) throws java.lang.Exception
java.lang.Exception
Method Detail |
---|
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
protected void startup() throws java.lang.Exception
java.lang.Exception
protected void copy() throws java.lang.Exception
java.lang.Exception
protected void shutdown(java.lang.Object quitToken) throws java.io.IOException
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |