Package io.netty.handler.codec.spdy
Class SpdySession.StreamState
- java.lang.Object
-
- io.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 booleanlocalSideClosedprivate java.util.Queue<SpdySession.PendingWrite>pendingWriteQueueprivate bytepriorityprivate booleanreceivedReplyprivate java.util.concurrent.atomic.AtomicIntegerreceiveWindowSizeprivate intreceiveWindowSizeLowerBoundprivate booleanremoteSideClosedprivate java.util.concurrent.atomic.AtomicIntegersendWindowSize
-
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) voidclearPendingWrites(java.lang.Throwable cause)(package private) voidcloseLocalSide()(package private) voidcloseRemoteSide()(package private) SpdySession.PendingWritegetPendingWrite()(package private) bytegetPriority()(package private) intgetReceiveWindowSizeLowerBound()(package private) intgetSendWindowSize()(package private) booleanhasReceivedReply()(package private) booleanisLocalSideClosed()(package private) booleanisRemoteSideClosed()(package private) booleanputPendingWrite(SpdySession.PendingWrite msg)(package private) voidreceivedReply()(package private) SpdySession.PendingWriteremovePendingWrite()(package private) voidsetReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)(package private) intupdateReceiveWindowSize(int deltaWindowSize)(package private) intupdateSendWindowSize(int deltaWindowSize)
-
-
-
Field Detail
-
priority
private final byte priority
-
remoteSideClosed
private boolean remoteSideClosed
-
localSideClosed
private 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 int receiveWindowSizeLowerBound
-
pendingWriteQueue
private final java.util.Queue<SpdySession.PendingWrite> 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(SpdySession.PendingWrite msg)
-
getPendingWrite
SpdySession.PendingWrite getPendingWrite()
-
removePendingWrite
SpdySession.PendingWrite removePendingWrite()
-
clearPendingWrites
void clearPendingWrites(java.lang.Throwable cause)
-
-