org.jboss.netty.handler.codec.spdy

Class SpdySession.StreamState

java.lang.Object

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

Enclosing class:

SpdySession

private static final class SpdySession.StreamState
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	localSideClosed
private java.util.concurrent.ConcurrentLinkedQueue<MessageEvent>	pendingWriteQueue
private byte	priority
private boolean	receivedReply
private java.util.concurrent.atomic.AtomicInteger	receiveWindowSize
private int	receiveWindowSizeLowerBound
private boolean	remoteSideClosed
private java.util.concurrent.atomic.AtomicInteger	sendWindowSize

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 java.lang.Object

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

Field Detail

priority

private final byte priority

remoteSideClosed

private volatile boolean remoteSideClosed

localSideClosed

private volatile boolean localSideClosed

receivedReply

private boolean receivedReply

sendWindowSize

private final java.util.concurrent.atomic.AtomicInteger sendWindowSize

receiveWindowSize

private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize

receiveWindowSizeLowerBound

private volatile int receiveWindowSizeLowerBound

pendingWriteQueue

private final java.util.concurrent.ConcurrentLinkedQueue<MessageEvent> pendingWriteQueue

Constructor Detail

StreamState

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

Method Detail

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