Skip to content

Commit

Permalink
remove flaky TestTcpSimultaneousConnect (#1425)
Browse files Browse the repository at this point in the history
  • Loading branch information
marten-seemann committed Apr 22, 2022
1 parent 7d50e43 commit 2b69671
Showing 1 changed file with 0 additions and 49 deletions.
49 changes: 0 additions & 49 deletions libp2p_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import (
"fmt"
"regexp"
"strings"
"sync"
"testing"

"github.com/libp2p/go-libp2p/p2p/transport/tcp"
Expand All @@ -16,9 +15,6 @@ import (
"github.com/libp2p/go-libp2p-core/peer"
"github.com/libp2p/go-libp2p-core/transport"

noise "github.com/libp2p/go-libp2p-noise"

ma "github.com/multiformats/go-multiaddr"
"github.com/stretchr/testify/require"
)

Expand Down Expand Up @@ -168,48 +164,3 @@ func TestChainOptions(t *testing.T) {
}
}
}

func TestTcpSimultaneousConnect(t *testing.T) {
// Host1
h1, err := New(Transport(tcp.NewTCPTransport), Security(noise.ID, noise.New), ListenAddrs(ma.StringCast("/ip4/0.0.0.0/tcp/0")))
require.NoError(t, err)
defer h1.Close()

// Host2
h2, err := New(Transport(tcp.NewTCPTransport), Security(noise.ID, noise.New), ListenAddrs(ma.StringCast("/ip4/0.0.0.0/tcp/0")))
require.NoError(t, err)
defer h2.Close()

h1Info := peer.AddrInfo{
ID: h1.ID(),
Addrs: h1.Addrs(),
}

h2Info := peer.AddrInfo{
ID: h2.ID(),
Addrs: h2.Addrs(),
}

wg := new(sync.WaitGroup)

wg.Add(1)
go func() {
defer wg.Done()
for i := 0; i < 20; i++ {
require.NoError(t, h1.Connect(context.Background(), h2Info))
require.NoError(t, h1.Network().ClosePeer(h2.ID()))
}
}()

// use another peer to constantly connect/disconnect with first peer.
wg.Add(1)
go func() {
defer wg.Done()
for i := 0; i < 20; i++ {
require.NoError(t, h2.Connect(context.Background(), h1Info))
require.NoError(t, h2.Network().ClosePeer(h1.ID()))
}
}()

wg.Wait()
}

0 comments on commit 2b69671

Please sign in to comment.