Package | Description |
---|---|
org.globus.ftp | |
org.globus.ftp.app | |
org.globus.ftp.dc | |
org.globus.ftp.exception | |
org.globus.ftp.extended | |
org.globus.ftp.vanilla |
Modifier and Type | Method and Description |
---|---|
void |
FTPClient.abort()
Aborts the current transfer.
|
protected void |
FTPClient.actualSetMode(int mode,
java.lang.String modeStr) |
void |
FTPClient.allocate(long size)
Reserve sufficient storage to accommodate the new file to be
transferred.
|
TransferState |
FTPClient.asynchGet(java.lang.String remoteFileName,
DataSink sink,
MarkerListener mListener)
Retrieves the file from the remote server.
|
TransferState |
FTPClient.asynchGet2(java.lang.String remoteFileName,
boolean passive,
DataSink sink,
MarkerListener mListener)
Retrieves a file asynchronously using the GFD.47 (a.k.a
GridFTP2) GET command.
|
TransferState |
FTPClient.asynchPut(java.lang.String remoteFileName,
DataSource source,
MarkerListener mListener)
Stores file at the remote server.
|
TransferState |
FTPClient.asynchPut(java.lang.String remoteFileName,
DataSource source,
MarkerListener mListener,
boolean append)
Stores file at the remote server.
|
TransferState |
FTPClient.asynchPut2(java.lang.String remoteFileName,
boolean passive,
DataSource source,
MarkerListener mListener)
Stores a file at the remote server using the GFD.47 (a.k.a
GridFTP2) PUT command.
|
void |
GridFTPClient.authenticate(org.ietf.jgss.GSSCredential credential)
Performs authentication with specified user credentials.
|
void |
GridFTPClient.authenticate(org.ietf.jgss.GSSCredential credential,
java.lang.String username)
Performs authentication with specified user credentials and
a specific username (assuming the user dn maps to the passed username).
|
void |
FTPClient.authorize(java.lang.String user,
java.lang.String password)
Performs user authorization with specified
user and password.
|
void |
FTPClient.changeDir(java.lang.String dir)
Changes the remote current working directory.
|
void |
GridFTPClient.changeGroup(java.lang.String group,
java.lang.String file)
Change the Unix group membership of a file.
|
void |
GridFTPClient.changeModificationTime(int year,
int month,
int day,
int hour,
int min,
int sec,
java.lang.String file)
Change the modification time of a file.
|
protected void |
FTPClient.checkGETPUTSupport()
Throws ServerException if GFD.47 GETPUT is not supported or
cannot be used.
|
protected void |
GridFTPClient.checkGridFTPSupport()
assure that the server supports extended transfer features;
throw exception if not
|
java.lang.String |
GridFTPClient.checksum(ChecksumAlgorithm algorithm,
long offset,
long length,
java.lang.String file)
Computes and returns a checksum of a file.
|
protected void |
FTPClient.checkTransferParams() |
protected void |
GridFTPClient.checkTransferParamsGet() |
protected void |
FTPClient.checkTransferParamsGet() |
protected void |
FTPClient.checkTransferParamsPut() |
void |
FTPClient.close()
Closes connection.
|
void |
FTPClient.close(boolean ignoreQuitReply)
Closes connection.
|
void |
GridFTPClient.createSymbolicLink(java.lang.String link_target,
java.lang.String link_name)
Create a symbolic link on the FTP server.
|
void |
FTPClient.deleteDir(java.lang.String dir)
Deletes the remote directory.
|
void |
FTPClient.deleteFile(java.lang.String filename)
Deletes the remote file.
|
boolean |
FTPClient.exists(java.lang.String filename)
Checks if given file/directory exists on the server.
|
void |
GridFTPClient.extendedGet(java.lang.String remoteFileName,
long size,
DataSink sink,
MarkerListener mListener)
Performs extended retrieve (partial retrieve mode starting
at offset 0).
|
void |
GridFTPClient.extendedGet(java.lang.String remoteFileName,
long offset,
long size,
DataSink sink,
MarkerListener mListener)
Performs extended retrieve (partial retrieve mode).
|
void |
GridFTPClient.extendedMultipleTransfer(long[] remoteSrcFileOffset,
long[] remoteSrcFileLength,
java.lang.String[] remoteSrcFile,
GridFTPClient destination,
long[] remoteDstFileOffset,
java.lang.String[] remoteDstFile,
MarkerListener mListener,
MultipleTransferCompleteListener doneListener) |
void |
GridFTPClient.extendedMultipleTransfer(java.lang.String[] remoteSrcFile,
GridFTPClient destination,
java.lang.String[] remoteDstFile,
MarkerListener mListener,
MultipleTransferCompleteListener doneListener) |
void |
GridFTPClient.extendedPut(java.lang.String remoteFileName,
DataSource source,
MarkerListener mListener)
Performs extended store (adujsted store mode with offset 0).
|
void |
GridFTPClient.extendedPut(java.lang.String remoteFileName,
long offset,
DataSource source,
MarkerListener mListener)
Performs extended store (adujsted store mode).
|
void |
GridFTPClient.extendedTransfer(java.lang.String remoteSrcFile,
GridFTPClient destination,
java.lang.String remoteDstFile,
MarkerListener mListener)
Performs a third-party transfer between two servers using extended
block mode.
|
void |
GridFTPClient.extendedTransfer(java.lang.String remoteSrcFile,
long remoteSrcFileOffset,
long remoteSrcFileLength,
GridFTPClient destination,
java.lang.String remoteDstFile,
long remoteDstFileOffset,
MarkerListener mListener)
Performs a third-party transfer between two servers using extended
block mode.
|
void |
FTPClient.get(java.lang.String remoteFileName,
DataSink sink,
MarkerListener mListener)
Retrieves the file from the remote server.
|
void |
GridFTPClient.get(java.lang.String remoteFileName,
java.io.File localFile) |
void |
FTPClient.get(java.lang.String remoteFileName,
java.io.File localFile) |
protected HostPort |
FTPClient.get127Reply()
Reads a GFD.47 compliant 127 reply and extracts the port
information from it.
|
void |
FTPClient.get2(java.lang.String remoteFileName,
boolean passive,
DataSink sink,
MarkerListener mListener)
Retrieves a file using the GFD.47 (a.k.a GridFTP2) GET command.
|
java.lang.String |
FTPClient.getChecksum(java.lang.String algorithm,
long offset,
long length,
java.lang.String path)
implement GridFTP v2 CKSM command from
GridFTP v2 Protocol Description
|
java.lang.String |
FTPClient.getChecksum(java.lang.String algorithm,
java.lang.String path)
GridFTP v2 CKSM command for the whole file
|
java.lang.String |
FTPClient.getCurrentDir()
Returns remote current working directory.
|
FeatureList |
FTPClient.getFeatureList()
Returns list of features supported by remote server.
|
java.util.Date |
FTPClient.getLastModified(java.lang.String filename)
Returns last modification time of the specifed file.
|
long |
FTPClient.getSize(java.lang.String filename)
Returns the remote file size.
|
java.util.List<java.lang.String> |
FTPClient.getSupportedCksumAlgorithms()
According to
GridFTP v2 Protocol Description
checksum feature has the following syntax:
|
void |
FTPClient.goUpDir()
Changes remote current working directory to the higher level.
|
boolean |
FTPClient.isCksumAlgorithmSupported(java.lang.String algorithm) |
boolean |
FTPClient.isFeatureSupported(java.lang.String feature)
Returns true if the given feature is supported by remote server,
false otherwise.
|
java.util.Date |
FTPClient.lastModified(java.lang.String filename) |
java.util.Vector |
FTPClient.list()
Performs remote directory listing.
|
java.util.Vector |
FTPClient.list(java.lang.String filter)
Performs remote directory listing with the specified filter.
|
java.util.Vector |
GridFTPClient.list(java.lang.String filter,
java.lang.String modifier)
Performs remote directory listing like
FTPClient.list() . |
java.util.Vector |
FTPClient.list(java.lang.String filter,
java.lang.String modifier)
Performs remote directory listing with the specified filter and
modifier.
|
void |
FTPClient.list(java.lang.String filter,
java.lang.String modifier,
DataSink sink)
Performs directory listing and writes the result
to the supplied data sink.
|
void |
FTPClient.makeDir(java.lang.String dir)
Creates remote directory.
|
java.util.Vector |
FTPClient.mlsd()
Performs remote directory listing of the current directory.
|
java.util.Vector |
GridFTPClient.mlsd(java.lang.String filter)
Performs remote directory listing like
FTPClient.mlsd() . |
java.util.Vector |
FTPClient.mlsd(java.lang.String path)
Performs remote directory listing on the given path.
|
void |
FTPClient.mlsd(java.lang.String path,
DataSink sink)
Performs remote directory listing on the given path.
|
void |
GridFTPClient.mlsr(java.lang.String path,
MlsxEntryWriter writer)
Performs a recursive directory listing starting at the given path
(or, if path is null, at the current directory of the FTP server).
|
MlsxEntry |
FTPClient.mlst(java.lang.String fileName)
Get info of a certain remote file in Mlsx format.
|
java.util.Vector |
FTPClient.nlist()
Performs remote directory listing of the current directory.
|
java.util.Vector |
GridFTPClient.nlist(java.lang.String path)
Performs remote directory listing like
FTPClient.nlist() . |
java.util.Vector |
FTPClient.nlist(java.lang.String path)
Performs remote directory listing on the given path.
|
void |
FTPClient.nlist(java.lang.String path,
DataSink sink)
Performs remote directory listing on the given path.
|
protected void |
FTPClient.performTransfer(Command cmd,
DataSink sink) |
void |
GridFTPClient.put(java.io.File localFile,
java.lang.String remoteFileName,
boolean append) |
void |
FTPClient.put(java.io.File localFile,
java.lang.String remoteFileName,
boolean append) |
void |
FTPClient.put(java.lang.String remoteFileName,
DataSource source,
MarkerListener mListener)
Stores file at the remote server.
|
void |
FTPClient.put(java.lang.String remoteFileName,
DataSource source,
MarkerListener mListener,
boolean append)
Stores file at the remote server.
|
void |
FTPClient.put2(java.lang.String remoteFileName,
boolean passive,
DataSource source,
MarkerListener mListener)
Stores a file at the remote server using the GFD.47 (a.k.a
GridFTP2) PUT command.
|
Reply |
FTPClient.quote(java.lang.String command)
Executes arbitrary operation on the server.
|
void |
FTPClient.rename(java.lang.String oldName,
java.lang.String newName)
Renames remote directory.
|
void |
FTPClient.setActive()
Sets remote server active, telling it to connect to the client.
|
void |
FTPClient.setActive(HostPort hostPort)
Sets remote server active, telling it to connect to the given
address.
|
void |
GridFTPClient.setChecksum(ChecksumAlgorithm algorithm,
java.lang.String value)
Sets the checksum values ahead of the transfer
|
void |
FTPClient.setChecksum(java.lang.String algorithm,
java.lang.String value)
implement GridFTP v2 SCKS command as described in
GridFTP v2 Protocol Description
|
void |
GridFTPClient.setDataChannelAuthentication(DataChannelAuthentication type)
Sets data channel authentication mode (DCAU)
|
void |
GridFTPClient.setDataChannelProtection(int protection)
Sets data channel protection level (PROT).
|
void |
FTPClient.setMode(int mode)
Sets transfer mode.
|
void |
FTPClient.setOptions(Options opts)
Sets the supplied options to the server.
|
HostPort |
FTPClient.setPassive()
Sets remote server to passive server mode.
|
void |
FTPClient.setPassiveMode(boolean passiveMode)
Enables/disables passive data connections.
|
void |
FTPClient.setProtectionBufferSize(int size)
Sets protection buffer size (defined in RFC 2228)
|
void |
FTPClient.setRestartMarker(RestartData restartData)
Sets restart parameter of the next transfer.
|
void |
GridFTPClient.setStripedActive(HostPortList hpl)
Sets remote server to striped active server mode (SPOR).
|
HostPortList |
GridFTPClient.setStripedPassive()
Sets remote server to striped passive server mode (SPAS).
|
void |
GridFTPClient.setTCPBufferSize(int size)
Sets remote server TCP buffer size, in the following way:
First see if server supports "SBUF" and if so, use it.
|
void |
FTPClient.setType(int type)
Sets transfer type.
|
Reply |
FTPClient.site(java.lang.String args)
Executes site-specific operation (using the SITE command).
|
long |
FTPClient.size(java.lang.String filename) |
static void |
FTPClient.transfer(FTPClient source,
java.lang.String remoteSrcFile,
FTPClient destination,
java.lang.String remoteDstFile,
int mode,
MarkerListener mListener)
Performs third-party transfer between two servers.
|
void |
FTPClient.transfer(java.lang.String remoteSrcFile,
FTPClient destination,
java.lang.String remoteDstFile,
boolean append,
MarkerListener mListener)
Performs third-party transfer between two servers.
|
protected void |
FTPClient.transferRun(BasicClientControlChannel other,
MarkerListener mListener)
Actual transfer management.
|
protected void |
FTPClient.transferRunSingleThread(BasicClientControlChannel other,
MarkerListener mListener) |
protected TransferState |
FTPClient.transferStart(BasicClientControlChannel other,
MarkerListener mListener) |
protected void |
FTPClient.transferWait(TransferState transferState) |
Constructor and Description |
---|
FTPClient(java.lang.String host,
int port)
Constructs client and connects it to the remote server.
|
GridFTPClient(java.lang.String host,
int port)
Constructs client and connects it to the remote server.
|
Constructor and Description |
---|
Transfer(java.lang.String sourceServer,
int sourcePort,
org.globus.gsi.gssapi.auth.Authorization sourceSubject,
java.lang.String absoluteSourceFile,
java.lang.String destServer,
int destPort,
org.globus.gsi.gssapi.auth.Authorization destSubject,
java.lang.String absoluteDestFile,
TransferParams params)
Constructor, performing a single third party transfer from
(grid)ftp://sourceServer:sourcePort/absoluteSourceFile
to (grid)ftp://destServer:destPort/absoluteDestFile.
|
Transfer(java.lang.String sourceServer,
int sourcePort,
java.lang.String sourceDir,
java.lang.String sourceFile,
java.lang.String destServer,
int destPort,
java.lang.String destDir,
java.lang.String destFile,
TransferParams params)
Constructor, performing a single third party transfer from
(grid)ftp://sourceServer:sourcePort/sourceDir/sourceFile
to (grid)ftp://destServer:destPort/destDir/destFile.
|
Transfer(java.lang.String sourceServer,
int sourcePort,
java.lang.String sourceSubject,
java.lang.String sourceDir,
java.lang.String sourceFile,
java.lang.String destServer,
int destPort,
java.lang.String destSubject,
java.lang.String destDir,
java.lang.String destFile,
TransferParams params)
Constructor, performing a single third party transfer from
(grid)ftp://sourceServer:sourcePort/sourceDir/sourceFile
to (grid)ftp://destServer:destPort/destDir/destFile.
|
Modifier and Type | Method and Description |
---|---|
void |
TransferThreadManager.passiveConnect(DataSink sink,
TransferContext context,
int connections,
java.net.ServerSocket serverSocket)
Accept connections from the remote server,
and start transfer threads that will read incoming data and store
in the sink.
|
void |
TransferThreadManager.passiveConnect(DataSource source,
TransferContext context,
java.net.ServerSocket serverSocket)
Accept connection from the remote server
and start transfer thread that will read incoming data and store in
the sink.
|
void |
TransferThreadManager.startTransfer(DataSink sink,
TransferContext context,
int connections,
boolean reusable)
This should be used once the remote active server connected to us.
|
void |
TransferThreadManager.startTransfer(DataSource source,
TransferContext context,
int connections,
boolean reusable)
This should be used once the remote active server connected to us.
|
Modifier and Type | Method and Description |
---|---|
static ServerException |
ServerException.embedFTPReplyParseException(FTPReplyParseException rpe) |
static ServerException |
ServerException.embedFTPReplyParseException(FTPReplyParseException rpe,
java.lang.String message)
Constructs server exception with FTPReplyParseException
nested in it.
|
static ServerException |
ServerException.embedUnexpectedReplyCodeException(UnexpectedReplyCodeException urce) |
static ServerException |
ServerException.embedUnexpectedReplyCodeException(UnexpectedReplyCodeException urce,
java.lang.String message)
Constructs server exception with UnexpectedReplyCodeException
nested in it.
|
Modifier and Type | Method and Description |
---|---|
void |
GridFTPControlChannel.authenticate(org.ietf.jgss.GSSCredential credential)
Performs authentication with specified user credentials.
|
void |
GridFTPControlChannel.authenticate(org.ietf.jgss.GSSCredential credential,
java.lang.String username)
Performs authentication with specified user credentials and
a specific username (assuming the user dn maps to the passed username).
|
Modifier and Type | Method and Description |
---|---|
void |
TransferState.checkError() |
Reply |
FTPControlChannel.exchange(Command cmd)
Write the command to the control channel,
block until reply arrives and return the reply.
|
Reply |
FTPControlChannel.execute(Command cmd)
Write the command to the control channel,
block until reply arrives and check if the command
completed successfully (reply code 200).
|
void |
FTPControlChannel.open()
opens the connection and returns after it is ready for communication.
|
Reply |
FTPServerFacade.LocalControlChannel.read() |
Reply |
FTPControlChannel.read()
Block until a reply is available in the control channel.
|
abstract Reply |
BasicClientControlChannel.read() |
protected void |
FTPControlChannel.readInitialReplies() |
void |
BasicClientControlChannel.waitFor(Flag flag,
int waitDelay)
Return when reply is waiting
|
void |
FTPServerFacade.LocalControlChannel.waitFor(Flag aborted,
int ioDelay,
int maxWait) |
void |
FTPControlChannel.waitFor(Flag aborted,
int ioDelay,
int maxWait)
Block until one of the conditions are true:
a reply is available in the control channel,
timeout (maxWait) expired
aborted flag changes to true.
|
abstract void |
BasicClientControlChannel.waitFor(Flag flag,
int waitDelay,
int maxWait)
Block until reply is waiting in the control channel,
or after timeout (maxWait), or when flag changes to true.
|
void |
TransferState.waitForEnd()
Blocks until the transfer is complete or
the transfer fails.
|
void |
TransferState.waitForStart()
Blocks until the transfer begins or
the transfer fails to start.
|