Commit 33d8110e authored by Brian Tiger Chow's avatar Brian Tiger Chow Committed by Juan Batiz-Benet

refactor: avoid loop reuse

License: MIT
Signed-off-by: default avatarBrian Tiger Chow <brian@perfmode.com>
parent 9069a8aa
...@@ -309,14 +309,16 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.Peer, incoming bsm ...@@ -309,14 +309,16 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.Peer, incoming bsm
// TODO: this is bad, and could be easily abused. // TODO: this is bad, and could be easily abused.
// Should only track *useful* messages in ledger // Should only track *useful* messages in ledger
var blkeys []u.Key
for _, block := range incoming.Blocks() { for _, block := range incoming.Blocks() {
blkeys = append(blkeys, block.Key())
hasBlockCtx, _ := context.WithTimeout(ctx, hasBlockTimeout) hasBlockCtx, _ := context.WithTimeout(ctx, hasBlockTimeout)
if err := bs.HasBlock(hasBlockCtx, block); err != nil { if err := bs.HasBlock(hasBlockCtx, block); err != nil {
log.Error(err) log.Error(err)
} }
} }
var blkeys []u.Key
for _, block := range incoming.Blocks() {
blkeys = append(blkeys, block.Key())
}
if len(blkeys) > 0 { if len(blkeys) > 0 {
bs.cancelBlocks(ctx, blkeys) bs.cancelBlocks(ctx, blkeys)
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment