query(nit): reliably fill rateLimit chan

libp2p · May 3, 2019 · f7005bd · f7005bd
1 parent 317a78e
commit f7005bd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/query.go b/query.go
@@ -135,7 +135,7 @@ func (r *dhtQueryRunner) run(ctx context.Context, peers []peer.ID) ([]peer.ID, e
 
 func (r *dhtQueryRunner) recurse(ctx context.Context, peers []peer.ID) error {
 	// setup concurrency rate limiting
-	for i := 0; i < r.query.concurrency; i++ {
+	for len(r.rateLimit) < cap(r.rateLimit) {
 		r.rateLimit <- struct{}{}
 	}