rm logs + stress test (1000msgs)

swarm/swarm.go

@@ -124,7 +124,6 @@ Loop:
 			break Loop
 
 		case data, ok := <-conn.Incoming.MsgChan:
-			fmt.Println("got back data", data)
 			if !ok {
 				e := fmt.Errorf("Error retrieving from conn: %v", conn)
 				s.Chan.Errors <- e

swarm/swarm_test.go

@@ -37,7 +37,6 @@ func pong(c net.Conn, peer *peer.Peer) {
 			fmt.Printf("error %v\n", err)
 			return
 		}
-		fmt.Println("pong")
 	}
 }
 
@@ -82,25 +81,34 @@ func TestSwarm(t *testing.T) {
 		listeners = append(listeners, &listener)
 	}
 
-	for i, p := range peers {
-		swarm.Chan.Outgoing <- Message{Peer: p, Data: []byte("ping")}
-		fmt.Println("ping", i)
+	MsgNum := 1000
+	for k := 0; k < MsgNum; k++ {
+		for _, p := range peers {
+			swarm.Chan.Outgoing <- Message{Peer: p, Data: []byte("ping")}
+		}
 	}
 
-	got := map[u.Key]bool{}
-	for _, _ = range peers {
+	got := map[u.Key]int{}
+	for k := 0; k < (MsgNum * len(peers)); k++ {
 		msg := <-swarm.Chan.Incoming
-		fmt.Println("recving", string(msg.Data))
 		if string(msg.Data) != "pong" {
 			t.Error("unexpected conn output", msg.Data)
 		}
-		got[msg.Peer.Key()] = true
+
+		n, _ := got[msg.Peer.Key()]
+		got[msg.Peer.Key()] = n + 1
 	}
 
 	if len(peers) != len(got) {
 		t.Error("got less messages than sent")
 	}
 
+	for p, n := range got {
+		if n != MsgNum {
+			t.Error("peer did not get all msgs", p, n, "/", MsgNum)
+		}
+	}
+
 	fmt.Println("closing")
 	swarm.Close()
 	for _, listener := range listeners {