eu.unicore.uftp.server

Class UFTPWorker

java.lang.Object

java.lang.Thread

eu.unicore.uftp.server.UFTPWorker

All Implemented Interfaces:

Runnable

public class UFTPWorker
extends Thread

A UFTPWorker processes a single Job

Author:

Tim Pohlmann, 2010, Forschungszentrum Juelich - JSC, schuller

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 int	BUFFSIZE NETWORK send/receive buffer size, this must be the same on client/server if multiple streams are to be used
static String	sessionModeTag tag used as "filename" to indicate session mode, i.e.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
UFTPWorker(ServerThread server, DPCServer.Connection connection, UFTPTransferRequest job, int maxStreams, int bufferSize)

Method Summary

Modifier and Type	Method and Description
int	getBufferSize()
DPCServer.Connection	getConnection()
UFTPTransferRequest	getJob()
protected void	logUsage(boolean send, long dataSize, long consumedMillis) computes transfer rates, bytes transferred and logs it to the USAGE logger at INFO level (If needed, Log4j can be configured to send these log messages to a specific file instead of the standard logfile)
protected Socket	makeSocket(int max, DPCServer.Connection connection) create a new Socket with the specified number of parallel TCP streams
protected void	readData(Session session)
void	run() Open data connections, perform the data transfer, and close the connection.
protected void	runSession(Session session) transfer multiple files.
protected void	runSingle(Session session, File localFile) transfer a single file - this is a UFTP-only behaviour not in line with the FTP protocol!
protected void	sendData(Session session) send data from a file
protected void	sendStreamData(Session session) send data from a file
protected void	syncMaster(Session session)
protected void	syncSlave(Session session)

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

BUFFSIZE

public static final int BUFFSIZE

NETWORK send/receive buffer size, this must be the same on client/server if multiple streams are to be used

See Also:

Constant Field Values

sessionModeTag

public static final String sessionModeTag

tag used as "filename" to indicate session mode, i.e. multifile and byte range support

See Also:

Constant Field Values

Constructor Detail

UFTPWorker

public UFTPWorker(ServerThread server,
                  DPCServer.Connection connection,
                  UFTPTransferRequest job,
                  int maxStreams,
                  int bufferSize)

Parameters:

server -

connection -

job -

maxStreams -

bufferSize -

Method Detail

run

public void run()

Open data connections, perform the data transfer, and close the connection. If appropriate, the target file permissions will be set to the user/group specified in the job

Specified by:

run in interface Runnable

Overrides:

run in class Thread

runSession

protected void runSession(Session session)

transfer multiple files. File names and byte ranges are read from the control channel, while data is sent over the data socket(s).

runSingle

protected void runSingle(Session session,
                         File localFile)

transfer a single file - this is a UFTP-only behaviour not in line with the FTP protocol!

sendData

protected void sendData(Session session)
                 throws IOException,
                        InterruptedException

send data from a file

Parameters:

session - - the session containing the required information

Throws:

IOException

InterruptedException

readData

protected void readData(Session session)
                 throws IOException

Throws:

IOException

sendStreamData

protected void sendStreamData(Session session)
                       throws IOException,
                              InterruptedException

send data from a file

Parameters:

session - - the session containing the required information

Throws:

IOException

InterruptedException

syncMaster

protected void syncMaster(Session session)
                   throws Exception

Throws:

Exception

syncSlave

protected void syncSlave(Session session)
                  throws Exception

Throws:

Exception

makeSocket

protected Socket makeSocket(int max,
                            DPCServer.Connection connection)
                     throws Exception

create a new Socket with the specified number of parallel TCP streams

Parameters:

max - - the number of parallel streams

connection - - the client connection

Returns:

a Socket

Throws:

Exception

getJob

public UFTPTransferRequest getJob()

Returns:

returns the UFTPTransferRequest for this connection

getConnection

public DPCServer.Connection getConnection()

getBufferSize

public int getBufferSize()

logUsage

protected void logUsage(boolean send,
                        long dataSize,
                        long consumedMillis)

computes transfer rates, bytes transferred and logs it to the USAGE logger at INFO level
(If needed, Log4j can be configured to send these log messages to a specific file instead of the standard logfile)

The format is: [Sent|Received] [clientIP] [user:group] [bytes] [kb/sec]