forked from quic-go/quic-go
@@ -55,6 +55,7 @@ func (p *packetPacker) AddHighPrioStreamFrame(f frames.StreamFrame) {
|
||||
}
|
||||
|
||||
func (p *packetPacker) AddBlocked(streamID protocol.StreamID, byteOffset protocol.ByteCount) {
|
||||
return
|
||||
// TODO: send out connection-level BlockedFrames at the right time
|
||||
// see https://github.com/lucas-clemente/quic-go/issues/113
|
||||
// TODO: remove this function completely once #113 is resolved
|
||||
|
||||
@@ -393,7 +393,7 @@ var _ = Describe("Packet packer", func() {
|
||||
})
|
||||
})
|
||||
|
||||
Context("Blocked frames", func() {
|
||||
PContext("Blocked frames", func() {
|
||||
It("adds a blocked frame to a packet if there is enough space", func() {
|
||||
length := 100
|
||||
packer.AddBlocked(5, protocol.ByteCount(length))
|
||||
|
||||
@@ -203,7 +203,7 @@ var _ = Describe("Session", func() {
|
||||
Expect(session.streamFrameQueue.Pop(1000)).To(BeNil())
|
||||
})
|
||||
|
||||
It("removes closed streams from BlockedManager", func() {
|
||||
PIt("removes closed streams from BlockedManager", func() {
|
||||
session.handleStreamFrame(&frames.StreamFrame{
|
||||
StreamID: 5,
|
||||
Data: []byte{0xde, 0xca, 0xfb, 0xad},
|
||||
@@ -444,7 +444,7 @@ var _ = Describe("Session", func() {
|
||||
Expect(conn.written[0]).To(ContainSubstring(string([]byte("PRST"))))
|
||||
})
|
||||
|
||||
Context("Blocked", func() {
|
||||
PContext("Blocked", func() {
|
||||
It("queues a Blocked frames", func() {
|
||||
len := 500
|
||||
frame := frames.StreamFrame{
|
||||
|
||||
@@ -499,7 +499,7 @@ var _ = Describe("Stream", func() {
|
||||
})
|
||||
})
|
||||
|
||||
Context("Blocked streams", func() {
|
||||
PContext("Blocked streams", func() {
|
||||
It("notifies the session when a stream is flow control blocked", func() {
|
||||
updated := str.flowController.UpdateSendWindow(1337)
|
||||
Expect(updated).To(BeTrue())
|
||||
|
||||
Reference in New Issue
Block a user