org.apache.sshd.client.channel

Class AbstractClientChannel

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.client.channel.AbstractClientChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, ClientChannel, ClientSessionHolder, AttributeRepository, AttributeStore, ChannelListenerManager, ChannelStreamPacketWriterResolver, ChannelStreamPacketWriterResolverManager, PacketWriter, PropertyResolver, SessionContextHolder, SessionHolder<Session>, ExecutorServiceCarrier

Direct Known Subclasses:

AgentForwardedChannel, ChannelDirectTcpip, ChannelForwardedX11, ChannelSession, TcpipClientChannel

public abstract class AbstractClientChannel
extends AbstractChannel
implements ClientChannel

TODO Add javadoc

Nested Class Summary

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.client.channel.ClientChannel

ClientChannel.Streaming

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

AttributeRepository.AttributeKey<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelAsyncInputStream	asyncErr
protected ChannelAsyncOutputStream	asyncIn
protected ChannelAsyncInputStream	asyncOut
private java.lang.String	channelType
protected java.io.OutputStream	err
protected java.util.concurrent.atomic.AtomicReference<java.lang.String>	exitSignalHolder
protected java.util.concurrent.atomic.AtomicReference<java.lang.Integer>	exitStatusHolder
protected java.io.InputStream	in
protected java.io.InputStream	invertedErr
protected java.io.OutputStream	invertedIn
protected java.io.InputStream	invertedOut
protected java.util.concurrent.atomic.AtomicBoolean	opened
protected java.lang.String	openFailureLang
protected java.lang.String	openFailureMsg
protected int	openFailureReason
protected OpenFuture	openFuture
protected java.io.OutputStream	out
protected ClientChannel.Streaming	streaming

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, futureLock, 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

Modifier	Constructor and Description
protected	AbstractClientChannel(java.lang.String type)
protected	AbstractClientChannel(java.lang.String type, java.util.Collection<? extends RequestHandler<Channel>> handlers)

Method Summary

