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

Modifier and Type	Field and 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 final SpdySession.StreamComparator	streamComparator

Access	Constructor and Description
pack-priv	SpdySession(int sendWindowSize, int receiveWindowSize)

Method Summary

Modifier and Type	Method and Description
pack-priv void	acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize, boolean remote)
pack-priv Map<Integer, SpdySession.StreamState>	activeStreams()
pack-priv void	closeLocalSide(int streamId, boolean remote)
pack-priv void	closeRemoteSide(int streamId, boolean remote)
pack-priv SpdySession.PendingWrite	getPendingWrite(int streamId)
pack-priv int	getReceiveWindowSizeLowerBound(int streamId)
pack-priv int	getSendWindowSize(int streamId)
pack-priv boolean	hasReceivedReply(int streamId)
pack-priv boolean	isActiveStream(int streamId)
pack-priv boolean	isLocalSideClosed(int streamId)
pack-priv boolean	isRemoteSideClosed(int streamId)
pack-priv boolean	noActiveStreams()
pack-priv int	numActiveStreams(boolean remote)
pack-priv boolean	putPendingWrite(int streamId, SpdySession.PendingWrite pendingWrite)
pack-priv void	receivedReply(int streamId)
private SpdySession.StreamState	removeActiveStream(int streamId, boolean remote)
pack-priv SpdySession.PendingWrite	removePendingWrite(int streamId)
pack-priv void	removeStream(int streamId, Throwable cause, boolean remote)
pack-priv void	updateAllReceiveWindowSizes(int deltaWindowSize)
pack-priv void	updateAllSendWindowSizes(int deltaWindowSize)
pack-priv int	updateReceiveWindowSize(int streamId, int deltaWindowSize)
pack-priv int	updateSendWindowSize(int streamId, int deltaWindowSize)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

activeLocalStreams	back to summary
private final AtomicInteger activeLocalStreams

activeRemoteStreams	back to summary
private final AtomicInteger activeRemoteStreams

activeStreams	back to summary
private final Map<Integer, SpdySession.StreamState> activeStreams

receiveWindowSize	back to summary
private final AtomicInteger receiveWindowSize

sendWindowSize	back to summary
private final AtomicInteger sendWindowSize

streamComparator	back to summary
private final SpdySession.StreamComparator streamComparator

SpdySession	back to summary
pack-priv SpdySession(int sendWindowSize, int receiveWindowSize)

Method Detail

acceptStream	back to summary
pack-priv void acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize, boolean remote)

activeStreams	back to summary
pack-priv Map<Integer, SpdySession.StreamState> activeStreams()

closeLocalSide	back to summary
pack-priv void closeLocalSide(int streamId, boolean remote)

closeRemoteSide	back to summary
pack-priv void closeRemoteSide(int streamId, boolean remote)

getPendingWrite	back to summary
pack-priv SpdySession.PendingWrite getPendingWrite(int streamId)

getReceiveWindowSizeLowerBound	back to summary
pack-priv int getReceiveWindowSizeLowerBound(int streamId)

getSendWindowSize	back to summary
pack-priv int getSendWindowSize(int streamId)

hasReceivedReply	back to summary
pack-priv boolean hasReceivedReply(int streamId)

isActiveStream	back to summary
pack-priv boolean isActiveStream(int streamId)

isLocalSideClosed	back to summary
pack-priv boolean isLocalSideClosed(int streamId)

isRemoteSideClosed	back to summary
pack-priv boolean isRemoteSideClosed(int streamId)

noActiveStreams	back to summary
pack-priv boolean noActiveStreams()

numActiveStreams	back to summary
pack-priv int numActiveStreams(boolean remote)

putPendingWrite	back to summary
pack-priv boolean putPendingWrite(int streamId, SpdySession.PendingWrite pendingWrite)

receivedReply	back to summary
pack-priv void receivedReply(int streamId)

