Class SftpFileSystem.DelegatingClient

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.client.subsystem.AbstractSubsystemClient

org.apache.sshd.sftp.client.impl.AbstractSftpClient

org.apache.sshd.sftp.client.fs.SftpFileSystem.DelegatingClient

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ClientChannelHolder, ClientSessionHolder, SubsystemClient, ChannelHolder, NamedResource, SessionContextHolder, SessionHolder<ClientSession>, FullAccessSftpClient, RawSftpClient, SftpClient, SftpErrorDataHandler

Direct Known Subclasses:

SftpFileSystem.SftpClientEnriched, SftpFileSystem.Wrapper

Enclosing class:

SftpFileSystem

private class SftpFileSystem.DelegatingClient
extends AbstractSftpClient

Nested Class Summary

Nested classes/interfaces inherited from interface SftpClient

SftpClient.Attribute, SftpClient.Attributes, SftpClient.CloseableHandle, SftpClient.CopyMode, SftpClient.DirEntry, SftpClient.Handle, SftpClient.OpenMode

Field Summary

Fields

Modifier and Type	Field	Description
protected final SftpClient	delegate
private final int	readSize
private final int	writeSize

Fields inherited from class AbstractSftpClient

errorDataHandler, INIT_COMMAND_SIZE, SFTP_CLIENT_CMD_TIMEOUT

Fields inherited from class AbstractLoggingBean

log

Fields inherited from interface NamedResource

BY_NAME_COMPARATOR, NAME_EXTRACTOR

Fields inherited from interface SftpClient

DEFAULT_CHANNEL_MODES, EMPTY_DIR_ENTRIES, IO_BUFFER_SIZE, MIN_BUFFER_SIZE, MIN_READ_BUFFER_SIZE, MIN_WRITE_BUFFER_SIZE

Fields inherited from interface SftpErrorDataHandler

EMPTY

Constructor Summary

Constructors

Constructor	Description
DelegatingClient(SftpClient delegate, SftpErrorDataHandler errorHandler, int readSize, int writeSize)

Method Summary

Modifier and Type	Method	Description
String	canonicalPath(String path)	The effective "normalized" remote path
void	close()
void	close(SftpClient.Handle handle)	Close the handle obtained from one of the open methods
ClientChannel	getClientChannel()
ClientSession	getClientSession()
Charset	getNameDecodingCharset()
NavigableMap<String,byte[]>	getServerExtensions()
int	getVersion()
boolean	isClosing()
boolean	isOpen()
void	link(String linkPath, String targetPath, boolean symbolic)	Create a link
Iterable<SftpClient.DirEntry>	listDir(SftpClient.Handle handle)
void	lock(SftpClient.Handle handle, long offset, long length, int mask)
SftpClient.Attributes	lstat(String path)	Retrieve remote path meta-data - do not follow symbolic links
void	mkdir(String path)	Create remote directory
SftpClient.CloseableHandle	open(String path, Collection<SftpClient.OpenMode> options)	Opens a remote file with the specified mode(s)
SftpClient.CloseableHandle	openDir(String path)	Obtain a handle for a directory
void	put(InputStream stream, String path)
void	put(InputStream stream, String path, Collection<SftpClient.OpenMode> modes)
void	put(InputStream stream, String path, SftpClient.OpenMode... modes)
void	put(Path localFile, String path)
void	put(Path localFile, String path, Collection<SftpClient.OpenMode> modes)
void	put(Path localFile, String path, SftpClient.OpenMode... modes)
InputStream	read(String path)
InputStream	read(String path, Collection<SftpClient.OpenMode> mode)
InputStream	read(String path, SftpClient.OpenMode... mode)
int	read(SftpClient.Handle handle, long fileOffset, byte[] dst, int dstOffset, int len)
List<SftpClient.DirEntry>	readDir(SftpClient.Handle handle)
List<SftpClient.DirEntry>	readDir(SftpClient.Handle handle, AtomicReference<Boolean> eolIndicator)
String	readLink(String path)	Retrieve target of a link
Buffer	receive(int id)
Buffer	receive(int id, long timeout)
Buffer	receive(int id, Duration timeout)
void	remove(String path)
void	rename(String oldPath, String newPath, Collection<SftpClient.CopyMode> options)
void	rmdir(String path)	Remove remote directory
int	send(int cmd, Buffer buffer)
void	setNameDecodingCharset(Charset cs)
void	setStat(String path, SftpClient.Attributes attributes)	Update remote node meta-data
void	setStat(SftpClient.Handle handle, SftpClient.Attributes attributes)	Update remote node meta-data
SftpClient.Attributes	stat(String path)	Retrieve remote path meta-data - follow symbolic links if encountered
SftpClient.Attributes	stat(SftpClient.Handle handle)	Retrieve file/directory handle meta-data
void	symLink(String linkPath, String targetPath)	Create symbolic link
void	unlock(SftpClient.Handle handle, long offset, long length)
SftpMessage	write(int cmd, Buffer buffer)
OutputStream	write(String path)
OutputStream	write(String path, Collection<SftpClient.OpenMode> mode)
OutputStream	write(String path, SftpClient.OpenMode... mode)
void	write(SftpClient.Handle handle, long fileOffset, byte[] src, int srcOffset, int len)	Write data to (open) file handle

