diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index a14d68cc0..608656e53 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -178,6 +178,9 @@ func (bs *bitswap) run(ctx context.Context) { } case ks := <-bs.batchRequests: // TODO: implement batching on len(ks) > X for some X + for _, k := range ks { + bs.wantlist.Add(k) + } if len(ks) == 0 { log.Warning("Received batch request for zero blocks") continue