Package org.globus.ftp.dc
Class PassiveConnectTask
java.lang.Object
org.globus.ftp.dc.Task
org.globus.ftp.dc.PassiveConnectTask
- Direct Known Subclasses:
GridFTPPassiveConnectTask
This task will wait on the local server for the new incoming connection
and when it comes it will start a new transfer thread on the new connection.
It is little tricky: it will cause data channel to start
a new thread. By the time this task completes, the new
thread is running the transfer.
Any resulting exceptions are piped to the local control channel.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected TransferContext
protected BasicServerControlChannel
protected DataChannelFactory
protected static org.apache.commons.logging.Log
protected ServerSocket
protected SocketBox
protected Session
protected DataSink
protected DataSource
-
Constructor Summary
ConstructorsConstructorDescriptionPassiveConnectTask
(ServerSocket myServer, DataSink sink, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) PassiveConnectTask
(ServerSocket myServer, DataSource source, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
close()
void
execute()
private void
init
(ServerSocket myServer, 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 -
myServer
-
mySocketBox
-
sink
-
source
-
control
-
session
-
factory
-
context
-
-
Constructor Details
-
PassiveConnectTask
public PassiveConnectTask(ServerSocket myServer, DataSink sink, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context) -
PassiveConnectTask
public PassiveConnectTask(ServerSocket myServer, DataSource source, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context)
-
-
Method Details
-
init
private void init(ServerSocket myServer, 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()
-