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 UFTPBaseRequest 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 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, boolean checkClientIP) create a new server thread

Method Summary

Modifier and Type	Method and Description
void	addJob(UFTPBaseRequest job)
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	setCheckClientIP(boolean checkIP)
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

Constructor Detail

ServerThread

public ServerThread(InetAddress ip,
                    int port,
                    int backlog,
                    int maxStreams,
                    String advertiseAddress,
                    PortManager pm,
                    boolean checkClientIP)
             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(UFTPBaseRequest 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)

setCheckClientIP

public void setCheckClientIP(boolean checkIP)

notifyConnectionClosed

public void notifyConnectionClosed(InetAddress client)

a connection to the given client was closed

Parameters:

client -

halt

public void halt()

cleanConnectionCounters

public void cleanConnectionCounters()

getFileAccess

public FileAccess getFileAccess()