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 final class	SpdySession.PendingWrite
private final class	SpdySession.StreamComparator
private static final class	SpdySession.StreamState

Field Summary

Fields

Modifier and Type	Field	Description
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 java.util.concurrent.atomic.AtomicInteger	receiveWindowSize
private final java.util.concurrent.atomic.AtomicInteger	sendWindowSize
private final SpdySession.StreamComparator	streamComparator

Constructor Summary

Constructors

Constructor	Description
SpdySession(int sendWindowSize, int receiveWindowSize)

Method Summary

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) 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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

Constructor Details

SpdySession

SpdySession(int sendWindowSize,
 int receiveWindowSize)

Method Details

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)