org.apache.sshd.client.subsystem.sftp.fs

Class SftpFileSystem.Wrapper

java.lang.Object

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

org.apache.sshd.client.subsystem.AbstractSubsystemClient

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

org.apache.sshd.client.subsystem.sftp.fs.SftpFileSystem.Wrapper

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, ClientChannelHolder, ClientSessionHolder, RawSftpClient, SftpClient, SubsystemClient, ChannelHolder, NamedResource, SessionHolder<ClientSession>

Enclosing class:

SftpFileSystem

private final class SftpFileSystem.Wrapper
extends AbstractSftpClient

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.sshd.client.subsystem.sftp.SftpClient

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

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicInteger	count
private SftpClient	delegate
private int	readSize
private int	writeSize

Fields inherited from class org.apache.sshd.client.subsystem.sftp.impl.AbstractSftpClient

DEFAULT_WRITE_CHUNK_SIZE, WRITE_CHUNK_SIZE

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Fields inherited from interface org.apache.sshd.client.subsystem.sftp.SftpClient

DEFAULT_CHANNEL_MODES, DEFAULT_CHANNEL_OPEN_TIMEOUT, DEFAULT_NAME_DECODING_CHARSET, DEFAULT_READ_BUFFER_SIZE, DEFAULT_WAIT_TIMEOUT, DEFAULT_WRITE_BUFFER_SIZE, EMPTY_DIR_ENTRIES, IO_BUFFER_SIZE, MIN_BUFFER_SIZE, MIN_READ_BUFFER_SIZE, MIN_WRITE_BUFFER_SIZE, NAME_DECODING_CHARSET, SFTP_CHANNEL_OPEN_TIMEOUT

Fields inherited from interface org.apache.sshd.common.NamedResource

BY_NAME_COMPARATOR, NAME_EXTRACTOR

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Wrapper(SftpClient delegate, int readSize, int writeSize)

Method Summary

