diff --git a/libp2p/protocols/rendezvous.nim b/libp2p/protocols/rendezvous.nim index e4c2d84eab..089f3a5f36 100644 --- a/libp2p/protocols/rendezvous.nim +++ b/libp2p/protocols/rendezvous.nim @@ -558,7 +558,7 @@ proc requestLocally*(rdv: RendezVous, ns: string): seq[PeerRecord] = @[] proc request*( - rdv: RendezVous, ns: string, limit: uint64 = DiscoverLimit, peers: seq[PeerId] + rdv: RendezVous, ns: string, peerLimit: uint64 = DiscoverLimit, peers: seq[PeerId] ): Future[seq[PeerRecord]] {.async.} = ## This async procedure discovers and returns peers for a given namespace ## by sending requests and processing responses. It limits the number of @@ -566,6 +566,7 @@ proc request*( ## var s: Table[PeerId, (PeerRecord, Register)] + limit = peerLimit d = Discover(ns: ns) if limit > DiscoverLimit: diff --git a/tests/testrendezvous.nim b/tests/testrendezvous.nim index e0c4c25776..d42ac9cc7b 100644 --- a/tests/testrendezvous.nim +++ b/tests/testrendezvous.nim @@ -130,8 +130,6 @@ suite "RendezVous": switch = createSwitch(rdv) expect RendezVousError: discard await rdv.request("A".repeat(300)) - expect RendezVousError: - discard await rdv.request("A", -1) expect RendezVousError: discard await rdv.request("A", 3000) expect RendezVousError: