diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index 75c347fd0..5234aefc9 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -228,14 +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