Methods inherited from class AbstractSftpClient

checkAttributes, checkAttributesResponse, checkCommandStatus, checkDataResponse, checkDirResponse, checkHandle, checkHandleResponse, checkOneName, checkOneNameResponse, checkResponseStatus, checkResponseStatus, errorData, getChannel, getExtension, getExtension, getParsedServerExtensions, getParsedServerExtensions, getReadBufferSize, getReferencedName, getWriteBufferSize, handleUnexpectedAttributesPacket, handleUnexpectedHandlePacket, handleUnexpectedPacket, handleUnknownDataPacket, handleUnknownDirListingPacket, handleUnknownOneNamePacket, openRemoteFileChannel, put, putReferencedName, read, read, readAttributes, readDir, response, rpc, throwStatusException, write, writeAttributes

Methods inherited from class AbstractSubsystemClient

toString

Methods inherited from class AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class Object

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

Methods inherited from interface SessionHolder

getSessionContext

Methods inherited from interface SftpClient

getExtension, getName, open, open, openRemoteFileChannel, openRemotePathChannel, openRemotePathChannel, put, put, put, put, put, read, read, read, read, readEntries, rename, rename, singleSessionInstance, write, write, write

Methods inherited from interface SubsystemClient

getSession

Field Details

delegate

protected final SftpClient delegate

readSize

private final int readSize

writeSize

private final int writeSize

Constructor Details

DelegatingClient

DelegatingClient(SftpClient delegate,
 SftpErrorDataHandler errorHandler,
 int readSize,
 int writeSize)

Method Details

getVersion

public int getVersion()

Returns:

The negotiated SFTP protocol version

getClientSession

public ClientSession getClientSession()

Returns:

The underlying ClientSession used

getClientChannel

public ClientChannel getClientChannel()

Returns:

The underlying ClientChannel used

getServerExtensions

public NavigableMap<String,byte[]> getServerExtensions()

Returns:

An (unmodifiable) NavigableMap of the reported server extensions. where key=extension name (case insensitive)

getNameDecodingCharset

public Charset getNameDecodingCharset()

Returns:

The (never null) Charset used to decode referenced files/folders names

See Also:

• SftpModuleProperties.NAME_DECODING_CHARSET

setNameDecodingCharset

public void setNameDecodingCharset(Charset cs)

isClosing

public boolean isClosing()

isOpen

public boolean isOpen()

close

public void close()
           throws IOException

Throws:

IOException

open

public SftpClient.CloseableHandle open(String path,
 Collection<SftpClient.OpenMode> options)
                                throws IOException

Description copied from interface: SftpClient

Opens a remote file with the specified mode(s)

Specified by:

open in interface SftpClient

Overrides:

open in class AbstractSftpClient

Parameters:

path - The remote path

options - The desired mode - if none specified then SftpClient.OpenMode.Read is assumed

Returns:

The file's SftpClient.CloseableHandle

Throws:

IOException - If failed to open the remote file

close

public void close(SftpClient.Handle handle)
           throws IOException

Description copied from interface: SftpClient

Close the handle obtained from one of the open methods

Specified by:

close in interface SftpClient

Overrides:

close in class AbstractSftpClient

Parameters:

handle - The Handle to close

Throws:

IOException - If failed to execute

remove

public void remove(String path)
            throws IOException

Specified by:

remove in interface SftpClient

Overrides:

remove in class AbstractSftpClient

Parameters:

path - The remote path to remove

Throws:

IOException - If failed to execute

rename

public void rename(String oldPath,
 String newPath,
 Collection<SftpClient.CopyMode> options)
            throws IOException

Specified by:

rename in interface SftpClient

Overrides:

rename in class AbstractSftpClient

Throws:

IOException

read

public int read(SftpClient.Handle handle,
 long fileOffset,
 byte[] dst,
 int dstOffset,
 int len)
         throws IOException

Throws:

IOException

write

public void write(SftpClient.Handle handle,
 long fileOffset,
 byte[] src,
 int srcOffset,
 int len)
           throws IOException

Description copied from interface: SftpClient

