org.waarp.openr66.commander

Class ClientRunner

java.lang.Object

java.lang.Thread

org.waarp.openr66.commander.ClientRunner

All Implemented Interfaces:

Runnable

public class ClientRunner
extends Thread

Client Runner from a TaskRunner

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static ConcurrentLinkedQueue<ClientRunner>	activeRunners

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ClientRunner(NetworkTransaction networkTransaction, DbTaskRunner taskRunner, R66Future futureRequest)

Method Summary

Modifier and Type	Method and Description
void	changeUpdatedInfo(AbstractDbData.UpdatedInfo info, ErrorCode code, boolean force) Change the UpdatedInfo of the current runner
R66Future	finishTransfer(LocalChannelReference localChannelReference) Finish the transfer (called at the end of runTransfer)
LocalChannelReference	getLocalChannelReference()
NetworkTransaction	getNetworkTransaction()
boolean	getSendThroughMode()
DbTaskRunner	getTaskRunner()
static String	hashStatus()
boolean	incrementTaskRunnerTry(DbTaskRunner runner, int limit)
LocalChannelReference	initRequest() Initialize the request
boolean	isLimitRetryConnection()
static boolean	isRecvHandlerJunit()
void	run()
R66Future	runTransfer() True transfer run (can be called directly to enable exception outside any executors)
void	setLimitRetryConnection(boolean limitRetryConnection)
static void	setRecvHandlerJunit(RecvThroughHandler handler)
void	setRecvThroughHandler(RecvThroughHandler handler)
void	setSendThroughMode()
R66Future	tryAgainTransferOnOverloaded(boolean retry, LocalChannelReference localChannelReference) In case an overloaded signal is returned by the requested

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

activeRunners

public static ConcurrentLinkedQueue<ClientRunner> activeRunners

Constructor Detail

ClientRunner

public ClientRunner(NetworkTransaction networkTransaction,
                    DbTaskRunner taskRunner,
                    R66Future futureRequest)

Method Detail

setRecvHandlerJunit

public static void setRecvHandlerJunit(RecvThroughHandler handler)

isRecvHandlerJunit

public static boolean isRecvHandlerJunit()

hashStatus

public static String hashStatus()

getNetworkTransaction

public final NetworkTransaction getNetworkTransaction()

Returns:

the networkTransaction

getTaskRunner

public final DbTaskRunner getTaskRunner()

Returns:

the taskRunner

getLocalChannelReference

public final LocalChannelReference getLocalChannelReference()

Returns:

the localChannelReference

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

incrementTaskRunnerTry

public final boolean incrementTaskRunnerTry(DbTaskRunner runner,
                                            int limit)

Parameters:

runner -

limit -

Returns:

True if the task was run less than limit, else False

runTransfer

public final R66Future runTransfer()
                            throws OpenR66RunnerErrorException,
                                   OpenR66ProtocolNoConnectionException,
                                   OpenR66ProtocolPacketException,
                                   OpenR66ProtocolNotYetConnectionException

True transfer run (can be called directly to enable exception outside any executors)

Returns:

The R66Future of the transfer operation

Throws:

OpenR66RunnerErrorException

OpenR66ProtocolNoConnectionException

OpenR66ProtocolPacketException

OpenR66ProtocolNotYetConnectionException

tryAgainTransferOnOverloaded

public final R66Future tryAgainTransferOnOverloaded(boolean retry,
                                                    LocalChannelReference localChannelReference)
                                             throws OpenR66RunnerErrorException,
                                                    OpenR66ProtocolNoConnectionException,
                                                    OpenR66ProtocolPacketException,
                                                    OpenR66ProtocolNotYetConnectionException

In case an overloaded signal is returned by the requested

Parameters:

retry - if True, it will retry in case of overloaded remote server, else it just stops

localChannelReference -

Returns:

The R66Future of the transfer operation

Throws:

OpenR66RunnerErrorException

OpenR66ProtocolNoConnectionException

OpenR66ProtocolPacketException

OpenR66ProtocolNotYetConnectionException

finishTransfer

public final R66Future finishTransfer(LocalChannelReference localChannelReference)

Finish the transfer (called at the end of runTransfer)

Parameters:

localChannelReference -

Returns:

The R66Future of the transfer operation

initRequest

public final LocalChannelReference initRequest()
                                        throws OpenR66ProtocolNoConnectionException,
                                               OpenR66ProtocolPacketException,
                                               OpenR66ProtocolNotYetConnectionException

Initialize the request

Returns:

the localChannelReference holding the transfer request

Throws:

OpenR66ProtocolNoConnectionException

OpenR66ProtocolPacketException

OpenR66ProtocolNotYetConnectionException

changeUpdatedInfo

public final void changeUpdatedInfo(AbstractDbData.UpdatedInfo info,
                                    ErrorCode code,
                                    boolean force)

Change the UpdatedInfo of the current runner

Parameters:

info -

setRecvThroughHandler

public final void setRecvThroughHandler(RecvThroughHandler handler)

Parameters:

handler - the handler to set

setSendThroughMode

public final void setSendThroughMode()

getSendThroughMode

public final boolean getSendThroughMode()

isLimitRetryConnection

public final boolean isLimitRetryConnection()

setLimitRetryConnection

public final void setLimitRetryConnection(boolean limitRetryConnection)