Class PassiveConnectTask

java.lang.Object

org.globus.ftp.dc.Task

org.globus.ftp.dc.PassiveConnectTask

Direct Known Subclasses:

GridFTPPassiveConnectTask

public class PassiveConnectTask
extends Task

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

Fields

Modifier and Type	Field	Description
protected TransferContext	context
protected BasicServerControlChannel	control
protected DataChannelFactory	factory
protected static org.apache.commons.logging.Log	logger
protected ServerSocket	myServer
protected SocketBox	mySocketBox
protected Session	session
protected DataSink	sink
protected DataSource	source

Fields inherited from class Task

complete, exception

Constructor Summary

Constructors

Constructor	Description
PassiveConnectTask(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 Type	Method	Description
private void	close()
void	execute()
private void	init(ServerSocket myServer, BasicServerControlChannel control, Session session, DataChannelFactory factory, TransferContext context)
protected SocketBox	openSocket()	Override this to implement authentication
void	stop()

Methods inherited from class Task

setComplete, waitFor

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

protected static org.apache.commons.logging.Log logger

myServer

protected ServerSocket myServer

mySocketBox

protected SocketBox mySocketBox

sink

protected DataSink sink

source

protected DataSource source

control

protected BasicServerControlChannel control

session

protected Session session

factory

protected DataChannelFactory factory

context

protected TransferContext 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()

Specified by:

execute in class Task

openSocket

protected SocketBox openSocket()
                        throws Exception

Override this to implement authentication

Throws:

Exception

close

private void close()

stop

public void stop()

Overrides:

stop in class Task