Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
UserAuthPassword.sendPassword(Buffer buffer,
ClientSession session,
java.lang.String oldPassword,
java.lang.String newPassword)
Sends the password via a
SSH_MSG_USERAUTH_REQUEST message. |
Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
AbstractClientSession.sendClientIdentification() |
protected IoWriteFuture |
ClientUserAuthService.sendInitialAuthRequest(ClientSession session,
java.lang.String service) |
Modifier and Type | Class and Description |
---|---|
class |
IoWriteFutureImpl |
protected static class |
SimpleIoOutputStream.DefaultIoWriteFuture |
Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
AbstractChannel.sendEof()
Sends
SSH_MSG_CHANNEL_EOF provided not already sent and current channel state allows it. |
protected IoWriteFuture |
AbstractChannel.sendResponse(Buffer buffer,
java.lang.String req,
RequestHandler.Result result,
boolean wantReply) |
IoWriteFuture |
SimpleIoOutputStream.writeBuffer(Buffer buffer) |
IoWriteFuture |
ChannelAsyncOutputStream.writeBuffer(Buffer buffer) |
IoWriteFuture |
BufferedIoOutputStream.writeBuffer(Buffer buffer) |
IoWriteFuture |
Channel.writePacket(Buffer buffer)
Encode and send the given buffer.
|
IoWriteFuture |
AbstractChannel.writePacket(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
ChannelAsyncOutputStream.onWritten(IoWriteFutureImpl future,
int total,
long length,
IoWriteFuture f) |
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 | Class and Description |
---|---|
class |
AbstractIoWriteFuture |
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
AbstractIoWriteFuture.verify(long timeout) |
IoWriteFuture |
IoSession.writeBuffer(Buffer buffer)
Write a packet on the socket.
|
IoWriteFuture |
IoOutputStream.writeBuffer(Buffer buffer)
Write the given buffer.
|
Modifier and Type | Class and Description |
---|---|
class |
Nio2DefaultIoWriteFuture |
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
Nio2Session.writeBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
IoWriteFuture |
Session.sendDebugMessage(boolean display,
java.lang.Object msg,
java.lang.String lang)
Sends an
SSH_MSG_DEBUG to the peer session |
IoWriteFuture |
Session.sendIgnoreMessage(byte... data)
Sends an
SSH_MSG_IGNORE to the peer session |
IoWriteFuture |
Session.writePacket(Buffer buffer)
Encode and send the given buffer.
|
default IoWriteFuture |
Session.writePacket(Buffer buffer,
java.time.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,
java.util.concurrent.TimeUnit unit)
Encode and send the given buffer with the specified timeout.
|
Modifier and Type | Class and Description |
---|---|
class |
PendingWriteFuture
Future holding a packet pending key exchange termination.
|
Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
AbstractSession.doWritePacket(Buffer buffer) |
protected IoWriteFuture |
AbstractConnectionService.globalRequest(Buffer buffer)
Process global requests
|
protected IoWriteFuture |
AbstractConnectionService.handleUnknownRequest(Buffer buffer,
java.lang.String req,
boolean wantReply) |
protected IoWriteFuture |
AbstractSession.notImplemented(int cmd,
Buffer buffer)
Send a
SSH_MSG_UNIMPLEMENTED packet. |
protected IoWriteFuture |
AbstractConnectionService.sendChannelOpenFailure(Buffer buffer,
int sender,
int reasonCode,
java.lang.String message,
java.lang.String lang) |
IoWriteFuture |
SessionHelper.sendDebugMessage(boolean display,
java.lang.Object msg,
java.lang.String lang) |
protected IoWriteFuture |
DefaultUnknownChannelReferenceHandler.sendFailureResponse(ConnectionService service,
byte cmd,
int channelId) |
protected IoWriteFuture |
AbstractConnectionService.sendGlobalResponse(Buffer buffer,
java.lang.String req,
RequestHandler.Result result,
boolean wantReply) |
protected IoWriteFuture |
SessionHelper.sendIdentification(java.lang.String ident)
Send our identification.
|
IoWriteFuture |
SessionHelper.sendIgnoreMessage(byte... data) |
protected IoWriteFuture |
AbstractSession.sendNewKeys()
Send a message to put new keys into use.
|
protected IoWriteFuture |
SessionHelper.sendNotImplemented(long seqNoValue)
Sends a
SSH_MSG_UNIMPLEMENTED message |
IoWriteFuture |
AbstractSession.writePacket(Buffer buffer) |
IoWriteFuture |
SessionHelper.writePacket(Buffer buffer,
long timeout,
java.util.concurrent.TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<java.util.AbstractMap.SimpleImmutableEntry<PendingWriteFuture,IoWriteFuture>> |
AbstractSession.sendPendingPackets(java.util.Queue<PendingWriteFuture> packetsQueue) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractConnectionService.futureDone(IoWriteFuture future) |
void |
PendingWriteFuture.operationComplete(IoWriteFuture future) |
Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
ChannelSession.sendResponse(Buffer buffer,
java.lang.String req,
RequestHandler.Result result,
boolean wantReply) |
Modifier and Type | Method and Description |
---|---|
protected IoWriteFuture |
AbstractServerSession.sendServerIdentification(java.lang.String... headerLines)
Sends the server identification + any extra header lines
|
IoWriteFuture |
ServerUserAuthService.sendWelcomeBanner(ServerSession session)
Sends the welcome banner (if any configured) and if not already invoked
|
IoWriteFuture |
ServerSession.signalAuthenticationSuccess(java.lang.String username,
java.lang.String authService,
Buffer buffer) |
IoWriteFuture |
AbstractServerSession.signalAuthenticationSuccess(java.lang.String username,
java.lang.String authService,
Buffer buffer) |