make randomsub test reliable

randomsub_test.go

@@ -25,6 +25,17 @@ func getRandomsubs(ctx context.Context, hs []host.Host, size int, opts ...Option
 	return psubs
 }
 
+func tryReceive(sub *Subscription) *Message {
+	ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
+	defer cancel()
+	m, err := sub.Next(ctx)
+	if err != nil {
+		return nil
+	} else {
+		return m
+	}
+}
+
 func TestRandomsubSmall(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -45,16 +56,23 @@ func TestRandomsubSmall(t *testing.T) {
 
 	time.Sleep(time.Second)
 
+	count := 0
 	for i := 0; i < 10; i++ {
 		msg := []byte(fmt.Sprintf("message %d", i))
 		psubs[i].Publish("test", msg)
 
 		for _, sub := range subs {
-			assertReceive(t, sub, msg)
+			if tryReceive(sub) != nil {
+				count++
 			}
 		}
 	}
 
+	if count < 9*len(hosts) {
+		t.Fatalf("received too few messages; expected at least %d but got %d", 9*len(hosts), count)
+	}
+}
+
 func TestRandomsubBig(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -75,16 +93,23 @@ func TestRandomsubBig(t *testing.T) {
 
 	time.Sleep(time.Second)
 
+	count := 0
 	for i := 0; i < 10; i++ {
 		msg := []byte(fmt.Sprintf("message %d", i))
 		psubs[i].Publish("test", msg)
 
 		for _, sub := range subs {
-			assertReceive(t, sub, msg)
+			if tryReceive(sub) != nil {
+				count++
 			}
 		}
 	}
 
+	if count < 9*len(hosts) {
+		t.Fatalf("received too few messages; expected at least %d but got %d", 9*len(hosts), count)
+	}
+}
+
 func TestRandomsubMixed(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
@@ -107,16 +132,23 @@ func TestRandomsubMixed(t *testing.T) {
 
 	time.Sleep(time.Second)
 
+	count := 0
 	for i := 0; i < 10; i++ {
 		msg := []byte(fmt.Sprintf("message %d", i))
 		psubs[i].Publish("test", msg)
 
 		for _, sub := range subs {
-			assertReceive(t, sub, msg)
+			if tryReceive(sub) != nil {
+				count++
 			}
 		}
 	}
 
+	if count < 9*len(hosts) {
+		t.Fatalf("received too few messages; expected at least %d but got %d", 9*len(hosts), count)
+	}
+}
+
 func TestRandomsubEnoughPeers(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()