forked from summerwind/h2spec
-
Notifications
You must be signed in to change notification settings - Fork 0
/
6_1.go
141 lines (118 loc) · 2.96 KB
/
6_1.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
package h2spec
import (
"github.com/bradfitz/http2"
"github.com/bradfitz/http2/hpack"
)
func TestData(ctx *Context) {
if !ctx.IsTarget("6.1") {
return
}
PrintHeader("6.1. DATA", 0)
func(ctx *Context) {
desc := "Sends a DATA frame with 0x0 stream identifier"
msg := "The endpoint MUST respond with a connection error of type PROTOCOL_ERROR."
result := false
http2Conn := CreateHttp2Conn(ctx, true)
defer http2Conn.conn.Close()
http2Conn.fr.WriteData(0, true, []byte("test"))
loop:
for {
f, err := http2Conn.ReadFrame(ctx.Timeout)
if err != nil {
break loop
}
switch f := f.(type) {
case *http2.GoAwayFrame:
if f.ErrCode == http2.ErrCodeProtocol {
result = true
}
}
}
PrintResult(result, desc, msg, 0)
}(ctx)
func(ctx *Context) {
desc := "Sends a DATA frame on the stream that is not opend"
msg := "The endpoint MUST respond with a stream error of type STREAM_CLOSED."
result := false
http2Conn := CreateHttp2Conn(ctx, true)
defer http2Conn.conn.Close()
hdrs := []hpack.HeaderField{
pair(":method", "GET"),
pair(":scheme", "http"),
pair(":path", "/"),
pair(":authority", ctx.Authority()),
}
var hp http2.HeadersFrameParam
hp.StreamID = 1
hp.EndStream = true
hp.EndHeaders = true
hp.BlockFragment = http2Conn.EncodeHeader(hdrs)
http2Conn.fr.WriteHeaders(hp)
http2Conn.fr.WriteData(1, true, []byte("test"))
loop:
for {
f, err := http2Conn.ReadFrame(ctx.Timeout)
if err != nil {
break loop
}
switch f := f.(type) {
case *http2.RSTStreamFrame:
if f.ErrCode == http2.ErrCodeStreamClosed {
result = true
}
case *http2.GoAwayFrame:
if f.ErrCode == http2.ErrCodeStreamClosed {
result = true
}
}
}
PrintResult(result, desc, msg, 0)
}(ctx)
// bradfitz/http2 does not support padding of DATA frame.
/*
func(ctx *Context) {
desc := "Sends a DATA frame with invalid pad length"
msg := "The endpoint MUST treat this as a connection error of type PROTOCOL_ERROR."
result := false
http2Conn := CreateHttp2Conn(ctx, true)
defer http2Conn.conn.Close()
var buf bytes.Buffer
hdrs := []hpack.HeaderField{
pair(":method", "GET"),
pair(":scheme", "http"),
pair(":path", "/"),
pair(":authority", ctx.Authority()),
}
enc := hpack.NewEncoder(&buf)
for _, hf := range hdrs {
_ = enc.WriteField(hf)
}
var hp http2.HeadersFrameParam
hp.StreamID = 1
hp.EndStream = true
hp.EndHeaders = true
hp.BlockFragment = buf.Bytes()
http2Conn.fr.WriteHeaders(hp)
http2Conn.fr.WriteData(1, true, []byte("test"))
timeCh := time.After(3 * time.Second)
loop:
for {
select {
case f := <-http2Conn.dataCh:
gf, ok := f.(*http2.GoAwayFrame)
if ok {
if gf.ErrCode == http2.ErrCodeProtocol {
result = true
}
}
case <-http2Conn.errCh:
break loop
case <-timeCh:
break loop
}
}
PrintResult(result, desc, msg, 0)
}(ctx)
*/
PrintFooter()
}