eu.unicore.uftp.dpc

Class DPCClient

java.lang.Object

eu.unicore.uftp.dpc.DPCClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class DPCClient
extends Object
implements Closeable

Client allowing parallel data transfer with dynamic port configuration using FTP

Author:

Tim Pohlmann, 2010, Forschungszentrum Juelich - JSC, schuller

Constructor Summary

Constructors

Constructor and Description
DPCClient()
DPCClient(ClientProtocol protocol)

Method Summary

Modifier and Type	Method and Description
void	close() close all
void	closeData() close all data connections
void	connect(InetAddress[] server, int port, String secret) establishes an authorised pseudo FTP connection.
int	getAuthTimeout()
Socket	getNewConnection() open new connection
int	getProtocolVersion()
List<String>	getServerFeatures()
int	getTimeout()
boolean	isConnected()
List<Socket>	openDataConnections(int numParCons) opens data connections
String	readControl() read a single line from the control channel
void	sendControl(String message) send a message over the control channel
void	setAuthTimeout(int authTimeout)
void	setTimeout(int timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

DPCClient

public DPCClient()

DPCClient

public DPCClient(ClientProtocol protocol)

Method Detail

connect

public void connect(InetAddress[] server,
                    int port,
                    String secret)
             throws IOException,
                    AuthorizationFailureException

establishes an authorised pseudo FTP connection. Only a single connection to a server can be open at the same time. A connection can be closed using close().

Parameters:

server - - server addresses

port - - server port

secret - - the authentication secret

Throws:

IOException

ProtocolViolationException

AuthorizationFailureException

openDataConnections

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

opens data connections

Parameters:

numParCons - number of parallel connections

Returns:

socket list

Throws:

IOException

ProtocolViolationException

getNewConnection

public Socket getNewConnection()
                        throws IOException

open new connection

Returns:

newly opened socket

Throws:

IOException

closeData

public void closeData()

close all data connections

Throws:

IOException

close

public void close()
           throws IOException

close all

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

isConnected

public boolean isConnected()

getServerFeatures

public List<String> getServerFeatures()

getProtocolVersion

public int getProtocolVersion()

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int timeout)

getAuthTimeout

public int getAuthTimeout()

setAuthTimeout

public void setAuthTimeout(int authTimeout)

sendControl

public void sendControl(String message)
                 throws IOException

send a message over the control channel

Parameters:

message - - the message to send

Throws:

IOException - when sending failed

readControl

public String readControl()
                   throws IOException

read a single line from the control channel

Throws:

IOException