From 78a2de6c8c8e6d2dfa9d8544307b5c4bae7f6bf1 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Thu, 2 May 2019 14:53:08 -0700 Subject: [PATCH] query(nit): reliably fill rateLimit chan --- query.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/query.go b/query.go index 585ee988d..703718c8f 100644 --- 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{}{} }