const priorityDefaultWeight … type PriorityWriteSchedulerConfig … // NewPriorityWriteScheduler constructs a WriteScheduler that schedules // frames by following HTTP/2 priorities as described in RFC 7540 Section 5.3. // If cfg is nil, default options are used. func NewPriorityWriteScheduler(cfg *PriorityWriteSchedulerConfig) WriteScheduler { … } type priorityNodeState … const priorityNodeOpen … const priorityNodeClosed … const priorityNodeIdle … type priorityNode … func (n *priorityNode) setParent(parent *priorityNode) { … } func (n *priorityNode) addBytes(b int64) { … } // walkReadyInOrder iterates over the tree in priority order, calling f for each node // with a non-empty write queue. When f returns true, this function returns true and the // walk halts. tmp is used as scratch space for sorting. // // f(n, openParent) takes two arguments: the node to visit, n, and a bool that is true // if any ancestor p of n is still open (ignoring the root node). func (n *priorityNode) walkReadyInOrder(openParent bool, tmp *[]*priorityNode, f func(*priorityNode, bool) bool) bool { … } type sortPriorityNodeSiblings … func (z sortPriorityNodeSiblings) Len() int { … } func (z sortPriorityNodeSiblings) Swap(i, k int) { … } func (z sortPriorityNodeSiblings) Less(i, k int) bool { … } type priorityWriteScheduler … func (ws *priorityWriteScheduler) OpenStream(streamID uint32, options OpenStreamOptions) { … } func (ws *priorityWriteScheduler) CloseStream(streamID uint32) { … } func (ws *priorityWriteScheduler) AdjustStream(streamID uint32, priority PriorityParam) { … } func (ws *priorityWriteScheduler) Push(wr FrameWriteRequest) { … } func (ws *priorityWriteScheduler) Pop() (wr FrameWriteRequest, ok bool) { … } func (ws *priorityWriteScheduler) addClosedOrIdleNode(list *[]*priorityNode, maxSize int, n *priorityNode) { … } func (ws *priorityWriteScheduler) removeNode(n *priorityNode) { … }
Codebase Browser
kubernetes