eu.unicore.uftp.dpc

Class DPCServer.Connection

java.lang.Object

eu.unicore.uftp.dpc.DPCServer.Connection

Enclosing class:

DPCServer

public class DPCServer.Connection
extends Object

Method Summary

Modifier and Type	Method and Description
void	addNewDataConnection(String cmd)
void	close() quietly close all sockets
void	closeData() quietly close all our data connections
protected Socket	createNewDataConnection() make a new (data) connection
Socket	createNewDataConnection(String cmd)
UFTPTransferRequest	establish() establish the connection using the pseudo FTP protocol
InetAddress	getAddress()
List<Socket>	getDataSockets()
Collection<String>	getFeatures()
List<UFTPTransferRequest>	getJobsForClientAddress(InetAddress ia)
List<UFTPTransferRequest>	getJobsForControlSocketAddress()
int	getProtocolVersion()
List<Socket>	openDataConnections(int maxParCons) Server part of opening data connections.
String	readControl() read a line from the control connection
void	sendControl(String message) send a message over the control channel
void	sendError(int code, String message) sends error message (with code) over the control connection
void	sendError(String message) sends error message (with code 500) over the control connection
void	setControlTimeout(int timeout) set the timeout on the control connection

Methods inherited from class java.lang.Object

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

Method Detail

getFeatures

public Collection<String> getFeatures()

establish

public UFTPTransferRequest establish()
                              throws AuthorizationFailureException,
                                     IOException

establish the connection using the pseudo FTP protocol

Throws:

AuthorizationFailureException

ProtocolViolationException

IOException

getDataSockets

public List<Socket> getDataSockets()

openDataConnections

public List<Socket> openDataConnections(int maxParCons)
                                 throws IOException

Server part of opening data connections. On the client side, the corresponding method DPCClient.openDataConnections() has to be called. No connections to this control connections must exist, use close(controlSocket) to close them. The client can choose the number of data connections, however, these must not exceed maxParcons. If maxParCons is exceeded, the number of connections is limited to maxParCons. A ProtocolViolationException is thrown when the client does not adhere to the protocol.

Parameters:

maxParCons - maximum number of data connections

Throws:

IOException

ProtocolViolationException - when protocol is violated, or data connections already exist

closeData

public void closeData()

quietly close all our data connections

close

public void close()

quietly close all sockets

getAddress

public InetAddress getAddress()

sendControl

public void sendControl(String message)
                 throws IOException

send a message over the control channel

Parameters:

message - - the message to send

Throws:

IOException - on socket errors

sendError

public void sendError(String message)
               throws IOException

sends error message (with code 500) over the control connection

Parameters:

message - message to send

Throws:

IOException - thrown upon socket error

sendError

public void sendError(int code,
                      String message)
               throws IOException

sends error message (with code) over the control connection

Parameters:

code - - error code

message - - message to send

Throws:

IOException - thrown upon socket error

readControl

public String readControl()
                   throws IOException

read a line from the control connection

Returns:

the line or null if end-of-stream

Throws:

IOException

setControlTimeout

public void setControlTimeout(int timeout)
                       throws SocketException

set the timeout on the control connection

Parameters:

timeout -

Throws:

SocketException

createNewDataConnection

protected Socket createNewDataConnection()
                                  throws IOException

make a new (data) connection

Returns:

new Data socket

Throws:

IOException

createNewDataConnection

public Socket createNewDataConnection(String cmd)
                               throws IOException

Throws:

IOException

addNewDataConnection

public void addNewDataConnection(String cmd)
                          throws IOException

Throws:

IOException

getJobsForClientAddress

public List<UFTPTransferRequest> getJobsForClientAddress(InetAddress ia)

getJobsForControlSocketAddress

public List<UFTPTransferRequest> getJobsForControlSocketAddress()

getProtocolVersion

public int getProtocolVersion()