Modifier and Type	Class and Description
private static class	WeightedFairQueueByteDistributor.ParentChangedEvent Allows a correlation to be made between a stream and its old parent before a parent change occurs.
private class	WeightedFairQueueByteDistributor.State The remote flow control state for a single stream.
private static class	WeightedFairQueueByteDistributor.StateOnlyComparator A comparator for `State` which has no associated `Http2Stream` object.
private static class	WeightedFairQueueByteDistributor.StatePseudoTimeComparator

Modifier and Type	Field and Description
private int	allocationQuantum The minimum number of bytes that we will attempt to allocate to a stream.
private final Http2Connection	connection
private final WeightedFairQueueByteDistributor.State	connectionState
private static final int	DEFAULT_MAX_STATE_ONLY_SIZE FireFox currently uses 5 streams to establish QoS classes.
pack-priv static final int	INITIAL_CHILDREN_MAP_SIZE The initial size of the children map is chosen to be conservative on initial memory allocations under the assumption that most streams will have a small number of children.
private final int	maxStateOnlySize
private final Http2Connection.PropertyKey	stateKey
private final IntObjectMap<WeightedFairQueueByteDistributor.State>	stateOnlyMap If there is no Http2Stream object, but we still persist priority information then this is where the state will reside.
private final PriorityQueue<WeightedFairQueueByteDistributor.State>	stateOnlyRemovalQueue This queue will hold streams that are not active and provides the capability to retain priority for streams which have no `Http2Stream` object.

Access	Constructor and Description
public	WeightedFairQueueByteDistributor(Http2Connection connection)
public	WeightedFairQueueByteDistributor(Http2Connection connection, int maxStateOnlySize)

Method Summary

Modifier and Type	Method and Description
public void	allocationQuantum(int the amount of bytes that will be allocated to each stream. Must be > 0. allocationQuantum) Sets the amount of bytes that will be allocated to each stream.
public boolean	distribute(int the maximum number of bytes to write. maxBytes, StreamByteDistributor.Writer writer) Implements io.netty.handler.codec.http2.StreamByteDistributor.distribute. Distributes up to `maxBytes` to those streams containing streamable bytes and iterates across those streams to write the appropriate bytes.
private int	distribute(int maxBytes, StreamByteDistributor.Writer writer, WeightedFairQueueByteDistributor.State state)
private int	distributeToChildren(int maxBytes, StreamByteDistributor.Writer writer, WeightedFairQueueByteDistributor.State state) It is a pre-condition that `state.poll()` returns a non-`null` value.
pack-priv boolean	isChild(int childId, int parentId, short weight) For testing only!
pack-priv void	notifyParentChanged(List<WeightedFairQueueByteDistributor.ParentChangedEvent> The events (top down order) which have changed events) Notify all listeners of the priority tree change events (in ascending order)
pack-priv int	numChildren(int streamId) For testing only!
private WeightedFairQueueByteDistributor.State	state(Http2Stream stream)
private WeightedFairQueueByteDistributor.State	state(int streamId)
public void	updateDependencyTree(int The stream identifier associated with the child stream. childStreamId, int The stream identifier associated with the parent stream. May be `0`, to make `childStreamId` and immediate child of the connection. parentStreamId, short The weight which is used relative to other child streams for `parentStreamId`. This value must be between 1 and 256 (inclusive). weight, boolean If `childStreamId` should be the exclusive dependency of `parentStreamId`. exclusive) Implements io.netty.handler.codec.http2.StreamByteDistributor.updateDependencyTree. Explicitly update the dependency tree.
public void	updateStreamableBytes(StreamByteDistributor.StreamState state) Implements io.netty.handler.codec.http2.StreamByteDistributor.updateStreamableBytes. Called when the streamable bytes for a stream has changed.

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

Field Detail

allocationQuantum	back to summary
private int allocationQuantum The minimum number of bytes that we will attempt to allocate to a stream. This is to help improve goodput on a per-stream basis.

connection	back to summary
private final Http2Connection connection

connectionState	back to summary
private final WeightedFairQueueByteDistributor.State connectionState

DEFAULT_MAX_STATE_ONLY_SIZE	back to summary
private static final int DEFAULT_MAX_STATE_ONLY_SIZE FireFox currently uses 5 streams to establish QoS classes.