Modifier and Type	Method and Description
protected void	addChannelSignalRequestHandlers(EventNotifier<java.lang.String> notifier)
protected abstract void	doOpen()
protected void	doWriteData(byte[] data, int off, long len)
protected void	doWriteExtendedData(byte[] data, int off, long len)
IoInputStream	getAsyncErr()
IoOutputStream	getAsyncIn()
IoInputStream	getAsyncOut()
java.util.Set<ClientChannelEvent>	getChannelState()
java.lang.String	getChannelType()
java.io.OutputStream	getErr()
java.lang.String	getExitSignal()
java.lang.Integer	getExitStatus()
java.io.InputStream	getIn()
protected Closeable	getInnerCloseable()
java.io.InputStream	getInvertedErr()
java.io.OutputStream	getInvertedIn() Access to an output stream to send data directly to the remote channel.
java.io.InputStream	getInvertedOut()
java.io.OutputStream	getOut()
ClientChannel.Streaming	getStreaming()
void	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	handleOpenSuccess(int 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	handleWindowAdjust(Buffer buffer) Invoked when SSH_MSG_CHANNEL_WINDOW_ADJUST received
OpenFuture	open()
OpenFuture	open(int recipient, long rwSize, long packetSize, Buffer buffer) For a server channel, this method will actually open the channel
void	setErr(java.io.OutputStream err)
void	setIn(java.io.InputStream in) Set an input stream that will be read by this channel and forwarded to the remote channel.
void	setOut(java.io.OutputStream out)
void	setStreaming(ClientChannel.Streaming streaming)
protected <C extends java.util.Collection<ClientChannelEvent>> C	updateCurrentChannelState(C state)
java.util.Set<ClientChannelEvent>	waitFor(java.util.Collection<ClientChannelEvent> mask, long timeout) Waits until any of the specified events in the mask is signaled

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, getSession, handleChannelRequest, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleInternalRequest, handleRequest, handleSuccess, handleUnknownChannelRequest, init, invokeChannelSignaller, isEofSent, isEofSignalled, isInitialized, notifyStateChanged, notifyStateChanged, preClose, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveChannelStreamPacketWriterResolver, sendEof, sendResponse, 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, getFutureLock, 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.client.channel.ClientChannel

getClientSession, validateCommandExitStatusCode, waitFor

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

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

Methods inherited from interface org.apache.sshd.common.session.SessionHolder

getSession, getSessionContext

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

addChannelListener, getChannelListenerProxy, removeChannelListener

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

getBoolean, getBooleanProperty, getCharset, 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

calculatePadLength, 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

opened

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

streaming

protected ClientChannel.Streaming streaming

asyncIn

protected ChannelAsyncOutputStream asyncIn

asyncOut

protected ChannelAsyncInputStream asyncOut

asyncErr

protected ChannelAsyncInputStream asyncErr

in

protected java.io.InputStream in

invertedIn

protected java.io.OutputStream invertedIn

out

protected java.io.OutputStream out

invertedOut

protected java.io.InputStream invertedOut

err

protected java.io.OutputStream err

invertedErr

protected java.io.InputStream invertedErr

exitStatusHolder

protected final java.util.concurrent.atomic.AtomicReference<java.lang.Integer> exitStatusHolder

exitSignalHolder

protected final java.util.concurrent.atomic.AtomicReference<java.lang.String> exitSignalHolder

openFailureReason

protected int openFailureReason

openFailureMsg

protected java.lang.String openFailureMsg

openFailureLang

protected java.lang.String openFailureLang

openFuture

protected OpenFuture openFuture

channelType

private final java.lang.String channelType

Constructor Detail

AbstractClientChannel

protected AbstractClientChannel(java.lang.String type)

AbstractClientChannel

protected AbstractClientChannel(java.lang.String type,
                                java.util.Collection<? extends RequestHandler<Channel>> handlers)

Method Detail

addChannelSignalRequestHandlers

protected void addChannelSignalRequestHandlers(EventNotifier<java.lang.String> notifier)

getChannelType

public java.lang.String getChannelType()

Specified by:

getChannelType in interface ClientChannel

Returns:

The type of channel reported when it was created

getStreaming

public ClientChannel.Streaming getStreaming()

Specified by:

getStreaming in interface ClientChannel

setStreaming

public void setStreaming(ClientChannel.Streaming streaming)

Specified by:

setStreaming in interface ClientChannel

getAsyncIn

public IoOutputStream getAsyncIn()

Specified by:

getAsyncIn in interface ClientChannel

getAsyncOut

public IoInputStream getAsyncOut()

Specified by:

getAsyncOut in interface ClientChannel

getAsyncErr

public IoInputStream getAsyncErr()

Specified by:

getAsyncErr in interface ClientChannel

getInvertedIn

public java.io.OutputStream getInvertedIn()

Description copied from interface: ClientChannel

Access to an output stream to send data directly to the remote channel. This can be used instead of using ClientChannel.setIn(java.io.InputStream) method and having the channel polling for data in that stream.

Specified by:

getInvertedIn in interface ClientChannel

Returns:

an OutputStream to be used to send data

getIn

public java.io.InputStream getIn()

setIn

public void setIn(java.io.InputStream in)

Description copied from interface: ClientChannel

Set an input stream that will be read by this channel and forwarded to the remote channel. Note that using such a stream will create an additional thread for pumping the stream which will only be able to end when that stream is actually closed or some data is read. It is recommended to use the ClientChannel.getInvertedIn() method instead and write data directly.

Specified by:

setIn in interface ClientChannel

Parameters:

in - an InputStream to be polled and forwarded

getInvertedOut

public java.io.InputStream getInvertedOut()

Specified by:

getInvertedOut in interface ClientChannel

getOut

public java.io.OutputStream getOut()

setOut

public void setOut(java.io.OutputStream out)

Specified by:

setOut in interface ClientChannel

getInvertedErr

public java.io.InputStream getInvertedErr()

Specified by:

getInvertedErr in interface ClientChannel

getErr

public java.io.OutputStream getErr()

setErr

public void setErr(java.io.OutputStream err)

Specified by:

setErr in interface ClientChannel

getInnerCloseable

protected Closeable getInnerCloseable()

Overrides:

getInnerCloseable in class AbstractChannel

waitFor

public java.util.Set<ClientChannelEvent> waitFor(java.util.Collection<ClientChannelEvent> mask,
                                                 long timeout)

Description copied from interface: ClientChannel

Waits until any of the specified events in the mask is signaled

Specified by:

waitFor in interface ClientChannel

Parameters:

mask - The ClientChannelEvents mask

timeout - The timeout to wait (msec.) - if non-positive then forever

Returns:

The actual signaled event - includes ClientChannelEvent.TIMEOUT if timeout expired before the expected event was signaled

getChannelState

public java.util.Set<ClientChannelEvent> getChannelState()

Specified by:

getChannelState in interface ClientChannel

Returns:

A snapshot of the current channel state

See Also:

ClientChannel.waitFor(Collection, long)

updateCurrentChannelState

protected <C extends java.util.Collection<ClientChannelEvent>> C updateCurrentChannelState(C state)

open

public OpenFuture open()
                throws java.io.IOException

Specified by:

open in interface ClientChannel

Throws:

java.io.IOException

open

public OpenFuture open(int recipient,
                       long rwSize,
                       long packetSize,
                       Buffer buffer)

Description copied from interface: Channel

For a server channel, this method will actually open the channel

Parameters:

recipient - Recipient identifier

rwSize - Read/Write window size (uint32)

packetSize - Preferred maximum packet size (uint32)

buffer - Incoming Buffer that triggered the call. Note: the buffer's read position is exactly after the information that read to this call was decoded

Returns:

An OpenFuture for the channel open request

handleOpenSuccess

public void handleOpenSuccess(int recipient,
                              long rwSize,
                              long packetSize,
                              Buffer buffer)

Description copied from interface: Channel

For a client channel, this method will be called internally by the session when the confirmation has been received.

Parameters:

recipient - Recipient identifier

rwSize - Read/Write window size (uint32)

packetSize - Preferred maximum packet size (uint32)

buffer - Incoming Buffer that triggered the call. Note: the buffer's read position is exactly after the information that read to this call was decoded

doOpen

protected abstract void doOpen()
                        throws java.io.IOException

Throws:

java.io.IOException

handleOpenFailure

public void handleOpenFailure(Buffer buffer)

Description copied from interface: Channel

For a client channel, this method will be called internally by the session when the server has rejected this channel opening.

Parameters:

buffer - Incoming Buffer that triggered the call. Note: the buffer's read position is exactly after the information that read to this call was decoded

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

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

getExitStatus

public java.lang.Integer getExitStatus()

Specified by:

getExitStatus in interface ClientChannel

Returns:

The signaled exit status via "exit-status" request - null if not signaled

getExitSignal

public java.lang.String getExitSignal()

Specified by:

getExitSignal in interface ClientChannel

Returns:

The signaled exit signal via "exit-signal" - null if not signaled