org.waarp.ftp.core.data

Class FtpTransferControl

java.lang.Object

org.waarp.ftp.core.data.FtpTransferControl

public class FtpTransferControl
extends Object

Main class that handles transfers and their execution

Constructor Summary

Constructors

Constructor and Description
FtpTransferControl(FtpSession session)

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the FtpTransferControl (called when the data connection must be over like from clear of FtpDataAsyncConn, abort from ABOR or ending control connection from NetworkHandler.
FtpTransfer	getExecutingFtpTransfer()
boolean	isFtpTransferExecuting() Is a command currently executing (called from NetworkHandler when a message is received to see if another transfer command is already in execution, which is not allowed)
void	openDataConnection() Wait for the client to be connected (Passive) or Wait for the server to be connected to the client (Active)
void	resetWaitForOpenedDataChannel() Allow to reset the waitForOpenedDataChannel
void	setEndOfTransfer() Set the current transfer as finished.
void	setNewFtpTransfer(FtpCommandCode command, FtpFile file) Add a new transfer to be executed.
void	setNewFtpTransfer(FtpCommandCode command, List<String> list, String path) Add a new transfer to be executed.
void	setOpenedDataChannel(io.netty.channel.Channel channel, DataNetworkHandler dataNetworkHandler) Set the new opened Channel (from channelConnected of DataNetworkHandler)
void	setPreEndOfTransfer() Called by channelClosed (from DataNetworkHandler ) or trueRetrieve (from FtpFile) when the transfer is over
void	setTransferAbortedFromInternal(boolean write) To enable abort from internal error
void	waitForDataNetworkHandlerReady() Wait for the DataNetworkHandler to be ready (from trueRetrieve of FtpFile)
void	waitForEndOfTransfer() Wait for the current transfer to finish, called from FtpTransferExecutor
io.netty.channel.Channel	waitForOpenedDataChannel() Wait that the new opened connection is ready (same method in FtpDataAsyncConn from openConnection)
boolean	waitFtpTransferExecuting()

Methods inherited from class java.lang.Object

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

Constructor Detail

FtpTransferControl

public FtpTransferControl(FtpSession session)

Parameters:

session -

Method Detail

waitForDataNetworkHandlerReady

public final void waitForDataNetworkHandlerReady()
                                          throws InterruptedException

Wait for the DataNetworkHandler to be ready (from trueRetrieve of FtpFile)

Throws:

InterruptedException

setOpenedDataChannel

public final void setOpenedDataChannel(io.netty.channel.Channel channel,
                                       DataNetworkHandler dataNetworkHandler)

Set the new opened Channel (from channelConnected of DataNetworkHandler)

Parameters:

channel -

dataNetworkHandler -

waitForOpenedDataChannel

public final io.netty.channel.Channel waitForOpenedDataChannel()
                                                        throws InterruptedException

Wait that the new opened connection is ready (same method in FtpDataAsyncConn from openConnection)

Returns:

the new opened Channel

Throws:

InterruptedException

resetWaitForOpenedDataChannel

public final void resetWaitForOpenedDataChannel()

Allow to reset the waitForOpenedDataChannel

openDataConnection

public final void openDataConnection()
                              throws Reply425Exception

Wait for the client to be connected (Passive) or Wait for the server to be connected to the client (Active)

Throws:

Reply425Exception

setNewFtpTransfer

public final void setNewFtpTransfer(FtpCommandCode command,
                                    FtpFile file)

Add a new transfer to be executed. This is to be called from Command after connection is opened and before answering to the client that command is ready to be executed (for Store or Retrieve like operations).

Parameters:

command -

file -

setNewFtpTransfer

public final void setNewFtpTransfer(FtpCommandCode command,
                                    List<String> list,
                                    String path)

Add a new transfer to be executed. This is to be called from Command after connection is opened and before answering to the client that command is ready to be executed (for List like operations).

Parameters:

command -

list -

path - as Original Path

waitFtpTransferExecuting

public final boolean waitFtpTransferExecuting()

Returns:

True if transfer is not yet finished

isFtpTransferExecuting

public final boolean isFtpTransferExecuting()

Is a command currently executing (called from NetworkHandler when a message is received to see if another transfer command is already in execution, which is not allowed)

Returns:

True if a command is currently executing

getExecutingFtpTransfer

public final FtpTransfer getExecutingFtpTransfer()
                                          throws FtpNoTransferException

Returns:

the current executing FtpTransfer

Throws:

FtpNoTransferException

setEndOfTransfer

public final void setEndOfTransfer()

Set the current transfer as finished. Called from FtpTransferExecutor when a transfer is over.

setTransferAbortedFromInternal

public final void setTransferAbortedFromInternal(boolean write)

To enable abort from internal error

Parameters:

write - True means the message is write back to the control command, false it is only prepared

setPreEndOfTransfer

public final void setPreEndOfTransfer()

Called by channelClosed (from DataNetworkHandler ) or trueRetrieve (from FtpFile) when the transfer is over

waitForEndOfTransfer

public final void waitForEndOfTransfer()
                                throws InterruptedException

Wait for the current transfer to finish, called from FtpTransferExecutor

Throws:

InterruptedException

clear

public final void clear()

Clear the FtpTransferControl (called when the data connection must be over like from clear of FtpDataAsyncConn, abort from ABOR or ending control connection from NetworkHandler.