query(nit): reliably fill rateLimit chan

libp2p · Jun 5, 2019 · 78a2de6 · 78a2de6
1 parent c9f523d
commit 78a2de6
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{}{}
 	}