public class TransferSinkThread extends TransferThread
Modifier and Type | Field and Description |
---|---|
protected TransferContext |
context |
protected BasicServerControlChannel |
localControlChannel |
protected static org.apache.commons.logging.Log |
logger |
protected DataChannelReader |
reader |
protected DataSink |
sink |
protected SocketBox |
socketBox |
Constructor and Description |
---|
TransferSinkThread(AbstractDataChannel dataChannel,
SocketBox socketBox,
DataSink sink,
BasicServerControlChannel localControlChannel,
TransferContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
copy() |
void |
run() |
protected void |
shutdown(java.lang.Object quitToken) |
protected void |
startup() |
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
protected static org.apache.commons.logging.Log logger
protected DataChannelReader reader
protected DataSink sink
protected BasicServerControlChannel localControlChannel
protected TransferContext context
protected SocketBox socketBox
public TransferSinkThread(AbstractDataChannel dataChannel, SocketBox socketBox, DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) throws java.lang.Exception
java.lang.Exception
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
Copyright © 2013. All Rights Reserved.