opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 02:30:39 +08:00
Code Issues Projects Releases Wiki Activity

fix swarm notif tests

Browse Source 
they were failing intermittently

License: MIT
Signed-off-by: Juan Batiz-Benet <juan@benet.ai>
This commit is contained in:
Juan Batiz-Benet
2015-06-27 00:32:34 -07:00
parent f796615e10
commit 59d6a9a19c
2 changed files with 24 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
p2p/net/swarm/swarm_notif_test.go
View File

@ -11,8 +11,6 @@ import (
) )
func TestNotifications(t *testing.T) { func TestNotifications(t *testing.T) {
t.Parallel()
ctx := context.Background() ctx := context.Background()
swarms := makeSwarms(ctx, t, 5) swarms := makeSwarms(ctx, t, 5)
defer func() { defer func() {
@ -44,24 +42,30 @@ func TestNotifications(t *testing.T) {
continue continue
} }
cos := s.ConnectionsToPeer(s2.LocalPeer()) var actual []inet.Conn
func() { for len(s.ConnectionsToPeer(s2.LocalPeer())) != len(actual) {
for i := 0; i < len(cos); i++ {
var c inet.Conn
select { select {
case c = <-n.connected: case c := <-n.connected:
actual = append(actual, c)
case <-time.After(timeout): case <-time.After(timeout):
t.Fatal("timeout") t.Fatal("timeout")
} }
for _, c2 := range cos { }
if c == c2 {
t.Log("got notif for conn", c) expect := s.ConnectionsToPeer(s2.LocalPeer())
return for _, c1 := range actual {
found := false
for _, c2 := range expect {
if c1 == c2 {
found = true
break
} }
} }
t.Error("connection not found", c) if !found {
t.Error("connection not found")
} }
}() }
} }
} }

2
p2p/net/swarm/swarm_test.go
View File

@ -325,6 +325,6 @@ func TestFilterBounds(t *testing.T) {
case <-time.After(time.Second): case <-time.After(time.Second):
t.Fatal("should have gotten connection") t.Fatal("should have gotten connection")
case <-conns: case <-conns:
fmt.Println("got connect") t.Log("got connect")
} }
} }