org.apache.sshd.sftp.client.impl

Class DefaultSftpClient

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.impl.DefaultSftpClient

All Implemented Interfaces:

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

public class DefaultSftpClient
extends AbstractSftpClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	DefaultSftpClient.SftpChannelSubsystem

Nested classes/interfaces inherited from interface org.apache.sshd.sftp.client.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 ChannelSubsystem	channel
private ClientSession	clientSession
private java.util.concurrent.atomic.AtomicBoolean	closing
private java.util.concurrent.atomic.AtomicInteger	cmdId
private java.util.NavigableMap<java.lang.String,byte[]>	exposedExtensions
private java.util.NavigableMap<java.lang.String,byte[]>	extensions
private java.util.Map<java.lang.Integer,Buffer>	messages
private java.nio.charset.Charset	nameDecodingCharset
private Buffer	receiveBuffer
private java.util.concurrent.atomic.AtomicInteger	versionHolder

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

errorDataHandler, INIT_COMMAND_SIZE

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

log

Fields inherited from interface org.apache.sshd.sftp.client.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 org.apache.sshd.common.NamedResource

BY_NAME_COMPARATOR, NAME_EXTRACTOR

Fields inherited from interface org.apache.sshd.sftp.client.SftpErrorDataHandler

EMPTY

Constructor Summary

Constructors

Constructor and Description
DefaultSftpClient(ClientSession clientSession, SftpVersionSelector initialVersionSelector, SftpErrorDataHandler errorDataHandler)

Method Summary

Modifier and Type	Method and Description
void	close()
protected ChannelSubsystem	createSftpChannelSubsystem(ClientSession clientSession)
protected int	data(byte[] buf, int start, int len) Receive binary data from server main stream
ClientChannel	getClientChannel()
ClientSession	getClientSession()
java.nio.charset.Charset	getNameDecodingCharset()
java.util.NavigableMap<java.lang.String,byte[]>	getServerExtensions()
int	getVersion()
protected void	handleInitResponse(Buffer buffer)
protected void	init(ClientSession session, SftpVersionSelector initialVersionSelector, java.time.Duration initializationTimeout)
boolean	isClosing()
boolean	isOpen()
int	negotiateVersion(SftpVersionSelector selector)
protected void	process(Buffer incoming) Process an SFTP packet
protected boolean	receive(Buffer incoming) Read SFTP packets from buffer
Buffer	receive(int id)
Buffer	receive(int id, java.time.Duration idleTimeout)
Buffer	receive(int id, long idleTimeout)
int	send(int cmd, Buffer buffer)
void	setNameDecodingCharset(java.nio.charset.Charset nameDecodingCharset)
protected Buffer	waitForInitResponse(java.time.Duration initializationTimeout)

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

canonicalPath, checkAttributes, checkAttributesResponse, checkCommandStatus, checkData, checkDataResponse, checkDirResponse, checkHandle, checkHandleResponse, checkOneName, checkOneNameResponse, checkResponseStatus, checkResponseStatus, close, errorData, getChannel, getExtension, getExtension, getParsedServerExtensions, getParsedServerExtensions, getReadBufferSize, getReferencedName, getWriteBufferSize, handleUnexpectedAttributesPacket, handleUnexpectedHandlePacket, handleUnexpectedPacket, handleUnknownDataPacket, handleUnknownDirListingPacket, handleUnknownOneNamePacket, link, listDir, lock, lstat, mkdir, open, openDir, openRemoteFileChannel, putReferencedName, read, read, readAttributes, readDir, readDir, readLink, remove, rename, rmdir, setStat, setStat, stat, stat, throwStatusException, unlock, validateIncomingResponse, write, write, writeAttributes

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

toString

Methods inherited from class org.apache.sshd.common.util.logging.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 java.lang.Object

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

Methods inherited from interface org.apache.sshd.sftp.client.FullAccessSftpClient

singleSessionInstance

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

