mirror of
https://github.com/genuinetools/reg.git
synced 2024-09-19 08:41:02 -04:00
542 lines
17 KiB
Go
542 lines
17 KiB
Go
|
// Copyright 2016 The Go Authors. All rights reserved.
|
||
|
// Use of this source code is governed by a BSD-style
|
||
|
// license that can be found in the LICENSE file.
|
||
|
|
||
|
package http2
|
||
|
|
||
|
import (
|
||
|
"bytes"
|
||
|
"fmt"
|
||
|
"sort"
|
||
|
"testing"
|
||
|
)
|
||
|
|
||
|
func defaultPriorityWriteScheduler() *priorityWriteScheduler {
|
||
|
return NewPriorityWriteScheduler(nil).(*priorityWriteScheduler)
|
||
|
}
|
||
|
|
||
|
func checkPriorityWellFormed(ws *priorityWriteScheduler) error {
|
||
|
for id, n := range ws.nodes {
|
||
|
if id != n.id {
|
||
|
return fmt.Errorf("bad ws.nodes: ws.nodes[%d] = %d", id, n.id)
|
||
|
}
|
||
|
if n.parent == nil {
|
||
|
if n.next != nil || n.prev != nil {
|
||
|
return fmt.Errorf("bad node %d: nil parent but prev/next not nil", id)
|
||
|
}
|
||
|
continue
|
||
|
}
|
||
|
found := false
|
||
|
for k := n.parent.kids; k != nil; k = k.next {
|
||
|
if k.id == id {
|
||
|
found = true
|
||
|
break
|
||
|
}
|
||
|
}
|
||
|
if !found {
|
||
|
return fmt.Errorf("bad node %d: not found in parent %d kids list", id, n.parent.id)
|
||
|
}
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
func fmtTree(ws *priorityWriteScheduler, fmtNode func(*priorityNode) string) string {
|
||
|
var ids []int
|
||
|
for _, n := range ws.nodes {
|
||
|
ids = append(ids, int(n.id))
|
||
|
}
|
||
|
sort.Ints(ids)
|
||
|
|
||
|
var buf bytes.Buffer
|
||
|
for _, id := range ids {
|
||
|
if buf.Len() != 0 {
|
||
|
buf.WriteString(" ")
|
||
|
}
|
||
|
if id == 0 {
|
||
|
buf.WriteString(fmtNode(&ws.root))
|
||
|
} else {
|
||
|
buf.WriteString(fmtNode(ws.nodes[uint32(id)]))
|
||
|
}
|
||
|
}
|
||
|
return buf.String()
|
||
|
}
|
||
|
|
||
|
func fmtNodeParentSkipRoot(n *priorityNode) string {
|
||
|
switch {
|
||
|
case n.id == 0:
|
||
|
return ""
|
||
|
case n.parent == nil:
|
||
|
return fmt.Sprintf("%d{parent:nil}", n.id)
|
||
|
default:
|
||
|
return fmt.Sprintf("%d{parent:%d}", n.id, n.parent.id)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func fmtNodeWeightParentSkipRoot(n *priorityNode) string {
|
||
|
switch {
|
||
|
case n.id == 0:
|
||
|
return ""
|
||
|
case n.parent == nil:
|
||
|
return fmt.Sprintf("%d{weight:%d,parent:nil}", n.id, n.weight)
|
||
|
default:
|
||
|
return fmt.Sprintf("%d{weight:%d,parent:%d}", n.id, n.weight, n.parent.id)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityTwoStreams(t *testing.T) {
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{})
|
||
|
|
||
|
want := "1{weight:15,parent:0} 2{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After open\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
|
||
|
// Move 1's parent to 2.
|
||
|
ws.AdjustStream(1, PriorityParam{
|
||
|
StreamDep: 2,
|
||
|
Weight: 32,
|
||
|
Exclusive: false,
|
||
|
})
|
||
|
want = "1{weight:32,parent:2} 2{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityAdjustExclusiveZero(t *testing.T) {
|
||
|
// 1, 2, and 3 are all children of the 0 stream.
|
||
|
// Exclusive reprioritization to any of the streams should bring
|
||
|
// the rest of the streams under the reprioritized stream.
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{})
|
||
|
ws.OpenStream(3, OpenStreamOptions{})
|
||
|
|
||
|
want := "1{weight:15,parent:0} 2{weight:15,parent:0} 3{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After open\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
|
||
|
ws.AdjustStream(2, PriorityParam{
|
||
|
StreamDep: 0,
|
||
|
Weight: 20,
|
||
|
Exclusive: true,
|
||
|
})
|
||
|
want = "1{weight:15,parent:2} 2{weight:20,parent:0} 3{weight:15,parent:2}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityAdjustOwnParent(t *testing.T) {
|
||
|
// Assigning a node as its own parent should have no effect.
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{})
|
||
|
ws.AdjustStream(2, PriorityParam{
|
||
|
StreamDep: 2,
|
||
|
Weight: 20,
|
||
|
Exclusive: true,
|
||
|
})
|
||
|
want := "1{weight:15,parent:0} 2{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityClosedStreams(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{MaxClosedNodesInTree: 2}).(*priorityWriteScheduler)
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 2})
|
||
|
ws.OpenStream(4, OpenStreamOptions{PusherID: 3})
|
||
|
|
||
|
// Close the first three streams. We lose 1, but keep 2 and 3.
|
||
|
ws.CloseStream(1)
|
||
|
ws.CloseStream(2)
|
||
|
ws.CloseStream(3)
|
||
|
|
||
|
want := "2{weight:15,parent:0} 3{weight:15,parent:2} 4{weight:15,parent:3}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After close\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
|
||
|
// Adding a stream as an exclusive child of 1 gives it default
|
||
|
// priorities, since 1 is gone.
|
||
|
ws.OpenStream(5, OpenStreamOptions{})
|
||
|
ws.AdjustStream(5, PriorityParam{StreamDep: 1, Weight: 15, Exclusive: true})
|
||
|
|
||
|
// Adding a stream as an exclusive child of 2 should work, since 2 is not gone.
|
||
|
ws.OpenStream(6, OpenStreamOptions{})
|
||
|
ws.AdjustStream(6, PriorityParam{StreamDep: 2, Weight: 15, Exclusive: true})
|
||
|
|
||
|
want = "2{weight:15,parent:0} 3{weight:15,parent:6} 4{weight:15,parent:3} 5{weight:15,parent:0} 6{weight:15,parent:2}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After add streams\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityClosedStreamsDisabled(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{}).(*priorityWriteScheduler)
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 2})
|
||
|
|
||
|
// Close the first two streams. We keep only 3.
|
||
|
ws.CloseStream(1)
|
||
|
ws.CloseStream(2)
|
||
|
|
||
|
want := "3{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After close\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityIdleStreams(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{MaxIdleNodesInTree: 2}).(*priorityWriteScheduler)
|
||
|
ws.AdjustStream(1, PriorityParam{StreamDep: 0, Weight: 15}) // idle
|
||
|
ws.AdjustStream(2, PriorityParam{StreamDep: 0, Weight: 15}) // idle
|
||
|
ws.AdjustStream(3, PriorityParam{StreamDep: 2, Weight: 20}) // idle
|
||
|
ws.OpenStream(4, OpenStreamOptions{})
|
||
|
ws.OpenStream(5, OpenStreamOptions{})
|
||
|
ws.OpenStream(6, OpenStreamOptions{})
|
||
|
ws.AdjustStream(4, PriorityParam{StreamDep: 1, Weight: 15})
|
||
|
ws.AdjustStream(5, PriorityParam{StreamDep: 2, Weight: 15})
|
||
|
ws.AdjustStream(6, PriorityParam{StreamDep: 3, Weight: 15})
|
||
|
|
||
|
want := "2{weight:15,parent:0} 3{weight:20,parent:2} 4{weight:15,parent:0} 5{weight:15,parent:2} 6{weight:15,parent:3}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After open\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityIdleStreamsDisabled(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{}).(*priorityWriteScheduler)
|
||
|
ws.AdjustStream(1, PriorityParam{StreamDep: 0, Weight: 15}) // idle
|
||
|
ws.AdjustStream(2, PriorityParam{StreamDep: 0, Weight: 15}) // idle
|
||
|
ws.AdjustStream(3, PriorityParam{StreamDep: 2, Weight: 20}) // idle
|
||
|
ws.OpenStream(4, OpenStreamOptions{})
|
||
|
|
||
|
want := "4{weight:15,parent:0}"
|
||
|
if got := fmtTree(ws, fmtNodeWeightParentSkipRoot); got != want {
|
||
|
t.Errorf("After open\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPrioritySection531NonExclusive(t *testing.T) {
|
||
|
// Example from RFC 7540 Section 5.3.1.
|
||
|
// A,B,C,D = 1,2,3,4
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(4, OpenStreamOptions{})
|
||
|
ws.AdjustStream(4, PriorityParam{
|
||
|
StreamDep: 1,
|
||
|
Weight: 15,
|
||
|
Exclusive: false,
|
||
|
})
|
||
|
want := "1{parent:0} 2{parent:1} 3{parent:1} 4{parent:1}"
|
||
|
if got := fmtTree(ws, fmtNodeParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPrioritySection531Exclusive(t *testing.T) {
|
||
|
// Example from RFC 7540 Section 5.3.1.
|
||
|
// A,B,C,D = 1,2,3,4
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(4, OpenStreamOptions{})
|
||
|
ws.AdjustStream(4, PriorityParam{
|
||
|
StreamDep: 1,
|
||
|
Weight: 15,
|
||
|
Exclusive: true,
|
||
|
})
|
||
|
want := "1{parent:0} 2{parent:4} 3{parent:4} 4{parent:1}"
|
||
|
if got := fmtTree(ws, fmtNodeParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func makeSection533Tree() *priorityWriteScheduler {
|
||
|
// Initial tree from RFC 7540 Section 5.3.3.
|
||
|
// A,B,C,D,E,F = 1,2,3,4,5,6
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(4, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(5, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(6, OpenStreamOptions{PusherID: 4})
|
||
|
return ws
|
||
|
}
|
||
|
|
||
|
func TestPrioritySection533NonExclusive(t *testing.T) {
|
||
|
// Example from RFC 7540 Section 5.3.3.
|
||
|
// A,B,C,D,E,F = 1,2,3,4,5,6
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(4, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(5, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(6, OpenStreamOptions{PusherID: 4})
|
||
|
ws.AdjustStream(1, PriorityParam{
|
||
|
StreamDep: 4,
|
||
|
Weight: 15,
|
||
|
Exclusive: false,
|
||
|
})
|
||
|
want := "1{parent:4} 2{parent:1} 3{parent:1} 4{parent:0} 5{parent:3} 6{parent:4}"
|
||
|
if got := fmtTree(ws, fmtNodeParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPrioritySection533Exclusive(t *testing.T) {
|
||
|
// Example from RFC 7540 Section 5.3.3.
|
||
|
// A,B,C,D,E,F = 1,2,3,4,5,6
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(4, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(5, OpenStreamOptions{PusherID: 3})
|
||
|
ws.OpenStream(6, OpenStreamOptions{PusherID: 4})
|
||
|
ws.AdjustStream(1, PriorityParam{
|
||
|
StreamDep: 4,
|
||
|
Weight: 15,
|
||
|
Exclusive: true,
|
||
|
})
|
||
|
want := "1{parent:4} 2{parent:1} 3{parent:1} 4{parent:0} 5{parent:3} 6{parent:1}"
|
||
|
if got := fmtTree(ws, fmtNodeParentSkipRoot); got != want {
|
||
|
t.Errorf("After adjust\ngot %q\nwant %q", got, want)
|
||
|
}
|
||
|
if err := checkPriorityWellFormed(ws); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func checkPopAll(ws WriteScheduler, order []uint32) error {
|
||
|
for k, id := range order {
|
||
|
wr, ok := ws.Pop()
|
||
|
if !ok {
|
||
|
return fmt.Errorf("Pop[%d]: got ok=false, want %d (order=%v)", k, id, order)
|
||
|
}
|
||
|
if got := wr.StreamID(); got != id {
|
||
|
return fmt.Errorf("Pop[%d]: got %v, want %d (order=%v)", k, got, id, order)
|
||
|
}
|
||
|
}
|
||
|
wr, ok := ws.Pop()
|
||
|
if ok {
|
||
|
return fmt.Errorf("Pop[%d]: got %v, want ok=false (order=%v)", len(order), wr.StreamID(), order)
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
func TestPriorityPopFrom533Tree(t *testing.T) {
|
||
|
ws := makeSection533Tree()
|
||
|
|
||
|
ws.Push(makeWriteHeadersRequest(3 /*C*/))
|
||
|
ws.Push(makeWriteNonStreamRequest())
|
||
|
ws.Push(makeWriteHeadersRequest(5 /*E*/))
|
||
|
ws.Push(makeWriteHeadersRequest(1 /*A*/))
|
||
|
t.Log("tree:", fmtTree(ws, fmtNodeParentSkipRoot))
|
||
|
|
||
|
if err := checkPopAll(ws, []uint32{0 /*NonStream*/, 1, 3, 5}); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityPopFromLinearTree(t *testing.T) {
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
ws.OpenStream(3, OpenStreamOptions{PusherID: 2})
|
||
|
ws.OpenStream(4, OpenStreamOptions{PusherID: 3})
|
||
|
|
||
|
ws.Push(makeWriteHeadersRequest(3))
|
||
|
ws.Push(makeWriteHeadersRequest(4))
|
||
|
ws.Push(makeWriteHeadersRequest(1))
|
||
|
ws.Push(makeWriteHeadersRequest(2))
|
||
|
ws.Push(makeWriteNonStreamRequest())
|
||
|
ws.Push(makeWriteNonStreamRequest())
|
||
|
t.Log("tree:", fmtTree(ws, fmtNodeParentSkipRoot))
|
||
|
|
||
|
if err := checkPopAll(ws, []uint32{0, 0 /*NonStreams*/, 1, 2, 3, 4}); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityFlowControl(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{ThrottleOutOfOrderWrites: false})
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
|
||
|
sc := &serverConn{maxFrameSize: 16}
|
||
|
st1 := &stream{id: 1, sc: sc}
|
||
|
st2 := &stream{id: 2, sc: sc}
|
||
|
|
||
|
ws.Push(FrameWriteRequest{&writeData{1, make([]byte, 16), false}, st1, nil})
|
||
|
ws.Push(FrameWriteRequest{&writeData{2, make([]byte, 16), false}, st2, nil})
|
||
|
ws.AdjustStream(2, PriorityParam{StreamDep: 1})
|
||
|
|
||
|
// No flow-control bytes available.
|
||
|
if wr, ok := ws.Pop(); ok {
|
||
|
t.Fatalf("Pop(limited by flow control)=%v,true, want false", wr)
|
||
|
}
|
||
|
|
||
|
// Add enough flow-control bytes to write st2 in two Pop calls.
|
||
|
// Should write data from st2 even though it's lower priority than st1.
|
||
|
for i := 1; i <= 2; i++ {
|
||
|
st2.flow.add(8)
|
||
|
wr, ok := ws.Pop()
|
||
|
if !ok {
|
||
|
t.Fatalf("Pop(%d)=false, want true", i)
|
||
|
}
|
||
|
if got, want := wr.DataSize(), 8; got != want {
|
||
|
t.Fatalf("Pop(%d)=%d bytes, want %d bytes", i, got, want)
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityThrottleOutOfOrderWrites(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{ThrottleOutOfOrderWrites: true})
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{PusherID: 1})
|
||
|
|
||
|
sc := &serverConn{maxFrameSize: 4096}
|
||
|
st1 := &stream{id: 1, sc: sc}
|
||
|
st2 := &stream{id: 2, sc: sc}
|
||
|
st1.flow.add(4096)
|
||
|
st2.flow.add(4096)
|
||
|
ws.Push(FrameWriteRequest{&writeData{2, make([]byte, 4096), false}, st2, nil})
|
||
|
ws.AdjustStream(2, PriorityParam{StreamDep: 1})
|
||
|
|
||
|
// We have enough flow-control bytes to write st2 in a single Pop call.
|
||
|
// However, due to out-of-order write throttling, the first call should
|
||
|
// only write 1KB.
|
||
|
wr, ok := ws.Pop()
|
||
|
if !ok {
|
||
|
t.Fatalf("Pop(st2.first)=false, want true")
|
||
|
}
|
||
|
if got, want := wr.StreamID(), uint32(2); got != want {
|
||
|
t.Fatalf("Pop(st2.first)=stream %d, want stream %d", got, want)
|
||
|
}
|
||
|
if got, want := wr.DataSize(), 1024; got != want {
|
||
|
t.Fatalf("Pop(st2.first)=%d bytes, want %d bytes", got, want)
|
||
|
}
|
||
|
|
||
|
// Now add data on st1. This should take precedence.
|
||
|
ws.Push(FrameWriteRequest{&writeData{1, make([]byte, 4096), false}, st1, nil})
|
||
|
wr, ok = ws.Pop()
|
||
|
if !ok {
|
||
|
t.Fatalf("Pop(st1)=false, want true")
|
||
|
}
|
||
|
if got, want := wr.StreamID(), uint32(1); got != want {
|
||
|
t.Fatalf("Pop(st1)=stream %d, want stream %d", got, want)
|
||
|
}
|
||
|
if got, want := wr.DataSize(), 4096; got != want {
|
||
|
t.Fatalf("Pop(st1)=%d bytes, want %d bytes", got, want)
|
||
|
}
|
||
|
|
||
|
// Should go back to writing 1KB from st2.
|
||
|
wr, ok = ws.Pop()
|
||
|
if !ok {
|
||
|
t.Fatalf("Pop(st2.last)=false, want true")
|
||
|
}
|
||
|
if got, want := wr.StreamID(), uint32(2); got != want {
|
||
|
t.Fatalf("Pop(st2.last)=stream %d, want stream %d", got, want)
|
||
|
}
|
||
|
if got, want := wr.DataSize(), 1024; got != want {
|
||
|
t.Fatalf("Pop(st2.last)=%d bytes, want %d bytes", got, want)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityWeights(t *testing.T) {
|
||
|
ws := defaultPriorityWriteScheduler()
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.OpenStream(2, OpenStreamOptions{})
|
||
|
|
||
|
sc := &serverConn{maxFrameSize: 8}
|
||
|
st1 := &stream{id: 1, sc: sc}
|
||
|
st2 := &stream{id: 2, sc: sc}
|
||
|
st1.flow.add(40)
|
||
|
st2.flow.add(40)
|
||
|
|
||
|
ws.Push(FrameWriteRequest{&writeData{1, make([]byte, 40), false}, st1, nil})
|
||
|
ws.Push(FrameWriteRequest{&writeData{2, make([]byte, 40), false}, st2, nil})
|
||
|
ws.AdjustStream(1, PriorityParam{StreamDep: 0, Weight: 34})
|
||
|
ws.AdjustStream(2, PriorityParam{StreamDep: 0, Weight: 9})
|
||
|
|
||
|
// st1 gets 3.5x the bandwidth of st2 (3.5 = (34+1)/(9+1)).
|
||
|
// The maximum frame size is 8 bytes. The write sequence should be:
|
||
|
// st1, total bytes so far is (st1=8, st=0)
|
||
|
// st2, total bytes so far is (st1=8, st=8)
|
||
|
// st1, total bytes so far is (st1=16, st=8)
|
||
|
// st1, total bytes so far is (st1=24, st=8) // 3x bandwidth
|
||
|
// st1, total bytes so far is (st1=32, st=8) // 4x bandwidth
|
||
|
// st2, total bytes so far is (st1=32, st=16) // 2x bandwidth
|
||
|
// st1, total bytes so far is (st1=40, st=16)
|
||
|
// st2, total bytes so far is (st1=40, st=24)
|
||
|
// st2, total bytes so far is (st1=40, st=32)
|
||
|
// st2, total bytes so far is (st1=40, st=40)
|
||
|
if err := checkPopAll(ws, []uint32{1, 2, 1, 1, 1, 2, 1, 2, 2, 2}); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func TestPriorityRstStreamOnNonOpenStreams(t *testing.T) {
|
||
|
ws := NewPriorityWriteScheduler(&PriorityWriteSchedulerConfig{
|
||
|
MaxClosedNodesInTree: 0,
|
||
|
MaxIdleNodesInTree: 0,
|
||
|
})
|
||
|
ws.OpenStream(1, OpenStreamOptions{})
|
||
|
ws.CloseStream(1)
|
||
|
ws.Push(FrameWriteRequest{write: streamError(1, ErrCodeProtocol)})
|
||
|
ws.Push(FrameWriteRequest{write: streamError(2, ErrCodeProtocol)})
|
||
|
|
||
|
if err := checkPopAll(ws, []uint32{1, 2}); err != nil {
|
||
|
t.Error(err)
|
||
|
}
|
||
|
}
|