Class SpdySession

java.lang.Object

org.jboss.netty.handler.codec.spdy.SpdySession

final class SpdySession
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	SpdySession.StreamComparator
private static final class	SpdySession.StreamState

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	activeLocalStreams
private final AtomicInteger	activeRemoteStreams
private final Map<Integer, SpdySession.StreamState>	activeStreams
private final AtomicInteger	receiveWindowSize
private final AtomicInteger	sendWindowSize
private static final SpdyProtocolException	STREAM_CLOSED
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) Map<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)

Methods inherited from class Object

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

Field Details

STREAM_CLOSED

private static final SpdyProtocolException STREAM_CLOSED

activeLocalStreams

private final AtomicInteger activeLocalStreams

activeRemoteStreams

private final AtomicInteger activeRemoteStreams

activeStreams

private final Map<Integer, SpdySession.StreamState> activeStreams

streamComparator

private final SpdySession.StreamComparator streamComparator

sendWindowSize

private final AtomicInteger sendWindowSize

receiveWindowSize

private final AtomicInteger receiveWindowSize

Constructor Details

SpdySession

public SpdySession(int sendWindowSize,
 int receiveWindowSize)

Method Details

numActiveStreams

int numActiveStreams(boolean remote)

noActiveStreams

boolean noActiveStreams()

isActiveStream

boolean isActiveStream(int streamId)

activeStreams

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