Class SpdySession.StreamState
java.lang.Object
org.jboss.netty.handler.codec.spdy.SpdySession.StreamState
- Enclosing class:
SpdySession
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final ConcurrentLinkedQueue
<MessageEvent> private final byte
private boolean
private final AtomicInteger
private int
private boolean
private final AtomicInteger
-
Constructor Summary
ConstructorsConstructorDescriptionStreamState
(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
(package private) MessageEvent
(package private) byte
(package private) int
(package private) int
(package private) boolean
(package private) boolean
(package private) boolean
(package private) boolean
(package private) void
(package private) MessageEvent
(package private) void
setReceiveWindowSizeLowerBound
(int receiveWindowSizeLowerBound) (package private) int
updateReceiveWindowSize
(int deltaWindowSize) (package private) int
updateSendWindowSize
(int deltaWindowSize)
-
Field Details
-
priority
private final byte priority -
remoteSideClosed
private volatile boolean remoteSideClosed -
localSideClosed
private volatile boolean localSideClosed -
receivedReply
private boolean receivedReply -
sendWindowSize
-
receiveWindowSize
-
receiveWindowSizeLowerBound
private volatile int receiveWindowSizeLowerBound -
pendingWriteQueue
-
-
Constructor Details
-
StreamState
StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)
-
-
Method Details
-
getPriority
byte getPriority() -
isRemoteSideClosed
boolean isRemoteSideClosed() -
closeRemoteSide
void closeRemoteSide() -
isLocalSideClosed
boolean isLocalSideClosed() -
closeLocalSide
void closeLocalSide() -
hasReceivedReply
boolean hasReceivedReply() -
receivedReply
void receivedReply() -
getSendWindowSize
int getSendWindowSize() -
updateSendWindowSize
int updateSendWindowSize(int deltaWindowSize) -
updateReceiveWindowSize
int updateReceiveWindowSize(int deltaWindowSize) -
getReceiveWindowSizeLowerBound
int getReceiveWindowSizeLowerBound() -
setReceiveWindowSizeLowerBound
void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) -
putPendingWrite
-
getPendingWrite
MessageEvent getPendingWrite() -
removePendingWrite
MessageEvent removePendingWrite()
-