io.netty.handler.codec.http2

类 UniformStreamByteDistributor

java.lang.Object

io.netty.handler.codec.http2.UniformStreamByteDistributor

所有已实现的接口:

StreamByteDistributor

@UnstableApi
public final class UniformStreamByteDistributor
extends java.lang.Object
implements StreamByteDistributor

A StreamByteDistributor that ignores stream priority and uniformly allocates bytes to all streams. This class uses a minimum chunk size that will be allocated to each stream. While fewer streams may be written to in each call to StreamByteDistributor.distribute(int, Writer), doing this should improve the goodput on each written stream.

嵌套类概要

从接口继承的嵌套类/接口 io.netty.handler.codec.http2.StreamByteDistributor

StreamByteDistributor.StreamState, StreamByteDistributor.Writer

构造器概要

构造器

构造器和说明
UniformStreamByteDistributor(Http2Connection connection)

方法概要

限定符和类型	方法和说明
boolean	distribute(int maxBytes, StreamByteDistributor.Writer writer) Distributes up to maxBytes to those streams containing streamable bytes and iterates across those streams to write the appropriate bytes.
void	minAllocationChunk(int minAllocationChunk) Sets the minimum allocation chunk that will be allocated to each stream.
void	updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) Explicitly update the dependency tree.
void	updateStreamableBytes(StreamByteDistributor.StreamState streamState) Called when the streamable bytes for a stream has changed.

从类继承的方法 java.lang.Object

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

构造器详细资料

UniformStreamByteDistributor

public UniformStreamByteDistributor(Http2Connection connection)

方法详细资料

minAllocationChunk

public void minAllocationChunk(int minAllocationChunk)

Sets the minimum allocation chunk that will be allocated to each stream. Defaults to 1KiB.

参数:

minAllocationChunk - the minimum number of bytes that will be allocated to each stream. Must be > 0.

updateStreamableBytes

public void updateStreamableBytes(StreamByteDistributor.StreamState streamState)

从接口复制的说明: StreamByteDistributor

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.

指定者:

updateStreamableBytes 在接口中 StreamByteDistributor

updateDependencyTree

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

从接口复制的说明: StreamByteDistributor

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

指定者:

updateDependencyTree 在接口中 StreamByteDistributor

参数:

childStreamId - The stream identifier associated with the child stream.

parentStreamId - The stream identifier associated with the parent stream. May be 0, to make childStreamId and immediate child of the connection.

weight - The weight which is used relative to other child streams for parentStreamId. This value must be between 1 and 256 (inclusive).

exclusive - If childStreamId should be the exclusive dependency of parentStreamId.

distribute

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

从接口复制的说明: StreamByteDistributor

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 StreamByteDistributor.updateStreamableBytes(StreamState).

指定者:

distribute 在接口中 StreamByteDistributor

参数:

maxBytes - the maximum number of bytes to write.

返回:

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

抛出:

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