Class SpdySession
- java.lang.Object
-
- org.jboss.netty.handler.codec.spdy.SpdySession
-
final class SpdySession extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
SpdySession.StreamComparator
private static class
SpdySession.StreamState
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicInteger
activeLocalStreams
private java.util.concurrent.atomic.AtomicInteger
activeRemoteStreams
private java.util.Map<java.lang.Integer,SpdySession.StreamState>
activeStreams
private java.util.concurrent.atomic.AtomicInteger
receiveWindowSize
private java.util.concurrent.atomic.AtomicInteger
sendWindowSize
private static SpdyProtocolException
STREAM_CLOSED
private SpdySession.StreamComparator
streamComparator
-
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) void
acceptStream(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) void
closeLocalSide(int streamId, boolean remote)
(package private) void
closeRemoteSide(int streamId, boolean remote)
(package private) MessageEvent
getPendingWrite(int streamId)
(package private) int
getReceiveWindowSizeLowerBound(int streamId)
(package private) int
getSendWindowSize(int streamId)
(package private) boolean
hasReceivedReply(int streamId)
(package private) boolean
isActiveStream(int streamId)
(package private) boolean
isLocalSideClosed(int streamId)
(package private) boolean
isRemoteSideClosed(int streamId)
(package private) boolean
noActiveStreams()
(package private) int
numActiveStreams(boolean remote)
(package private) boolean
putPendingWrite(int streamId, MessageEvent evt)
(package private) void
receivedReply(int streamId)
private SpdySession.StreamState
removeActiveStream(int streamId, boolean remote)
(package private) MessageEvent
removePendingWrite(int streamId)
(package private) void
removeStream(int streamId, boolean remote)
(package private) void
updateAllReceiveWindowSizes(int deltaWindowSize)
(package private) void
updateAllSendWindowSizes(int deltaWindowSize)
(package private) int
updateReceiveWindowSize(int streamId, int deltaWindowSize)
(package private) int
updateSendWindowSize(int streamId, int deltaWindowSize)
-
-
-
Field Detail
-
STREAM_CLOSED
private static final SpdyProtocolException STREAM_CLOSED
-
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, 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, MessageEvent evt)
-
getPendingWrite
MessageEvent getPendingWrite(int streamId)
-
removePendingWrite
MessageEvent removePendingWrite(int streamId)
-
-