Package org.globus.ftp.dc
Class ActiveConnectTask
java.lang.Object
org.globus.ftp.dc.Task
org.globus.ftp.dc.ActiveConnectTask
Makes a connection to a remote data channel (FTPClient use only).
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected TransferContext
protected BasicServerControlChannel
protected DataChannelFactory
protected HostPort
protected static org.apache.commons.logging.Log
protected SocketBox
protected Session
protected DataSink
protected DataSource
-
Constructor Summary
ConstructorsConstructorDescriptionActiveConnectTask
(HostPort hostPort, DataSink sink, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) ActiveConnectTask
(HostPort hostPort, DataSource source, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
close()
void
execute()
private void
init
(HostPort hostPort, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) protected SocketBox
Override this to implement authenticationvoid
stop()
Methods inherited from class org.globus.ftp.dc.Task
setComplete, waitFor
-
Field Details
-
logger
protected static org.apache.commons.logging.Log logger -
hostPort
-
mySocketBox
-
sink
-
source
-
control
-
session
-
factory
-
context
-
-
Constructor Details
-
ActiveConnectTask
public ActiveConnectTask(HostPort hostPort, DataSink sink, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) -
ActiveConnectTask
public ActiveConnectTask(HostPort hostPort, DataSource source, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context)
-
-
Method Details
-
init
private void init(HostPort hostPort, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) -
execute
public void execute() -
openSocket
Override this to implement authentication- Throws:
Exception
-
close
private void close() -
stop
public void stop()
-