Skip to content

Commit e10384f

Browse files
authored
test: Try to fix test timeout (#2930)
1 parent 6c12e22 commit e10384f

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

p2p/transport/webrtc/transport_test.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1014,13 +1014,16 @@ func TestConnectionClosedWhenRemoteCloses(t *testing.T) {
10141014
listenT, p := getTransport(t)
10151015
listener, err := listenT.Listen(ma.StringCast("/ip4/127.0.0.1/udp/0/webrtc-direct"))
10161016
require.NoError(t, err)
1017+
defer listener.Close()
10171018

1019+
accepted := make(chan struct{})
10181020
dialer, _ := getTransport(t)
10191021
var wg sync.WaitGroup
10201022
wg.Add(1)
10211023
go func() {
10221024
defer wg.Done()
10231025
c, err := listener.Accept()
1026+
close(accepted)
10241027
if !assert.NoError(t, err) {
10251028
return
10261029
}
@@ -1031,6 +1034,7 @@ func TestConnectionClosedWhenRemoteCloses(t *testing.T) {
10311034

10321035
c, err := dialer.Dial(context.Background(), listener.Multiaddr(), p)
10331036
require.NoError(t, err)
1037+
<-accepted
10341038
c.Close()
10351039
wg.Wait()
10361040
}

0 commit comments

Comments
 (0)