Java Globus API: Class SimpleDataChannel

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:
SecureDataChannel

public class SimpleDataChannel
extends AbstractDataChannel

Data channel receives in the constructor a socket that should be ready for communication, and starts a new thread that will perform the transfer.


Field Summary
protected static org.apache.log4j.Logger logger
           
protected  SocketBox socketBox
           
protected  org.globus.ftp.dc.SimpleDataChannel.TransferThread transferThread
           
 
Fields inherited from class org.globus.ftp.dc.AbstractDataChannel
dataHandlers, session
 
Constructor Summary
SimpleDataChannel(Session session, SocketBox socketBox)
           
 
Method Summary
 void 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, installDefaultHandlers, isDataSinkModeSupported, isDataSourceModeSupported, registerHandler
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

protected static org.apache.log4j.Logger logger

socketBox

protected SocketBox socketBox

transferThread

protected org.globus.ftp.dc.SimpleDataChannel.TransferThread transferThread
Constructor Detail

SimpleDataChannel

public SimpleDataChannel(Session session,
                         SocketBox socketBox)
Parameters:
socketBox - should be opened and ready for comunication
Method Detail

close

public void close()
           throws IOException

startTransfer

public void startTransfer(DataSink sink,
                          BasicServerControlChannel localControlChannel,
                          TransferContext context)
                   throws Exception

startTransfer

public void startTransfer(DataSource source,
                          BasicServerControlChannel localControlChannel,
                          TransferContext context)
                   throws Exception