gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

fix flaky session test

Browse Source 
fixes #277
This commit is contained in:
Lucas Clemente
2016-08-12 20:22:05 +02:00
parent 2fccb9d45d
commit 10b847be8e
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
session_test.go
View File

@@ -591,18 +591,17 @@ var _ = Describe("Session", func() {
Expect(err).NotTo(HaveOccurred())
s2, err := session.GetOrOpenStream(7)
Expect(err).NotTo(HaveOccurred())
go func() {
time.Sleep(time.Millisecond)
session.run()
}()
go func() {
_, err2 := s1.Write([]byte("foobar1"))
Expect(err2).NotTo(HaveOccurred())
}()
_, err = s2.Write([]byte("foobar2"))
Expect(err).NotTo(HaveOccurred())
time.Sleep(10 * time.Millisecond)
Expect(conn.written).To(HaveLen(1))
// Put data directly into the streams
s1.(*stream).dataForWriting = []byte("foobar1")
s2.(*stream).dataForWriting = []byte("foobar2")
session.scheduleSending()
go session.run()
Eventually(func() [][]byte { return conn.written }).Should(HaveLen(1))
Expect(conn.written[0]).To(ContainSubstring("foobar1"))
Expect(conn.written[0]).To(ContainSubstring("foobar2"))
})
It("sends out two big frames in two packets", func() {