Commit04985a1

authored

fix: Close TURN connections to resolve flake (#1079)

1 parent89aa39b commit04985a1Copy full SHA for 04985a1

File tree

-6

lines changed

-6

lines changed

Lines changed: 7 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,9 @@ func TestTURNConn(t *testing.T) {`
`44`	`44`	`Logger:logger.Named("client"),`
`45`	`45`	`})`
`46`	`46`	`require.NoError(t,err)`
	`47`	`+deferfunc() {`
	`48`	`+_=client.Close()`
	`49`	`+}()`
`47`	`50`
`48`	`51`	`serverDialer,serverTURN:=net.Pipe()`
`49`	`52`	`turnServer.Accept(serverTURN,&net.TCPAddr{`
`@@ -62,6 +65,9 @@ func TestTURNConn(t *testing.T) {`
`62`	`65`	`Logger:logger.Named("server"),`
`63`	`66`	`})`
`64`	`67`	`require.NoError(t,err)`
	`68`	`+deferfunc() {`
	`69`	`+_=server.Close()`
	`70`	`+}()`
`65`	`71`	`exchange(t,client,server)`
`66`	`72`
`67`	`73`	`_,err=client.Ping()`
`@@ -71,12 +77,7 @@ func TestTURNConn(t *testing.T) {`
`71`	`77`	`funcexchange(ttesting.T,client,serverpeer.Conn) {`
`72`	`78`	`varwg sync.WaitGroup`
`73`	`79`	`wg.Add(2)`
`74`		`-t.Cleanup(func() {`
`75`		`-_=client.Close()`
`76`		`-_=server.Close()`
`77`		`-`
`78`		`-wg.Wait()`
`79`		`-})`
	`80`	`+t.Cleanup(wg.Wait)`
`80`	`81`	`gofunc() {`
`81`	`82`	`deferwg.Done()`
`82`	`83`	`for {`

Comments

(0)