mirror of
https://github.com/refraction-networking/uquic.git
synced 2025-04-03 20:27:35 +03:00
95575f5fe7
uTLS is not yet bumped to the new version, so this commit breaks the dependencies relationship by getting rid of the local replace.
67 lines
2.2 KiB
Go
67 lines
2.2 KiB
Go
package wire
|
|
|
|
import (
|
|
"bytes"
|
|
|
|
"github.com/refraction-networking/uquic/internal/protocol"
|
|
"github.com/refraction-networking/uquic/internal/qerr"
|
|
"github.com/refraction-networking/uquic/quicvarint"
|
|
|
|
. "github.com/onsi/ginkgo/v2"
|
|
. "github.com/onsi/gomega"
|
|
)
|
|
|
|
var _ = Describe("RESET_STREAM frame", func() {
|
|
Context("when parsing", func() {
|
|
It("accepts sample frame", func() {
|
|
data := encodeVarInt(0xdeadbeef) // stream ID
|
|
data = append(data, encodeVarInt(0x1337)...) // error code
|
|
data = append(data, encodeVarInt(0x987654321)...) // byte offset
|
|
b := bytes.NewReader(data)
|
|
frame, err := parseResetStreamFrame(b, protocol.Version1)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
Expect(frame.StreamID).To(Equal(protocol.StreamID(0xdeadbeef)))
|
|
Expect(frame.FinalSize).To(Equal(protocol.ByteCount(0x987654321)))
|
|
Expect(frame.ErrorCode).To(Equal(qerr.StreamErrorCode(0x1337)))
|
|
})
|
|
|
|
It("errors on EOFs", func() {
|
|
data := encodeVarInt(0xdeadbeef) // stream ID
|
|
data = append(data, encodeVarInt(0x1337)...) // error code
|
|
data = append(data, encodeVarInt(0x987654321)...) // byte offset
|
|
_, err := parseResetStreamFrame(bytes.NewReader(data), protocol.Version1)
|
|
Expect(err).NotTo(HaveOccurred())
|
|
for i := range data {
|
|
_, err := parseResetStreamFrame(bytes.NewReader(data[:i]), protocol.Version1)
|
|
Expect(err).To(HaveOccurred())
|
|
}
|
|
})
|
|
})
|
|
|
|
Context("when writing", func() {
|
|
It("writes a sample frame", func() {
|
|
frame := ResetStreamFrame{
|
|
StreamID: 0x1337,
|
|
FinalSize: 0x11223344decafbad,
|
|
ErrorCode: 0xcafe,
|
|
}
|
|
b, err := frame.Append(nil, protocol.Version1)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
expected := []byte{resetStreamFrameType}
|
|
expected = append(expected, encodeVarInt(0x1337)...)
|
|
expected = append(expected, encodeVarInt(0xcafe)...)
|
|
expected = append(expected, encodeVarInt(0x11223344decafbad)...)
|
|
Expect(b).To(Equal(expected))
|
|
})
|
|
|
|
It("has the correct length", func() {
|
|
rst := ResetStreamFrame{
|
|
StreamID: 0x1337,
|
|
FinalSize: 0x1234567,
|
|
ErrorCode: 0xde,
|
|
}
|
|
expectedLen := 1 + quicvarint.Len(0x1337) + quicvarint.Len(0x1234567) + 2
|
|
Expect(rst.Length(protocol.Version1)).To(Equal(expectedLen))
|
|
})
|
|
})
|
|
})
|