removeActiveStream	back to summary
private SpdySession.StreamState removeActiveStream(int streamId, boolean remote)

removePendingWrite	back to summary
pack-priv SpdySession.PendingWrite removePendingWrite(int streamId)

removeStream	back to summary
pack-priv void removeStream(int streamId, Throwable cause, boolean remote)

updateAllReceiveWindowSizes	back to summary
pack-priv void updateAllReceiveWindowSizes(int deltaWindowSize)

updateAllSendWindowSizes	back to summary
pack-priv void updateAllSendWindowSizes(int deltaWindowSize)

updateReceiveWindowSize	back to summary
pack-priv int updateReceiveWindowSize(int streamId, int deltaWindowSize)

updateSendWindowSize	back to summary
pack-priv int updateSendWindowSize(int streamId, int deltaWindowSize)

io.netty.handler.codec.spdy back to summary

public final Class SpdySession.PendingWrite

Class Inheritance

extends Object

java.lang.Object
io.netty.handler.codec.spdy.SpdySession.PendingWrite

Field Summary

Modifier and Type	Field and Description
pack-priv final ChannelPromise	promise
pack-priv final SpdyDataFrame	spdyDataFrame

Constructor Summary

Access	Constructor and Description
pack-priv	PendingWrite(SpdyDataFrame spdyDataFrame, ChannelPromise promise)

Method Summary

Modifier and Type	Method and Description
pack-priv void	fail(Throwable cause)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

promise	back to summary
pack-priv final ChannelPromise promise

spdyDataFrame	back to summary
pack-priv final SpdyDataFrame spdyDataFrame

Constructor Detail

PendingWrite	back to summary
pack-priv PendingWrite(SpdyDataFrame spdyDataFrame, ChannelPromise promise)

Method Detail

fail	back to summary
pack-priv void fail(Throwable cause)

io.netty.handler.codec.spdy back to summary

private final Class SpdySession.StreamComparator

Class Inheritance

extends Object
implements Comparator<Integer>

java.lang.Object
io.netty.handler.codec.spdy.SpdySession.StreamComparator

All Implemented Interfaces

java.util.Comparator

Constructor Summary

Access	Constructor and Description
pack-priv	StreamComparator()

Method Summary

Modifier and Type	Method and Description
public int	compare(Integer the first object to be compared. id1, Integer the second object to be compared. id2) Implements java.util.Comparator.compare. Compares its two arguments for order.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

StreamComparator	back to summary
pack-priv StreamComparator()

Method Detail

compare back to summary

compare	back to summary
public int compare(Integer id1, Integer id2) Implements java.util.Comparator.compare. Doc from java.util.Comparator.compare. Compares its two arguments for order. Returns a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second. The implementor must ensure that `signum(compare(x, y)) == -signum(compare(y, x))` for all `x` and `y`. (This implies that `compare(x, y)` must throw an exception if and only if `compare(y, x)` throws an exception.) The implementor must also ensure that the relation is transitive: `((compare(x, y)>0) && (compare(y, z)>0))` implies `compare(x, z)>0`. Finally, the implementor must ensure that `compare(x, y)==0` implies that `signum(compare(x, z))==signum(compare(y, z))` for all `z`. Parameters id1:Integer the first object to be compared. id2:Integer the second object to be compared. Returns:int a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second. Annotations @Override

public int compare(Integer id1, Integer id2)

Implements java.util.Comparator.compare.

Doc from java.util.Comparator.compare.

Compares its two arguments for order. Returns a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second.

The implementor must ensure that signum(compare(x, y)) == -signum(compare(y, x)) for all x and y. (This implies that compare(x, y) must throw an exception if and only if compare(y, x) throws an exception.)

The implementor must also ensure that the relation is transitive: ((compare(x, y)>0) && (compare(y, z)>0)) implies compare(x, z)>0.