INITIAL_CHILDREN_MAP_SIZE	back to summary
pack-priv static final int INITIAL_CHILDREN_MAP_SIZE The initial size of the children map is chosen to be conservative on initial memory allocations under the assumption that most streams will have a small number of children. This choice may be sub-optimal if when children are present there are many children (i.e. a web page which has many dependencies to load). Visible only for testing!

maxStateOnlySize	back to summary
private final int maxStateOnlySize

stateKey	back to summary
private final Http2Connection.PropertyKey stateKey

stateOnlyMap	back to summary
private final IntObjectMap<WeightedFairQueueByteDistributor.State> stateOnlyMap If there is no Http2Stream object, but we still persist priority information then this is where the state will reside.

stateOnlyRemovalQueue	back to summary
private final PriorityQueue<WeightedFairQueueByteDistributor.State> stateOnlyRemovalQueue This queue will hold streams that are not active and provides the capability to retain priority for streams which have no `Http2Stream` object. See `StateOnlyComparator` for the priority comparator.

WeightedFairQueueByteDistributor	back to summary
public WeightedFairQueueByteDistributor(Http2Connection connection)

WeightedFairQueueByteDistributor	back to summary
public WeightedFairQueueByteDistributor(Http2Connection connection, int maxStateOnlySize)

Method Detail

allocationQuantum	back to summary
public void allocationQuantum(int allocationQuantum) Sets the amount of bytes that will be allocated to each stream. Defaults to 1KiB. Parameters allocationQuantum:int the amount of bytes that will be allocated to each stream. Must be > 0.

allocationQuantum

back to summary

public void allocationQuantum(int allocationQuantum)

Sets the amount of bytes that will be allocated to each stream. Defaults to 1KiB.

Parameters

allocationQuantum:int: the amount of bytes that will be allocated to each stream. Must be > 0.

distribute back to summary

distribute	back to summary
public boolean distribute(int maxBytes, StreamByteDistributor.Writer writer) throws Http2Exception Implements io.netty.handler.codec.http2.StreamByteDistributor.distribute. Doc from io.netty.handler.codec.http2.StreamByteDistributor.distribute. Distributes up to `maxBytes` to those streams containing streamable bytes and iterates across those streams to write the appropriate bytes. Criteria for traversing streams is undefined and it is up to the implementation to determine when to stop at a given stream. The streamable bytes are not automatically updated by calling this method. It is up to the caller to indicate the number of bytes streamable after the write by calling `updateStreamableBytes(StreamState)`. Parameters maxBytes:int the maximum number of bytes to write. Returns:boolean `true` if there are still streamable bytes that have not yet been written, otherwise `false`. Annotations @Override Exceptions Http2Exception: If an internal exception occurs and internal connection state would otherwise be corrupted.

public boolean distribute(int maxBytes, StreamByteDistributor.Writer writer) throws Http2Exception

Implements io.netty.handler.codec.http2.StreamByteDistributor.distribute.

Doc from io.netty.handler.codec.http2.StreamByteDistributor.distribute.

Distributes up to maxBytes to those streams containing streamable bytes and iterates across those streams to write the appropriate bytes. Criteria for traversing streams is undefined and it is up to the implementation to determine when to stop at a given stream.

The streamable bytes are not automatically updated by calling this method. It is up to the caller to indicate the number of bytes streamable after the write by calling updateStreamableBytes(StreamState).

Parameters

maxBytes:int: the maximum number of bytes to write.

Returns:boolean

true if there are still streamable bytes that have not yet been written, otherwise false.

Annotations

@Override

Exceptions

Http2Exception:: If an internal exception occurs and internal connection state would otherwise be corrupted.

distribute	back to summary
private int distribute(int maxBytes, StreamByteDistributor.Writer writer, WeightedFairQueueByteDistributor.State state) throws Http2Exception

distributeToChildren back to summary

distributeToChildren	back to summary
private int distributeToChildren(int maxBytes, StreamByteDistributor.Writer writer, WeightedFairQueueByteDistributor.State state) throws Http2Exception It is a pre-condition that `state.poll()` returns a non-`null` value. This is a result of the way the allocation algorithm is structured and can be explained in the following cases: For the recursive case If a stream has no children (in the allocation tree) than that node must be active or it will not be in the allocation tree. If a node is active then it will not delegate to children and recursion ends. For the initial case We check connectionState.activeCountForTree == 0 before any allocation is done. So if the connection stream has no active children we don't get into this method.

private int distributeToChildren(int maxBytes, StreamByteDistributor.Writer writer, WeightedFairQueueByteDistributor.State state) throws Http2Exception

It is a pre-condition that state.poll() returns a non-null value. This is a result of the way the allocation algorithm is structured and can be explained in the following cases:

For the recursive case

If a stream has no children (in the allocation tree) than that node must be active or it will not be in the allocation tree. If a node is active then it will not delegate to children and recursion ends.

For the initial case

We check connectionState.activeCountForTree == 0 before any allocation is done. So if the connection stream has no active children we don't get into this method.

isChild	back to summary
pack-priv boolean isChild(int childId, int parentId, short weight) For testing only!

notifyParentChanged	back to summary
pack-priv void notifyParentChanged(List<WeightedFairQueueByteDistributor.ParentChangedEvent> events) Notify all listeners of the priority tree change events (in ascending order) Parameters events:List<WeightedFairQueueByteDistributor.ParentChangedEvent> The events (top down order) which have changed

notifyParentChanged

back to summary

pack-priv void notifyParentChanged(List<WeightedFairQueueByteDistributor.ParentChangedEvent> events)

Notify all listeners of the priority tree change events (in ascending order)

Parameters

events:List<WeightedFairQueueByteDistributor.ParentChangedEvent>: The events (top down order) which have changed

numChildren	back to summary
pack-priv int numChildren(int streamId) For testing only!

state	back to summary
private WeightedFairQueueByteDistributor.State state(Http2Stream stream)

state	back to summary
private WeightedFairQueueByteDistributor.State state(int streamId)

updateDependencyTree back to summary

updateDependencyTree	back to summary
public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) Implements io.netty.handler.codec.http2.StreamByteDistributor.updateDependencyTree. Doc from io.netty.handler.codec.http2.StreamByteDistributor.updateDependencyTree. Explicitly update the dependency tree. This method is called independently of stream state changes. Parameters childStreamId:int The stream identifier associated with the child stream. parentStreamId:int The stream identifier associated with the parent stream. May be `0`, to make `childStreamId` and immediate child of the connection. weight:short The weight which is used relative to other child streams for `parentStreamId`. This value must be between 1 and 256 (inclusive). exclusive:boolean If `childStreamId` should be the exclusive dependency of `parentStreamId`. Annotations @Override

public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive)

Implements io.netty.handler.codec.http2.StreamByteDistributor.updateDependencyTree.

Doc from io.netty.handler.codec.http2.StreamByteDistributor.updateDependencyTree.

Explicitly update the dependency tree. This method is called independently of stream state changes.

Parameters

childStreamId:int: The stream identifier associated with the child stream.
parentStreamId:int: The stream identifier associated with the parent stream. May be 0, to make childStreamId and immediate child of the connection.
weight:short: The weight which is used relative to other child streams for parentStreamId. This value must be between 1 and 256 (inclusive).
exclusive:boolean: If childStreamId should be the exclusive dependency of parentStreamId.

Annotations

@Override

updateStreamableBytes	back to summary
public void updateStreamableBytes(StreamByteDistributor.StreamState state) Implements io.netty.handler.codec.http2.StreamByteDistributor.updateStreamableBytes. Doc from io.netty.handler.codec.http2.StreamByteDistributor.updateStreamableBytes. Called when the streamable bytes for a stream has changed. Until this method is called for the first time for a give stream, the stream is assumed to have no streamable bytes. Annotations @Override

updateStreamableBytes

back to summary

public void updateStreamableBytes(StreamByteDistributor.StreamState state)

Implements io.netty.handler.codec.http2.StreamByteDistributor.updateStreamableBytes.

Doc from io.netty.handler.codec.http2.StreamByteDistributor.updateStreamableBytes.

Called when the streamable bytes for a stream has changed. Until this method is called for the first time for a give stream, the stream is assumed to have no streamable bytes.

Annotations

@Override

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

private final Class WeightedFairQueueByteDistributor.ParentChangedEvent

Class Inheritance

extends Object

java.lang.Object
io.netty.handler.codec.http2.WeightedFairQueueByteDistributor.ParentChangedEvent

