eu.unicore.uftp.dpc

Class DPCServer

java.lang.Object

eu.unicore.uftp.dpc.DPCServer

public class DPCServer
extends Object

Server allowing parallel data transfer with dynamic port configuration using FTP

Author:

Tim Pohlmann, 2010, Forschungszentrum Juelich - JSC, schuller

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DPCServer.Connection

Field Summary

Fields

Modifier and Type	Field and Description
protected static String[]	responses String-Array holding response messages used to establish the pseudo-FTP connection
static String	VER

Constructor Summary

Constructors

Constructor and Description
DPCServer(InetAddress ip, int port, int backlog, JobStore jobStore, String advertiseAddress, PortManager pm, boolean checkClientIP) create a new server listening on the given interface

Method Summary

Modifier and Type	Method and Description
DPCServer.Connection	accept() Waits for incoming client
void	close() close the server socket, disallowing any new connections.
static String[]	getFeatures() get the list of features supported by this server
String	getHost()
int	getPort()
int	getTimeout()
boolean	isCheckClientIP()
void	setCheckClientIP(boolean checkIP)
void	setTimeout(int timeout)

Methods inherited from class java.lang.Object

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

Field Detail

VER

public static final String VER

See Also:

Constant Field Values

responses

protected static final String[] responses

String-Array holding response messages used to establish the pseudo-FTP connection

Constructor Detail

DPCServer

public DPCServer(InetAddress ip,
                 int port,
                 int backlog,
                 JobStore jobStore,
                 String advertiseAddress,
                 PortManager pm,
                 boolean checkClientIP)
          throws IOException

create a new server listening on the given interface

Parameters:

ip - server interface to bind to, if null, all interfaces are used

port - listen port

backlog - maximum backlog of incoming connections

advertiseAddress - Advertise this address as our own address in the control connection

pm - - PortManager

Throws:

IOException

Method Detail

accept

public DPCServer.Connection accept()
                            throws IOException

Waits for incoming client

Returns:

control connection - which needs to be established before use

Throws:

IOException - on IO errors or if the connection is from a client address for which no UFTPTransferRequest exists

close

public void close()
           throws IOException

close the server socket, disallowing any new connections. Existing connections are kept

Throws:

IOException - as thrown from ServerSocket.close()

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int timeout)

setCheckClientIP

public void setCheckClientIP(boolean checkIP)

getPort

public int getPort()

getHost

public String getHost()

isCheckClientIP

public boolean isCheckClientIP()

getFeatures

public static String[] getFeatures()

get the list of features supported by this server

Returns:

string list of features