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

stop the listener in the server unit tests

Browse Source
This commit is contained in:
Marten Seemann
2018-09-27 11:55:39 -06:00
parent d227c4edf7
commit 2d10796bc2
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server_test.go
View File

@@ -254,12 +254,12 @@ var _ = Describe("Server", func() {
Expect(serv.Close()).To(Succeed()) Expect(serv.Close()).To(Succeed())
}) })
It("works if no quic.Config is given", func(done Done) { It("works if no quic.Config is given", func() {
ln, err := ListenAddr("127.0.0.1:0", testdata.GetTLSConfig(), nil) ln, err := ListenAddr("127.0.0.1:0", testdata.GetTLSConfig(), nil)
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())
// stop the listener
Expect(ln.Close()).To(Succeed()) Expect(ln.Close()).To(Succeed())
close(done) })
}, 1)
It("closes properly", func() { It("closes properly", func() {
ln, err := ListenAddr("127.0.0.1:0", testdata.GetTLSConfig(), config) ln, err := ListenAddr("127.0.0.1:0", testdata.GetTLSConfig(), config)
@@ -271,7 +271,7 @@ var _ = Describe("Server", func() {
ln.Accept() ln.Accept()
close(done) close(done)
}() }()
ln.Close() Expect(ln.Close()).To(Succeed())
Eventually(done).Should(BeClosed()) Eventually(done).Should(BeClosed())
}) })
@@ -426,6 +426,8 @@ var _ = Describe("Server", func() {
Expect(server.config.IdleTimeout).To(Equal(42 * time.Minute)) Expect(server.config.IdleTimeout).To(Equal(42 * time.Minute))
Expect(reflect.ValueOf(server.config.AcceptCookie)).To(Equal(reflect.ValueOf(acceptCookie))) Expect(reflect.ValueOf(server.config.AcceptCookie)).To(Equal(reflect.ValueOf(acceptCookie)))
Expect(server.config.KeepAlive).To(BeTrue()) Expect(server.config.KeepAlive).To(BeTrue())
// stop the listener
Expect(ln.Close()).To(Succeed())
}) })
It("errors when the Config contains an invalid version", func() { It("errors when the Config contains an invalid version", func() {
@@ -443,6 +445,8 @@ var _ = Describe("Server", func() {
Expect(server.config.IdleTimeout).To(Equal(protocol.DefaultIdleTimeout)) Expect(server.config.IdleTimeout).To(Equal(protocol.DefaultIdleTimeout))
Expect(reflect.ValueOf(server.config.AcceptCookie)).To(Equal(reflect.ValueOf(defaultAcceptCookie))) Expect(reflect.ValueOf(server.config.AcceptCookie)).To(Equal(reflect.ValueOf(defaultAcceptCookie)))
Expect(server.config.KeepAlive).To(BeFalse()) Expect(server.config.KeepAlive).To(BeFalse())
// stop the listener
Expect(ln.Close()).To(Succeed())
}) })
It("listens on a given address", func() { It("listens on a given address", func() {
@@ -451,6 +455,8 @@ var _ = Describe("Server", func() {
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())
serv := ln.(*server) serv := ln.(*server)
Expect(serv.Addr().String()).To(Equal(addr)) Expect(serv.Addr().String()).To(Equal(addr))
// stop the listener
Expect(ln.Close()).To(Succeed())
}) })
It("errors if given an invalid address", func() { It("errors if given an invalid address", func() {