Allows a correlation to be made between a stream and its old parent before a parent change occurs.

Field Summary

Modifier and Type	Field and Description
pack-priv final WeightedFairQueueByteDistributor.State	oldParent
pack-priv final WeightedFairQueueByteDistributor.State	state

Constructor Summary

Access	Constructor and Description
pack-priv	ParentChangedEvent(WeightedFairQueueByteDistributor.State The state who has had a parent change. state, WeightedFairQueueByteDistributor.State The previous parent. oldParent) Create a new instance.

Method Summary

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

Field Detail

oldParent	back to summary
pack-priv final WeightedFairQueueByteDistributor.State oldParent

state	back to summary
pack-priv final WeightedFairQueueByteDistributor.State state

Constructor Detail

ParentChangedEvent	back to summary
pack-priv ParentChangedEvent(WeightedFairQueueByteDistributor.State state, WeightedFairQueueByteDistributor.State oldParent) Create a new instance. Parameters state:WeightedFairQueueByteDistributor.State The state who has had a parent change. oldParent:WeightedFairQueueByteDistributor.State The previous parent.

ParentChangedEvent

back to summary

pack-priv ParentChangedEvent(WeightedFairQueueByteDistributor.State state, WeightedFairQueueByteDistributor.State oldParent)

Create a new instance.

Parameters

state:WeightedFairQueueByteDistributor.State: The state who has had a parent change.
oldParent:WeightedFairQueueByteDistributor.State: The previous parent.

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

private final Class WeightedFairQueueByteDistributor.State

Class Inheritance

extends Object
implements PriorityQueueNode

java.lang.Object
io.netty.handler.codec.http2.WeightedFairQueueByteDistributor.State

All Implemented Interfaces

io.netty.util.internal.PriorityQueueNode

The remote flow control state for a single stream.

Field Summary

Modifier and Type	Field and Description
pack-priv int	activeCountForTree Count of nodes rooted at this sub tree with `isActive()` equal to `true`.
pack-priv IntObjectMap<WeightedFairQueueByteDistributor.State>	children
pack-priv int	dependencyTreeDepth
private byte	flags
pack-priv WeightedFairQueueByteDistributor.State	parent
pack-priv long	pseudoTime A pseudo time maintained for immediate children to base their `pseudoTimeToWrite` off of.
private final PriorityQueue<WeightedFairQueueByteDistributor.State>	pseudoTimeQueue
private int	pseudoTimeQueueIndex
pack-priv long	pseudoTimeToWrite An estimate of when this node should be given the opportunity to write data.
private static final byte	STATE_IS_ACTIVE
private static final byte	STATE_IS_DISTRIBUTING
private static final byte	STATE_STREAM_ACTIVATED
private int	stateOnlyQueueIndex
pack-priv Http2Stream	stream Maybe `null` if the stream if the stream is not active.
pack-priv int	streamableBytes
pack-priv final int	streamId
pack-priv long	totalQueuedWeights
pack-priv short	weight

Constructor Summary

Access	Constructor and Description
pack-priv	State(int streamId)
pack-priv	State(Http2Stream stream)
pack-priv	State(Http2Stream stream, int initialSize)
pack-priv	State(int streamId, Http2Stream stream, int initialSize)

Method Summary

