Package unlimited.fc.client.api.multiclient

Class FCClientWorker<T extends FileTransferMechanism>

java.lang.Object

unlimited.fc.client.api.multiclient.FCClientWorker<T>

Type Parameters:

T - the generic type

All Implemented Interfaces:

java.lang.Runnable, TransferRunner

public class FCClientWorker<T extends FileTransferMechanism>
extends java.lang.Object
implements TransferRunner

The Class FCClientWorker.

Field Summary

Fields

Modifier and Type	Field	Description
protected T	client
protected MultiClientManager	parent
protected boolean	resetThread

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FCClientWorker(MultiClientManager parent, T client)

Method Summary

Modifier and Type	Method	Description
protected void	cleanup()	Cleans up the current job if is defined
protected void	disconnectClient()	Disconnects the client from the server that is connected to
protected void	executeRun()
java.util.concurrent.locks.Lock	getCleanupFutureLock()
FileTransferMechanism	getClient()	Returns the current FileTransferMechanism that this runner uses to transfer files
TransferJob	getJob()	Returns the current TransferJob that this runner is using
protected java.lang.String	initRun()
boolean	isRunning()	Returns whether or not the runner is currently executing
void	run()
protected void	runJob()	Runs the job that is currently assigned to this FCClientWorker instance
void	setCleanupFuture(java.util.concurrent.Future<?> someFuture)
void	setPool(FCClientWorkerPool fcClientWorkerPool)
void	shutDown()	Shut down.
protected boolean	synchWithMaster()	Syncs this client with the master parent client object

Methods inherited from class java.lang.Object

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

Field Detail

parent

protected MultiClientManager parent

client

protected T extends FileTransferMechanism client

resetThread

protected boolean resetThread

Constructor Detail

FCClientWorker

protected FCClientWorker(MultiClientManager parent,
                         T client)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

executeRun

protected void executeRun()
                   throws unlimited.core.util.common.exception.FCException.Retriable

Throws:

unlimited.core.util.common.exception.FCException.Retriable

initRun

protected java.lang.String initRun()

disconnectClient

protected void disconnectClient()

Disconnects the client from the server that is connected to

runJob

protected void runJob()
               throws unlimited.core.util.common.exception.FCException,
                      java.io.IOException

Runs the job that is currently assigned to this FCClientWorker instance

Throws:

unlimited.core.util.common.exception.FCException - If an error in the FC protocol occurs

java.io.IOException - If a timeout, or other IO error occurs

synchWithMaster

protected boolean synchWithMaster()

Syncs this client with the master parent client object

Returns:

Whether or not the sync was successful

cleanup

protected void cleanup()

Cleans up the current job if is defined

shutDown

public void shutDown()

Shut down.

setPool

public void setPool(FCClientWorkerPool fcClientWorkerPool)

isRunning

public boolean isRunning()

Description copied from interface: TransferRunner

Returns whether or not the runner is currently executing

Specified by:

isRunning in interface TransferRunner

Returns:

True if running, false if not

getJob

public TransferJob getJob()

Description copied from interface: TransferRunner

Returns the current TransferJob that this runner is using

Specified by:

getJob in interface TransferRunner

Returns:

TransferJob containing the work to be executed

getClient

public FileTransferMechanism getClient()

Description copied from interface: TransferRunner

Returns the current FileTransferMechanism that this runner uses to transfer files

Specified by:

getClient in interface TransferRunner

Returns:

Client to be used when executing the job

setCleanupFuture

public void setCleanupFuture(java.util.concurrent.Future<?> someFuture)

getCleanupFutureLock

public java.util.concurrent.locks.Lock getCleanupFutureLock()