org.apache.sshd.server.channel

Class ChannelSession

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.util.closeable.IoBaseCloseable

org.apache.sshd.common.util.closeable.AbstractCloseable

org.apache.sshd.common.util.closeable.AbstractInnerCloseable

org.apache.sshd.common.channel.AbstractChannel

org.apache.sshd.server.channel.AbstractServerChannel

org.apache.sshd.server.channel.ChannelSession

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, AttributeRepository, AttributeStore, ChannelListenerManager, ChannelStreamPacketWriterResolver, ChannelStreamPacketWriterResolverManager, PacketWriter, PropertyResolver, ExecutorServiceCarrier, ServerChannel, ServerSessionHolder

public class ChannelSession
extends AbstractServerChannel

TODO Add javadocWindowInitTest

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ChannelSession.CommandCloseable

Nested classes/interfaces inherited from class org.apache.sshd.common.channel.AbstractChannel

AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState

Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

AbstractCloseable.State

Nested classes/interfaces inherited from interface org.apache.sshd.common.AttributeRepository

AttributeRepository.AttributeKey<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelAsyncOutputStream	asyncErr
protected ChannelAsyncOutputStream	asyncOut
protected CloseFuture	commandExitFuture
protected Command	commandInstance
protected java.util.concurrent.atomic.AtomicBoolean	commandStarted
static java.util.List<ChannelRequestHandler>	DEFAULT_HANDLERS
protected StandardEnvironment	env
protected java.io.OutputStream	err
protected java.io.OutputStream	out
protected ChannelDataReceiver	receiver
protected Buffer	tempBuffer
protected java.lang.String	type

Fields inherited from class org.apache.sshd.server.channel.AbstractServerChannel

exitStatusSent

Fields inherited from class org.apache.sshd.common.channel.AbstractChannel

channelListenerProxy, channelListeners, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service

Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

closeFuture, lock, state

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

log

Fields inherited from interface org.apache.sshd.common.channel.Channel

CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM

Fields inherited from interface org.apache.sshd.common.PropertyResolver

EMPTY

Fields inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamPacketWriterResolver

NONE

Fields inherited from interface org.apache.sshd.common.Closeable

CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
ChannelSession()
ChannelSession(java.util.Collection<? extends RequestHandler<Channel>> handlers)

Method Summary

