public class TcpipClientChannel extends AbstractClientChannel implements ForwardingTunnelEndpointsProvider
Modifier and Type | Class and Description |
---|---|
static class |
TcpipClientChannel.Type
Type of channel being created.
|
AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState
AbstractCloseable.State
ClientChannel.Streaming
AttributeRepository.AttributeKey<T>
Modifier and Type | Field and Description |
---|---|
protected SshdSocketAddress |
localEntry |
protected SshdSocketAddress |
remote |
protected IoSession |
serverSession |
asyncErr, asyncIn, asyncOut, err, exitSignalHolder, exitStatusHolder, in, invertedErr, invertedIn, invertedOut, opened, openFailureLang, openFailureMsg, openFailureReason, openFuture, out, streaming
channelListenerProxy, channelListeners, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service
closeFuture, lock, state
log
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM
EMPTY
NONE
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
TcpipClientChannel(TcpipClientChannel.Type type,
IoSession serverSession,
SshdSocketAddress remote) |
Modifier and Type | Method and Description |
---|---|
protected void |
doOpen() |
protected void |
doWriteData(byte[] data,
int off,
long len) |
protected void |
doWriteExtendedData(byte[] data,
int off,
long len) |
protected Closeable |
getInnerCloseable() |
OpenFuture |
getOpenFuture() |
ClientChannelPendingMessagesQueue |
getPendingMessagesQueue() |
TcpipClientChannel.Type |
getTcpipChannelType() |
SshdSocketAddress |
getTunnelEntrance() |
SshdSocketAddress |
getTunnelExit() |
OpenFuture |
open() |
protected void |
preClose()
preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
|
void |
updateLocalForwardingEntry(LocalForwardingEntry entry) |
addChannelSignalRequestHandlers, getAsyncErr, getAsyncIn, getAsyncOut, getChannelState, getChannelType, getClientSession, getErr, getExitSignal, getExitStatus, getIn, getInvertedErr, getInvertedIn, getInvertedOut, getOut, getStreaming, handleOpenFailure, handleOpenSuccess, handleWindowAdjust, open, setErr, setIn, setOut, setStreaming, updateCurrentChannelState, waitFor
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, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveChannelStreamPacketWriterResolver, sendEof, sendResponse, sendWindowAdjust, setAttribute, setChannelStreamPacketWriterResolver, setRecipient, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
validateCommandExitStatusCode
addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleRequest, handleSuccess, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers, resolveAttribute, resolveAttribute
addChannelListener, getChannelListenerProxy, removeChannelListener
getBoolean, getBooleanProperty, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute
attributeKeys, getAttribute, getAttributesCount, ofAttributesMap, ofKeyValuePair
writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
protected final SshdSocketAddress remote
protected final IoSession serverSession
protected SshdSocketAddress localEntry
public TcpipClientChannel(TcpipClientChannel.Type type, IoSession serverSession, SshdSocketAddress remote)
public OpenFuture getOpenFuture()
public TcpipClientChannel.Type getTcpipChannelType()
public ClientChannelPendingMessagesQueue getPendingMessagesQueue()
public void updateLocalForwardingEntry(LocalForwardingEntry entry)
public OpenFuture open() throws IOException
open
in interface ClientChannel
open
in class AbstractClientChannel
IOException
protected void doOpen() throws IOException
doOpen
in class AbstractClientChannel
IOException
protected void preClose()
AbstractCloseable
preClose
in class AbstractChannel
protected Closeable getInnerCloseable()
getInnerCloseable
in class AbstractClientChannel
protected void doWriteData(byte[] data, int off, long len) throws IOException
doWriteData
in class AbstractClientChannel
IOException
protected void doWriteExtendedData(byte[] data, int off, long len) throws IOException
doWriteExtendedData
in class AbstractClientChannel
IOException
public SshdSocketAddress getTunnelEntrance()
getTunnelEntrance
in interface ForwardingTunnelEndpointsProvider
public SshdSocketAddress getTunnelExit()
getTunnelExit
in interface ForwardingTunnelEndpointsProvider
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.