final class SpdySession
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
SpdySession.PendingWrite |
private class |
SpdySession.StreamComparator |
private static class |
SpdySession.StreamState |
Modifier and Type | Field and 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 SpdySession.StreamComparator |
streamComparator |
Constructor and Description |
---|
SpdySession(int sendWindowSize,
int receiveWindowSize) |
Modifier and Type | Method and 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) SpdySession.PendingWrite |
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,
SpdySession.PendingWrite pendingWrite) |
(package private) void |
receivedReply(int streamId) |
private SpdySession.StreamState |
removeActiveStream(int streamId,
boolean remote) |
(package private) SpdySession.PendingWrite |
removePendingWrite(int streamId) |
(package private) void |
removeStream(int streamId,
java.lang.Throwable cause,
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) |
private final java.util.concurrent.atomic.AtomicInteger activeLocalStreams
private final java.util.concurrent.atomic.AtomicInteger activeRemoteStreams
private final java.util.Map<java.lang.Integer,SpdySession.StreamState> activeStreams
private final SpdySession.StreamComparator streamComparator
private final java.util.concurrent.atomic.AtomicInteger sendWindowSize
private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize
int numActiveStreams(boolean remote)
boolean noActiveStreams()
boolean isActiveStream(int streamId)
java.util.Map<java.lang.Integer,SpdySession.StreamState> activeStreams()
void acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize, boolean remote)
private SpdySession.StreamState removeActiveStream(int streamId, boolean remote)
void removeStream(int streamId, java.lang.Throwable cause, boolean remote)
boolean isRemoteSideClosed(int streamId)
void closeRemoteSide(int streamId, boolean remote)
boolean isLocalSideClosed(int streamId)
void closeLocalSide(int streamId, boolean remote)
boolean hasReceivedReply(int streamId)
void receivedReply(int streamId)
int getSendWindowSize(int streamId)
int updateSendWindowSize(int streamId, int deltaWindowSize)
int updateReceiveWindowSize(int streamId, int deltaWindowSize)
int getReceiveWindowSizeLowerBound(int streamId)
void updateAllSendWindowSizes(int deltaWindowSize)
void updateAllReceiveWindowSizes(int deltaWindowSize)
boolean putPendingWrite(int streamId, SpdySession.PendingWrite pendingWrite)
SpdySession.PendingWrite getPendingWrite(int streamId)
SpdySession.PendingWrite removePendingWrite(int streamId)