publish block before writing to disk

whyrusleeping · whyrusleeping · commit a25352d80e14 · 2015-07-13T11:24:49.000-07:00
License: MIT
Signed-off-by: Jeromy &lt;jeromyj@gmail.com&gt;
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -228,13 +228,14 @@ func (bs Bitswap) HasBlock(ctx context.Context, blk blocks.Block) error {`
`228`	`228`	`default:`
`229`	`229`	`}`
`230`	`230`
	`231`	`+ bs.notifications.Publish(blk)`
	`232`	`+`
`231`	`233`	`err := bs.tryPutBlock(blk, 4) // attempt to store block up to four times`
`232`	`234`	`if err != nil {`
`233`	`235`	`log.Errorf("Error writing block to datastore: %s", err)`
`234`	`236`	`return err`
`235`	`237`	`}`
`236`	`238`
`237`		`- bs.notifications.Publish(blk)`
`238`	`239`	`select {`
`239`	`240`	`case bs.newBlocks <- blk:`
`240`	`241`	`// send block off to be reprovided`