Modifier and Type	Method and Description
protected void	addEnvVariable(java.lang.String name, java.lang.String value)
protected void	closeImmediately0()
protected void	closeShell(int exitValue)
protected void	doWriteData(byte[] data, int off, long len)
protected void	doWriteExtendedData(byte[] data, int off, long len)
StandardEnvironment	getEnvironment()
protected Closeable	getInnerCloseable()
protected int	getPtyModeValue(PtyMode mode)
ServerSession	getSession()
protected RequestHandler.Result	handleAgentForwarding(java.lang.String requestType, Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleBreak(Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleEnv(Buffer buffer, boolean wantReply)
void	handleEof() Invoked when SSH_MSG_CHANNEL_EOF received
protected RequestHandler.Result	handleExec(java.lang.String request, Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleInternalRequest(java.lang.String requestType, 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.
protected RequestHandler.Result	handlePtyReq(Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleShell(java.lang.String request, Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleSignal(Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleSubsystem(java.lang.String request, Buffer buffer, boolean wantReply)
void	handleWindowAdjust(Buffer buffer) Invoked when SSH_MSG_CHANNEL_WINDOW_ADJUST received
protected RequestHandler.Result	handleWindowChange(Buffer buffer, boolean wantReply)
protected RequestHandler.Result	handleX11Forwarding(java.lang.String requestType, Buffer buffer, boolean wantReply)
protected RequestHandler.Result	prepareChannelCommand(java.lang.String request, Command cmd)
protected Command	prepareCommand(java.lang.String requestType, Command command) Called by prepareChannelCommand(String, Command) in order to set up the command's streams, session, file-system, exit callback, etc..
protected IoWriteFuture	sendResponse(Buffer buffer, java.lang.String req, RequestHandler.Result result, boolean wantReply)
void	setDataReceiver(ChannelDataReceiver receiver) For Command to install ChannelDataReceiver.

Methods inherited from class org.apache.sshd.server.channel.AbstractServerChannel

doInit, getServerSession, handleOpenFailure, handleOpenSuccess, open, sendExitStatus

Methods inherited from class org.apache.sshd.common.channel.AbstractChannel

addChannelListener, addPendingRequest, addRequestHandler, attributeKeys, clearAttributes, computeAttributeIfAbsent, configureWindow, getAttribute, getAttributesCount, getChannelListenerProxy, getChannelStreamPacketWriterResolver, getExecutorService, getId, getLocalWindow, getParentPropertyResolver, getProperties, getRecipient, getRemoteWindow, getRequestHandlers, handleChannelRequest, handleClose, handleData, handleExtendedData, handleFailure, handleRequest, handleSuccess, handleUnknownChannelRequest, init, invokeChannelSignaller, isEofSent, isEofSignalled, isInitialized, notifyStateChanged, notifyStateChanged, preClose, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveChannelStreamPacketWriterResolver, sendEof, sendWindowAdjust, setAttribute, setChannelStreamPacketWriterResolver, setRecipient, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

addCloseFutureListener, builder, close, isClosed, isClosing, removeCloseFutureListener

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

getSimplifiedLogger

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sshd.common.channel.Channel

addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, handleClose, handleData, handleExtendedData, handleFailure, handleRequest, handleSuccess, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers, resolveAttribute, resolveAttribute

Methods inherited from interface org.apache.sshd.common.channel.ChannelListenerManager

addChannelListener, getChannelListenerProxy, removeChannelListener

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

getBoolean, getBooleanProperty, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty

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

clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute

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

attributeKeys, getAttribute, getAttributesCount, ofAttributesMap, ofKeyValuePair

Methods inherited from interface org.apache.sshd.common.io.PacketWriter

writePacket

Methods inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamPacketWriterResolverManager

getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver

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

addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener

Field Detail

DEFAULT_HANDLERS

public static final java.util.List<ChannelRequestHandler> DEFAULT_HANDLERS

type

protected java.lang.String type

asyncOut

protected ChannelAsyncOutputStream asyncOut

asyncErr

protected ChannelAsyncOutputStream asyncErr

out

protected java.io.OutputStream out

err

protected java.io.OutputStream err

commandInstance

protected Command commandInstance

receiver

protected ChannelDataReceiver receiver

tempBuffer

protected Buffer tempBuffer

commandStarted

protected final java.util.concurrent.atomic.AtomicBoolean commandStarted

env

protected final StandardEnvironment env

commandExitFuture

protected final CloseFuture commandExitFuture

Constructor Detail

ChannelSession

public ChannelSession()

ChannelSession

public ChannelSession(java.util.Collection<? extends RequestHandler<Channel>> handlers)

Method Detail

getSession

public ServerSession getSession()

Overrides:

getSession in class AbstractChannel

Returns:

The channel's underlying Session

handleWindowAdjust

public void handleWindowAdjust(Buffer buffer)
                        throws java.io.IOException

Description copied from interface: Channel

Invoked when SSH_MSG_CHANNEL_WINDOW_ADJUST received

Overrides:

handleWindowAdjust in class AbstractChannel

Parameters:

buffer - The rest of the message data Buffer after decoding the channel identifiers

Throws:

java.io.IOException - If failed to handle the message

getInnerCloseable

protected Closeable getInnerCloseable()

Overrides:

getInnerCloseable in class AbstractChannel

closeImmediately0

protected void closeImmediately0()

handleEof

public void handleEof()
               throws java.io.IOException

Description copied from interface: Channel

Invoked when SSH_MSG_CHANNEL_EOF received

Overrides:

handleEof in class AbstractChannel

Throws:

java.io.IOException - If failed to handle the message

doWriteData

protected void doWriteData(byte[] data,
                           int off,
                           long len)
                    throws java.io.IOException

Specified by:

doWriteData in class AbstractChannel

Throws:

java.io.IOException

doWriteExtendedData

protected void doWriteExtendedData(byte[] data,
                                   int off,
                                   long len)
                            throws java.io.IOException

Specified by:

doWriteExtendedData in class AbstractChannel

Throws:

java.io.IOException

handleInternalRequest

protected RequestHandler.Result handleInternalRequest(java.lang.String requestType,
                                                      boolean wantReply,
                                                      Buffer buffer)
                                               throws java.io.IOException

Description copied from class: AbstractChannel

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.

Overrides:

handleInternalRequest in class AbstractChannel

Parameters:

requestType - The request type

wantReply - Whether reply is requested

buffer - The Buffer containing extra request-specific data

Returns:

The handling result - if null or Unsupported and reply is required then a failure message will be sent

Throws:

java.io.IOException - If failed to process the request internally

sendResponse

protected IoWriteFuture sendResponse(Buffer buffer,
                                     java.lang.String req,
                                     RequestHandler.Result result,
                                     boolean wantReply)
                              throws java.io.IOException

Overrides:

sendResponse in class AbstractChannel

Throws:

java.io.IOException

handleEnv

protected RequestHandler.Result handleEnv(Buffer buffer,
                                          boolean wantReply)
                                   throws java.io.IOException

Throws:

java.io.IOException

handlePtyReq

protected RequestHandler.Result handlePtyReq(Buffer buffer,
                                             boolean wantReply)
                                      throws java.io.IOException

Throws:

java.io.IOException

handleWindowChange

protected RequestHandler.Result handleWindowChange(Buffer buffer,
                                                   boolean wantReply)
                                            throws java.io.IOException

Throws:

java.io.IOException

handleSignal

protected RequestHandler.Result handleSignal(Buffer buffer,
                                             boolean wantReply)
                                      throws java.io.IOException

Throws:

java.io.IOException

handleBreak

protected RequestHandler.Result handleBreak(Buffer buffer,
                                            boolean wantReply)
                                     throws java.io.IOException

Throws:

java.io.IOException

handleShell

protected RequestHandler.Result handleShell(java.lang.String request,
                                            Buffer buffer,
                                            boolean wantReply)
                                     throws java.io.IOException

Throws:

java.io.IOException

handleExec

protected RequestHandler.Result handleExec(java.lang.String request,
                                           Buffer buffer,
                                           boolean wantReply)
                                    throws java.io.IOException

Throws:

java.io.IOException

handleSubsystem

protected RequestHandler.Result handleSubsystem(java.lang.String request,
                                                Buffer buffer,
                                                boolean wantReply)
                                         throws java.io.IOException

Throws:

java.io.IOException

prepareChannelCommand

protected RequestHandler.Result prepareChannelCommand(java.lang.String request,
                                                      Command cmd)
                                               throws java.io.IOException

Throws:

java.io.IOException

setDataReceiver

public void setDataReceiver(ChannelDataReceiver receiver)

For Command to install ChannelDataReceiver. When you do this, Command.setInputStream(java.io.InputStream) or AsyncCommand.setIoInputStream(org.apache.sshd.common.io.IoInputStream) will no longer be invoked. If you call this method from CommandLifecycle.start(Environment), the input stream you received in Command.setInputStream(java.io.InputStream) will not read any data.

Parameters:

receiver - The ChannelDataReceiver instance

prepareCommand

protected Command prepareCommand(java.lang.String requestType,
                                 Command command)
                          throws java.io.IOException

Called by prepareChannelCommand(String, Command) in order to set up the command's streams, session, file-system, exit callback, etc..

Parameters:

requestType - The request that caused the command to be created

command - The created Command - may be null

Returns:

The updated command instance - if null then the request that initially caused the creation of the command is failed and the original command (if any) destroyed (eventually). Note: if a different command instance than the input one is returned, then it is up to the implementor to take care of the wrapping or destruction of the original command instance.

Throws:

java.io.IOException - If failed to prepare the command

getPtyModeValue

protected int getPtyModeValue(PtyMode mode)

handleAgentForwarding

protected RequestHandler.Result handleAgentForwarding(java.lang.String requestType,
                                                      Buffer buffer,
                                                      boolean wantReply)
                                               throws java.io.IOException

Throws:

java.io.IOException

handleX11Forwarding

protected RequestHandler.Result handleX11Forwarding(java.lang.String requestType,
                                                    Buffer buffer,
                                                    boolean wantReply)
                                             throws java.io.IOException

Throws:

java.io.IOException

addEnvVariable

protected void addEnvVariable(java.lang.String name,
                              java.lang.String value)

getEnvironment

public StandardEnvironment getEnvironment()

closeShell

protected void closeShell(int exitValue)
                   throws java.io.IOException

Throws:

java.io.IOException