Commit f31d6fbf authored by Steven Allen's avatar Steven Allen

don't hang tests on dial failure

parent d921f5c9
...@@ -27,13 +27,13 @@ func TestSimultOpen(t *testing.T) { ...@@ -27,13 +27,13 @@ func TestSimultOpen(t *testing.T) {
{ {
var wg sync.WaitGroup var wg sync.WaitGroup
connect := func(s *Swarm, dst peer.ID, addr ma.Multiaddr) { connect := func(s *Swarm, dst peer.ID, addr ma.Multiaddr) {
defer wg.Done()
// copy for other peer // copy for other peer
log.Debugf("TestSimultOpen: connecting: %s --> %s (%s)", s.LocalPeer(), dst, addr) log.Debugf("TestSimultOpen: connecting: %s --> %s (%s)", s.LocalPeer(), dst, addr)
s.Peerstore().AddAddr(dst, addr, pstore.PermanentAddrTTL) s.Peerstore().AddAddr(dst, addr, pstore.PermanentAddrTTL)
if _, err := s.DialPeer(ctx, dst); err != nil { if _, err := s.DialPeer(ctx, dst); err != nil {
t.Fatal("error swarm dialing to peer", err) t.Error("error swarm dialing to peer", err)
} }
wg.Done()
} }
log.Info("Connecting swarms simultaneously.") log.Info("Connecting swarms simultaneously.")
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment