|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.mindbright.ssh2.SSH2Channel
com.mindbright.ssh2.SSH2StreamChannel
Class implementing streams-based channels. That is channels which locally are connected to a pair of Input/Output streams. It is also possible to apply filters to the channels.
Field Summary | |
protected java.io.InputStream |
in
|
protected java.io.OutputStream |
out
|
protected java.lang.Thread |
receiver
|
protected long |
rxCounter
|
protected Queue |
rxQueue
|
protected java.lang.Thread |
transmitter
|
protected long |
txCounter
|
Fields inherited from class com.mindbright.ssh2.SSH2Channel |
channelId, channelType, closeListeners, closeReceived, closeSent, connection, creator, deleted, eofReceived, eofSent, openMonitor, openStatus, peerChanId, rxCurrWinSz, rxInitWinSz, rxMaxPktSz, STATUS_CLOSED, STATUS_FAILED, STATUS_OPEN, STATUS_UNDEFINED, txCurrWinSz, txInitWinSz, txMaxPktSz |
Constructor Summary | |
protected |
SSH2StreamChannel(int channelType,
SSH2Connection connection,
java.lang.Object creator,
java.io.InputStream in,
java.io.OutputStream out)
Create a new stream channel of the given type. |
Method Summary | |
void |
applyFilter(SSH2StreamFilter filter)
Apply the given filter to this channel. |
protected void |
checkRxWindowSize(int len)
|
protected void |
closeImpl()
Channel specific handler for the recipent of a channel close message. |
protected void |
createStreams()
Create the transmitter and receiver threads. |
protected void |
data(SSH2TransportPDU pdu)
Handle incoming data on the channel. |
protected void |
eofImpl()
Channel specific handler for the recipent of an EOF. |
protected void |
handleRequestImpl(java.lang.String type,
boolean wantReply,
SSH2TransportPDU pdu)
Channel specific handler for incoming channel requests. |
protected void |
openConfirmationImpl(SSH2TransportPDU pdu)
Channel specific handling of open confirmations. |
protected boolean |
openFailureImpl(int reasonCode,
java.lang.String reasonText,
java.lang.String langTag)
Channel specific handling of open failures. |
protected void |
outputClosed()
Called when no more data can be written to the channel. |
protected void |
startStreams()
Starts the transmitter and receiver threads. |
void |
waitUntilClosed()
Wait until the channel is closed. |
protected void |
windowAdjustImpl(int inc)
Channel specific implementation of window adjust messages. |
Methods inherited from class com.mindbright.ssh2.SSH2Channel |
addCloseListener, close, extData, getChannelId, getConnection, getCreator, getPeerId, getType, handleRequest, init, openConfirmation, openFailure, openStatus, recvClose, recvEOF, removeCloseListener, requestFailure, requestSuccess, sendClose, sendEOF, transmit, windowAdjust |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected java.io.InputStream in
protected java.io.OutputStream out
protected java.lang.Thread transmitter
protected java.lang.Thread receiver
protected Queue rxQueue
protected long txCounter
protected long rxCounter
Constructor Detail |
protected SSH2StreamChannel(int channelType, SSH2Connection connection, java.lang.Object creator, java.io.InputStream in, java.io.OutputStream out)
SSH2Connection
and starts with
CH_TYPE
.
channelType
- Type of channel to create.connection
- The ssh connection to associate the channel with.creator
- The object the channel is created from.in
- The input stream from which data to be sent over the
channel is read.out
- The output stream onto which data received from the
channel is written.Method Detail |
public void applyFilter(SSH2StreamFilter filter)
filter
- Filter to apply.protected final void checkRxWindowSize(int len)
protected void data(SSH2TransportPDU pdu)
SSH2Channel
data
in class SSH2Channel
pdu
- The data packet.protected void openConfirmationImpl(SSH2TransportPDU pdu)
SSH2Channel
openConfirmationImpl
in class SSH2Channel
pdu
- Confirmation packet.protected boolean openFailureImpl(int reasonCode, java.lang.String reasonText, java.lang.String langTag)
SSH2Channel
openFailureImpl
in class SSH2Channel
reasonCode
- Code which tells why the open failed. See the
ssh protocol drafts for values.reasonText
- A text explaining why the open failed.langTag
- Tag identifying the language of the reason text.protected void windowAdjustImpl(int inc)
SSH2Channel
windowAdjustImpl
in class SSH2Channel
inc
- The amount to increase the window with.protected void eofImpl()
SSH2Channel
eofImpl
in class SSH2Channel
protected void closeImpl()
SSH2Channel
closeImpl
in class SSH2Channel
protected void outputClosed()
protected void handleRequestImpl(java.lang.String type, boolean wantReply, SSH2TransportPDU pdu)
SSH2Channel
handleRequestImpl
in class SSH2Channel
type
- The type of request.wantReply
- True if an reply is expected.pdu
- The actual channel request.protected void createStreams()
protected void startStreams()
public void waitUntilClosed()
SSH2Channel
waitUntilClosed
in class SSH2Channel
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |