org.waarp.openr66.client

Class AbstractTransfer

java.lang.Object

org.waarp.openr66.client.AbstractTransfer

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

DirectTransfer, ProgressBarTransfer, RecvThroughClient, SendThroughClient, SubmitTransfer

public abstract class AbstractTransfer
extends Object
implements Runnable

Abstract class for Transfer operation

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	_INFO_ARGS
protected static int	block
protected int	blocksize
protected String	fileinfo
protected static String	fileInfo
protected String	filename
protected R66Future	future
protected long	id
protected static long	idt
protected static boolean	ismd5
protected boolean	isMD5
protected static String	localFilename
protected static WaarpLogger	logger Internal Logger
protected static String	NO_INFO_ARGS
protected static boolean	nolog
protected boolean	normalInfoAsWarn
protected String	remoteHost
protected static String	rhost
protected static String	rule
protected String	rulename
protected static boolean	snormalInfoAsWarn
protected Timestamp	startTime
protected static Timestamp	ttimestart

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTransfer(Class<?> clasz, R66Future future, String filename, String rulename, String fileinfo, boolean isMD5, String remoteHost, int blocksize, long id, Timestamp timestart)

Method Summary

Modifier and Type	Method and Description
protected static void	clear()
protected void	finalizeInErrorTransferRequest(ClientRunner runner, DbTaskRunner taskRunner, ErrorCode code) Shared code for finalize one Transfer request in error
List<String>	getLocalFiles(DbRule dbrule, String[] localfilenames)
protected static boolean	getParams(String[] args, boolean submitOnly) Parse the parameter and set current values
protected static boolean	getParamsInternal(String[] args) Internal getParams without configuration initialization, but still as first argument
List<String>	getRemoteFiles(DbRule dbrule, String[] localfilenames, String requested, NetworkTransaction networkTransaction)
protected DbTaskRunner	initRequest() Initiate the Request and return a potential DbTaskRunner
protected static void	prepareKoOutputFormat(R66Future future, OutputFormat outputFormat)
protected static void	prepareKoOutputFormat(R66Future future, R66Result result, OutputFormat outputFormat)
protected static void	prepareOkOutputFormat(long delay, R66Result result, OutputFormat outputFormat)
protected static void	prepareSubmitKoOutputFormat(R66Future future, DbTaskRunner runner, OutputFormat outputFormat)
protected static void	prepareSubmitOkOutputFormat(DbTaskRunner runner, OutputFormat outputFormat)
static boolean	sendValidPacket(DbHostAuth host, LocalChannelReference localChannelReference, AbstractLocalPacket packet, R66Future future)
void	setNormalInfoAsWarn(boolean normalInfoAsWarn1)
static LocalChannelReference	tryConnect(DbHostAuth host, R66Future future, NetworkTransaction networkTransaction) Helper to connect

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

logger

protected static volatile WaarpLogger logger

Internal Logger

_INFO_ARGS

protected static final String _INFO_ARGS

NO_INFO_ARGS

protected static final String NO_INFO_ARGS

See Also:

Constant Field Values

future

protected final R66Future future

filename

protected final String filename

rulename

protected final String rulename

fileinfo

protected final String fileinfo

isMD5

protected final boolean isMD5

remoteHost

protected final String remoteHost

blocksize

protected final int blocksize

id

protected final long id

startTime

protected final Timestamp startTime

normalInfoAsWarn

protected boolean normalInfoAsWarn

rhost

protected static String rhost

localFilename

protected static String localFilename

rule

protected static String rule

fileInfo

protected static String fileInfo

ismd5

protected static boolean ismd5

block

protected static int block

nolog

protected static boolean nolog

idt

protected static long idt

ttimestart

protected static Timestamp ttimestart

snormalInfoAsWarn

protected static boolean snormalInfoAsWarn

Constructor Detail

AbstractTransfer

protected AbstractTransfer(Class<?> clasz,
                           R66Future future,
                           String filename,
                           String rulename,
                           String fileinfo,
                           boolean isMD5,
                           String remoteHost,
                           int blocksize,
                           long id,
                           Timestamp timestart)

Parameters:

clasz - Class of Client Transfer

future -

filename -

rulename -

fileinfo -

isMD5 -

remoteHost -

blocksize -

id -

Method Detail

sendValidPacket

public static boolean sendValidPacket(DbHostAuth host,
                                      LocalChannelReference localChannelReference,
                                      AbstractLocalPacket packet,
                                      R66Future future)

Parameters:

host -

localChannelReference -

packet -

future -

Returns:

True if OK

initRequest

protected DbTaskRunner initRequest()

Initiate the Request and return a potential DbTaskRunner

Returns:

null if an error occurs or a DbTaskRunner

clear

protected static void clear()

getParams

protected static boolean getParams(String[] args,
                                   boolean submitOnly)

Parse the parameter and set current values

Parameters:

args -

submitOnly - True if the client is only a submitter (through database)

Returns:

True if all parameters were found and correct

getParamsInternal

protected static boolean getParamsInternal(String[] args)

Internal getParams without configuration initialization, but still as first argument

Parameters:

args -

Returns:

True if all parameters were found and correct

finalizeInErrorTransferRequest

protected void finalizeInErrorTransferRequest(ClientRunner runner,
                                              DbTaskRunner taskRunner,
                                              ErrorCode code)

Shared code for finalize one Transfer request in error

Parameters:

runner -

taskRunner -

setNormalInfoAsWarn

public void setNormalInfoAsWarn(boolean normalInfoAsWarn1)

getRemoteFiles

public List<String> getRemoteFiles(DbRule dbrule,
                                   String[] localfilenames,
                                   String requested,
                                   NetworkTransaction networkTransaction)

getLocalFiles

public List<String> getLocalFiles(DbRule dbrule,
                                  String[] localfilenames)

tryConnect

public static LocalChannelReference tryConnect(DbHostAuth host,
                                               R66Future future,
                                               NetworkTransaction networkTransaction)

Helper to connect

Parameters:

host -

future -

networkTransaction -

Returns:

localChannelReference not null if ok

prepareKoOutputFormat

protected static void prepareKoOutputFormat(R66Future future,
                                            R66Result result,
                                            OutputFormat outputFormat)

prepareKoOutputFormat

protected static void prepareKoOutputFormat(R66Future future,
                                            OutputFormat outputFormat)

prepareOkOutputFormat

protected static void prepareOkOutputFormat(long delay,
                                            R66Result result,
                                            OutputFormat outputFormat)

prepareSubmitKoOutputFormat

protected static void prepareSubmitKoOutputFormat(R66Future future,
                                                  DbTaskRunner runner,
                                                  OutputFormat outputFormat)

prepareSubmitOkOutputFormat

protected static void prepareSubmitOkOutputFormat(DbTaskRunner runner,
                                                  OutputFormat outputFormat)