From a25352d80e14838308b9758662d2302fd75f228c Mon Sep 17 00:00:00 2001 From: Jeromy Date: Mon, 13 Jul 2015 11:24:49 -0700 Subject: [PATCH] publish block before writing to disk License: MIT Signed-off-by: Jeromy --- exchange/bitswap/bitswap.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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