mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-03 20:27:35 +03:00
Code Issues Projects Releases Packages Wiki Activity

use round-robin scheduling in StreamFramer

Browse source 
fixes #207
This commit is contained in:
Marten Seemann 2016-08-06 17:01:28 +07:00
parent 8e7215aaeb
commit 71dcad29b5
2 changed files with 14 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
stream_framer.go
View file

@ -125,7 +125,7 @@ func (f *streamFramer) maybePopNormalFrames(maxBytes protocol.ByteCount) (res []
return true, nil
}
f.streamsMap.Iterate(fn)
f.streamsMap.RoundRobinIterate(fn)
return
}

13
stream_framer_test.go
View file

@ -117,6 +117,19 @@ var _ = Describe("Stream Framer", func() {
Expect(fs[0].FinBit).To(BeFalse())
})
It("uses the round-robin scheduling", func() {
stream1.dataForWriting = bytes.Repeat([]byte("f"), 100)
stream2.dataForWriting = bytes.Repeat([]byte("e"), 100)
fs := framer.PopStreamFrames(10)
Expect(fs).To(HaveLen(1))
// it doesn't matter here if this data is from stream1 or from stream2...
firstStreamID := fs[0].StreamID
fs = framer.PopStreamFrames(10)
Expect(fs).To(HaveLen(1))
// ... but the data popped this time has to be from the other stream
Expect(fs[0].StreamID).ToNot(Equal(firstStreamID))
})
Context("splitting of frames", func() {
It("splits off nothing", func() {
f := &frames.StreamFrame{