private static final class SpdySession.StreamState
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
localSideClosed |
private java.util.Queue<SpdySession.PendingWrite> |
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 and Description |
---|
StreamState(byte priority,
boolean remoteSideClosed,
boolean localSideClosed,
int sendWindowSize,
int receiveWindowSize) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
clearPendingWrites(java.lang.Throwable cause) |
(package private) void |
closeLocalSide() |
(package private) void |
closeRemoteSide() |
(package private) SpdySession.PendingWrite |
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(SpdySession.PendingWrite msg) |
(package private) void |
receivedReply() |
(package private) SpdySession.PendingWrite |
removePendingWrite() |
(package private) void |
setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound) |
(package private) int |
updateReceiveWindowSize(int deltaWindowSize) |
(package private) int |
updateSendWindowSize(int deltaWindowSize) |
private final byte priority
private boolean remoteSideClosed
private boolean localSideClosed
private boolean receivedReply
private final java.util.concurrent.atomic.AtomicInteger sendWindowSize
private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize
private int receiveWindowSizeLowerBound
private final java.util.Queue<SpdySession.PendingWrite> pendingWriteQueue
StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)
byte getPriority()
boolean isRemoteSideClosed()
void closeRemoteSide()
boolean isLocalSideClosed()
void closeLocalSide()
boolean hasReceivedReply()
void receivedReply()
int getSendWindowSize()
int updateSendWindowSize(int deltaWindowSize)
int updateReceiveWindowSize(int deltaWindowSize)
int getReceiveWindowSizeLowerBound()
void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)
boolean putPendingWrite(SpdySession.PendingWrite msg)
SpdySession.PendingWrite getPendingWrite()
SpdySession.PendingWrite removePendingWrite()
void clearPendingWrites(java.lang.Throwable cause)