Class SpdySession.StreamState
- java.lang.Object
-
- org.jboss.netty.handler.codec.spdy.SpdySession.StreamState
-
- Enclosing class:
- SpdySession
private static final class SpdySession.StreamState extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
localSideClosed
private java.util.concurrent.ConcurrentLinkedQueue<MessageEvent>
pendingWriteQueue
private byte
priority
private boolean
receivedReply
private java.util.concurrent.atomic.AtomicInteger
receiveWindowSize
private int
receiveWindowSizeLowerBound
private boolean
remoteSideClosed
private java.util.concurrent.atomic.AtomicInteger
sendWindowSize
-
Constructor Summary
Constructors Constructor Description StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
closeLocalSide()
(package private) void
closeRemoteSide()
(package private) MessageEvent
getPendingWrite()
(package private) byte
getPriority()
(package private) int
getReceiveWindowSizeLowerBound()
(package private) int
getSendWindowSize()
(package private) boolean
hasReceivedReply()
(package private) boolean
isLocalSideClosed()
(package private) boolean
isRemoteSideClosed()
(package private) boolean
putPendingWrite(MessageEvent evt)
(package private) void
receivedReply()
(package private) MessageEvent
removePendingWrite()
(package private) void
setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)
(package private) int
updateReceiveWindowSize(int deltaWindowSize)
(package private) int
updateSendWindowSize(int deltaWindowSize)
-
-
-
Field Detail
-
priority
private final byte priority
-
remoteSideClosed
private volatile boolean remoteSideClosed
-
localSideClosed
private volatile boolean localSideClosed
-
receivedReply
private boolean receivedReply
-
sendWindowSize
private final java.util.concurrent.atomic.AtomicInteger sendWindowSize
-
receiveWindowSize
private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize
-
receiveWindowSizeLowerBound
private volatile int receiveWindowSizeLowerBound
-
pendingWriteQueue
private final java.util.concurrent.ConcurrentLinkedQueue<MessageEvent> pendingWriteQueue
-
-
Method Detail
-
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
boolean putPendingWrite(MessageEvent evt)
-
getPendingWrite
MessageEvent getPendingWrite()
-
removePendingWrite
MessageEvent removePendingWrite()
-
-