Modifier and Type	Method and Description
pack-priv void	activeCountChangeForTree(int increment)
pack-priv void	close()
private long	getTotalWeight()
private void	initChildren()
private void	initChildrenIfEmpty()
pack-priv boolean	isActive()
pack-priv boolean	isDescendantOf(WeightedFairQueueByteDistributor.State state)
pack-priv boolean	isDistributing()
pack-priv void	offerAndInitializePseudoTime(WeightedFairQueueByteDistributor.State state) The concept of pseudoTime can be influenced by priority tree manipulations or if a stream goes from "active" to "non-active".
pack-priv void	offerPseudoTimeQueue(WeightedFairQueueByteDistributor.State state)
pack-priv WeightedFairQueueByteDistributor.State	peekPseudoTimeQueue()
pack-priv WeightedFairQueueByteDistributor.State	pollPseudoTimeQueue() Must only be called if the pseudoTimeQueue is non-empty!
public int	priorityQueueIndex(DefaultPriorityQueue<?> queue) Implements io.netty.util.internal.PriorityQueueNode.priorityQueueIndex. Get the last value set by `priorityQueueIndex(DefaultPriorityQueue, int)` for the value corresponding to `queue`.
public void	priorityQueueIndex(DefaultPriorityQueue<?> The queue for which the index is being set. queue, int The index as used by `DefaultPriorityQueue`. i) Implements io.netty.util.internal.PriorityQueueNode.priorityQueueIndex. Used by `DefaultPriorityQueue` to maintain state for an element in the queue.
private IntObjectMap<WeightedFairQueueByteDistributor.State>	Returns: The map of children prior to this operation, excluding `streamToRetain` if present. removeAllChildrenExcept(WeightedFairQueueByteDistributor.State stateToRetain) Remove all children with the exception of `streamToRetain`.
pack-priv void	removeChild(WeightedFairQueueByteDistributor.State child) Removes the child priority and moves any of its dependencies to being direct dependencies on this node.
pack-priv void	removePseudoTimeQueue(WeightedFairQueueByteDistributor.State state)
private void	setActive()
pack-priv void	setDistributing()
private void	setParent(WeightedFairQueueByteDistributor.State newParent)
pack-priv void	setStreamReservedOrActivated()
pack-priv void	takeChild(WeightedFairQueueByteDistributor.State child, boolean exclusive, List<WeightedFairQueueByteDistributor.ParentChangedEvent> events)
pack-priv void	takeChild(Iterator<IntObjectMap.PrimitiveEntry<WeightedFairQueueByteDistributor.State>> childItr, WeightedFairQueueByteDistributor.State child, boolean exclusive, List<WeightedFairQueueByteDistributor.ParentChangedEvent> events) Adds a child to this priority.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private void	toString(StringBuilder sb)
private void	unsetActive()
pack-priv void	unsetDistributing()
pack-priv void	updatePseudoTime(WeightedFairQueueByteDistributor.State parentState, int nsent, long totalQueuedWeights) Assumes the parents `totalQueuedWeights` includes this node's weight.
pack-priv void	updateStreamableBytes(int newStreamableBytes, boolean isActive)
pack-priv boolean	wasStreamReservedOrActivated()
pack-priv void	write(int numBytes, StreamByteDistributor.Writer writer)

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

Field Detail

activeCountForTree	back to summary
pack-priv int activeCountForTree Count of nodes rooted at this sub tree with `isActive()` equal to `true`.

children	back to summary
pack-priv IntObjectMap<WeightedFairQueueByteDistributor.State> children

dependencyTreeDepth	back to summary
pack-priv int dependencyTreeDepth

flags	back to summary
private byte flags

parent	back to summary
pack-priv WeightedFairQueueByteDistributor.State parent

pseudoTime	back to summary
pack-priv long pseudoTime A pseudo time maintained for immediate children to base their `pseudoTimeToWrite` off of.

pseudoTimeQueue	back to summary
private final PriorityQueue<WeightedFairQueueByteDistributor.State> pseudoTimeQueue

pseudoTimeQueueIndex	back to summary
private int pseudoTimeQueueIndex

pseudoTimeToWrite	back to summary
pack-priv long pseudoTimeToWrite An estimate of when this node should be given the opportunity to write data.

STATE_IS_ACTIVE	back to summary
private static final byte STATE_IS_ACTIVE

STATE_IS_DISTRIBUTING	back to summary
private static final byte STATE_IS_DISTRIBUTING

STATE_STREAM_ACTIVATED	back to summary
private static final byte STATE_STREAM_ACTIVATED

stateOnlyQueueIndex	back to summary
private int stateOnlyQueueIndex

stream	back to summary
pack-priv Http2Stream stream Maybe `null` if the stream if the stream is not active.

streamableBytes	back to summary
pack-priv int streamableBytes

streamId	back to summary
pack-priv final int streamId

totalQueuedWeights	back to summary
pack-priv long totalQueuedWeights

weight	back to summary
pack-priv short weight

Constructor Detail

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

State	back to summary
pack-priv State(Http2Stream stream)

State	back to summary
pack-priv State(Http2Stream stream, int initialSize)

State	back to summary
pack-priv State(int streamId, Http2Stream stream, int initialSize)

Method Detail

