Package org.globus.ftp.dc
Class SimpleDataChannel
java.lang.Object
org.globus.ftp.dc.AbstractDataChannel
org.globus.ftp.dc.SimpleDataChannel
- All Implemented Interfaces:
DataChannel
- Direct Known Subclasses:
GridFTPDataChannel
Data channel receives in the constructor a socket that should
be ready for communication, and starts a new thread that
will perform the transfer.
In previous version, the data channel would perform socket initialization (server.accept() etc.). This is now done by the facade's manager thread, so it can start several data channels.
In previous version, the data channel would perform socket initialization (server.accept() etc.). This is now done by the facade's manager thread, so it can start several data channels.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static org.apache.commons.logging.Log
protected SocketBox
protected TransferThread
protected TransferThreadFactory
Fields inherited from class org.globus.ftp.dc.AbstractDataChannel
dataHandlers, session
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
startTransfer
(DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) void
startTransfer
(DataSource source, BasicServerControlChannel localControlChannel, TransferContext context) Methods inherited from class org.globus.ftp.dc.AbstractDataChannel
getDataChannelSink, getDataChannelSource, isDataSinkModeSupported, isDataSourceModeSupported, registerHandler
-
Field Details
-
logger
protected static org.apache.commons.logging.Log logger -
socketBox
-
transferThread
-
transferThreadFactory
-
-
Constructor Details
-
SimpleDataChannel
- Parameters:
socketBox
- should be opened and ready for comunication
-
-
Method Details
-
close
- Throws:
IOException
-
startTransfer
public void startTransfer(DataSink sink, BasicServerControlChannel localControlChannel, TransferContext context) throws Exception - Throws:
Exception
-
startTransfer
public void startTransfer(DataSource source, BasicServerControlChannel localControlChannel, TransferContext context) throws Exception - Throws:
Exception
-