Finally, the implementor must ensure that compare(x, y)==0 implies that signum(compare(x, z))==signum(compare(y, z)) for all z.

Parameters

id1:Integer: the first object to be compared.
id2:Integer: the second object to be compared.

Returns:int

a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second.

Annotations

@Override

io.netty.handler.codec.spdy back to summary

private final Class SpdySession.StreamState

Class Inheritance

extends Object

java.lang.Object
io.netty.handler.codec.spdy.SpdySession.StreamState

Field Summary

Modifier and Type	Field and 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

Access	Constructor and Description
pack-priv	StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)

Method Summary

Modifier and Type	Method and Description
pack-priv void	clearPendingWrites(Throwable cause)
pack-priv void	closeLocalSide()
pack-priv void	closeRemoteSide()
pack-priv SpdySession.PendingWrite	getPendingWrite()
pack-priv byte	getPriority()
pack-priv int	getReceiveWindowSizeLowerBound()
pack-priv int	getSendWindowSize()
pack-priv boolean	hasReceivedReply()
pack-priv boolean	isLocalSideClosed()
pack-priv boolean	isRemoteSideClosed()
pack-priv boolean	putPendingWrite(SpdySession.PendingWrite msg)
pack-priv void	receivedReply()
pack-priv SpdySession.PendingWrite	removePendingWrite()
pack-priv void	setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)
pack-priv int	updateReceiveWindowSize(int deltaWindowSize)
pack-priv int	updateSendWindowSize(int deltaWindowSize)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

localSideClosed	back to summary
private boolean localSideClosed

pendingWriteQueue	back to summary
private final Queue<SpdySession.PendingWrite> pendingWriteQueue

priority	back to summary
private final byte priority

receivedReply	back to summary
private boolean receivedReply

receiveWindowSize	back to summary
private final AtomicInteger receiveWindowSize

receiveWindowSizeLowerBound	back to summary
private int receiveWindowSizeLowerBound

remoteSideClosed	back to summary
private boolean remoteSideClosed

sendWindowSize	back to summary
private final AtomicInteger sendWindowSize

Constructor Detail

StreamState	back to summary
pack-priv StreamState(byte priority, boolean remoteSideClosed, boolean localSideClosed, int sendWindowSize, int receiveWindowSize)

Method Detail

clearPendingWrites	back to summary
pack-priv void clearPendingWrites(Throwable cause)

closeLocalSide	back to summary
pack-priv void closeLocalSide()

closeRemoteSide	back to summary
pack-priv void closeRemoteSide()

getPendingWrite	back to summary
pack-priv SpdySession.PendingWrite getPendingWrite()

getPriority	back to summary
pack-priv byte getPriority()

getReceiveWindowSizeLowerBound	back to summary
pack-priv int getReceiveWindowSizeLowerBound()

getSendWindowSize	back to summary
pack-priv int getSendWindowSize()

hasReceivedReply	back to summary
pack-priv boolean hasReceivedReply()

isLocalSideClosed	back to summary
pack-priv boolean isLocalSideClosed()

isRemoteSideClosed	back to summary
pack-priv boolean isRemoteSideClosed()

putPendingWrite	back to summary
pack-priv boolean putPendingWrite(SpdySession.PendingWrite msg)

receivedReply	back to summary
pack-priv void receivedReply()

removePendingWrite	back to summary
pack-priv SpdySession.PendingWrite removePendingWrite()

setReceiveWindowSizeLowerBound	back to summary
pack-priv void setReceiveWindowSizeLowerBound(int receiveWindowSizeLowerBound)

updateReceiveWindowSize	back to summary
pack-priv int updateReceiveWindowSize(int deltaWindowSize)

updateSendWindowSize	back to summary
pack-priv int updateSendWindowSize(int deltaWindowSize)

pack-priv final Class SpdySession

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class SpdySession.PendingWrite

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class SpdySession.StreamComparator

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private final Class SpdySession.StreamState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail