|
||||||||||
| 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 SSH2Channelpdu - The data packet.protected void openConfirmationImpl(SSH2TransportPDU pdu)
SSH2Channel
openConfirmationImpl in class SSH2Channelpdu - Confirmation packet.
protected boolean openFailureImpl(int reasonCode,
java.lang.String reasonText,
java.lang.String langTag)
SSH2Channel
openFailureImpl in class SSH2ChannelreasonCode - 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 SSH2Channelinc - The amount to increase the window with.protected void eofImpl()
SSH2Channel
eofImpl in class SSH2Channelprotected void closeImpl()
SSH2Channel
closeImpl in class SSH2Channelprotected void outputClosed()
protected void handleRequestImpl(java.lang.String type,
boolean wantReply,
SSH2TransportPDU pdu)
SSH2Channel
handleRequestImpl in class SSH2Channeltype - 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 | |||||||||