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) |
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 |
---|---|
protected Buffer |
AgentClient.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
ChannelAgentForwarding.doInit(Buffer buffer) |
protected void |
AgentClient.messageReceived(Buffer buffer) |
protected void |
AgentServer.SshAgentSession.reply(Buffer buf) |
protected Buffer |
AgentClient.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
UserAuth.process(Buffer buffer) |
boolean |
AbstractUserAuth.process(Buffer buffer) |
protected abstract boolean |
AbstractUserAuth.processAuthDataRequest(ClientSession session,
String service,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UserAuthHostBased.processAuthDataRequest(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 void |
UserAuthPassword.sendPassword(Buffer buffer,
ClientSession session,
String oldPassword,
String newPassword)
Sends the password via a
SSH_MSG_USERAUTH_REQUEST message. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UserAuthPublicKey.processAuthDataRequest(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(int recipient,
int rwSize,
int packetSize,
Buffer buffer) |
void |
AbstractClientChannel.handleWindowAdjust(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleXonXoff(Buffer buffer,
boolean wantReply) |
OpenFuture |
AbstractClientChannel.open(int recipient,
int rwSize,
int packetSize,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
RequestHandler.Result |
AbstractChannelExitRequestHandler.process(Channel channel,
String request,
boolean wantReply,
Buffer buffer) |
protected Integer |
ExitStatusChannelRequestHandler.processRequestValue(Channel channel,
String request,
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 |
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 |
DHGEXClient.next(int cmd,
Buffer buffer) |
boolean |
DHGClient.next(int cmd,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientSessionImpl.handleDisconnect(int code,
String msg,
String lang,
Buffer buffer) |
protected void |
ClientSessionImpl.handleMessage(Buffer buffer) |
void |
ClientUserAuthService.process(int cmd,
Buffer buffer) |
protected void |
ClientUserAuthService.processUserAuth(Buffer buffer)
Execute one step in user authentication.
|
protected boolean |
ClientSessionImpl.readIdentification(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
DefaultSftpClient.read() |
Buffer |
RawSftpClient.receive(int id) |
Buffer |
DefaultSftpClient.receive(int id) |
Modifier and Type | Method and Description |
---|---|
protected SftpClient.Attributes |
AbstractSftpClient.checkAttributes(Buffer buffer) |
protected SftpClient.Attributes |
AbstractSftpClient.checkAttributes(int cmd,
Buffer request) |
protected int |
AbstractSftpClient.checkData(Buffer buffer,
int dstoff,
byte[] dst,
AtomicReference<Boolean> eofSignalled) |
protected int |
AbstractSftpClient.checkData(int cmd,
Buffer request,
int dstOffset,
byte[] dst,
AtomicReference<Boolean> eofSignalled) |
protected List<SftpClient.DirEntry> |
AbstractSftpClient.checkDir(Buffer buffer,
AtomicReference<Boolean> eolIndicator) |
protected byte[] |
AbstractSftpClient.checkHandle(Buffer buffer) |
protected byte[] |
AbstractSftpClient.checkHandle(int cmd,
Buffer request) |
protected String |
AbstractSftpClient.checkOneName(Buffer buffer) |
protected String |
AbstractSftpClient.checkOneName(int cmd,
Buffer request) |
protected void |
AbstractSftpClient.checkStatus(Buffer buffer)
Checks if the incoming response is an
SSH_FXP_STATUS one,
and if so whether the substatus is SSH_FX_OK . |
protected void |
AbstractSftpClient.checkStatus(int cmd,
Buffer request)
Sends the specified command, waits for the response and then invokes
AbstractSftpClient.checkStatus(Buffer) |
protected SftpClient.Attributes |
AbstractSftpClient.handleUnexpectedAttributesPacket(int id,
int type,
int length,
Buffer buffer) |
protected byte[] |
AbstractSftpClient.handleUnexpectedHandlePacket(int id,
int type,
int length,
Buffer buffer) |
protected IOException |
AbstractSftpClient.handleUnexpectedPacket(int expected,
int id,
int type,
int length,
Buffer buffer) |
protected int |
AbstractSftpClient.handleUnknownDataPacket(int id,
int type,
int length,
Buffer buffer) |
protected List<SftpClient.DirEntry> |
AbstractSftpClient.handleUnknownDirListingPacket(int id,
int type,
int length,
Buffer buffer) |
protected String |
AbstractSftpClient.handleUnknownOneNamePacket(int id,
int type,
int length,
Buffer buffer) |
protected void |
DefaultSftpClient.process(Buffer incoming)
Process an SFTP packet
|
protected SftpClient.Attributes |
AbstractSftpClient.readAttributes(Buffer buffer) |
protected boolean |
DefaultSftpClient.receive(Buffer incoming)
Read SFTP packets from buffer
|
int |
RawSftpClient.send(int cmd,
Buffer buffer) |
int |
DefaultSftpClient.send(int cmd,
Buffer buffer) |
protected void |
AbstractSftpClient.writeAttributes(Buffer buffer,
SftpClient.Attributes attributes) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static OpenSSHStatExtensionInfo |
OpenSSHStatExtensionInfo.decode(Buffer buffer) |
static void |
OpenSSHStatExtensionInfo.decode(Buffer buffer,
OpenSSHStatExtensionInfo info) |
static void |
OpenSSHStatExtensionInfo.encode(Buffer buffer,
OpenSSHStatExtensionInfo info) |
Constructor and Description |
---|
OpenSSHStatExtensionInfo(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
Service.process(int cmd,
Buffer buffer)
Service the request.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
IoWriteFutureImpl.getBuffer() |
Buffer |
ChannelAsyncInputStream.IoReadFutureImpl.getBuffer() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractChannel.handleChannelRequest(String req,
boolean wantReply,
Buffer buffer) |
void |
Channel.handleData(Buffer buffer) |
void |
AbstractChannel.handleData(Buffer buffer) |
void |
Channel.handleExtendedData(Buffer buffer) |
void |
AbstractChannel.handleExtendedData(Buffer buffer) |
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(int recipient,
int rwSize,
int packetSize,
Buffer buffer)
For a client channel, this method will be called internally by the
session when the confirmation has been received.
|
void |
Channel.handleRequest(Buffer buffer) |
void |
AbstractChannel.handleRequest(Buffer buffer) |
protected void |
AbstractChannel.handleUnknownChannelRequest(String req,
boolean wantReply,
Buffer buffer)
Called when none of the register request handlers reported handling the request
|
void |
Channel.handleWindowAdjust(Buffer buffer) |
void |
AbstractChannel.handleWindowAdjust(Buffer buffer) |
OpenFuture |
Channel.open(int recipient,
int rwSize,
int 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 void |
AbstractChannel.sendResponse(Buffer buffer,
String req,
RequestHandler.Result result,
boolean wantReply) |
IoWriteFuture |
ChannelAsyncOutputStream.write(Buffer buffer) |
IoWriteFuture |
BufferedIoOutputStream.write(Buffer buffer) |
protected void |
AbstractChannel.writePacket(Buffer buffer) |
Constructor and Description |
---|
IoReadFutureImpl(Buffer buffer) |
IoWriteFutureImpl(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
CompressionZlib.compress(Buffer buffer) |
void |
CompressionNone.compress(Buffer buffer) |
void |
Compression.compress(Buffer buffer)
Compress the given buffer in place.
|
void |
CompressionZlib.uncompress(Buffer from,
Buffer to) |
void |
CompressionNone.uncompress(Buffer from,
Buffer to) |
void |
Compression.uncompress(Buffer from,
Buffer to)
Uncompress the data in a buffer into another buffer.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
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() |
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.write(Buffer buffer)
Write a packet on the socket.
|
IoWriteFuture |
IoOutputStream.write(Buffer buffer)
NOTE: the buffer must not be touched until the returned write future is completed.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.mina.core.buffer.IoBuffer |
MinaSupport.asIoBuffer(Buffer buffer) |
IoWriteFuture |
MinaSession.write(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
Nio2Session.write(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
KeyExchange.next(int cmd,
Buffer buffer)
Process the next packet
|
Modifier and Type | Field and Description |
---|---|
protected Buffer |
AbstractSession.decoderBuffer |
protected Buffer |
AbstractSession.uncompressBuffer |
Modifier and Type | Method and Description |
---|---|
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 |
AbstractSession.createBuffer(byte cmd) |
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 |
AbstractSession.createBuffer(byte cmd,
int len) |
Buffer |
PendingWriteFuture.getBuffer() |
Buffer |
Session.prepareBuffer(byte cmd,
Buffer buffer)
Prepare a new "clean" buffer while reserving the needed space
(5 bytes) for the packet header.
|
Buffer |
AbstractSession.prepareBuffer(byte cmd,
Buffer buffer) |
Buffer |
Session.request(Buffer buffer,
long timeout,
TimeUnit unit)
Send a global request and wait for the response.
|
Buffer |
AbstractSession.request(Buffer buffer,
long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
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 String |
AbstractSession.doReadIdentification(Buffer buffer,
boolean server)
Read the remote identification from this buffer.
|
protected IoWriteFuture |
AbstractSession.doWritePacket(Buffer buffer) |
protected void |
AbstractSession.encode(Buffer buffer)
Encode a buffer into the SSH protocol.
|
protected Channel |
AbstractConnectionService.getChannel(Buffer buffer)
Retrieve the channel designated by the given packet
|
protected void |
AbstractConnectionService.globalRequest(Buffer buffer)
Process global requests
|
protected void |
AbstractSession.handleDebug(boolean display,
String msg,
String lang,
Buffer buffer) |
protected void |
AbstractSession.handleDebug(Buffer buffer) |
protected void |
AbstractSession.handleDisconnect(Buffer buffer) |
protected void |
AbstractSession.handleDisconnect(int code,
String msg,
String lang,
Buffer buffer) |
protected boolean |
AbstractSession.handleFirstKexPacketFollows(int cmd,
Buffer buffer,
boolean followFlag) |
protected void |
AbstractSession.handleIgnore(Buffer buffer) |
protected void |
AbstractSession.handleIgnore(byte[] data,
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.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 void |
AbstractSession.handleServiceRequest(String serviceName,
Buffer buffer) |
protected void |
AbstractSession.handleUnimplemented(Buffer buffer) |
protected void |
AbstractSession.handleUnimplemented(int seqNo,
Buffer buffer) |
protected void |
AbstractConnectionService.handleUnknownRequest(Buffer buffer,
String req,
boolean wantReply) |
Buffer |
Session.prepareBuffer(byte cmd,
Buffer buffer)
Prepare a new "clean" buffer while reserving the needed space
(5 bytes) for the packet header.
|
Buffer |
AbstractSession.prepareBuffer(byte cmd,
Buffer buffer) |
RequestHandler.Result |
ConnectionServiceRequestHandler.process(ConnectionService service,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
AbstractConnectionServiceRequestHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
void |
AbstractConnectionService.process(int cmd,
Buffer buffer) |
protected abstract boolean |
AbstractSession.readIdentification(Buffer buffer)
Read the other side identification.
|
protected void |
AbstractSession.receiveKexInit(Buffer buffer) |
protected byte[] |
AbstractSession.receiveKexInit(Buffer buffer,
Map<KexProposalOption,String> proposal)
Receive the remote key exchange init message.
|
Buffer |
Session.request(Buffer buffer,
long timeout,
TimeUnit unit)
Send a global request and wait for the response.
|
Buffer |
AbstractSession.request(Buffer buffer,
long timeout,
TimeUnit unit) |
protected void |
AbstractSession.requestFailure(Buffer buffer) |
protected void |
AbstractConnectionService.requestFailure(Buffer buffer) |
protected void |
AbstractSession.requestSuccess(Buffer buffer) |
protected void |
AbstractConnectionService.requestSuccess(Buffer buffer) |
protected void |
AbstractConnectionService.sendChannelOpenFailure(Buffer buffer,
int sender,
int reasonCode,
String message,
String lang) |
protected void |
AbstractConnectionService.sendGlobalResponse(Buffer buffer,
String req,
RequestHandler.Result result,
boolean wantReply) |
IoWriteFuture |
Session.writePacket(Buffer buffer)
Encode and send the given buffer.
|
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer)
Encode and send the given buffer.
|
IoWriteFuture |
Session.writePacket(Buffer buffer,
long timeout,
TimeUnit unit)
Encode and send the given buffer with the specified timeout.
|
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer,
long timeout,
TimeUnit unit) |
Constructor and Description |
---|
PendingWriteFuture(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
static List<AclEntry> |
SftpHelper.decodeACLs(Buffer buffer,
int version) |
static void |
SftpHelper.encodeACLs(Buffer buffer,
int version,
Collection<? extends AclEntry> acl) |
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 Map<String,Object> |
SftpHelper.readAttrs(Buffer buffer,
int version) |
static Map<String,byte[]> |
SftpHelper.readExtensions(Buffer buffer) |
static FileTime |
SftpHelper.readTime(Buffer buffer,
int version,
int flags)
Decodes a
FileTime value from a buffer |
static void |
SftpHelper.writeAclEntry(Buffer buffer,
AclEntry acl) |
static void |
SftpHelper.writeACLs(Buffer buffer,
int version,
Collection<? extends AclEntry> acl) |
static void |
SftpHelper.writeAttrs(Buffer buffer,
int version,
Map<String,?> attributes)
Writes a file / folder's attributes to a buffer
|
static void |
SftpHelper.writeAttrsV3(Buffer buffer,
int version,
Map<String,?> attributes)
Writes the retrieved file / directory attributes in V3 format
|
static void |
SftpHelper.writeAttrsV4(Buffer buffer,
int version,
Map<String,?> attributes)
Writes the retrieved file / directory attributes in V4+ format
|
static void |
SftpHelper.writeExtensions(Buffer buffer,
Map<?,?> extensions) |
static void |
SftpHelper.writeTime(Buffer buffer,
int version,
int flags,
FileTime time)
Encodes a
FileTime value into 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) |
SupportedParser.Supported |
SupportedParser.parse(Buffer buffer) |
Supported2Parser.Supported2 |
Supported2Parser.parse(Buffer buffer) |
AclSupportedParser.AclCapabilities |
AclSupportedParser.parse(Buffer buffer) |
Constructor and Description |
---|
SpaceAvailableExtensionInfo(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 |
---|---|
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,
int 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) |
RSAPublicKey |
RSABufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
PublicKey |
ED25519BufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
ECPublicKey |
ECBufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
DSAPublicKey |
DSSBufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
PUB |
BufferPublicKeyParser.getRawPublicKey(String keyType,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Boolean |
UserAuth.auth(ServerSession session,
String username,
String service,
Buffer buffer)
Try to authenticate the user.
|
Boolean |
AbstractUserAuth.auth(ServerSession session,
String username,
String service,
Buffer buffer) |
Boolean |
UserAuthNone.doAuth(Buffer buffer,
boolean init) |
protected abstract Boolean |
AbstractUserAuth.doAuth(Buffer buffer,
boolean init) |
Boolean |
UserAuth.next(Buffer buffer)
Handle another step in the authentication process.
|
Boolean |
AbstractUserAuth.next(Buffer buffer) |
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> |
PromptEntry.append(B buffer) |
<B extends Buffer> |
InteractiveChallenge.append(B buffer) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthKeyboardInteractive.doAuth(Buffer buffer,
boolean init) |
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) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
ChannelSession.tempBuffer |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
AbstractServerChannel.doInit(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleAgentForwarding(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(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleInternalRequest(String requestType,
boolean wantReply,
Buffer buffer) |
void |
AbstractServerChannel.handleOpenFailure(Buffer buffer) |
void |
AbstractServerChannel.handleOpenSuccess(int recipient,
int rwSize,
int packetSize,
Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handlePtyReq(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleShell(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleSignal(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleSubsystem(Buffer buffer,
boolean wantReply) |
void |
ChannelSession.handleWindowAdjust(Buffer buffer) |
protected RequestHandler.Result |
ChannelSession.handleWindowChange(Buffer buffer,
boolean wantReply) |
protected RequestHandler.Result |
ChannelSession.handleX11Forwarding(Buffer buffer,
boolean wantReply) |
OpenFuture |
AbstractServerChannel.open(int recipient,
int rwSize,
int 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) |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
TcpipServerChannel.doInit(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 |
NoMoreSessionsHandler.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) |
Modifier and Type | Method and Description |
---|---|
boolean |
DHGServer.next(int cmd,
Buffer buffer) |
boolean |
DHGEXServer.next(int cmd,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerUserAuthService.handleAuthenticationFailure(int cmd,
Buffer buffer) |
protected void |
ServerUserAuthService.handleAuthenticationInProgress(int cmd,
Buffer buffer) |
protected void |
ServerUserAuthService.handleAuthenticationSuccess(int cmd,
Buffer buffer) |
void |
ServerUserAuthService.process(int cmd,
Buffer buffer) |
protected boolean |
ServerSessionImpl.readIdentification(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 |
---|---|
protected int |
SftpSubsystem.appendAclSupportedExtension(Buffer buffer) |
protected void |
SftpSubsystem.appendExtensions(Buffer buffer,
String supportedVersions) |
protected void |
SftpSubsystem.appendNewlineExtension(Buffer buffer,
String value)
Appends the "newline" extension to the buffer.
|
protected List<AbstractOpenSSHExtensionParser.OpenSSHExtension> |
SftpSubsystem.appendOpenSSHExtensions(Buffer buffer) |
protected void |
SftpSubsystem.appendSupported2Extension(Buffer buffer,
Collection<String> extras)
Appends the "supported2" extension to the buffer.
|
protected void |
SftpSubsystem.appendSupportedExtension(Buffer buffer,
Collection<String> extras)
Appends the "supported" extension to the buffer.
|
protected void |
SftpSubsystem.appendVendorIdExtension(Buffer buffer,
Map<String,?> versionProperties)
Appends the "vendor-id" extension to the buffer.
|
protected void |
SftpSubsystem.appendVersionsExtension(Buffer buffer,
String value)
Appends the "versions" extension to the buffer.
|
protected String |
SftpSubsystem.checkVersionCompatibility(Buffer buffer,
int id,
int proposed,
int failureOpcode)
Checks if a proposed version is within supported range.
|
protected void |
SftpSubsystem.doBlock(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doCheckFileHash(Buffer buffer,
int id,
String targetType) |
protected void |
SftpSubsystem.doCheckFileHash(int id,
Path file,
NamedFactory<? extends Digest> factory,
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 |
SftpSubsystem.doClose(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doCopyData(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doCopyFile(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doExtended(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doFSetStat(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doFStat(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doInit(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doLink(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doLStat(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doMakeDirectory(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doMD5Hash(Buffer buffer,
int id,
String targetType) |
protected void |
SftpSubsystem.doOpen(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doOpenDir(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doOpenSSHFsync(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doRead(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doReadDir(Buffer buffer,
int id) |
protected int |
SftpSubsystem.doReadDir(int id,
String handle,
DirectoryHandle dir,
Buffer buffer,
int maxSize) |
protected void |
SftpSubsystem.doReadLink(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doRealPath(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doRemove(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doRemoveDirectory(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doRename(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doSetStat(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doSpaceAvailable(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doStat(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doSymLink(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doTextSeek(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doUnblock(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doVersionSelect(Buffer buffer,
int id) |
protected void |
SftpSubsystem.doWrite(Buffer buffer,
int id) |
protected void |
SftpSubsystem.executeExtendedCommand(Buffer buffer,
int id,
String extension) |
protected void |
SftpSubsystem.process(Buffer buffer) |
protected Map<String,Object> |
SftpSubsystem.readAttrs(Buffer buffer) |
protected void |
SftpSubsystem.send(Buffer buffer) |
protected void |
SftpSubsystem.sendAttrs(Buffer buffer,
int id,
Map<String,?> attributes) |
protected void |
SftpSubsystem.sendHandle(Buffer buffer,
int id,
String handle) |
protected void |
SftpSubsystem.sendLink(Buffer buffer,
int id,
String link) |
protected void |
SftpSubsystem.sendPath(Buffer buffer,
int id,
Path f,
Map<String,?> attrs) |
protected void |
SftpSubsystem.sendStatus(Buffer buffer,
int id,
Exception e) |
protected void |
SftpSubsystem.sendStatus(Buffer buffer,
int id,
int substatus,
String msg) |
protected void |
SftpSubsystem.sendStatus(Buffer buffer,
int id,
int substatus,
String msg,
String lang) |
protected Boolean |
SftpSubsystem.validateProposedVersion(Buffer buffer,
int id,
String proposed) |
protected void |
SftpSubsystem.writeAttrs(Buffer buffer,
Map<String,?> attributes) |
protected void |
SftpSubsystem.writeDirEntry(int id,
DirectoryHandle dir,
Map<String,Path> entries,
Buffer buffer,
int index,
Path f,
String shortName,
LinkOption... options) |
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.