Class SpdySession.StreamState

java.lang.Object

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

Enclosing class:

SpdySession

private static final class SpdySession.StreamState
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	localSideClosed
private final ConcurrentLinkedQueue<MessageEvent>	pendingWriteQueue
private final byte	priority
private boolean	receivedReply
private final AtomicInteger	receiveWindowSize
private int	receiveWindowSizeLowerBound
private boolean	remoteSideClosed
private final AtomicInteger	sendWindowSize

Constructor Summary

Constructors

Constructor	Description
StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)

Method Summary

Modifier and Type	Method	Description
(package private) void	closeLocalSide()
(package private) void	closeRemoteSide()
(package private) MessageEvent	getPendingWrite()
(package private) byte	getPriority()
(package private) int	getReceiveWindowSizeLowerBound()
(package private) int	getSendWindowSize()
(package private) boolean	hasReceivedReply()
(package private) boolean	isLocalSideClosed()
(package private) boolean	isRemoteSideClosed()
(package private) boolean	putPendingWrite(MessageEvent evt)
(package private) void	receivedReply()
(package private) MessageEvent	removePendingWrite()
(package private) void	setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)
(package private) int	updateReceiveWindowSize(int deltaWindowSize)
(package private) int	updateSendWindowSize(int deltaWindowSize)

Methods inherited from class Object

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

Field Details

priority

private final byte priority

remoteSideClosed

private volatile boolean remoteSideClosed

localSideClosed

private volatile boolean localSideClosed

receivedReply

private boolean receivedReply

sendWindowSize

private final AtomicInteger sendWindowSize

receiveWindowSize

private final AtomicInteger receiveWindowSize

receiveWindowSizeLowerBound

private volatile int receiveWindowSizeLowerBound

pendingWriteQueue

private final ConcurrentLinkedQueue<MessageEvent> pendingWriteQueue

Constructor Details

StreamState

StreamState(byte priority,
 boolean remoteSideClosed,
 boolean localSideClosed,
 int sendWindowSize,
 int receiveWindowSize)

Method Details

getPriority

byte getPriority()

isRemoteSideClosed

boolean isRemoteSideClosed()

closeRemoteSide

void closeRemoteSide()

isLocalSideClosed

boolean isLocalSideClosed()

closeLocalSide

void closeLocalSide()

hasReceivedReply

boolean hasReceivedReply()

receivedReply

void receivedReply()

getSendWindowSize

int getSendWindowSize()

updateSendWindowSize

int updateSendWindowSize(int deltaWindowSize)

updateReceiveWindowSize

int updateReceiveWindowSize(int deltaWindowSize)

getReceiveWindowSizeLowerBound

int getReceiveWindowSizeLowerBound()

setReceiveWindowSizeLowerBound

void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)

putPendingWrite

boolean putPendingWrite(MessageEvent evt)

getPendingWrite

MessageEvent getPendingWrite()

removePendingWrite

MessageEvent removePendingWrite()