From ab8d7cc9683585fb2173f38eafec58aa44731561 Mon Sep 17 00:00:00 2001 From: Giovanni Petrantoni Date: Fri, 26 Jun 2020 16:24:56 +0900 Subject: [PATCH] make sure to waitsub in sparse test --- libp2p/protocols/pubsub/gossipsub.nim | 2 +- tests/pubsub/testgossipsub.nim | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/libp2p/protocols/pubsub/gossipsub.nim b/libp2p/protocols/pubsub/gossipsub.nim index 727217a31..36f8da174 100644 --- a/libp2p/protocols/pubsub/gossipsub.nim +++ b/libp2p/protocols/pubsub/gossipsub.nim @@ -552,7 +552,7 @@ method publish*(g: GossipSub, let msg = newMessage(g.peerInfo, data, topic, g.sign) debug "created new message", msg - debug "publishing on topic", name = topic + debug "publishing on topic", name = topic, peers = peers if msg.msgId notin g.mcache: g.mcache.put(msg) diff --git a/tests/pubsub/testgossipsub.nim b/tests/pubsub/testgossipsub.nim index a6d4b927b..5eaf4c7a6 100644 --- a/tests/pubsub/testgossipsub.nim +++ b/tests/pubsub/testgossipsub.nim @@ -379,7 +379,7 @@ suite "GossipSub": nodes.add newStandardSwitch(triggerSelf = true, gossip = true, secureManagers = [SecureProtocol.Secio]) awaitters.add((await nodes[i].start())) - await subscribeSparseNodes(nodes, 4) + await subscribeSparseNodes(nodes, 4) var seen: Table[string, int] var subs: seq[Future[void]] @@ -398,6 +398,7 @@ suite "GossipSub": seenFut.complete() subs &= dialer.subscribe("foobar", handler) + subs &= waitSub(nodes[0], dialer, "foobar") await allFuturesThrowing(subs) await wait(nodes[0].publish("foobar",