Package org.globus.ftp.dc

Class ActiveStartTransferTask

java.lang.Object

org.globus.ftp.dc.Task

org.globus.ftp.dc.ActiveStartTransferTask

public class ActiveStartTransferTask
extends Task

This task will start the transfer on the supplied socket. The socket is assumed to have been already connected to the remote server (for instance, by active connect task). 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
(package private) SocketBox	box
(package private) TransferContext	context
(package private) BasicServerControlChannel	control
(package private) DataChannelFactory	factory
(package private) HostPort	hostPort
(package private) static org.apache.commons.logging.Log	logger
(package private) int	operation
protected static int	RETR
(package private) Session	session
(package private) DataSink	sink
(package private) DataSource	source
protected static int	STOR

Fields inherited from class org.globus.ftp.dc.Task

complete, exception

Constructor Summary

Constructors

Constructor	Description
ActiveStartTransferTask(DataSink sink, BasicServerControlChannel control, SocketBox box, Session session, DataChannelFactory factory, TransferContext context)
ActiveStartTransferTask(DataSource source, BasicServerControlChannel control, SocketBox box, Session session, DataChannelFactory factory, TransferContext context)

Method Summary

Modifier and Type	Method	Description
void	execute()
private void	init(int operation, BasicServerControlChannel control, SocketBox box, Session session, DataChannelFactory factory, TransferContext context)

Methods inherited from class org.globus.ftp.dc.Task

setComplete, stop, waitFor

Methods inherited from class java.lang.Object

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

Field Detail

logger

static org.apache.commons.logging.Log logger

hostPort

HostPort hostPort

control

BasicServerControlChannel control

STOR

protected static final int STOR

See Also:

Constant Field Values

RETR

protected static final int RETR

See Also:

Constant Field Values

operation

int operation

sink

DataSink sink

source

DataSource source

box

SocketBox box

session

Session session

factory

DataChannelFactory factory

context

TransferContext context

Constructor Detail

ActiveStartTransferTask

public ActiveStartTransferTask(DataSink sink,
                               BasicServerControlChannel control,
                               SocketBox box,
                               Session session,
                               DataChannelFactory factory,
                               TransferContext context)

ActiveStartTransferTask

public ActiveStartTransferTask(DataSource source,
                               BasicServerControlChannel control,
                               SocketBox box,
                               Session session,
                               DataChannelFactory factory,
                               TransferContext context)

Method Detail

init

private void init(int operation,
                  BasicServerControlChannel control,
                  SocketBox box,
                  Session session,
                  DataChannelFactory factory,
                  TransferContext context)

execute

public void execute()

Specified by:

execute in class Task