Package | Description |
---|---|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
Modifier and Type | Field and Description |
---|---|
private WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.connectionState |
(package private) WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.ParentChangedEvent.oldParent |
(package private) WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.State.parent |
(package private) WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.ParentChangedEvent.state |
Modifier and Type | Field and Description |
---|---|
(package private) IntObjectMap<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.State.children |
private PriorityQueue<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.State.pseudoTimeQueue |
private IntObjectMap<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.stateOnlyMap
If there is no Http2Stream object, but we still persist priority information then this is where the state will
reside.
|
private PriorityQueue<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.stateOnlyRemovalQueue
This queue will hold streams that are not active and provides the capability to retain priority for streams which
have no
Http2Stream object. |
Modifier and Type | Method and Description |
---|---|
(package private) WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.State.peekPseudoTimeQueue() |
(package private) WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.State.pollPseudoTimeQueue()
Must only be called if the pseudoTimeQueue is non-empty!
|
private WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.state(Http2Stream stream) |
private WeightedFairQueueByteDistributor.State |
WeightedFairQueueByteDistributor.state(int streamId) |
Modifier and Type | Method and Description |
---|---|
private IntObjectMap<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.State.removeAllChildrenExcept(WeightedFairQueueByteDistributor.State stateToRetain)
Remove all children with the exception of
streamToRetain . |
Modifier and Type | Method and Description |
---|---|
int |
WeightedFairQueueByteDistributor.StateOnlyComparator.compare(WeightedFairQueueByteDistributor.State o1,
WeightedFairQueueByteDistributor.State o2) |
int |
WeightedFairQueueByteDistributor.StatePseudoTimeComparator.compare(WeightedFairQueueByteDistributor.State o1,
WeightedFairQueueByteDistributor.State o2) |
private int |
WeightedFairQueueByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer,
WeightedFairQueueByteDistributor.State state) |
private int |
WeightedFairQueueByteDistributor.distributeToChildren(int maxBytes,
StreamByteDistributor.Writer writer,
WeightedFairQueueByteDistributor.State state)
It is a pre-condition that
state.poll() returns a non-null value. |
(package private) boolean |
WeightedFairQueueByteDistributor.State.isDescendantOf(WeightedFairQueueByteDistributor.State state) |
(package private) void |
WeightedFairQueueByteDistributor.State.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".
|
(package private) void |
WeightedFairQueueByteDistributor.State.offerPseudoTimeQueue(WeightedFairQueueByteDistributor.State state) |
private IntObjectMap<WeightedFairQueueByteDistributor.State> |
WeightedFairQueueByteDistributor.State.removeAllChildrenExcept(WeightedFairQueueByteDistributor.State stateToRetain)
Remove all children with the exception of
streamToRetain . |
(package private) void |
WeightedFairQueueByteDistributor.State.removeChild(WeightedFairQueueByteDistributor.State child)
Removes the child priority and moves any of its dependencies to being direct dependencies on this node.
|
(package private) void |
WeightedFairQueueByteDistributor.State.removePseudoTimeQueue(WeightedFairQueueByteDistributor.State state) |
private void |
WeightedFairQueueByteDistributor.State.setParent(WeightedFairQueueByteDistributor.State newParent) |
(package private) void |
WeightedFairQueueByteDistributor.State.takeChild(java.util.Iterator<IntObjectMap.PrimitiveEntry<WeightedFairQueueByteDistributor.State>> childItr,
WeightedFairQueueByteDistributor.State child,
boolean exclusive,
java.util.List<WeightedFairQueueByteDistributor.ParentChangedEvent> events)
Adds a child to this priority.
|
(package private) void |
WeightedFairQueueByteDistributor.State.takeChild(WeightedFairQueueByteDistributor.State child,
boolean exclusive,
java.util.List<WeightedFairQueueByteDistributor.ParentChangedEvent> events) |
(package private) void |
WeightedFairQueueByteDistributor.State.updatePseudoTime(WeightedFairQueueByteDistributor.State parentState,
int nsent,
long totalQueuedWeights)
Assumes the parents
totalQueuedWeights includes this node's weight. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
WeightedFairQueueByteDistributor.State.takeChild(java.util.Iterator<IntObjectMap.PrimitiveEntry<WeightedFairQueueByteDistributor.State>> childItr,
WeightedFairQueueByteDistributor.State child,
boolean exclusive,
java.util.List<WeightedFairQueueByteDistributor.ParentChangedEvent> events)
Adds a child to this priority.
|
Constructor and Description |
---|
ParentChangedEvent(WeightedFairQueueByteDistributor.State state,
WeightedFairQueueByteDistributor.State oldParent)
Create a new instance.
|