Modifier and Type | Method and Description |
---|---|
protected Buffer |
AbstractAgentProxy.createBuffer(byte cmd) |
protected Buffer |
AbstractAgentClient.prepare(Buffer buf) |
protected Buffer |
AbstractAgentProxy.prepare(Buffer buffer) |
protected abstract Buffer |
AbstractAgentProxy.request(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAgentClient.messageReceived(Buffer message) |
protected Buffer |
AbstractAgentClient.prepare(Buffer buf) |
protected Buffer |
AbstractAgentProxy.prepare(Buffer buffer) |
protected void |
AbstractAgentClient.process(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) |
Modifier and Type | Method and Description |
---|---|
boolean |
UserAuthPublicKey.process(Buffer buffer) |
boolean |
UserAuthKeyboardInteractive.process(Buffer buffer) |
boolean |
UserAuthPassword.process(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
UserAuth.Result |
UserAuthAgent.next(Buffer buffer) |
UserAuth.Result |
UserAuthPublicKey.next(Buffer buffer) |
UserAuth.Result |
UserAuth.next(Buffer buffer) |
UserAuth.Result |
UserAuthKeyboardInteractive.next(Buffer buffer) |
UserAuth.Result |
UserAuthPassword.next(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClientChannel.handleOpenFailure(Buffer buffer) |
void |
AbstractClientChannel.handleOpenSuccess(int recipient,
int rwsize,
int rmpsize,
Buffer buffer) |
void |
AbstractClientChannel.handleWindowAdjust(Buffer buffer) |
OpenFuture |
AbstractClientChannel.open(int recipient,
int rwsize,
int rmpsize,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
DHGEX.next(Buffer buffer) |
boolean |
AbstractDHGClient.next(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientSessionImpl.handleMessage(Buffer buffer) |
void |
ClientUserAuthService.process(byte cmd,
Buffer buffer) |
void |
ClientUserAuthServiceNew.process(byte cmd,
Buffer buffer) |
void |
ClientUserAuthServiceOld.process(byte cmd,
Buffer buffer) |
protected boolean |
ClientSessionImpl.readIdentification(Buffer buffer) |
protected void |
ClientSessionImpl.receiveKexInit(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
DefaultSftpClient.read() |
protected Buffer |
DefaultSftpClient.receive(int id) |
Modifier and Type | Method and Description |
---|---|
protected SftpClient.Attributes |
DefaultSftpClient.checkAttributes(Buffer buffer) |
protected int |
DefaultSftpClient.checkData(Buffer buffer,
int dstoff,
byte[] dst) |
protected SftpClient.DirEntry[] |
DefaultSftpClient.checkDir(Buffer buffer) |
protected SftpClient.Handle |
DefaultSftpClient.checkHandle(Buffer buffer) |
protected String |
DefaultSftpClient.checkOneName(Buffer buffer) |
protected void |
DefaultSftpClient.checkStatus(Buffer buffer) |
protected void |
DefaultSftpClient.process(Buffer incoming)
Process an SFTP packet
|
protected SftpClient.Attributes |
DefaultSftpClient.readAttributes(Buffer buffer) |
protected boolean |
DefaultSftpClient.receive(Buffer incoming)
Read SFTP packets from buffer
|
protected int |
DefaultSftpClient.send(int cmd,
Buffer buffer) |
protected void |
DefaultSftpClient.writeAttributes(Buffer buffer,
SftpClient.Attributes attributes) |
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 |
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.request(Buffer buffer)
Send a global request and wait for the response.
|
Modifier and Type | Method and Description |
---|---|
void |
Compression.compress(Buffer buffer)
Compress the given buffer in place.
|
void |
Channel.handleData(Buffer buffer) |
void |
Channel.handleExtendedData(Buffer buffer) |
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 rmpsize,
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 |
Channel.handleWindowAdjust(Buffer buffer) |
boolean |
KeyExchange.next(Buffer buffer)
Process the next packet
|
OpenFuture |
Channel.open(int recipient,
int rwsize,
int rmpsize,
Buffer buffer)
For a server channel, this method will actually open the channel
|
void |
Service.process(byte cmd,
Buffer buffer)
Service the request.
|
RequestHandler.Result |
RequestHandler.process(T t,
String request,
boolean wantReply,
Buffer buffer)
Process the ssh-connection global request.
|
Buffer |
Session.request(Buffer buffer)
Send a global request and wait for the response.
|
void |
Compression.uncompress(Buffer from,
Buffer to)
Uncompress the data in a buffer into another buffer.
|
IoWriteFuture |
Session.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.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
ChannelAsyncOutputStream.IoWriteFutureImpl.getBuffer() |
Buffer |
ChannelAsyncInputStream.IoReadFutureImpl.getBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractChannel.handleData(Buffer buffer) |
void |
AbstractChannel.handleExtendedData(Buffer buffer) |
void |
AbstractChannel.handleRequest(Buffer buffer) |
void |
AbstractChannel.handleWindowAdjust(Buffer buffer) |
IoReadFuture |
ChannelAsyncInputStream.read(Buffer buf) |
IoWriteFuture |
BufferedIoOutputStream.write(Buffer buffer) |
IoWriteFuture |
ChannelAsyncOutputStream.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 |
CompressionZlib.uncompress(Buffer from,
Buffer to) |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
TcpipServerChannel.doInit(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 |
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 |
IoOutputStream.write(Buffer buffer)
NOTE: the buffer must not be touched until the returned write future is completed.
|
IoWriteFuture |
IoSession.write(Buffer buffer)
Write a packet on the socket.
|
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 | Field and Description |
---|---|
protected Buffer |
AbstractSession.decoderBuffer |
protected Buffer |
AbstractSession.uncompressBuffer |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Buffer> |
AbstractSession.requestResult |
Modifier and Type | Method and Description |
---|---|
Buffer |
AbstractSession.createBuffer(byte cmd) |
Buffer |
AbstractSession.createBuffer(byte cmd,
int len)
Create a new buffer for the specified SSH packet and reserve the needed space
(5 bytes) for the packet header.
|
Buffer |
AbstractSession.PendingWriteFuture.getBuffer() |
Buffer |
AbstractSession.request(Buffer buffer)
Send a global request and wait for the response.
|
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.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 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.handleMessage(Buffer buffer)
Abstract method for processing incoming decoded packets.
|
void |
AbstractConnectionService.process(byte cmd,
Buffer buffer) |
protected abstract boolean |
AbstractSession.readIdentification(Buffer buffer)
Read the other side identification.
|
protected abstract void |
AbstractSession.receiveKexInit(Buffer buffer) |
protected byte[] |
AbstractSession.receiveKexInit(Buffer buffer,
String[] proposal)
Receive the remote key exchange init message.
|
Buffer |
AbstractSession.request(Buffer buffer)
Send a global request and wait for the response.
|
protected void |
AbstractSession.requestFailure(Buffer buffer) |
protected void |
AbstractConnectionService.requestFailure(Buffer buffer) |
protected void |
AbstractSession.requestSuccess(Buffer buffer) |
protected void |
AbstractConnectionService.requestSuccess(Buffer buffer) |
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer)
Encode and send the given buffer.
|
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer,
long timeout,
TimeUnit unit) |
Constructor and Description |
---|
PendingWriteFuture(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 |
UserAuth.next(Buffer buffer)
Handle another step in the authentication process.
|
Modifier and Type | Method and Description |
---|---|
Boolean |
AbstractUserAuth.auth(ServerSession session,
String username,
String service,
Buffer buffer) |
protected abstract Boolean |
AbstractUserAuth.doAuth(Buffer buffer,
boolean init) |
Boolean |
UserAuthPublicKey.doAuth(Buffer buffer,
boolean init) |
protected Boolean |
UserAuthKeyboardInteractive.doAuth(Buffer buffer,
boolean init) |
Boolean |
UserAuthNone.doAuth(Buffer buffer,
boolean init) |
Boolean |
UserAuthPassword.doAuth(Buffer buffer,
boolean init) |
Boolean |
AbstractUserAuth.next(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
UserAuthGSS.doAuth(Buffer buffer,
boolean initial)
Handle the first authentication step.
|
Modifier and Type | Field and Description |
---|---|
protected Buffer |
ChannelSession.tempBuffer |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
AbstractServerChannel.doInit(Buffer buffer) |
protected boolean |
ChannelSession.handleAgentForwarding(Buffer buffer) |
protected boolean |
ChannelSession.handleBreak(Buffer buffer) |
protected boolean |
ChannelSession.handleEnv(Buffer buffer) |
protected boolean |
ChannelSession.handleExec(Buffer buffer) |
void |
AbstractServerChannel.handleOpenFailure(Buffer buffer) |
void |
AbstractServerChannel.handleOpenSuccess(int recipient,
int rwsize,
int rmpsize,
Buffer buffer) |
protected boolean |
ChannelSession.handlePtyReq(Buffer buffer) |
Boolean |
ChannelSession.handleRequest(String type,
Buffer buffer) |
protected boolean |
ChannelSession.handleShell(Buffer buffer) |
protected boolean |
ChannelSession.handleSignal(Buffer buffer) |
protected boolean |
ChannelSession.handleSubsystem(Buffer buffer) |
void |
ChannelSession.handleWindowAdjust(Buffer buffer) |
protected boolean |
ChannelSession.handleWindowChange(Buffer buffer) |
protected boolean |
ChannelSession.handleX11Forwarding(Buffer buffer) |
OpenFuture |
AbstractServerChannel.open(int recipient,
int rwsize,
int rmpsize,
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 |
---|---|
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 |
CancelTcpipForwardHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
RequestHandler.Result |
KeepAliveHandler.process(ConnectionService connectionService,
String request,
boolean wantReply,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractDHGServer.next(Buffer buffer) |
boolean |
DHGEX.next(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
ServerUserAuthService.process(byte cmd,
Buffer buffer) |
protected boolean |
ServerSession.readIdentification(Buffer buffer) |
protected void |
ServerSession.receiveKexInit(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
SftpSubsystem.process(Buffer buffer) |
protected Map<SshFile.Attribute,Object> |
SftpSubsystem.readAttrs(Buffer buffer) |
protected void |
SftpSubsystem.send(Buffer buffer) |
protected void |
SftpSubsystem.writeAttrs(Buffer buffer,
SshFile file,
boolean followLinks) |
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.