Write data to (open) file handle

Specified by:

write in interface SftpClient

Overrides:

write in class AbstractSftpClient

Parameters:

handle - The file SftpClient.Handle

fileOffset - Zero-based offset to write in file

src - Data buffer

srcOffset - Offset of valid data in buffer

len - Number of bytes to write

Throws:

IOException - If failed to write the data

mkdir

public void mkdir(String path)
           throws IOException

Description copied from interface: SftpClient

Create remote directory

Specified by:

mkdir in interface SftpClient

Overrides:

mkdir in class AbstractSftpClient

Parameters:

path - Remote directory path

Throws:

IOException - If failed to execute

rmdir

public void rmdir(String path)
           throws IOException

Description copied from interface: SftpClient

Remove remote directory

Specified by:

rmdir in interface SftpClient

Overrides:

rmdir in class AbstractSftpClient

Parameters:

path - Remote directory path

Throws:

IOException - If failed to execute

openDir

public SftpClient.CloseableHandle openDir(String path)
                                   throws IOException

Description copied from interface: SftpClient

Obtain a handle for a directory

Specified by:

openDir in interface SftpClient

Overrides:

openDir in class AbstractSftpClient

Parameters:

path - Remote directory path

Returns:

The associated directory SftpClient.Handle

Throws:

IOException - If failed to execute

readDir

public List<SftpClient.DirEntry> readDir(SftpClient.Handle handle)
                                  throws IOException

Parameters:

handle - Directory SftpClient.Handle to read from

Returns:

A List of entries - null to indicate no more entries Note: the list may be incomplete since the client and server have some internal imposed limit on the number of entries they can process. Therefore several calls to this method may be required (until null). In order to iterate over all the entries use SftpClient.readDir(String)

Throws:

IOException - If failed to access the remote site

listDir

public Iterable<SftpClient.DirEntry> listDir(SftpClient.Handle handle)
                                      throws IOException

Specified by:

listDir in interface SftpClient

Overrides:

listDir in class AbstractSftpClient

Parameters:

handle - A directory SftpClient.Handle

Returns:

An Iterable that can be used to iterate over all the directory entries (like SftpClient.readDir(String)). Note: the iterable instance is not re-usable - i.e., files can be iterated only once

Throws:

IOException - If failed to access the directory

canonicalPath

public String canonicalPath(String path)
                     throws IOException

Description copied from interface: SftpClient

The effective "normalized" remote path

Specified by:

canonicalPath in interface SftpClient

Overrides:

canonicalPath in class AbstractSftpClient

Parameters:

path - The requested path - may be relative, and/or contain dots - e.g., ".", "..", "./foo", "../bar"

Returns:

The effective "normalized" remote path

Throws:

IOException - If failed to execute

stat

public SftpClient.Attributes stat(String path)
                           throws IOException

Description copied from interface: SftpClient

Retrieve remote path meta-data - follow symbolic links if encountered

Specified by:

stat in interface SftpClient

Overrides:

stat in class AbstractSftpClient

Parameters:

path - The remote path

Returns:

The associated SftpClient.Attributes

Throws:

IOException - If failed to execute

lstat

public SftpClient.Attributes lstat(String path)
                            throws IOException

Description copied from interface: SftpClient

Retrieve remote path meta-data - do not follow symbolic links

Specified by:

lstat in interface SftpClient

Overrides:

lstat in class AbstractSftpClient

Parameters:

path - The remote path

Returns:

The associated SftpClient.Attributes

Throws:

IOException - If failed to execute

stat

public SftpClient.Attributes stat(SftpClient.Handle handle)
                           throws IOException

Description copied from interface: SftpClient

Retrieve file/directory handle meta-data

Specified by:

stat in interface SftpClient

Overrides:

stat in class AbstractSftpClient

Parameters:

handle - The SftpClient.Handle obtained via one of the open calls

Returns:

The associated SftpClient.Attributes

Throws:

IOException - If failed to execute

setStat

public void setStat(String path,
 SftpClient.Attributes attributes)
             throws IOException

Description copied from interface: SftpClient

Update remote node meta-data

Specified by:

setStat in interface SftpClient

Overrides:

setStat in class AbstractSftpClient

Parameters:

path - The remote path

attributes - The SftpClient.Attributes to update

Throws:

IOException - If failed to execute

setStat

public void setStat(SftpClient.Handle handle,
 SftpClient.Attributes attributes)
             throws IOException

Description copied from interface: SftpClient

Update remote node meta-data

Specified by:

setStat in interface SftpClient

Overrides:

setStat in class AbstractSftpClient

Parameters:

handle - The SftpClient.Handle obtained via one of the open calls

attributes - The SftpClient.Attributes to update

Throws:

IOException - If failed to execute

readLink

public String readLink(String path)
                throws IOException

Description copied from interface: SftpClient

Retrieve target of a link

Specified by:

readLink in interface SftpClient

Overrides:

readLink in class AbstractSftpClient

Parameters:

path - Remote path that represents a link

Returns:

The link target

Throws:

IOException - If failed to execute

symLink

public void symLink(String linkPath,
 String targetPath)
             throws IOException

Description copied from interface: SftpClient

Create symbolic link

Parameters:

linkPath - The link location

targetPath - The referenced target by the link

Throws:

IOException - If failed to execute

See Also:

• SftpClient.link(String, String, boolean)

readDir

public List<SftpClient.DirEntry> readDir(SftpClient.Handle handle,
 AtomicReference<Boolean> eolIndicator)
                                  throws IOException

Specified by:

readDir in interface SftpClient

Overrides:

readDir in class AbstractSftpClient

Parameters:

handle - Directory SftpClient.Handle to read from

eolIndicator - An indicator that can be used to get information whether end of list has been reached - ignored if null. Upon return, set value indicates whether all entries have been exhausted - a null value means that this information cannot be provided and another call to readDir is necessary in order to verify that no more entries are pending

Returns:

A List of entries - null to indicate no more entries

Throws:

IOException - If failed to access the remote site

See Also:

• SFTP v6 - section 9.4

read

public InputStream read(String path)
                 throws IOException

Throws:

IOException

read

public InputStream read(String path,
 SftpClient.OpenMode... mode)
                 throws IOException

Throws:

IOException

read

public InputStream read(String path,
 Collection<SftpClient.OpenMode> mode)
                 throws IOException

Throws:

IOException

write

public OutputStream write(String path)
                   throws IOException

Throws:

IOException

write

public OutputStream write(String path,
 SftpClient.OpenMode... mode)
                   throws IOException

Throws:

IOException

write

public OutputStream write(String path,
 Collection<SftpClient.OpenMode> mode)
                   throws IOException

Throws:

IOException

put

public void put(Path localFile,
 String path)
         throws IOException

Throws:

IOException

put

public void put(InputStream stream,
 String path)
         throws IOException

Throws:

IOException

put

public void put(Path localFile,
 String path,
 SftpClient.OpenMode... modes)
         throws IOException

Throws:

IOException

put

public void put(InputStream stream,
 String path,
 SftpClient.OpenMode... modes)
         throws IOException

Throws:

IOException

put

public void put(Path localFile,
 String path,
 Collection<SftpClient.OpenMode> modes)
         throws IOException

Throws:

IOException

put

public void put(InputStream stream,
 String path,
 Collection<SftpClient.OpenMode> modes)
         throws IOException

Throws:

IOException

link

public void link(String linkPath,
 String targetPath,
 boolean symbolic)
          throws IOException

Description copied from interface: SftpClient

Create a link

Specified by:

link in interface SftpClient

Overrides:

link in class AbstractSftpClient

Parameters:

linkPath - The link location

targetPath - The referenced target by the link

symbolic - If true then make this a symbolic link, otherwise a hard one

Throws:

IOException - If failed to execute

lock

public void lock(SftpClient.Handle handle,
 long offset,
 long length,
 int mask)
          throws IOException

Specified by:

lock in interface SftpClient

Overrides:

lock in class AbstractSftpClient

Throws:

IOException

unlock

public void unlock(SftpClient.Handle handle,
 long offset,
 long length)
            throws IOException

Specified by:

unlock in interface SftpClient

Overrides:

unlock in class AbstractSftpClient

Throws:

IOException

send

public int send(int cmd,
 Buffer buffer)
         throws IOException

Parameters:

cmd - Command to send - Note: only lower 8-bits are used

buffer - The Buffer containing the command data

Returns:

The assigned request id

Throws:

IOException - if failed to send command

write

public SftpMessage write(int cmd,
 Buffer buffer)
                  throws IOException

Throws:

IOException

receive

public Buffer receive(int id)
               throws IOException

Parameters:

id - The expected request id

Returns:

The received response Buffer containing the request id

Throws:

IOException - If connection closed or interrupted

receive

public Buffer receive(int id,
 long timeout)
               throws IOException

Parameters:

id - The expected request id

timeout - The amount of time to wait for the response

Returns:

The received response Buffer containing the request id

Throws:

IOException - If connection closed or interrupted

receive

public Buffer receive(int id,
 Duration timeout)
               throws IOException

Parameters:

id - The expected request id

timeout - The amount of time to wait for the response

Returns:

The received response Buffer containing the request id

Throws:

IOException - If connection closed or interrupted