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

Merge pull request #604 from lucas-clemente/fix-603

Browse Source 
fix flaky session test
This commit is contained in:
Marten Seemann
2017-05-09 18:59:00 +08:00
committed by GitHub
parent 8a0ab02c6c e9db78ace3
commit 86c408e4bc
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
session_test.go
View File

@@ -1163,17 +1163,17 @@ var _ = Describe("Session", func() {
})
It("closes when crypto stream errors", func() {
go sess.run()
s, err := sess.GetOrOpenStream(3)
Expect(err).NotTo(HaveOccurred())
err = sess.handleStreamFrame(&frames.StreamFrame{
var runErr error
go func() {
runErr = sess.run()
}()
err := sess.handleStreamFrame(&frames.StreamFrame{
StreamID: 1,
Data: []byte("4242\x00\x00\x00\x00"),
})
Expect(err).NotTo(HaveOccurred())
Eventually(func() bool { return atomic.LoadUint32(&sess.closed) != 0 }).Should(BeTrue())
_, err = s.Write([]byte{})
Expect(err.(*qerr.QuicError).ErrorCode).To(Equal(qerr.InvalidCryptoMessageType))
Eventually(func() error { return runErr }).Should(HaveOccurred())
Expect(runErr.(qerr.ErrorCode)).To(Equal(qerr.InvalidCryptoMessageType))
})
Context("sending a Public Reset when receiving undecryptable packets during the handshake", func() {