Class ProxyModule

java.lang.Object

ecmwf.common.ectrans.TransferModule

ecmwf.ecpds.mover.ProxyModule

All Implemented Interfaces:

ECpdsProxy, Closeable, AutoCloseable

Direct Known Subclasses:

ECauthModule

public abstract class ProxyModule
extends TransferModule
implements ECpdsProxy

The Class ProxyModule.

Constructor Summary

Constructors

Constructor	Description
ProxyModule()

Method Summary

Modifier and Type	Method	Description
void	check(long sent, String checksum)	Check if the last put was successful comparing the number of bytes sent and the checksum provided to the one calculated.
void	close()	Close.
InputStream	get(String name, long posn)	Gets the input stream to read the file given by name starting at posn.
abstract void	get(String name, long posn, ProxySocket socket)	Gets the.
OutputStream	put(String name, long posn, long size)	Provide an output stream to write the content of the file given by its name starting at position posn.
abstract void	put(String name, long posn, long size, ProxySocket socket)	Puts the.
abstract void	remove(boolean closedOnError)	Removes the.
void	setInputStream(InputStream in)	Sets the input stream.
void	setOutputStream(OutputStream out)	Sets the output stream.

Methods inherited from class ecmwf.common.ectrans.TransferModule

connect, containsAttribute, copy, del, delegateChecksum, get, getAttribute, getAttribute, getAvailable, getClearPassword, getClosedOnError, getCookie, getDebug, getECtransDestination, getECtransModule, getECUser, getMSUser, getPort, getRemoteProvider, getStatus, list, listAsByteArray, listAsStringArray, mkdir, move, preGet, prePut, put, rmdir, setAttribute, setAttribute, setAvailable, setClosedOnError, setDebug, setInputFilter, setInputMd5, setInputSize, setOutputFilter, size, updateSocketStatistics

Methods inherited from class java.lang.Object

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

Constructor Details

ProxyModule

public ProxyModule()

Method Details

setOutputStream

public void setOutputStream(OutputStream out)

Sets the output stream. Sets the output stream.

Specified by:

setOutputStream in interface ECpdsProxy

Parameters:

out - the new output stream

setInputStream

public void setInputStream(InputStream in)

Sets the input stream. Sets the input stream.

Specified by:

setInputStream in interface ECpdsProxy

Parameters:

in - the new input stream

put

public abstract void put(String name,
 long posn,
 long size,
 ProxySocket socket)
                  throws Exception

Puts the.

Parameters:

name - the name

posn - the posn

size - the size

socket - the socket

Throws:

Exception - the exception

put

public OutputStream put(String name,
 long posn,
 long size)
                 throws IOException

Provide an output stream to write the content of the file given by its name starting at position posn. Put.

Specified by:

put in class TransferModule

Parameters:

name - the name

posn - the posn

size - the size

Returns:

the output stream

Throws:

IOException - Signals that an I/O exception has occurred.

get

public abstract void get(String name,
 long posn,
 ProxySocket socket)
                  throws Exception

Gets the.

Parameters:

name - the name

posn - the posn

socket - the socket

Throws:

Exception - the exception

get

public InputStream get(String name,
 long posn)
                throws IOException

Gets the input stream to read the file given by name starting at posn. Gets the.

Specified by:

get in class TransferModule

Parameters:

name - the name

posn - the posn

Returns:

the input stream

Throws:

IOException - Signals that an I/O exception has occurred.

remove

public abstract void remove(boolean closedOnError)
                     throws IOException

Removes the.

Parameters:

closedOnError - the closed on error

Throws:

IOException - Signals that an I/O exception has occurred.

close

public void close()
           throws IOException

Close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

check

public void check(long sent,
 String checksum)
           throws IOException

Check if the last put was successful comparing the number of bytes sent and the checksum provided to the one calculated. By default, doing nothing. Check.

Overrides:

check in class TransferModule

Parameters:

sent - the sent

checksum - the checksum

Throws:

IOException - Signals that an I/O exception has occurred.