Commit 55b425a8 authored by Brian Tiger Chow's avatar Brian Tiger Chow

fix(bitswap) use passed ctx

parent df164fa9
...@@ -168,7 +168,7 @@ func (bs *bitswap) ReceiveMessage( ...@@ -168,7 +168,7 @@ func (bs *bitswap) ReceiveMessage(
// send strives to ensure that accounting is always performed when a message is // send strives to ensure that accounting is always performed when a message is
// sent // sent
func (bs *bitswap) send(ctx context.Context, p *peer.Peer, m bsmsg.BitSwapMessage) { func (bs *bitswap) send(ctx context.Context, p *peer.Peer, m bsmsg.BitSwapMessage) {
bs.sender.SendMessage(context.Background(), p, m) bs.sender.SendMessage(ctx, p, m)
bs.strategy.MessageSent(p, m) bs.strategy.MessageSent(p, m)
} }
......
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