Package org.apache.sshd.common.channel
Class ChannelAsyncOutputStream.WriteState
java.lang.Object
org.apache.sshd.common.channel.ChannelAsyncOutputStream.WriteState
- Enclosing class:
ChannelAsyncOutputStream
Collects state variables; access is always synchronized on the single instance per stream.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected AbstractCloseable.StateA copy of this stream's state as set by the superclass.protected IoWriteFutureImplThe future describing the current packet write; ifnull, there is nothing to write orChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)is running.protected intNumber of bytes still to send.protected intNumber of bytes to send in total.protected booleanSet to true when there was a remote window expansion whileChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)was in progress.protected booleanFlag to throw an exception if non-sequentialChannelAsyncOutputStream.writeBuffer(Buffer)calls should occur. -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
pendingWrite
The future describing the current packet write; ifnull, there is nothing to write orChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)is running. -
writeInProgress
protected boolean writeInProgressFlag to throw an exception if non-sequentialChannelAsyncOutputStream.writeBuffer(Buffer)calls should occur. -
windowExpanded
protected boolean windowExpandedSet to true when there was a remote window expansion whileChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)was in progress. If set,ChannelAsyncOutputStream.doWriteIfPossible(boolean)will run aChannelAsyncOutputStream.writePacket(IoWriteFutureImpl, boolean)again. -
openState
A copy of this stream's state as set by the superclass. -
totalLength
protected int totalLengthNumber of bytes to send in total. -
toSend
protected int toSendNumber of bytes still to send.
-
-
Constructor Details
-
WriteState
protected WriteState()
-