public class ChannelSession extends AbstractClientChannel
AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState
CloseableUtils.AbstractCloseable.State
ClientChannel.Streaming
asyncErr, asyncIn, asyncOut, err, exitSignal, exitStatus, in, invertedErr, invertedIn, invertedOut, opened, openFailureMsg, openFailureReason, openFuture, out, streaming, type
DEFAULT_CHANNEL_CLOSE_TIMEOUT, DEFAULT_PACKET_SIZE, DEFAULT_WINDOW_SIZE, eof, gracefulFuture, gracefulState, handlers, id, localWindow, recipient, remoteWindow, service, session
closeFuture, lock, log, state
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM, CLOSED, EOF, EXIT_SIGNAL, EXIT_STATUS, OPENED, STDERR_DATA, STDOUT_DATA, TIMEOUT
Constructor and Description |
---|
ChannelSession() |
Modifier and Type | Method and Description |
---|---|
protected void |
doCloseImmediately()
doCloseImmediately is called once and only once
with state == Immediate
Overriding methods should always call the base implementation.
|
protected void |
doOpen() |
protected void |
pumpInputStream() |
protected int |
securedRead(InputStream in,
byte[] buf,
int off,
int len) |
doWriteData, doWriteExtendedData, getAsyncErr, getAsyncIn, getAsyncOut, getErr, getExitStatus, getIn, getInnerCloseable, getInvertedErr, getInvertedIn, getInvertedOut, getOut, getStreaming, handleOpenFailure, handleOpenSuccess, handleWindowAdjust, open, open, setErr, setIn, setOut, setStreaming, waitFor
addRequestHandler, configureWindow, getId, getLocalWindow, getRecipient, getRemoteWindow, getSession, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleRequest, init, notifyStateChanged, sendEof, sendWindowAdjust, toString, writePacket
doCloseGracefully
builder, close, isClosed, isClosing, preClose
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close
protected void doOpen() throws IOException
doOpen
in class AbstractClientChannel
IOException
protected void doCloseImmediately()
CloseableUtils.AbstractCloseable
doCloseImmediately
in class AbstractChannel
protected void pumpInputStream()
protected int securedRead(InputStream in, byte[] buf, int off, int len) throws IOException
IOException
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.