mirror of
https://github.com/ipfs/kubo.git
synced 2025-07-01 19:24:14 +08:00
feat(bitswap) broadcast block to routing, peers on receipt
This commit is contained in:
@ -118,6 +118,7 @@ func (bs *bitswap) ReceiveMessage(
|
|||||||
for _, block := range incoming.Blocks() {
|
for _, block := range incoming.Blocks() {
|
||||||
go bs.blockstore.Put(block) // FIXME(brian): err ignored
|
go bs.blockstore.Put(block) // FIXME(brian): err ignored
|
||||||
go bs.notifications.Publish(block)
|
go bs.notifications.Publish(block)
|
||||||
|
go bs.HasBlock(ctx, block) // FIXME err ignored
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user