Class AbstractSftpClient

java.lang.Object

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

org.apache.sshd.client.subsystem.AbstractSubsystemClient

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DefaultSftpClient

public abstract class AbstractSftpClient
extends AbstractSubsystemClient
implements FullAccessSftpClient, SftpErrorDataHandler

Author:

Apache MINA SSHD Project

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 SftpErrorDataHandler	errorDataHandler
static final int	INIT_COMMAND_SIZE
static final Property<Duration>	SFTP_CLIENT_CMD_TIMEOUT	Property that can be used on the FactoryManager to control the internal timeout used by the client to complete the buffer sending in RawSftpClient.send(int, Buffer).

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

Modifier	Constructor	Description
protected	AbstractSftpClient(SftpErrorDataHandler delegateHandler)

Method Summary

Modifier and Type	Method	Description
String	canonicalPath(String path)	The effective "normalized" remote path
protected SftpClient.Attributes	checkAttributes(int cmd, Buffer request)
protected SftpClient.Attributes	checkAttributesResponse(SftpResponse response)
protected void	checkCommandStatus(int cmd, Buffer request)	Sends the specified command, waits for the response and then invokes checkResponseStatus(SftpResponse)
protected Buffer	checkDataResponse(SftpAckData ack, SftpResponse response, AtomicReference<Boolean> eofSignalled)	Processes a response to an SSH_FXP_READ request.
protected List<SftpClient.DirEntry>	checkDirResponse(SftpResponse response, AtomicReference<Boolean> eolIndicator)
protected byte[]	checkHandle(int cmd, Buffer request)
protected byte[]	checkHandleResponse(SftpResponse response)
protected String	checkOneName(int cmd, Buffer request)
protected String	checkOneNameResponse(SftpResponse response)
protected void	checkResponseStatus(int cmd, int id, SftpStatus status)
protected void	checkResponseStatus(SftpResponse response)	Checks if the incoming response is an SSH_FXP_STATUS one, and if so whether the substatus is SSH_FX_OK.
void	close(SftpClient.Handle handle)	Close the handle obtained from one of the open methods
void	errorData(byte[] buf, int start, int len)	Receive binary data from server error stream
Channel	getChannel()
<E extends SftpClientExtension> E	getExtension(Class<? extends E> extensionType)
SftpClientExtension	getExtension(SftpClientExtensionFactory factory)
protected Map<String,Object>	getParsedServerExtensions()
protected Map<String,Object>	getParsedServerExtensions(Map<String,byte[]> extensions)
protected int	getReadBufferSize()
protected String	getReferencedName(int cmd, Buffer buf, int nameIndex)
protected int	getWriteBufferSize()
protected SftpClient.Attributes	handleUnexpectedAttributesPacket(SftpResponse response)
protected byte[]	handleUnexpectedHandlePacket(SftpResponse response)
protected IOException	handleUnexpectedPacket(int expected, SftpResponse response)
protected int	handleUnknownDataPacket(SftpResponse response)
protected List<SftpClient.DirEntry>	handleUnknownDirListingPacket(SftpResponse response)
protected String	handleUnknownOneNamePacket(SftpResponse response)
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
FileChannel	openRemoteFileChannel(String path, Collection<SftpClient.OpenMode> modes)	Opens an FileChannel on the specified remote path
void	put(InputStream stream, int bufferSize, String path, Collection<SftpClient.OpenMode> modes)	Write data from an InputStream to a remote file.
protected <B extends Buffer> B	putReferencedName(int cmd, B buf, String name, int nameIndex)
InputStream	read(String path, int bufferSize, Collection<SftpClient.OpenMode> mode)	Read a remote file's data via an input stream
int	read(SftpClient.Handle handle, long fileOffset, byte[] dst, int dstOffset, int len, AtomicReference<Boolean> eofSignalled)	Reads data from the open (file) handle
protected SftpClient.Attributes	readAttributes(int cmd, Buffer buffer, AtomicInteger nameIndex)
Iterable<SftpClient.DirEntry>	readDir(String path)
List<SftpClient.DirEntry>	readDir(SftpClient.Handle handle, AtomicReference<Boolean> eolIndicator)
String	readLink(String path)	Retrieve target of a link
void	remove(String path)
void	rename(String oldPath, String newPath, Collection<SftpClient.CopyMode> options)
protected SftpResponse	response(int cmd, int requestId)	Receives a response buffer, validates and returns it as a SftpResponse.
void	rmdir(String path)	Remove remote directory
protected SftpResponse	rpc(int cmd, Buffer request)	Perform an SFTP request and wait until the response has been received.
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
protected void	throwStatusException(int cmd, int id, SftpStatus status)
void	unlock(SftpClient.Handle handle, long offset, long length)
SftpOutputStreamAsync	write(String path, int bufferSize, Collection<SftpClient.OpenMode> mode)	Write to a remote file via an output stream
void	write(SftpClient.Handle handle, long fileOffset, byte[] src, int srcOffset, int len)	Write data to (open) file handle
protected <B extends Buffer> B	writeAttributes(int cmd, B buffer, SftpClient.Attributes attributes)

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 Channel