getExtension, getName, open, open, openRemoteFileChannel, openRemotePathChannel, openRemotePathChannel, read, read, read, read, read, read, read, read, readDir, readEntries, rename, rename, singleSessionInstance, symLink, write, write, write, write, write, write

Methods inherited from interface org.apache.sshd.client.subsystem.SubsystemClient

getSession

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

getSessionContext

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

findByName, findFirstMatchByName, getNameList, getNames, ofName, removeByName, safeCompareByName

Field Detail

clientSession

private final ClientSession clientSession

channel

private final ChannelSubsystem channel

messages

private final java.util.Map<java.lang.Integer,Buffer> messages

cmdId

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

receiveBuffer

private final Buffer receiveBuffer

versionHolder

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

closing

private final java.util.concurrent.atomic.AtomicBoolean closing

extensions

private final java.util.NavigableMap<java.lang.String,byte[]> extensions

exposedExtensions

private final java.util.NavigableMap<java.lang.String,byte[]> exposedExtensions

nameDecodingCharset

private java.nio.charset.Charset nameDecodingCharset

Constructor Detail

DefaultSftpClient

public DefaultSftpClient(ClientSession clientSession,
                         SftpVersionSelector initialVersionSelector,
                         SftpErrorDataHandler errorDataHandler)
                  throws java.io.IOException

Parameters:

clientSession - The ClientSession

initialVersionSelector - The initial SftpVersionSelector - if null then version 6 is assumed.

errorDataHandler - The SftpErrorDataHandler to handle incoming data through the error stream - if null the data is silently ignored

Throws:

java.io.IOException - If failed to initialize

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:

SftpModuleProperties.NAME_DECODING_CHARSET

setNameDecodingCharset

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

isClosing

public boolean isClosing()

isOpen

public boolean isOpen()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

data

protected int data(byte[] buf,
                   int start,
                   int len)
            throws java.io.IOException

Receive binary data from server main stream

Parameters:

buf - The buffer containing the incoming data

start - Offset in buffer to read the data

len - Available data in buffer

Returns:

Actual size of received data

Throws:

java.io.IOException - If failed to receive incoming data

receive

protected boolean receive(Buffer incoming)
                   throws java.io.IOException

Read SFTP packets from buffer

Parameters:

incoming - The received Buffer

Returns:

true if data from incoming buffer was processed

Throws:

java.io.IOException - if failed to process the buffer

See Also:

process(Buffer)

process

protected void process(Buffer incoming)
                throws java.io.IOException

Process an SFTP packet

Parameters:

incoming - The received Buffer

Throws:

java.io.IOException - if failed to process the buffer

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

receive

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

Parameters:

id - The expected request id

idleTimeout - The amount of time to wait for the response

Returns:

The received response Buffer containing the request id

Throws:

java.io.IOException - If connection closed or interrupted

receive

public Buffer receive(int id,
                      java.time.Duration idleTimeout)
               throws java.io.IOException

Parameters:

id - The expected request id

idleTimeout - The amount of time to wait for the response

Returns:

The received response Buffer containing the request id

Throws:

java.io.IOException - If connection closed or interrupted

init

protected void init(ClientSession session,
                    SftpVersionSelector initialVersionSelector,
                    java.time.Duration initializationTimeout)
             throws java.io.IOException

Throws:

java.io.IOException

handleInitResponse

protected void handleInitResponse(Buffer buffer)
                           throws java.io.IOException

Throws:

java.io.IOException

waitForInitResponse

protected Buffer waitForInitResponse(java.time.Duration initializationTimeout)
                              throws java.io.IOException

Throws:

java.io.IOException

negotiateVersion

public int negotiateVersion(SftpVersionSelector selector)
                     throws java.io.IOException

Parameters:

selector - The SftpVersionSelector to use - ignored if null

Returns:

The selected version (may be same as current)

Throws:

java.io.IOException - If failed to negotiate

createSftpChannelSubsystem

protected ChannelSubsystem createSftpChannelSubsystem(ClientSession clientSession)