Modifier and Type | Method and Description |
---|---|
void |
SshAgentKeyConstraint.put(Buffer buffer)
Writes this constraint into the given
Buffer . |
void |
SshAgentKeyConstraint.LifeTime.put(Buffer buffer) |
void |
SshAgentKeyConstraint.Extension.put(Buffer buffer) |
void |
SshAgentKeyConstraint.FidoProviderExtension.put(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
AbstractAgentProxy.createBuffer(byte cmd) |
protected Buffer |
AbstractAgentProxy.createBuffer(byte cmd,
int extraLen) |
protected Buffer |
AbstractAgentProxy.prepare(Buffer buffer) |
protected Buffer |
AbstractAgentClient.prepare(Buffer buf) |
protected abstract Buffer |
AbstractAgentProxy.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAgentClient.messageReceived(Buffer message) |
protected Buffer |
AbstractAgentProxy.prepare(Buffer buffer) |
protected Buffer |
AbstractAgentClient.prepare(Buffer buf) |
protected void |
AbstractAgentClient.process(int cmd,
Buffer req,
Buffer rep) |
protected abstract void |
AbstractAgentClient.reply(Buffer buf) |
protected abstract Buffer |
AbstractAgentProxy.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
AgentForwardedChannel.request(Buffer buffer) |
protected Buffer |
AgentForwardedChannel.waitForMessageBuffer() |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
ChannelAgentForwarding.doInit(Buffer buffer) |
protected void |
ChannelAgentForwarding.AgentClient.reply(Buffer buf) |
protected Buffer |
AgentForwardedChannel.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractUserAuth.process(Buffer buffer) |
boolean |
UserAuth.process(Buffer buffer) |
protected abstract boolean |
AbstractUserAuth.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
default void |
UserAuth.signalAuthMethodFailure(ClientSession session,
String service,
boolean partial,
List<String> serverMethods,
Buffer buffer)
Signals reception of
SSH_MSG_USERAUTH_FAILURE message |
default void |
UserAuth.signalAuthMethodSuccess(ClientSession session,
String service,
Buffer buffer)
Signal reception of
SSH_MSG_USERAUTH_SUCCESS message |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
UserAuthHostBased.appendSignature(ClientSession session,
String service,
String keyType,
PublicKey key,
byte[] keyBytes,
String clientHostname,
String clientUsername,
Signature verifier,
Buffer buffer) |
protected boolean |
UserAuthHostBased.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
void |
UserAuthHostBased.signalAuthMethodFailure(ClientSession session,
String service,
boolean partial,
List<String> serverMethods,
Buffer buffer) |
void |
UserAuthHostBased.signalAuthMethodSuccess(ClientSession session,
String service,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UserAuthKeyboardInteractive.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UserAuthPassword.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
protected IoWriteFuture |
UserAuthPassword.sendPassword(Buffer buffer,
ClientSession session,
String oldPassword,
String newPassword)
Sends the password via a
SSH_MSG_USERAUTH_REQUEST message. |
void |
UserAuthPassword.signalAuthMethodFailure(ClientSession session,
String service,
boolean partial,
List<String> serverMethods,
Buffer buffer) |
void |
UserAuthPassword.signalAuthMethodSuccess(ClientSession session,
String service,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
UserAuthPublicKey.appendSignature(ClientSession session,
String service,
String name,
String username,
String algo,
PublicKey key,
PublicKey serverKey,
Buffer buffer) |
protected boolean |
UserAuthPublicKey.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
void |
UserAuthPublicKey.signalAuthMethodFailure(ClientSession session,
String service,
boolean partial,
List<String> serverMethods,
Buffer buffer) |
void |
UserAuthPublicKey.signalAuthMethodSuccess(ClientSession session,
String service,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected RequestHandler.Result |
ChannelSession.handleInternalRequest(String req,
boolean wantReply,
Buffer buffer) |
void |
AbstractClientChannel.handleOpenFailure(Buffer buffer) |
void |
AbstractClientChannel.handleOpenSuccess(long recipient,
long rwSize,
long packetSize,
Buffer buffer) |
void |
AbstractClientChannel.handleWindowAdjust(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleXonXoff(Buffer buffer,
boolean wantReply) |
OpenFuture |
AbstractClientChannel.open(long recipient,
long rwSize,
long packetSize,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
RequestHandler.Result |
AbstractChannelExitRequestHandler.process(Channel channel,
String request,
boolean wantReply,
Buffer buffer) |
protected String |
ExitSignalChannelRequestHandler.processRequestValue(Channel channel,
String request,
Buffer buffer) |
protected abstract V |
AbstractChannelExitRequestHandler.processRequestValue(Channel channel,
String request,
Buffer buffer)
Invoked by default from
AbstractChannelExitRequestHandler.process(Channel, String, boolean, Buffer) when a request matching the handler's
name is received |
protected Integer |
ExitStatusChannelRequestHandler.processRequestValue(Channel channel,
String request,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected RequestHandler.Result |
OpenSshHostKeysHandler.handleHostKeys(Session session,
Collection<? extends PublicKey> keys,
boolean wantReply,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
DHGClient.next(int cmd,
Buffer buffer) |
boolean |
DHGEXClient.next(int cmd,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientSessionImpl.handleDisconnect(int code,
String msg,
String lang,
Buffer buffer) |
void |
ClientUserAuthService.process(int cmd,
Buffer buffer) |
protected void |
ClientUserAuthService.processUserAuth(Buffer buffer)
Execute one step in user authentication.
|
protected boolean |
AbstractClientSession.readIdentification(Buffer buffer) |
protected byte[] |
AbstractClientSession.receiveKexInit(Buffer buffer) |
void |
AbstractClientSession.startService(String name,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
Service.process(int cmd,
Buffer buffer)
Service the request.
|
Modifier and Type | Method and Description |
---|---|
protected Buffer |
ChannelAsyncOutputStream.createSendBuffer(Buffer buffer,
Channel channel,
int length) |
Buffer |
IoWriteFutureImpl.getBuffer() |
Buffer |
ChannelAsyncInputStream.IoReadFutureImpl.getBuffer() |
protected Buffer |
ChannelOutputStream.newBuffer(int size) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
ChannelAsyncOutputStream.createSendBuffer(Buffer buffer,
Channel channel,
int length) |
protected void |
AbstractChannel.handleChannelRequest(String req,
boolean wantReply,
Buffer buffer) |
void |
AbstractChannel.handleData(Buffer buffer) |
void |
Channel.handleData(Buffer buffer)
Invoked when
SSH_MSG_CHANNEL_DATA received |
void |
AbstractChannel.handleExtendedData(Buffer buffer) |
void |
Channel.handleExtendedData(Buffer buffer)
Invoked when
SSH_MSG_CHANNEL_EXTENDED_DATA received |
protected RequestHandler.Result |
AbstractChannel.handleInternalRequest(String req,
boolean wantReply,
Buffer buffer)
Called by
AbstractChannel.handleUnknownChannelRequest(String, boolean, Buffer) in order to allow channel request
handling if none of the registered handlers processed the request - last chance. |
void |
Channel.handleOpenFailure(Buffer buffer)
For a client channel, this method will be called internally by the session when the server has rejected this
channel opening.
|
void |
Channel.handleOpenSuccess(long recipient,
long rwSize,
long packetSize,
Buffer buffer)
For a client channel, this method will be called internally by the session when the confirmation has been
received.
|
void |
AbstractChannel.handleRequest(Buffer buffer) |
void |
Channel.handleRequest(Buffer buffer)
Invoked when
SSH_MSG_CHANNEL_REQUEST received |
protected void |
AbstractChannel.handleUnknownChannelRequest(String req,
boolean wantReply,
Buffer buffer)
Called when none of the register request handlers reported handling the request
|
void |
AbstractChannel.handleWindowAdjust(Buffer buffer) |
void |
Channel.handleWindowAdjust(Buffer buffer)
Invoked when
SSH_MSG_CHANNEL_WINDOW_ADJUST received |
OpenFuture |
Channel.open(long recipient,
long rwSize,
long packetSize,
Buffer buffer)
For a server channel, this method will actually open the channel
|
RequestHandler.Result |
ChannelRequestHandler.process(Channel channel,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
RequestHandler.process(T t,
String request,
boolean wantReply,
Buffer buffer)
Process an SSH request.
|
IoReadFuture |
ChannelAsyncInputStream.read(Buffer buf) |
protected IoWriteFuture |
AbstractChannel.sendResponse(Buffer buffer,
String req,
RequestHandler.Result result,
boolean wantReply) |
IoWriteFuture |
BufferedIoOutputStream.writeBuffer(Buffer buffer) |
IoWriteFuture |
ChannelAsyncOutputStream.writeBuffer(Buffer buffer)
Write the given buffer.
|
IoWriteFuture |
SimpleIoOutputStream.writeBuffer(Buffer buffer) |
IoWriteFuture |
AbstractChannel.writePacket(Buffer buffer) |
IoWriteFuture |
Channel.writePacket(Buffer buffer)
Encode and send the given buffer.
|
Constructor and Description |
---|
IoReadFutureImpl(Object id,
Buffer buffer) |
IoWriteFutureImpl(Object id,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
DefaultChannelStreamWriter.writeData(Buffer buffer) |
IoWriteFuture |
ChannelStreamWriter.writeData(Buffer buffer)
Encode and send the given data packet buffer.
|
Modifier and Type | Method and Description |
---|---|
void |
Compression.compress(Buffer buffer)
Compress the given buffer in place.
|
void |
CompressionNone.compress(Buffer buffer) |
void |
CompressionZlib.compress(Buffer buffer) |
void |
Compression.uncompress(Buffer from,
Buffer to)
Uncompress the data in a buffer into another buffer.
|
void |
CompressionNone.uncompress(Buffer from,
Buffer to) |
void |
CompressionZlib.uncompress(Buffer from,
Buffer to) |
Modifier and Type | Method and Description |
---|---|
protected String |
SocksProxy.Socks5.getBLString(Buffer buffer) |
protected String |
SocksProxy.Socks4.getNTString(Buffer buffer) |
protected int |
SocksProxy.Proxy.getUByte(Buffer buffer) |
protected int |
SocksProxy.Proxy.getUShort(Buffer buffer) |
protected void |
SocksProxy.Proxy.onMessage(Buffer buffer) |
protected void |
SocksProxy.Socks4.onMessage(Buffer buffer) |
protected void |
SocksProxy.Socks5.onMessage(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
GlobalRequestFuture.getBuffer()
Obtains the reply
Buffer if the request was successful. |
Modifier and Type | Method and Description |
---|---|
void |
GlobalRequestFuture.ReplyHandler.accept(int cmd,
Buffer buffer)
Invoked by the framework upon reception of the reply.
|
Modifier and Type | Method and Description |
---|---|
protected abstract RequestHandler.Result |
AbstractOpenSshHostKeysHandler.handleHostKeys(Session session,
Collection<? extends PublicKey> keys,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
AbstractOpenSshHostKeysHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
IoReadFuture.getBuffer()
Retrieves the buffer data was read into.
|
Modifier and Type | Method and Description |
---|---|
IoReadFuture |
IoInputStream.read(Buffer buffer)
NOTE: the buffer must not be touched until the returned read future is completed.
|
IoWriteFuture |
IoSession.writeBuffer(Buffer buffer)
Write a packet on the socket.
|
IoWriteFuture |
IoOutputStream.writeBuffer(Buffer buffer)
Write the given buffer.
|
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
Nio2Session.writeBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
KeyExchange.next(int cmd,
Buffer buffer)
Process the next packet
|
void |
XDH.putE(Buffer buffer,
byte[] e) |
void |
ECDH.putE(Buffer buffer,
byte[] e) |
void |
AbstractDH.putE(Buffer buffer,
byte[] e) |
void |
XDH.putF(Buffer buffer,
byte[] f) |
void |
ECDH.putF(Buffer buffer,
byte[] f) |
void |
AbstractDH.putF(Buffer buffer,
byte[] f) |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
AbstractDHKeyExchange.updateE(Buffer buffer) |
protected byte[] |
AbstractDHKeyExchange.updateF(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
default boolean |
KexExtensionHandler.handleKexCompressionMessage(Session session,
Buffer buffer)
Parses the
SSH_MSG_NEWCOMPRESS message. |
default boolean |
KexExtensionHandler.handleKexExtensionsMessage(Session session,
Buffer buffer)
Parses the
SSH_MSG_EXT_INFO message. |
T |
KexExtensionParser.parseExtension(Buffer buffer) |
static List<Map.Entry<String,?>> |
KexExtensions.parseExtensions(Buffer buffer)
Attempts to parse an
SSH_MSG_EXT_INFO message |
void |
KexExtensionParser.putExtension(T value,
Buffer buffer)
Adds the name + value to the buffer
|
static void |
KexExtensions.putExtensions(Collection<? extends Map.Entry<String,?>> exts,
Buffer buffer)
Creates an
SSH_MSG_EXT_INFO message using the provided extensions. |
Modifier and Type | Method and Description |
---|---|
protected void |
DelayCompression.encode(DelayedCompressionAlgorithms algos,
Buffer buffer) |
protected void |
HostBoundPubkeyAuthentication.encode(Integer version,
Buffer buffer) |
protected void |
ServerSignatureAlgorithms.encode(List<String> names,
Buffer buffer) |
protected void |
NoFlowControl.encode(String value,
Buffer buffer) |
protected void |
Elevation.encode(String value,
Buffer buffer) |
protected abstract void |
AbstractKexExtensionParser.encode(T value,
Buffer buffer) |
DelayedCompressionAlgorithms |
DelayCompression.parseExtension(Buffer buffer) |
Integer |
HostBoundPubkeyAuthentication.parseExtension(Buffer buffer) |
List<String> |
ServerSignatureAlgorithms.parseExtension(Buffer buffer) |
String |
NoFlowControl.parseExtension(Buffer buffer) |
String |
Elevation.parseExtension(Buffer buffer) |
void |
AbstractKexExtensionParser.putExtension(T value,
Buffer buffer) |
Modifier and Type | Class and Description |
---|---|
class |
SessionWorkBuffer |
Modifier and Type | Method and Description |
---|---|
Buffer |
SessionWorkBuffer.clear(boolean wipeData) |
default Buffer |
Session.createBuffer(byte cmd)
Create a new buffer for the specified SSH packet and reserve the needed space (5 bytes) for the packet header.
|
Buffer |
Session.createBuffer(byte cmd,
int estimatedSize)
Create a new buffer for the specified SSH packet and reserve the needed space (5 bytes) for the packet header.
|
Buffer |
Session.prepareBuffer(byte cmd,
Buffer buffer)
Prepare a new "clean" buffer while reserving the needed space (5 bytes) for the packet header.
|
default Buffer |
Session.request(String request,
Buffer buffer,
Duration timeout)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
Buffer |
Session.request(String request,
Buffer buffer,
long maxWaitMillis)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
default Buffer |
Session.request(String request,
Buffer buffer,
long timeout,
TimeUnit unit)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
Modifier and Type | Method and Description |
---|---|
default void |
ReservedSessionMessagesHandler.handleDebugMessage(Session session,
Buffer buffer)
Invoked when an
SSH_MSG_DEBUG packet is received |
default void |
ReservedSessionMessagesHandler.handleIgnoreMessage(Session session,
Buffer buffer)
Invoked when an
SSH_MSG_IGNORE packet is received |
default boolean |
ReservedSessionMessagesHandler.handleUnimplementedMessage(Session session,
int cmd,
Buffer buffer)
Invoked when a packet with an un-implemented message is received - including
SSH_MSG_UNIMPLEMENTED itself |
Channel |
UnknownChannelReferenceHandler.handleUnknownChannelCommand(ConnectionService service,
byte cmd,
long channelId,
Buffer buffer)
Invoked when the connection service responsible for handling channel messages receives a message intended for an
unknown channel.
|
default boolean |
SessionDisconnectHandler.handleUnsupportedServiceDisconnectReason(Session session,
int cmd,
String serviceName,
Buffer buffer)
Invoked when a request has been made related to an unknown SSH service as described in
RFC 4253 - section 10.
|
Buffer |
Session.prepareBuffer(byte cmd,
Buffer buffer)
Prepare a new "clean" buffer while reserving the needed space (5 bytes) for the packet header.
|
RequestHandler.Result |
ConnectionServiceRequestHandler.process(ConnectionService service,
String request,
boolean wantReply,
Buffer buffer) |
GlobalRequestFuture |
Session.request(Buffer buffer,
String request,
GlobalRequestFuture.ReplyHandler replyHandler)
Send a global request and handle the reply asynchronously.
|
default Buffer |
Session.request(String request,
Buffer buffer,
Duration timeout)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
Buffer |
Session.request(String request,
Buffer buffer,
long maxWaitMillis)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
default Buffer |
Session.request(String request,
Buffer buffer,
long timeout,
TimeUnit unit)
Send a global request and wait for the response, if the request is sent with
want-reply = true . |
default IoWriteFuture |
ReservedSessionMessagesHandler.sendKexInitRequest(Session session,
Map<KexProposalOption,String> proposal,
Buffer packet)
Invoked before sending the
SSH_MSG_KEXINIT packet |
void |
Session.startService(String name,
Buffer buffer) |
IoWriteFuture |
Session.writePacket(Buffer buffer)
Encode and send the given buffer.
|
default IoWriteFuture |
Session.writePacket(Buffer buffer,
Duration timeout)
Encode and send the given buffer with the specified timeout.
|
default IoWriteFuture |
Session.writePacket(Buffer buffer,
long maxWaitMillis)
Encode and send the given buffer with the specified timeout.
|
IoWriteFuture |
Session.writePacket(Buffer buffer,
long timeout,
TimeUnit unit)
Encode and send the given buffer with the specified timeout.
|
Modifier and Type | Method and Description |
---|---|
protected <B extends Buffer> |
AbstractSession.validateTargetBuffer(int cmd,
B buffer)
Makes sure that the buffer used for output is not
null or one of the session's internal ones used for
decoding and uncompressing |
Modifier and Type | Method and Description |
---|---|
Buffer |
AbstractSession.createBuffer(byte cmd,
int len) |
protected Buffer |
AbstractSession.encode(Buffer buffer)
Encode a buffer into the SSH protocol.
|
Buffer |
PendingWriteFuture.getBuffer() |
Buffer |
AbstractSession.prepareBuffer(byte cmd,
Buffer buffer) |
protected Buffer |
SessionHelper.preProcessEncodeBuffer(int cmd,
Buffer buffer)
Invoked by the session before encoding the buffer in order to make sure that it is at least of size
SSH_PACKET_HEADER_LEN . |
protected Buffer |
AbstractSession.preProcessEncodeBuffer(int cmd,
Buffer buffer) |
Buffer |
AbstractSession.request(String request,
Buffer buffer,
long maxWaitMillis) |
protected Buffer |
AbstractSession.resolveOutputPacket(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSession.aeadOutgoingBuffer(Buffer buf,
int offset,
int len) |
protected void |
AbstractSession.appendOutgoingMac(Buffer buf,
int offset,
int len) |
void |
AbstractConnectionService.channelClose(Buffer buffer)
Close a channel due to a close packet received
|
void |
AbstractConnectionService.channelData(Buffer buffer)
Process incoming data on a channel
|
void |
AbstractConnectionService.channelEof(Buffer buffer)
Process end of file on a channel
|
void |
AbstractConnectionService.channelExtendedData(Buffer buffer)
Process incoming extended data on a channel
|
void |
AbstractConnectionService.channelFailure(Buffer buffer)
Process a failure on a channel
|
protected void |
AbstractConnectionService.channelOpen(Buffer buffer) |
void |
AbstractConnectionService.channelOpenConfirmation(Buffer buffer) |
void |
AbstractConnectionService.channelOpenFailure(Buffer buffer) |
void |
AbstractConnectionService.channelRequest(Buffer buffer)
Service a request on a channel
|
void |
AbstractConnectionService.channelSuccess(Buffer buffer)
Process a success on a channel
|
void |
AbstractConnectionService.channelWindowAdjust(Buffer buffer)
Process a window adjust packet on a channel
|
protected void |
AbstractSession.doHandleMessage(Buffer buffer) |
protected void |
SessionHelper.doInvokeDebugMessageHandler(Buffer buffer)
Invoked by
SessionHelper.handleDebug(Buffer) after validating that the buffer structure seems well-formed and also
resetting the idle timeout. |
protected void |
SessionHelper.doInvokeIgnoreMessageHandler(Buffer buffer)
Invoked by
SessionHelper.handleDebug(Buffer) after validating that the buffer structure seems well-formed and also
resetting the idle timeout. |
protected boolean |
SessionHelper.doInvokeUnimplementedMessageHandler(int cmd,
Buffer buffer) |
protected boolean |
AbstractSession.doInvokeUnimplementedMessageHandler(int cmd,
Buffer buffer) |
protected List<String> |
SessionHelper.doReadIdentification(Buffer buffer,
boolean server)
Read the remote identification from this buffer.
|
protected IoWriteFuture |
AbstractSession.doWritePacket(Buffer buffer) |
protected Buffer |
AbstractSession.encode(Buffer buffer)
Encode a buffer into the SSH protocol.
|
protected void |
AbstractSession.encryptOutgoingBuffer(Buffer buf,
int offset,
int len) |
protected PendingWriteFuture |
KeyExchangeMessageHandler.enqueuePendingPacket(int cmd,
Buffer buffer)
Enqueues a packet to be written once a running key exchange terminates.
|
protected Channel |
AbstractConnectionService.getChannel(byte cmd,
Buffer buffer)
Retrieve the channel designated by the given packet
|
protected Channel |
AbstractConnectionService.getChannel(byte cmd,
long recipient,
Buffer buffer) |
protected IoWriteFuture |
AbstractConnectionService.globalRequest(Buffer buffer)
Process global requests
|
protected void |
SessionHelper.handleDebug(Buffer buffer) |
void |
ReservedSessionMessagesHandlerAdapter.handleDebugMessage(Session session,
boolean display,
String msg,
String lang,
Buffer buffer) |
void |
ReservedSessionMessagesHandlerAdapter.handleDebugMessage(Session session,
Buffer buffer) |
protected void |
SessionHelper.handleDisconnect(Buffer buffer) |
protected void |
SessionHelper.handleDisconnect(int code,
String msg,
String lang,
Buffer buffer) |
protected boolean |
AbstractSession.handleFirstKexPacketFollows(int cmd,
Buffer buffer,
boolean followFlag) |
protected void |
SessionHelper.handleIgnore(Buffer buffer) |
void |
ReservedSessionMessagesHandlerAdapter.handleIgnoreMessage(Session session,
Buffer buffer) |
void |
ReservedSessionMessagesHandlerAdapter.handleIgnoreMessage(Session session,
byte[] data,
Buffer buffer) |
protected void |
AbstractSession.handleKexExtension(int cmd,
Buffer buffer) |
protected void |
AbstractSession.handleKexInit(Buffer buffer) |
protected void |
AbstractSession.handleKexMessage(int cmd,
Buffer buffer) |
protected void |
AbstractSession.handleMessage(Buffer buffer)
Abstract method for processing incoming decoded packets.
|
protected void |
AbstractSession.handleNewCompression(int cmd,
Buffer buffer) |
protected void |
AbstractSession.handleNewKeys(int cmd,
Buffer buffer) |
protected void |
AbstractSession.handleServiceAccept(Buffer buffer) |
protected void |
AbstractSession.handleServiceAccept(String serviceName,
Buffer buffer) |
protected void |
AbstractSession.handleServiceRequest(Buffer buffer) |
protected boolean |
AbstractSession.handleServiceRequest(String serviceName,
Buffer buffer) |
protected void |
SessionHelper.handleUnimplemented(Buffer buffer) |
boolean |
ReservedSessionMessagesHandlerAdapter.handleUnimplementedMessage(Session session,
int cmd,
Buffer buffer) |
Channel |
DefaultUnknownChannelReferenceHandler.handleUnknownChannelCommand(ConnectionService service,
byte cmd,
long channelId,
Buffer buffer) |
protected IoWriteFuture |
AbstractConnectionService.handleUnknownRequest(Buffer buffer,
String req,
boolean wantReply) |
protected IoWriteFuture |
AbstractSession.notImplemented(int cmd,
Buffer buffer)
Send a
SSH_MSG_UNIMPLEMENTED packet. |
Buffer |
AbstractSession.prepareBuffer(byte cmd,
Buffer buffer) |
protected Buffer |
SessionHelper.preProcessEncodeBuffer(int cmd,
Buffer buffer)
Invoked by the session before encoding the buffer in order to make sure that it is at least of size
SSH_PACKET_HEADER_LEN . |
protected Buffer |
AbstractSession.preProcessEncodeBuffer(int cmd,
Buffer buffer) |
RequestHandler.Result |
AbstractConnectionServiceRequestHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
boolean |
CurrentService.process(int cmd,
Buffer buffer)
Processes a service request.
|
void |
AbstractConnectionService.process(int cmd,
Buffer buffer) |
protected abstract boolean |
AbstractSession.readIdentification(Buffer buffer)
Read the other side identification.
|
protected byte[] |
AbstractSession.receiveKexInit(Buffer buffer) |
protected byte[] |
AbstractSession.receiveKexInit(Buffer buffer,
Map<KexProposalOption,String> proposal)
Receive the remote key exchange init message.
|
GlobalRequestFuture |
AbstractSession.request(Buffer buffer,
String request,
GlobalRequestFuture.ReplyHandler replyHandler) |
Buffer |
AbstractSession.request(String request,
Buffer buffer,
long maxWaitMillis) |
protected void |
AbstractConnectionService.requestFailure(Buffer buffer) |
protected void |
AbstractSession.requestFailure(Buffer buffer)
Indicates the reception of a
SSH_MSG_REQUEST_FAILURE message |
protected void |
AbstractConnectionService.requestSuccess(Buffer buffer) |
protected void |
AbstractSession.requestSuccess(Buffer buffer)
Indicates the reception of a
SSH_MSG_REQUEST_SUCCESS message |
protected Buffer |
AbstractSession.resolveOutputPacket(Buffer buffer) |
protected IoWriteFuture |
AbstractConnectionService.sendChannelOpenFailure(Buffer buffer,
long sender,
int reasonCode,
String message,
String lang) |
protected IoWriteFuture |
AbstractConnectionService.sendGlobalResponse(Buffer buffer,
String req,
RequestHandler.Result result,
boolean wantReply) |
protected IoWriteFuture |
KeyExchangeMessageHandler.writeOrEnqueue(int cmd,
Buffer buffer,
long timeout,
TimeUnit unit)
Writes an SSH packet.
|
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer) |
IoWriteFuture |
KeyExchangeMessageHandler.writePacket(Buffer buffer,
long timeout,
TimeUnit unit)
Writes a packet.
|
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer,
long timeout,
TimeUnit unit) |
Constructor and Description |
---|
PendingWriteFuture(Object id,
Buffer buffer) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayBuffer
Provides an implementation of
Buffer using a backing byte array |
Modifier and Type | Method and Description |
---|---|
static <B extends Buffer> |
BufferUtils.clear(B buffer)
Invokes
clear() |
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.clear()
Reset read/write positions to zero - Note: zeroes any previously existing data
|
Buffer |
ByteArrayBuffer.clear(boolean wipeData) |
abstract Buffer |
Buffer.clear(boolean wipeData)
Reset read/write positions to zero
|
Buffer |
Buffer.ensureCapacity(int capacity) |
Buffer |
ByteArrayBuffer.ensureCapacity(int capacity,
IntUnaryOperator growthFactor) |
abstract Buffer |
Buffer.ensureCapacity(int capacity,
IntUnaryOperator growthFactor) |
Modifier and Type | Method and Description |
---|---|
static int |
BufferUtils.updateLengthPlaceholder(Buffer buffer,
int lenPos)
Used for encodings where we don't know the data length before adding it to the buffer.
|
static void |
BufferUtils.updateLengthPlaceholder(Buffer buffer,
int lenPos,
long dataLength)
Updates a 32-bit "placeholder" location for data length - moves the write position to the specified
placeholder position, updates the length value and then moves the write position it back to its original value.
|
Modifier and Type | Method and Description |
---|---|
protected ECPublicKey |
ECBufferPublicKeyParser.getRawECKey(String expectedCurve,
ECParameterSpec spec,
Buffer buffer) |
SkEcdsaPublicKey |
SkECBufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
PublicKey |
ED25519BufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
DSAPublicKey |
DSSBufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
ECPublicKey |
ECBufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
SkED25519PublicKey |
SkED25519BufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
OpenSshCertificate |
OpenSSHCertPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
PUB |
BufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
RSAPublicKey |
RSABufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
static <B extends Buffer> |
SecurityUtils.putEDDSAKeyPair(B buffer,
KeyPair kp) |
static <B extends Buffer> |
SecurityUtils.putEDDSAKeyPair(B buffer,
PublicKey pubKey,
PrivateKey prvKey) |
static <B extends Buffer> |
SecurityUtils.putRawEDDSAPublicKey(B buffer,
PublicKey key) |
Modifier and Type | Method and Description |
---|---|
static KeyPair |
SecurityUtils.extractEDDSAKeyPair(Buffer buffer,
String keyType) |
Modifier and Type | Method and Description |
---|---|
static <B extends Buffer> |
EdDSASecurityProviderUtils.putEDDSAKeyPair(B buffer,
PublicKey pubKey,
PrivateKey prvKey) |
static <B extends Buffer> |
EdDSASecurityProviderUtils.putRawEDDSAPublicKey(B buffer,
PublicKey key) |
Modifier and Type | Method and Description |
---|---|
Boolean |
AbstractUserAuth.auth(ServerSession session,
String username,
String service,
Buffer buffer) |
Boolean |
UserAuth.auth(ServerSession session,
String username,
String service,
Buffer buffer)
Try to authenticate the user.
|
protected abstract Boolean |
AbstractUserAuth.doAuth(Buffer buffer,
boolean init) |
Boolean |
UserAuthNone.doAuth(Buffer buffer,
boolean init) |
Boolean |
AbstractUserAuth.next(Buffer buffer) |
Boolean |
UserAuth.next(Buffer buffer)
Handle another step in the authentication process.
|
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthGSS.doAuth(Buffer buffer,
boolean initial) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthHostBased.doAuth(Buffer buffer,
boolean init) |
Modifier and Type | Method and Description |
---|---|
<B extends Buffer> |
InteractiveChallenge.append(B buffer) |
<B extends Buffer> |
PromptEntry.append(B buffer) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthKeyboardInteractive.doAuth(Buffer buffer,
boolean init) |
protected Boolean |
UserAuthKeyboardInteractive.doInitialAuth(ServerSession session,
String username,
KeyboardInteractiveAuthenticator auth,
Buffer buffer) |
protected Boolean |
UserAuthKeyboardInteractive.doValidateAuthResponse(ServerSession session,
String username,
KeyboardInteractiveAuthenticator auth,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthPassword.checkPassword(Buffer buffer,
ServerSession session,
String username,
String password)
Invokes the configured
PasswordAuthenticator and returns the result. |
Boolean |
UserAuthPassword.doAuth(Buffer buffer,
boolean init) |
protected Boolean |
UserAuthPassword.handleClientPasswordChangeRequest(Buffer buffer,
ServerSession session,
String username,
String oldPassword,
String newPassword)
Invoked when the client sends a
SSH_MSG_USERAUTH_REQUEST indicating a password change. |
protected Boolean |
UserAuthPassword.handleServerPasswordChangeRequest(Buffer buffer,
ServerSession session,
String username,
String password,
PasswordChangeRequiredException e)
Invoked by
UserAuthPassword.checkPassword(Buffer, ServerSession, String, String) when a
PasswordChangeRequiredException was thrown by the authenticator. |
Modifier and Type | Method and Description |
---|---|
Boolean |
UserAuthPublicKey.doAuth(Buffer buffer,
boolean init) |
protected void |
UserAuthPublicKey.sendPublicKeyResponse(ServerSession session,
String username,
String alg,
PublicKey key,
byte[] keyBlob,
int offset,
int blobLen,
Buffer buffer) |
protected boolean |
UserAuthPublicKey.verifySignature(ServerSession session,
String username,
String alg,
PublicKey key,
Buffer buffer,
Signature verifier,
byte[] sig) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
ChannelSession.extendedDataBuffer |
protected Buffer |
ChannelSession.receiverBuffer |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
AbstractServerChannel.doInit(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleAgentForwarding(String requestType,
Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleBreak(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleEnv(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleExec(String request,
Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleInternalRequest(String requestType,
boolean wantReply,
Buffer buffer) |
void |
AbstractServerChannel.handleOpenFailure(Buffer buffer) |
void |
AbstractServerChannel.handleOpenSuccess(long recipient,
long rwSize,
long packetSize,
Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handlePtyReq(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleShell(String request,
Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleSignal(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleSubsystem(String request,
Buffer buffer,
boolean wantReply) |
void |
ChannelSession.handleWindowAdjust(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleWindowChange(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleX11Forwarding(String requestType,
Buffer buffer,
boolean wantReply) |
OpenFuture |
AbstractServerChannel.open(long recipient,
long rwSize,
long packetSize,
Buffer buffer) |
RequestHandler.Result |
PuttyRequestHandler.process(Channel channel,
String request,
boolean wantReply,
Buffer buffer) |
protected RequestHandler.Result |
PuttyRequestHandler.processPuttyOpcode(Channel channel,
String request,
String opcode,
boolean wantReply,
Buffer buffer) |
protected IoWriteFuture |
ChannelSession.sendResponse(Buffer buffer,
String req,
RequestHandler.Result result,
boolean wantReply) |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
TcpipServerChannel.doInit(Buffer buffer) |
void |
TcpipServerChannel.handleWindowAdjust(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected RequestHandler.Result |
OpenSshHostKeysHandler.handleHostKeys(Session session,
Collection<? extends PublicKey> keys,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
TcpipForwardHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
KeepAliveHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
CancelTcpipForwardHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
NoMoreSessionsHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
DHGEXServer.next(int cmd,
Buffer buffer) |
boolean |
DHGServer.next(int cmd,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
ServerProxyAcceptor.acceptServerProxyMetadata(ServerSession session,
Buffer buffer)
Invoked before any attempt is made to retrieve the SSH client identification data of the standard SSH
protocol.
|
protected void |
ServerUserAuthService.asyncAuth(int cmd,
Buffer buffer,
boolean authed) |
protected void |
ServerUserAuthService.handleAuthenticationFailure(int cmd,
Buffer buffer) |
protected void |
ServerUserAuthService.handleAuthenticationInProgress(int cmd,
Buffer buffer) |
protected void |
ServerUserAuthService.handleAuthenticationSuccess(int cmd,
Buffer buffer) |
protected void |
AbstractServerSession.handleServiceAccept(String serviceName,
Buffer buffer) |
protected boolean |
AbstractServerSession.handleServiceRequest(String serviceName,
Buffer buffer) |
protected boolean |
ServerUserAuthService.handleUserAuthRequestMessage(ServerSession session,
Buffer buffer,
AtomicReference<Boolean> authHolder) |
void |
ServerUserAuthService.process(int cmd,
Buffer buffer) |
protected boolean |
AbstractServerSession.readIdentification(Buffer buffer) |
IoWriteFuture |
ServerSession.signalAuthenticationSuccess(String username,
String authService,
Buffer buffer) |
IoWriteFuture |
AbstractServerSession.signalAuthenticationSuccess(String username,
String authService,
Buffer buffer) |
void |
AbstractServerSession.startService(String name,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
TtyFilterInputStream.insertCharacter(Buffer org,
int c) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
TtyFilterInputStream.insertCharacter(Buffer org,
int c) |
Modifier and Type | Method and Description |
---|---|
Buffer |
RawSftpClient.receive(int id) |
Buffer |
RawSftpClient.receive(int id,
Duration timeout) |
Buffer |
RawSftpClient.receive(int id,
long timeout) |
Modifier and Type | Method and Description |
---|---|
int |
RawSftpClient.send(int cmd,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
AbstractSftpClientExtension.checkExtendedReplyBuffer(Buffer buffer) |
protected Buffer |
AbstractSftpClientExtension.getCommandBuffer(int extraSize) |
protected Buffer |
AbstractSftpClientExtension.getCommandBuffer(Object target) |
protected Buffer |
AbstractSftpClientExtension.getCommandBuffer(Object target,
int extraSize) |
Buffer |
AbstractSftpClientExtension.putTarget(Buffer buffer,
Object target) |
Buffer |
AbstractSftpClientExtension.receive(int id) |
Buffer |
AbstractSftpClientExtension.receive(int id,
Duration timeout) |
Buffer |
AbstractSftpClientExtension.receive(int id,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
AbstractSftpClientExtension.checkExtendedReplyBuffer(Buffer buffer) |
protected void |
AbstractSftpClientExtension.checkStatus(Buffer buffer) |
Buffer |
AbstractSftpClientExtension.putTarget(Buffer buffer,
Object target) |
int |
AbstractSftpClientExtension.send(int cmd,
Buffer buffer) |
protected void |
AbstractSftpClientExtension.sendAndCheckExtendedCommandStatus(Buffer buffer) |
protected int |
AbstractSftpClientExtension.sendExtendedCommand(Buffer buffer) |
protected void |
AbstractSftpClientExtension.validateIncomingResponse(int cmd,
int id,
int type,
int length,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
<B extends Buffer> |
OpenSSHLimitsExtensionInfo.encode(B buffer) |
<B extends Buffer> |
OpenSSHStatExtensionInfo.encode(B buffer) |
static <B extends Buffer> |
OpenSSHLimitsExtensionInfo.encode(B buffer,
OpenSSHLimitsExtensionInfo info) |
static <B extends Buffer> |
OpenSSHStatExtensionInfo.encode(B buffer,
OpenSSHStatExtensionInfo info) |
Modifier and Type | Method and Description |
---|---|
static OpenSSHStatExtensionInfo |
OpenSSHStatExtensionInfo.decode(Buffer buffer) |
static <I extends OpenSSHLimitsExtensionInfo> |
OpenSSHLimitsExtensionInfo.decode(Buffer buffer,
I info) |
static <I extends OpenSSHStatExtensionInfo> |
OpenSSHStatExtensionInfo.decode(Buffer buffer,
I info) |
Constructor and Description |
---|
OpenSSHLimitsExtensionInfo(Buffer buffer) |
OpenSSHStatExtensionInfo(Buffer buffer) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
SftpInputStreamAsync.buffer |
protected Buffer |
SftpOutputStreamAsync.buffer |
Modifier and Type | Method and Description |
---|---|
protected <B extends Buffer> |
AbstractSftpClient.putReferencedName(int cmd,
B buf,
String name,
int nameIndex) |
protected <B extends Buffer> |
AbstractSftpClient.writeAttributes(int cmd,
B buffer,
SftpClient.Attributes attributes) |
Modifier and Type | Method and Description |
---|---|
Buffer |
DefaultSftpClient.receive(int id) |
Buffer |
DefaultSftpClient.receive(int id,
Duration idleTimeout) |
Buffer |
DefaultSftpClient.receive(int id,
long idleTimeout) |
protected Buffer |
DefaultSftpClient.waitForInitResponse(Duration initializationTimeout) |
Modifier and Type | Method and Description |
---|---|
protected SftpClient.Attributes |
AbstractSftpClient.checkAttributes(int cmd,
Buffer request) |
protected SftpClient.Attributes |
AbstractSftpClient.checkAttributesResponse(int cmd,
Buffer buffer) |
protected void |
AbstractSftpClient.checkCommandStatus(int cmd,
Buffer request)
Sends the specified command, waits for the response and then invokes
AbstractSftpClient.checkResponseStatus(int, Buffer) |
protected int |
AbstractSftpClient.checkData(int cmd,
Buffer request,
int dstOffset,
byte[] dst,
AtomicReference<Boolean> eofSignalled) |
protected int |
AbstractSftpClient.checkDataResponse(int cmd,
Buffer buffer,
int dstoff,
byte[] dst,
AtomicReference<Boolean> eofSignalled) |
protected List<SftpClient.DirEntry> |
AbstractSftpClient.checkDirResponse(int cmd,
Buffer buffer,
AtomicReference<Boolean> eolIndicator) |
protected byte[] |
AbstractSftpClient.checkHandle(int cmd,
Buffer request) |
protected byte[] |
AbstractSftpClient.checkHandleResponse(int cmd,
Buffer buffer) |
protected String |
AbstractSftpClient.checkOneName(int cmd,
Buffer request) |
protected String |
AbstractSftpClient.checkOneNameResponse(int cmd,
Buffer buffer) |
protected void |
AbstractSftpClient.checkResponseStatus(int cmd,
Buffer buffer)
Checks if the incoming response is an
SSH_FXP_STATUS one, and if so whether the substatus is
SSH_FX_OK . |
protected String |
AbstractSftpClient.getReferencedName(int cmd,
Buffer buf,
int nameIndex) |
protected void |
DefaultSftpClient.handleInitResponse(Buffer buffer) |
protected SftpClient.Attributes |
AbstractSftpClient.handleUnexpectedAttributesPacket(int cmd,
int id,
int type,
int length,
Buffer buffer) |
protected byte[] |
AbstractSftpClient.handleUnexpectedHandlePacket(int cmd,
int id,
int type,
int length,
Buffer buffer) |
protected IOException |
AbstractSftpClient.handleUnexpectedPacket(int cmd,
int expected,
int id,
int type,
int length,
Buffer buffer) |
protected int |
AbstractSftpClient.handleUnknownDataPacket(int cmd,
int id,
int type,
int length,
Buffer buffer) |
protected List<SftpClient.DirEntry> |
AbstractSftpClient.handleUnknownDirListingPacket(int cmd,
int id,
int type,
int length,
Buffer buffer) |
protected String |
AbstractSftpClient.handleUnknownOneNamePacket(int cmd,
int id,
int type,
int length,
Buffer buffer) |
protected void |
DefaultSftpClient.process(Buffer incoming)
Process an SFTP packet
|
protected SftpClient.Attributes |
AbstractSftpClient.readAttributes(int cmd,
Buffer buffer,
AtomicInteger nameIndex) |
protected boolean |
DefaultSftpClient.receive(Buffer incoming)
Read SFTP packets from buffer
|
int |
DefaultSftpClient.send(int cmd,
Buffer buffer) |
protected void |
AbstractSftpClient.validateIncomingResponse(int cmd,
int id,
int type,
int length,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
static <B extends Buffer> |
SftpHelper.encodeACLs(B buffer,
int version,
Collection<AclEntry> acl) |
static <B extends Buffer> |
SftpHelper.writeAclEntry(B buffer,
AclEntry acl) |
static <B extends Buffer> |
SftpHelper.writeACLs(B buffer,
int version,
Collection<AclEntry> acl) |
static <B extends Buffer> |
SftpHelper.writeAttributes(B buffer,
SftpClient.Attributes attributes,
int sftpVersion) |
static <B extends Buffer> |
SftpHelper.writeAttrs(B buffer,
int version,
Map<String,?> attributes)
Writes a file / folder's attributes to a buffer
|
static <B extends Buffer> |
SftpHelper.writeAttrsV3(B buffer,
int version,
Map<String,?> attributes)
Writes the retrieved file / directory attributes in V3 format
|
static <B extends Buffer> |
SftpHelper.writeAttrsV4(B buffer,
int version,
Map<String,?> attributes)
Writes the retrieved file / directory attributes in V4+ format
|
static <B extends Buffer> |
SftpHelper.writeExtensions(B buffer,
Map<?,?> extensions) |
static <B extends Buffer> |
SftpHelper.writeTime(B buffer,
int version,
int flags,
FileTime time)
Encodes a
FileTime value into a buffer |
Modifier and Type | Method and Description |
---|---|
static List<AclEntry> |
SftpHelper.decodeACLs(Buffer buffer,
int version) |
static Boolean |
SftpHelper.getEndOfFileIndicatorValue(Buffer buffer,
int version)
Retrieves the end-of-file indicator for
SSH_FXP_DATA responses, provided the version is at least 6, and
the buffer has enough available data |
static Boolean |
SftpHelper.getEndOfListIndicatorValue(Buffer buffer,
int version)
Retrieves the end-of-list indicator for
SSH_FXP_NAME responses, provided the version is at least 6, and
the buffer has enough available data |
static Boolean |
SftpHelper.indicateEndOfNamesList(Buffer buffer,
int version,
PropertyResolver resolver)
Appends the end-of-list=
TRUE indicator for SSH_FXP_NAME responses, provided the version is at
least 6 and the feature is enabled |
static Boolean |
SftpHelper.indicateEndOfNamesList(Buffer buffer,
int version,
PropertyResolver resolver,
boolean indicatorValue)
Appends the end-of-list indicator for
SSH_FXP_NAME responses, provided the version is at least 6, the
feature is enabled and the indicator value is not null |
static List<AclEntry> |
SftpHelper.readACLs(Buffer buffer,
int version) |
static NavigableMap<String,Object> |
SftpHelper.readAttrs(Buffer buffer,
int version) |
static NavigableMap<String,byte[]> |
SftpHelper.readExtensions(Buffer buffer) |
static FileTime |
SftpHelper.readTime(Buffer buffer,
int version,
int flags)
Decodes a
FileTime value from a buffer |
Modifier and Type | Method and Description |
---|---|
static SpaceAvailableExtensionInfo |
SpaceAvailableExtensionInfo.decode(Buffer buffer) |
static void |
SpaceAvailableExtensionInfo.decode(Buffer buffer,
SpaceAvailableExtensionInfo info) |
static void |
SpaceAvailableExtensionInfo.encode(Buffer buffer,
SpaceAvailableExtensionInfo info) |
VendorIdParser.VendorId |
VendorIdParser.parse(Buffer buffer) |
Supported2Parser.Supported2 |
Supported2Parser.parse(Buffer buffer) |
AclSupportedParser.AclCapabilities |
AclSupportedParser.parse(Buffer buffer) |
SupportedParser.Supported |
SupportedParser.parse(Buffer buffer) |
Constructor and Description |
---|
SpaceAvailableExtensionInfo(Buffer buffer) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
SftpSubsystem.buffer |
protected static Buffer |
SftpSubsystem.CLOSE |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<Buffer> |
SftpSubsystem.requests |
Modifier and Type | Method and Description |
---|---|
protected abstract Buffer |
AbstractSftpSubsystemHelper.prepareReply(Buffer buffer) |
protected Buffer |
SftpSubsystem.prepareReply(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractSftpSubsystemHelper.appendAclSupportedExtension(Buffer buffer,
ServerSession session) |
protected void |
AbstractSftpSubsystemHelper.appendExtensions(Buffer buffer,
String supportedVersions) |
protected String |
AbstractSftpSubsystemHelper.appendNewlineExtension(Buffer buffer,
ServerSession session)
Appends the "newline" extension to the buffer.
|
protected List<AbstractOpenSSHExtensionParser.OpenSSHExtension> |
AbstractSftpSubsystemHelper.appendOpenSSHExtensions(Buffer buffer,
ServerSession session) |
protected void |
AbstractSftpSubsystemHelper.appendSupported2Extension(Buffer buffer,
Collection<String> extras)
Appends the "supported2" extension to the buffer.
|
protected void |
AbstractSftpSubsystemHelper.appendSupportedExtension(Buffer buffer,
Collection<String> extras)
Appends the "supported" extension to the buffer.
|
protected Map<String,?> |
AbstractSftpSubsystemHelper.appendVendorIdExtension(Buffer buffer,
Map<String,?> versionProperties,
ServerSession session)
Appends the "vendor-id" extension to the buffer.
|
protected String |
AbstractSftpSubsystemHelper.appendVersionsExtension(Buffer buffer,
String value,
ServerSession session)
Appends the "versions" extension to the buffer.
|
protected Map.Entry<Integer,String> |
AbstractSftpSubsystemHelper.checkVersionCompatibility(Buffer buffer,
int id,
int proposed,
int failureOpcode)
Checks if a proposed version is within supported range.
|
protected void |
AbstractSftpSubsystemHelper.doBlock(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doCheckFileHash(Buffer buffer,
int id,
String targetType) |
protected void |
AbstractSftpSubsystemHelper.doCheckFileHash(int id,
Path file,
NamedFactory<? extends Digest> factory,
long startOffset,
long length,
int blockSize,
Buffer buffer) |
protected abstract void |
AbstractSftpSubsystemHelper.doCheckFileHash(int id,
String targetType,
String target,
Collection<String> algos,
long startOffset,
long length,
int blockSize,
Buffer buffer) |
protected void |
SftpSubsystem.doCheckFileHash(int id,
String targetType,
String target,
Collection<String> algos,
long startOffset,
long length,
int blockSize,
Buffer buffer) |
protected void |
AbstractSftpSubsystemHelper.doClose(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doCopyData(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doCopyFile(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doExtended(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doFSetStat(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doFStat(Buffer buffer,
int id) |
protected abstract void |
AbstractSftpSubsystemHelper.doInit(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doInit(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doLink(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doLStat(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doMakeDirectory(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doMD5Hash(Buffer buffer,
int id,
String targetType) |
protected void |
AbstractSftpSubsystemHelper.doOpen(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doOpenDir(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doOpenSSHFsync(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doOpenSSHHardLink(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doOpenSSHLimits(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doPosixRename(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doProcess(Buffer buffer,
int length,
int type,
int id) |
protected void |
SftpSubsystem.doProcess(Buffer buffer,
int length,
int type,
int id) |
protected void |
AbstractSftpSubsystemHelper.doRead(Buffer buffer,
int id) |
protected abstract void |
AbstractSftpSubsystemHelper.doReadDir(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doReadDir(Buffer buffer,
int id) |
protected int |
AbstractSftpSubsystemHelper.doReadDir(int id,
String handle,
DirectoryHandle dir,
Buffer buffer,
int maxSize,
boolean followLinks) |
protected void |
AbstractSftpSubsystemHelper.doReadLink(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doRealPath(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doRemove(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doRemoveDirectory(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doRename(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doSetStat(Buffer buffer,
int id,
String extension,
int cmd,
Boolean followLinks) |
protected void |
AbstractSftpSubsystemHelper.doSpaceAvailable(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doStat(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doSymLink(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doTextSeek(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doUnblock(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.doUnsupported(Buffer buffer,
int length,
int type,
int id) |
protected void |
AbstractSftpSubsystemHelper.doUnsupportedExtension(Buffer buffer,
int id,
String extension) |
protected void |
AbstractSftpSubsystemHelper.doVersionSelect(Buffer buffer,
int id) |
protected abstract void |
AbstractSftpSubsystemHelper.doVersionSelect(Buffer buffer,
int id,
String proposed) |
protected void |
SftpSubsystem.doVersionSelect(Buffer buffer,
int id,
String proposed) |
protected void |
AbstractSftpSubsystemHelper.doWrite(Buffer buffer,
int id) |
protected void |
AbstractSftpSubsystemHelper.executeExtendedCommand(Buffer buffer,
int id,
String extension) |
protected abstract Buffer |
AbstractSftpSubsystemHelper.prepareReply(Buffer buffer) |
protected Buffer |
SftpSubsystem.prepareReply(Buffer buffer) |
protected void |
AbstractSftpSubsystemHelper.process(Buffer buffer)
Process an SFTP command.
|
default void |
SftpFileSystemAccessor.putRemoteFileName(SftpSubsystemProxy subsystem,
Path path,
Buffer buf,
String name,
boolean shortName)
Invoked in order to encode the outgoing referenced file name/path
|
protected Map<String,Object> |
AbstractSftpSubsystemHelper.readAttrs(Buffer buffer) |
protected abstract void |
AbstractSftpSubsystemHelper.send(Buffer buffer) |
protected void |
SftpSubsystem.send(Buffer buffer) |
protected void |
AbstractSftpSubsystemHelper.sendAttrs(Buffer buffer,
int id,
Map<String,?> attributes) |
protected void |
AbstractSftpSubsystemHelper.sendHandle(Buffer buffer,
int id,
String handle) |
protected void |
AbstractSftpSubsystemHelper.sendLink(Buffer buffer,
int id,
Path file,
String link) |
protected void |
AbstractSftpSubsystemHelper.sendPath(Buffer buffer,
int id,
Path f,
Map<String,?> attrs) |
protected void |
AbstractSftpSubsystemHelper.sendStatus(Buffer buffer,
int id,
int substatus,
String msg) |
protected void |
AbstractSftpSubsystemHelper.sendStatus(Buffer buffer,
int id,
int substatus,
String msg,
String lang) |
protected void |
AbstractSftpSubsystemHelper.sendStatus(Buffer buffer,
int id,
Throwable e,
int cmd,
Object... args)
Invoked when an exception was thrown due to the execution of some SFTP command
|
protected Boolean |
AbstractSftpSubsystemHelper.validateProposedVersion(Buffer buffer,
int id,
String proposal) |
protected void |
AbstractSftpSubsystemHelper.writeAttrs(Buffer buffer,
Map<String,?> attributes) |
protected void |
AbstractSftpSubsystemHelper.writeDirEntry(int id,
DirectoryHandle dir,
Map<String,Path> entries,
Buffer buffer,
int index,
Path f,
String shortName,
LinkOption... options) |
protected void |
AbstractSftpSubsystemHelper.writeDirEntry(ServerSession session,
int id,
Buffer buffer,
int index,
Path f,
String shortName,
SftpClient.Attributes attributes) |
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.