close, isOpen

Methods inherited from interface ClientChannelHolder

getClientChannel

Methods inherited from interface ClientSessionHolder

getClientSession

Methods inherited from interface RawSftpClient

receive, receive, receive, send, write

Methods inherited from interface SessionHolder

getSessionContext

Methods inherited from interface SftpClient

getExtension, getName, getNameDecodingCharset, getServerExtensions, getVersion, isClosing, open, open, openRemoteFileChannel, openRemotePathChannel, openRemotePathChannel, put, put, put, put, put, put, put, put, put, put, put, read, read, read, read, read, read, read, read, readDir, readEntries, rename, rename, setNameDecodingCharset, singleSessionInstance, symLink, write, write, write, write, write, write

Methods inherited from interface SubsystemClient

getSession

Field Details

INIT_COMMAND_SIZE

public static final int INIT_COMMAND_SIZE

See Also:

• Constant Field Values

SFTP_CLIENT_CMD_TIMEOUT

public static final Property<Duration> SFTP_CLIENT_CMD_TIMEOUT

Property that can be used on the FactoryManager to control the internal timeout used by the client to complete the buffer sending in RawSftpClient.send(int, Buffer).

errorDataHandler

protected final SftpErrorDataHandler errorDataHandler

Constructor Details

AbstractSftpClient

protected AbstractSftpClient(SftpErrorDataHandler delegateHandler)

Method Details

getChannel

public Channel getChannel()

Specified by:

getChannel in interface ChannelHolder

Specified by:

getChannel in interface ClientChannelHolder

Returns:

The associated Channel instance

getExtension

public <E extends SftpClientExtension> E getExtension(Class<? extends E> extensionType)

Specified by:

getExtension in interface SftpClient

Type Parameters:

E - The generic extension type

Parameters:

extensionType - The extension type

Returns:

The extension instance - Note: it is up to the caller to invoke OptionalFeature.isSupported() - null if this extension type is not implemented by the client

See Also:

• SftpClient.getServerExtensions()

getExtension

public SftpClientExtension getExtension(SftpClientExtensionFactory factory)

Specified by:

getExtension in interface SftpClient

Parameters:

factory - The SftpClientExtensionFactory instance to use - ignored if null

Returns:

The extension instance - Note: it is up to the caller to invoke OptionalFeature.isSupported() - null if this extension type is not implemented by the client

getParsedServerExtensions

protected Map<String,Object> getParsedServerExtensions()

getParsedServerExtensions

protected Map<String,Object> getParsedServerExtensions(Map<String,byte[]> extensions)

getReferencedName

protected String getReferencedName(int cmd,
 Buffer buf,
 int nameIndex)

Parameters:

cmd - The command that was sent whose response contains the name to be decoded

buf - The Buffer containing the encoded name

nameIndex - The zero-based order of the requested names for the command - e.g.,

• When listing a directory's contents each successive name will have an increasing index.
• For SFTP version 3, when retrieving a single name, short name will have index=0 and the long one index=1.

Returns:

The decoded referenced name

putReferencedName

protected <B extends Buffer> B putReferencedName(int cmd,
 B buf,
 String name,
 int nameIndex)

Type Parameters:

B - Type of Buffer being updated

Parameters:

cmd - The command for which this name is being added

buf - The buffer instance to update

name - The name to place in the buffer

nameIndex - The zero-based order of the name for the specific command if more than one name required - e.g., rename, link/symbolic link

Returns:

The updated buffer

rpc

protected SftpResponse rpc(int cmd,
 Buffer request)
                    throws IOException

Perform an SFTP request and wait until the response has been received.

Parameters:

cmd - the SFTP command code

request - a Buffer containing the request data

Returns:

the SftpResponse for the request

Throws:

IOException - if an error occurs

response

protected SftpResponse response(int cmd,
 int requestId)
                         throws IOException

Receives a response buffer, validates and returns it as a SftpResponse.

Parameters:

cmd - the command of the request the response is for

requestId - the id of the request

Returns:

the SftpResponse

Throws:

IOException - if the received buffer is malformed

checkCommandStatus

protected void checkCommandStatus(int cmd,
 Buffer request)
                           throws IOException

Sends the specified command, waits for the response and then invokes checkResponseStatus(SftpResponse)

Parameters:

cmd - The command to send

request - The request Buffer

Throws:

IOException - If failed to send, receive or check the returned status

See Also:

• RawSftpClient.send(int, Buffer)
• RawSftpClient.receive(int)
• checkResponseStatus(SftpResponse)

checkResponseStatus

protected void checkResponseStatus(SftpResponse response)
                            throws IOException

Checks if the incoming response is an SSH_FXP_STATUS one, and if so whether the substatus is SSH_FX_OK.

Parameters:

response - The received SftpResponse

Throws:

IOException - If response does not carry a status or carries a bad status code

See Also:

• checkResponseStatus(int, int, SftpStatus)

checkResponseStatus

protected void checkResponseStatus(int cmd,
 int id,
 SftpStatus status)
                            throws IOException

Parameters:

cmd - The sent command opcode

id - The request id

status - The SftpStatus

Throws:

IOException - if !status.isOk()

See Also:

• throwStatusException(int, int, SftpStatus)

throwStatusException

protected void throwStatusException(int cmd,
 int id,
 SftpStatus status)
                             throws IOException

Throws:

IOException

checkHandle

protected byte[] checkHandle(int cmd,
 Buffer request)
                      throws IOException

Parameters:

cmd - Command to be sent

request - The Buffer containing the request

Returns:

The received handle identifier

Throws:

IOException - If failed to send/receive or process the response

See Also:

• RawSftpClient.send(int, Buffer)
• RawSftpClient.receive(int)
• checkHandleResponse(SftpResponse)

checkHandleResponse

protected byte[] checkHandleResponse(SftpResponse response)
                              throws IOException

Throws:

IOException

handleUnexpectedHandlePacket

protected byte[] handleUnexpectedHandlePacket(SftpResponse response)
                                       throws IOException

Throws:

IOException

checkAttributes

protected SftpClient.Attributes checkAttributes(int cmd,
 Buffer request)
                                         throws IOException

Parameters:

cmd - Command to be sent

request - Request Buffer

Returns:

The decoded response Attributes

Throws:

IOException - If failed to send/receive or process the response

See Also:

• RawSftpClient.send(int, Buffer)
• RawSftpClient.receive(int)
• checkAttributesResponse(SftpResponse)

checkAttributesResponse

protected SftpClient.Attributes checkAttributesResponse(SftpResponse response)
                                                 throws IOException

Throws:

IOException

handleUnexpectedAttributesPacket

protected SftpClient.Attributes handleUnexpectedAttributesPacket(SftpResponse response)
                                                          throws IOException

Throws:

IOException

checkOneName

protected String checkOneName(int cmd,
 Buffer request)
                       throws IOException

Parameters:

cmd - Command to be sent

request - The request Buffer

Returns:

The retrieved name

Throws:

IOException - If failed to send/receive or process the response

See Also:

• RawSftpClient.send(int, Buffer)
• RawSftpClient.receive(int)
• checkOneNameResponse(SftpResponse)

checkOneNameResponse

protected String checkOneNameResponse(SftpResponse response)
                               throws IOException

Throws:

IOException

handleUnknownOneNamePacket

protected String handleUnknownOneNamePacket(SftpResponse response)
                                     throws IOException

Throws:

IOException

readAttributes

protected SftpClient.Attributes readAttributes(int cmd,
 Buffer buffer,
 AtomicInteger nameIndex)
                                        throws IOException

Throws:

IOException

writeAttributes

protected <B extends Buffer> B writeAttributes(int cmd,
 B buffer,
 SftpClient.Attributes attributes)

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

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

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

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

Throws:

IOException

read

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

Description copied from interface: SftpClient

Reads data from the open (file) handle

Specified by:

read in interface SftpClient

Parameters:

handle - The file SftpClient.Handle to read from

fileOffset - The file offset to read from

dst - The destination buffer

dstOffset - Offset in destination buffer to place the read data

len - Available destination buffer size to read

eofSignalled - If not null then upon return holds a value indicating whether EOF was reached due to the read. If null indicator value then this indication is not available

Returns:

Number of read bytes - -1 if EOF reached

Throws:

IOException - If failed to read the data

See Also:

• SFTP v6 - section 9.3

checkDataResponse

protected Buffer checkDataResponse(SftpAckData ack,
 SftpResponse response,
 AtomicReference<Boolean> eofSignalled)
                            throws IOException

Processes a response to an SSH_FXP_READ request.

Parameters:

ack - describing the SSH_FXP_READ request

response - SFTP response received

eofSignalled - if non-null, set to true if an EOF was received

Returns:

a Buffer containing the data received (may be empty), or null if the response was an SSH_FXP_EOF status

Throws:

IOException - on errors

handleUnknownDataPacket

protected int handleUnknownDataPacket(SftpResponse response)
                               throws IOException

Throws:

IOException

errorData

public void errorData(byte[] buf,
 int start,
 int len)
               throws IOException

Description copied from interface: SftpErrorDataHandler

Receive binary data from server error stream

Specified by:

errorData in interface SftpErrorDataHandler

Parameters:

buf - The buffer of the incoming data

start - Offset in buffer to read the data

len - Available data in buffer

Throws:

IOException - If failed to receive incoming data

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

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

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

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

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,
 AtomicReference<Boolean> eolIndicator)
                                  throws IOException

Specified by:

readDir in interface SftpClient

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

checkDirResponse

protected List<SftpClient.DirEntry> checkDirResponse(SftpResponse response,
 AtomicReference<Boolean> eolIndicator)
                                              throws IOException

Throws:

IOException

handleUnknownDirListingPacket

protected List<SftpClient.DirEntry> handleUnknownDirListingPacket(SftpResponse response)
                                                           throws IOException

Throws:

IOException

handleUnexpectedPacket

protected IOException handleUnexpectedPacket(int expected,
 SftpResponse response)
                                      throws IOException

Parameters:

expected - The expected packet type

response - The actual SftpResponse received

Returns:

The exception to throw - if null then implementor assumed to handle the exception internal. Otherwise, the exception is re-thrown

Throws:

IOException - If failed to handle the exception internally

canonicalPath

public String canonicalPath(String path)
                     throws IOException

Description copied from interface: SftpClient

The effective "normalized" remote path

Specified by:

canonicalPath in interface SftpClient

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

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

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

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

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

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

Parameters:

path - Remote path that represents a link

Returns:

The link target

Throws:

IOException - If failed to execute

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

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

Throws:

IOException

unlock

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

Specified by:

unlock in interface SftpClient

Throws:

IOException

readDir

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

Specified by:

readDir in interface SftpClient

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:

IOException - If failed to access the remote site

See Also:

• SftpClient.readDir(Handle)

listDir

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

Specified by:

listDir in interface SftpClient

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

openRemoteFileChannel

public FileChannel openRemoteFileChannel(String path,
 Collection<SftpClient.OpenMode> modes)
                                  throws IOException

Description copied from interface: SftpClient

Opens an FileChannel on the specified remote path

Specified by:

openRemoteFileChannel in interface SftpClient

Parameters:

path - The remote path

modes - The access mode(s) - if null/empty then the SftpClient.DEFAULT_CHANNEL_MODES are used

Returns:

The open FileChannel - Note: do not close this owner client instance until the channel is no longer needed since it uses the client for providing the channel's functionality.

Throws:

IOException - If failed to open the channel

See Also:

• Channels.newInputStream(java.nio.channels.ReadableByteChannel)
• Channels.newOutputStream(java.nio.channels.WritableByteChannel)

read

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

Description copied from interface: SftpClient

Read a remote file's data via an input stream

Specified by:

read in interface SftpClient

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:

IOException - If failed to execute

write

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

Description copied from interface: SftpClient

Write to a remote file via an output stream

Specified by:

write in interface SftpClient

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:

IOException - If failed to execute

put

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

Description copied from interface: SftpClient

Write data from an InputStream to a remote file.

Specified by:

put in interface SftpClient

Parameters:

stream - InputStream to read from

bufferSize - SFTP packet size; i.e., amount of data to send in a single SFTP request. Most servers have a limit of 256kB. If zero, a default buffer size is chosen depending on the peer's channel packet size; so typically about 32kB.

path - The remote file path

modes - The remote file SftpClient.OpenModes

Throws:

IOException - if data cannot be read, or cannot be written

getReadBufferSize

protected int getReadBufferSize()

getWriteBufferSize

protected int getWriteBufferSize()