activeCountChangeForTree	back to summary
pack-priv void activeCountChangeForTree(int increment)

close	back to summary
pack-priv void close()

getTotalWeight	back to summary
private long getTotalWeight()

initChildren	back to summary
private void initChildren()

initChildrenIfEmpty	back to summary
private void initChildrenIfEmpty()

isActive	back to summary
pack-priv boolean isActive()

isDescendantOf	back to summary
pack-priv boolean isDescendantOf(WeightedFairQueueByteDistributor.State state)

isDistributing	back to summary
pack-priv boolean isDistributing()

offerAndInitializePseudoTime	back to summary
pack-priv void offerAndInitializePseudoTime(WeightedFairQueueByteDistributor.State state) The concept of pseudoTime can be influenced by priority tree manipulations or if a stream goes from "active" to "non-active". This method accounts for that by initializing the `pseudoTimeToWrite` for `state` to `pseudoTime` of this node and then calls `offerPseudoTimeQueue(State)`.

offerPseudoTimeQueue	back to summary
pack-priv void offerPseudoTimeQueue(WeightedFairQueueByteDistributor.State state)

peekPseudoTimeQueue	back to summary
pack-priv WeightedFairQueueByteDistributor.State peekPseudoTimeQueue()

pollPseudoTimeQueue	back to summary
pack-priv WeightedFairQueueByteDistributor.State pollPseudoTimeQueue() Must only be called if the pseudoTimeQueue is non-empty!

priorityQueueIndex back to summary

public int priorityQueueIndex(DefaultPriorityQueue<?> queue)

Implements io.netty.util.internal.PriorityQueueNode.priorityQueueIndex.

Doc from io.netty.util.internal.PriorityQueueNode.priorityQueueIndex.

Get the last value set by priorityQueueIndex(DefaultPriorityQueue, int) for the value corresponding to queue.

Throwing exceptions from this method will result in undefined behavior.

Annotations

@Override

priorityQueueIndex back to summary

public void priorityQueueIndex(DefaultPriorityQueue<?> queue, int i)

Implements io.netty.util.internal.PriorityQueueNode.priorityQueueIndex.

Doc from io.netty.util.internal.PriorityQueueNode.priorityQueueIndex.

Used by DefaultPriorityQueue to maintain state for an element in the queue.

Throwing exceptions from this method will result in undefined behavior.

Parameters

queue:DefaultPriorityQueue<?>: The queue for which the index is being set.
i:int: The index as used by DefaultPriorityQueue.

Annotations

@Override

removeAllChildrenExcept back to summary

private IntObjectMap<WeightedFairQueueByteDistributor.State> removeAllChildrenExcept(WeightedFairQueueByteDistributor.State stateToRetain)

Remove all children with the exception of streamToRetain. This method is intended to be used to support an exclusive priority dependency operation.

Returns:IntObjectMap<WeightedFairQueueByteDistributor.State>: The map of children prior to this operation, excluding streamToRetain if present.

removeChild	back to summary
pack-priv void removeChild(WeightedFairQueueByteDistributor.State child) Removes the child priority and moves any of its dependencies to being direct dependencies on this node.

removePseudoTimeQueue	back to summary
pack-priv void removePseudoTimeQueue(WeightedFairQueueByteDistributor.State state)

setActive	back to summary
private void setActive()

setDistributing	back to summary
pack-priv void setDistributing()

setParent	back to summary
private void setParent(WeightedFairQueueByteDistributor.State newParent)

setStreamReservedOrActivated	back to summary
pack-priv void setStreamReservedOrActivated()

takeChild	back to summary
pack-priv void takeChild(WeightedFairQueueByteDistributor.State child, boolean exclusive, List<WeightedFairQueueByteDistributor.ParentChangedEvent> events)

takeChild	back to summary
pack-priv void takeChild(Iterator<IntObjectMap.PrimitiveEntry<WeightedFairQueueByteDistributor.State>> childItr, WeightedFairQueueByteDistributor.State child, boolean exclusive, List<WeightedFairQueueByteDistributor.ParentChangedEvent> events) Adds a child to this priority. If exclusive is set, any children of this node are moved to being dependent on the child.

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object

Annotations

@Override

toString	back to summary
private void toString(StringBuilder sb)

