Package io.netty.handler.codec.spdy

Class SpdySession.StreamState

java.lang.Object

io.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 Queue<SpdySession.PendingWrite>	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	clearPendingWrites(Throwable cause)
(package private) void	closeLocalSide()
(package private) void	closeRemoteSide()
(package private) SpdySession.PendingWrite	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(SpdySession.PendingWrite msg)
(package private) void	receivedReply()
(package private) SpdySession.PendingWrite	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 Details

priority

private final byte priority

remoteSideClosed

private boolean remoteSideClosed

localSideClosed

private boolean localSideClosed

receivedReply

private boolean receivedReply

sendWindowSize

private final AtomicInteger sendWindowSize

receiveWindowSize

private final AtomicInteger receiveWindowSize

receiveWindowSizeLowerBound

private int receiveWindowSizeLowerBound

pendingWriteQueue

private final Queue<SpdySession.PendingWrite> 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(SpdySession.PendingWrite msg)

getPendingWrite

SpdySession.PendingWrite getPendingWrite()

removePendingWrite

SpdySession.PendingWrite removePendingWrite()

clearPendingWrites

void clearPendingWrites(Throwable cause)