Modifier and Type	Method and Description
java.lang.String	canonicalPath(java.lang.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()
java.nio.charset.Charset	getNameDecodingCharset()
java.util.NavigableMap<java.lang.String,byte[]>	getServerExtensions()
int	getVersion()
void	increment()
boolean	isClosing()
boolean	isOpen()
void	link(java.lang.String linkPath, java.lang.String targetPath, boolean symbolic) Create a link
java.lang.Iterable<SftpClient.DirEntry>	listDir(SftpClient.Handle handle)
void	lock(SftpClient.Handle handle, long offset, long length, int mask)
SftpClient.Attributes	lstat(java.lang.String path) Retrieve remote path meta-data - do not follow symbolic links
void	mkdir(java.lang.String path) Create remote directory
SftpClient.CloseableHandle	open(java.lang.String path, java.util.Collection<SftpClient.OpenMode> options) Opens a remote file with the specified mode(s)
SftpClient.CloseableHandle	openDir(java.lang.String path) Obtain a handle for a directory
int	read(SftpClient.Handle handle, long fileOffset, byte[] dst, int dstOffset, int len)
java.io.InputStream	read(java.lang.String path)
java.io.InputStream	read(java.lang.String path, java.util.Collection<SftpClient.OpenMode> mode)
java.io.InputStream	read(java.lang.String path, int bufferSize, java.util.Collection<SftpClient.OpenMode> mode) Read a remote file's data via an input stream
java.io.InputStream	read(java.lang.String path, SftpClient.OpenMode... mode)
java.util.List<SftpClient.DirEntry>	readDir(SftpClient.Handle handle)
java.lang.Iterable<SftpClient.DirEntry>	readDir(java.lang.String path)
java.lang.String	readLink(java.lang.String path) Retrieve target of a link
Buffer	receive(int id)
void	remove(java.lang.String path)
void	rename(java.lang.String oldPath, java.lang.String newPath, java.util.Collection<SftpClient.CopyMode> options)
void	rmdir(java.lang.String path) Remove remote directory
int	send(int cmd, Buffer buffer)
void	setNameDecodingCharset(java.nio.charset.Charset cs)
void	setStat(SftpClient.Handle handle, SftpClient.Attributes attributes) Update remote node meta-data
void	setStat(java.lang.String path, SftpClient.Attributes attributes) Update remote node meta-data
SftpClient.Attributes	stat(SftpClient.Handle handle) Retrieve file/directory handle meta-data
SftpClient.Attributes	stat(java.lang.String path) Retrieve remote path meta-data - follow symbolic links if encountered
void	symLink(java.lang.String linkPath, java.lang.String targetPath) Create symbolic link
void	unlock(SftpClient.Handle handle, long offset, long length)
void	write(SftpClient.Handle handle, long fileOffset, byte[] src, int srcOffset, int len) Write data to (open) file handle
java.io.OutputStream	write(java.lang.String path)
java.io.OutputStream	write(java.lang.String path, java.util.Collection<SftpClient.OpenMode> mode)
java.io.OutputStream	write(java.lang.String path, int bufferSize, java.util.Collection<SftpClient.OpenMode> mode) Write to a remote file via an output stream
java.io.OutputStream	write(java.lang.String path, SftpClient.OpenMode... mode)

Methods inherited from class org.apache.sshd.client.subsystem.sftp.impl.AbstractSftpClient

checkAttributes, checkAttributesResponse, checkCommandStatus, checkData, checkDataResponse, checkDirResponse, checkHandle, checkHandleResponse, checkOneName, checkOneNameResponse, checkResponseStatus, checkResponseStatus, getChannel, getExtension, getExtension, getExtension, getParsedServerExtensions, getParsedServerExtensions, getReferencedName, handleUnexpectedAttributesPacket, handleUnexpectedHandlePacket, handleUnexpectedPacket, handleUnknownDataPacket, handleUnknownDirListingPacket, handleUnknownOneNamePacket, putReferencedName, read, readAttributes, readDir, throwStatusException, validateIncomingResponse, writeAttributes

Methods inherited from class org.apache.sshd.client.subsystem.AbstractSubsystemClient

getSession, toString

Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

getSimplifiedLogger

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sshd.client.subsystem.sftp.SftpClient

getName, open, open, openRemoteFileChannel, openRemoteFileChannel, openRemotePathChannel, openRemotePathChannel, read, read, read, read, rename, rename, write, write, write

Methods inherited from interface org.apache.sshd.common.session.SessionHolder

getSession

Methods inherited from interface org.apache.sshd.common.NamedResource

findByName, getNameList, getNames, ofName, removeByName

Field Detail

delegate

private final SftpClient delegate

count

private final java.util.concurrent.atomic.AtomicInteger count

readSize

private final int readSize

writeSize

private final int writeSize

Constructor Detail

Wrapper

private Wrapper(SftpClient delegate,
                int readSize,
                int writeSize)

Method Detail

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 java.util.NavigableMap<java.lang.String,byte[]> getServerExtensions()

Returns:

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

getNameDecodingCharset

public java.nio.charset.Charset getNameDecodingCharset()

Returns:

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

See Also:

SftpClient.NAME_DECODING_CHARSET

setNameDecodingCharset

public void setNameDecodingCharset(java.nio.charset.Charset cs)

isClosing

public boolean isClosing()

isOpen

public boolean isOpen()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

increment

public void increment()

open

public SftpClient.CloseableHandle open(java.lang.String path,
                                       java.util.Collection<SftpClient.OpenMode> options)
                                throws java.io.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:

java.io.IOException - If failed to open the remote file

close

public void close(SftpClient.Handle handle)
           throws java.io.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:

java.io.IOException - If failed to execute

remove

public void remove(java.lang.String path)
            throws java.io.IOException

Specified by:

remove in interface SftpClient

Overrides:

remove in class AbstractSftpClient

Parameters:

path - The remote path to remove

Throws:

java.io.IOException - If failed to execute

rename

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

Specified by:

rename in interface SftpClient

Overrides:

rename in class AbstractSftpClient

Throws:

java.io.IOException

read

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

Throws:

java.io.IOException

write

public void write(SftpClient.Handle handle,
                  long fileOffset,
                  byte[] src,
                  int srcOffset,
                  int len)
           throws java.io.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:

java.io.IOException - If failed to write the data

mkdir

public void mkdir(java.lang.String path)
           throws java.io.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:

java.io.IOException - If failed to execute

rmdir

public void rmdir(java.lang.String path)
           throws java.io.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:

java.io.IOException - If failed to execute

openDir

public SftpClient.CloseableHandle openDir(java.lang.String path)
                                   throws java.io.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:

java.io.IOException - If failed to execute

readDir

public java.util.List<SftpClient.DirEntry> readDir(SftpClient.Handle handle)
                                            throws java.io.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:

java.io.IOException - If failed to access the remote site

listDir

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

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:

java.io.IOException - If failed to access the directory

canonicalPath

public java.lang.String canonicalPath(java.lang.String path)
                               throws java.io.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:

java.io.IOException - If failed to execute

stat

public SftpClient.Attributes stat(java.lang.String path)
                           throws java.io.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:

java.io.IOException - If failed to execute

lstat

public SftpClient.Attributes lstat(java.lang.String path)
                            throws java.io.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:

java.io.IOException - If failed to execute

stat

public SftpClient.Attributes stat(SftpClient.Handle handle)
                           throws java.io.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:

java.io.IOException - If failed to execute

setStat

public void setStat(java.lang.String path,
                    SftpClient.Attributes attributes)
             throws java.io.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:

java.io.IOException - If failed to execute

setStat

public void setStat(SftpClient.Handle handle,
                    SftpClient.Attributes attributes)
             throws java.io.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:

java.io.IOException - If failed to execute

readLink

public java.lang.String readLink(java.lang.String path)
                          throws java.io.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:

java.io.IOException - If failed to execute

symLink

public void symLink(java.lang.String linkPath,
                    java.lang.String targetPath)
             throws java.io.IOException

Description copied from interface: SftpClient

Create symbolic link

Parameters:

linkPath - The link location

targetPath - The referenced target by the link

Throws:

java.io.IOException - If failed to execute

See Also:

SftpClient.link(String, String, boolean)

readDir

public java.lang.Iterable<SftpClient.DirEntry> readDir(java.lang.String path)
                                                throws java.io.IOException

Parameters:

path - The remote directory path

Returns:

An Iterable that can be used to iterate over all the directory entries (unlike SftpClient.readDir(Handle))

Throws:

java.io.IOException - If failed to access the remote site

See Also:

SftpClient.readDir(Handle)

read

public java.io.InputStream read(java.lang.String path)
                         throws java.io.IOException

Throws:

java.io.IOException

read

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

Throws:

java.io.IOException

read

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

Throws:

java.io.IOException

read

public java.io.InputStream read(java.lang.String path,
                                int bufferSize,
                                java.util.Collection<SftpClient.OpenMode> mode)
                         throws java.io.IOException

Description copied from interface: SftpClient

Read a remote file's data via an input stream

Parameters:

path - The remote file path

bufferSize - The internal read buffer size

mode - The remote file SftpClient.OpenModes

Returns:

An InputStream for reading the remote file data

Throws:

java.io.IOException - If failed to execute

write

public java.io.OutputStream write(java.lang.String path)
                           throws java.io.IOException

Throws:

java.io.IOException

write

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

Throws:

java.io.IOException

write

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

Throws:

java.io.IOException

write

public java.io.OutputStream write(java.lang.String path,
                                  int bufferSize,
                                  java.util.Collection<SftpClient.OpenMode> mode)
                           throws java.io.IOException

Description copied from interface: SftpClient

Write to a remote file via an output stream

Parameters:

path - The remote file path

bufferSize - The internal write buffer size

mode - The remote file SftpClient.OpenModes

Returns:

An OutputStream for writing the data

Throws:

java.io.IOException - If failed to execute

link

public void link(java.lang.String linkPath,
                 java.lang.String targetPath,
                 boolean symbolic)
          throws java.io.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:

java.io.IOException - If failed to execute

lock

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

Specified by:

lock in interface SftpClient

Overrides:

lock in class AbstractSftpClient

Throws:

java.io.IOException

unlock

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

Specified by:

unlock in interface SftpClient

Overrides:

unlock in class AbstractSftpClient

Throws:

java.io.IOException

send

public int send(int cmd,
                Buffer buffer)
         throws java.io.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:

java.io.IOException - if failed to send command

receive

public Buffer receive(int id)
               throws java.io.IOException

Parameters:

id - The expected request id

Returns:

The received response Buffer containing the request id

Throws:

java.io.IOException - If connection closed or interrupted