unsetActive	back to summary
private void unsetActive()

unsetDistributing	back to summary
pack-priv void unsetDistributing()

updatePseudoTime	back to summary
pack-priv void updatePseudoTime(WeightedFairQueueByteDistributor.State parentState, int nsent, long totalQueuedWeights) Assumes the parents `totalQueuedWeights` includes this node's weight.

updateStreamableBytes	back to summary
pack-priv void updateStreamableBytes(int newStreamableBytes, boolean isActive)

wasStreamReservedOrActivated	back to summary
pack-priv boolean wasStreamReservedOrActivated()

write	back to summary
pack-priv void write(int numBytes, StreamByteDistributor.Writer writer) throws Http2Exception

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

private final Class WeightedFairQueueByteDistributor.StateOnlyComparator

Class Inheritance

extends Object
implements Comparator<WeightedFairQueueByteDistributor.State>, Serializable

java.lang.Object
io.netty.handler.codec.http2.WeightedFairQueueByteDistributor.StateOnlyComparator

All Implemented Interfaces

java.io.Serializable, java.util.Comparator

A comparator for State which has no associated Http2Stream object. The general precedence is:

Was a stream activated or reserved (streams only used for priority are higher priority)
Depth in the priority tree (closer to root is higher priority>
Stream ID (higher stream ID is higher priority - used for tie breaker)

Field Summary

Modifier and Type	Field and Description
pack-priv static final WeightedFairQueueByteDistributor.StateOnlyComparator	INSTANCE
private static final long	serialVersionUID

Constructor Summary

Access	Constructor and Description
private	StateOnlyComparator()

Method Summary

Modifier and Type	Method and Description
public int	compare(WeightedFairQueueByteDistributor.State the first object to be compared. o1, WeightedFairQueueByteDistributor.State the second object to be compared. o2) 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

Field Detail

INSTANCE	back to summary
pack-priv static final WeightedFairQueueByteDistributor.StateOnlyComparator INSTANCE

serialVersionUID	back to summary
private static final long serialVersionUID

Constructor Detail

StateOnlyComparator	back to summary
private StateOnlyComparator()

Method Detail

compare back to summary

public int compare(WeightedFairQueueByteDistributor.State o1, WeightedFairQueueByteDistributor.State o2)

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

o1:WeightedFairQueueByteDistributor.State: the first object to be compared.
o2:WeightedFairQueueByteDistributor.State: 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.http2 back to summary

private final Class WeightedFairQueueByteDistributor.StatePseudoTimeComparator

Class Inheritance

extends Object
implements Comparator<WeightedFairQueueByteDistributor.State>, Serializable

java.lang.Object
io.netty.handler.codec.http2.WeightedFairQueueByteDistributor.StatePseudoTimeComparator

All Implemented Interfaces

java.io.Serializable, java.util.Comparator

Field Summary

Modifier and Type	Field and Description
pack-priv static final WeightedFairQueueByteDistributor.StatePseudoTimeComparator	INSTANCE
private static final long	serialVersionUID

Constructor Summary

Access	Constructor and Description
private	StatePseudoTimeComparator()

Method Summary

Modifier and Type	Method and Description
public int	compare(WeightedFairQueueByteDistributor.State the first object to be compared. o1, WeightedFairQueueByteDistributor.State the second object to be compared. o2) 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

Field Detail

INSTANCE	back to summary
pack-priv static final WeightedFairQueueByteDistributor.StatePseudoTimeComparator INSTANCE

serialVersionUID	back to summary
private static final long serialVersionUID

Constructor Detail

StatePseudoTimeComparator	back to summary
private StatePseudoTimeComparator()

Method Detail

compare back to summary

public int compare(WeightedFairQueueByteDistributor.State o1, WeightedFairQueueByteDistributor.State o2)

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

o1:WeightedFairQueueByteDistributor.State: the first object to be compared.
o2:WeightedFairQueueByteDistributor.State: 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 final Class WeightedFairQueueByteDistributor

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

For the recursive case

For the initial case

private final Class WeightedFairQueueByteDistributor.ParentChangedEvent

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private final Class WeightedFairQueueByteDistributor.State

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class WeightedFairQueueByteDistributor.StateOnlyComparator

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class WeightedFairQueueByteDistributor.StatePseudoTimeComparator

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail