diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index 206b44f1e..75c347fd0 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -228,13 +228,14 @@ func (bs *Bitswap) HasBlock(ctx context.Context, blk *blocks.Block) error { default: } + bs.notifications.Publish(blk) + err := bs.tryPutBlock(blk, 4) // attempt to store block up to four times if err != nil { log.Errorf("Error writing block to datastore: %s", err) return err } - bs.notifications.Publish(blk) select { case bs.newBlocks <- blk: // send block off to be reprovided