eu.unicore.uftp.server

Class ServerThread

java.lang.Object

java.lang.Thread

eu.unicore.uftp.server.ServerThread

All Implemented Interfaces:

Runnable

public class ServerThread
extends Thread

This class manages a list of UFTPTransferRequest instances, and waits for connection attempts from clients. For each connection attempt, it is checked whether a matching job exists.
If no client connects, a job will be expired after a while.

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 long	MAX_JOB_AGE_DEFAULT
long	maxJobAge

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ServerThread(InetAddress ip, int port, int backlog, int maxStreams, String advertiseAddress, PortManager pm) create a new server thread

Method Summary

Modifier and Type	Method and Description
void	addJob(UFTPTransferRequest job) adds job
void	checkForExpiredJobs() check if "zombie" jobs exist and clean them up
void	cleanConnectionCounters()
void	close() shut down the server
int	getBufferSize()
FileAccess	getFileAccess()
String	getHost()
int	getMaxControlConnectionsPerClient()
int	getPort()
int	getTimeout() return the server timeout
void	halt()
void	notifyConnectionClosed(InetAddress client) a connection to the given client was closed
void	run() while not halted, new connections are accepted and processed asynchronously using a thread pool
void	setBufferSize(int bufferSize)
void	setMaxControlConnectionsPerClient(int maxControlConnectionsPerClient)
void	setMaxStreamsPerConnection(int maxStreams)
void	setTimeout(int time) set the timeout for accepting new connections

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

MAX_JOB_AGE_DEFAULT

public static final long MAX_JOB_AGE_DEFAULT

See Also:

Constant Field Values

maxJobAge

public final long maxJobAge

Constructor Detail

ServerThread

public ServerThread(InetAddress ip,
                    int port,
                    int backlog,
                    int maxStreams,
                    String advertiseAddress,
                    PortManager pm)
             throws IOException

create a new server thread

Parameters:

ip - - server IP address

port - - server listen port

backlog - - server socket backlog

maxStreams - - maximum number of TCP streams per transfer

Throws:

IOException

Method Detail

run

public void run()

while not halted, new connections are accepted and processed asynchronously using a thread pool

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addJob

public void addJob(UFTPTransferRequest job)

adds job

Parameters:

job -

close

public void close()
           throws IOException

shut down the server

Throws:

IOException

setTimeout

public void setTimeout(int time)

set the timeout for accepting new connections

Parameters:

time - Timeout in ms

getTimeout

public int getTimeout()

return the server timeout

Returns:

Timeout in ms

getPort

public int getPort()

getHost

public String getHost()

getMaxControlConnectionsPerClient

public int getMaxControlConnectionsPerClient()

setMaxControlConnectionsPerClient

public void setMaxControlConnectionsPerClient(int maxControlConnectionsPerClient)

setMaxStreamsPerConnection

public void setMaxStreamsPerConnection(int maxStreams)

getBufferSize

public int getBufferSize()

setBufferSize

public void setBufferSize(int bufferSize)

notifyConnectionClosed

public void notifyConnectionClosed(InetAddress client)

a connection to the given client was closed

Parameters:

client -

halt

public void halt()

checkForExpiredJobs

public void checkForExpiredJobs()

check if "zombie" jobs exist and clean them up

cleanConnectionCounters

public void cleanConnectionCounters()

getFileAccess

public FileAccess getFileAccess()