Package io.netty.handler.codec.spdy
Class SpdySession
- java.lang.Object
-
- io.netty.handler.codec.spdy.SpdySession
-
final class SpdySession extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSpdySession.PendingWriteprivate classSpdySession.StreamComparatorprivate static classSpdySession.StreamState
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicIntegeractiveLocalStreamsprivate java.util.concurrent.atomic.AtomicIntegeractiveRemoteStreamsprivate java.util.Map<java.lang.Integer,SpdySession.StreamState>activeStreamsprivate java.util.concurrent.atomic.AtomicIntegerreceiveWindowSizeprivate java.util.concurrent.atomic.AtomicIntegersendWindowSizeprivate SpdySession.StreamComparatorstreamComparator
-
Constructor Summary
Constructors Constructor Description SpdySession(int sendWindowSize, int receiveWindowSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidacceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize, boolean remote)(package private) java.util.Map<java.lang.Integer,SpdySession.StreamState>activeStreams()(package private) voidcloseLocalSide(int streamId, boolean remote)(package private) voidcloseRemoteSide(int streamId, boolean remote)(package private) SpdySession.PendingWritegetPendingWrite(int streamId)(package private) intgetReceiveWindowSizeLowerBound(int streamId)(package private) intgetSendWindowSize(int streamId)(package private) booleanhasReceivedReply(int streamId)(package private) booleanisActiveStream(int streamId)(package private) booleanisLocalSideClosed(int streamId)(package private) booleanisRemoteSideClosed(int streamId)(package private) booleannoActiveStreams()(package private) intnumActiveStreams(boolean remote)(package private) booleanputPendingWrite(int streamId, SpdySession.PendingWrite pendingWrite)(package private) voidreceivedReply(int streamId)private SpdySession.StreamStateremoveActiveStream(int streamId, boolean remote)(package private) SpdySession.PendingWriteremovePendingWrite(int streamId)(package private) voidremoveStream(int streamId, java.lang.Throwable cause, boolean remote)(package private) voidupdateAllReceiveWindowSizes(int deltaWindowSize)(package private) voidupdateAllSendWindowSizes(int deltaWindowSize)(package private) intupdateReceiveWindowSize(int streamId, int deltaWindowSize)(package private) intupdateSendWindowSize(int streamId, int deltaWindowSize)
-
-
-
Field Detail
-
activeLocalStreams
private final java.util.concurrent.atomic.AtomicInteger activeLocalStreams
-
activeRemoteStreams
private final java.util.concurrent.atomic.AtomicInteger activeRemoteStreams
-
activeStreams
private final java.util.Map<java.lang.Integer,SpdySession.StreamState> activeStreams
-
streamComparator
private final SpdySession.StreamComparator streamComparator
-
sendWindowSize
private final java.util.concurrent.atomic.AtomicInteger sendWindowSize
-
receiveWindowSize
private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize
-
-
Method Detail
-
numActiveStreams
int numActiveStreams(boolean remote)
-
noActiveStreams
boolean noActiveStreams()
-
isActiveStream
boolean isActiveStream(int streamId)
-
activeStreams
java.util.Map<java.lang.Integer,SpdySession.StreamState> activeStreams()
-
acceptStream
void acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize, boolean remote)
-
removeActiveStream
private SpdySession.StreamState removeActiveStream(int streamId, boolean remote)
-
removeStream
void removeStream(int streamId, java.lang.Throwable cause, boolean remote)
-
isRemoteSideClosed
boolean isRemoteSideClosed(int streamId)
-
closeRemoteSide
void closeRemoteSide(int streamId, boolean remote)
-
isLocalSideClosed
boolean isLocalSideClosed(int streamId)
-
closeLocalSide
void closeLocalSide(int streamId, boolean remote)
-
hasReceivedReply
boolean hasReceivedReply(int streamId)
-
receivedReply
void receivedReply(int streamId)
-
getSendWindowSize
int getSendWindowSize(int streamId)
-
updateSendWindowSize
int updateSendWindowSize(int streamId, int deltaWindowSize)
-
updateReceiveWindowSize
int updateReceiveWindowSize(int streamId, int deltaWindowSize)
-
getReceiveWindowSizeLowerBound
int getReceiveWindowSizeLowerBound(int streamId)
-
updateAllSendWindowSizes
void updateAllSendWindowSizes(int deltaWindowSize)
-
updateAllReceiveWindowSizes
void updateAllReceiveWindowSizes(int deltaWindowSize)
-
putPendingWrite
boolean putPendingWrite(int streamId, SpdySession.PendingWrite pendingWrite)
-
getPendingWrite
SpdySession.PendingWrite getPendingWrite(int streamId)
-
removePendingWrite
SpdySession.PendingWrite removePendingWrite(int streamId)
-
-