handle error

2ec4c9ac · Jeromy · 11de3643 · 2ec4c9ac
Commit 2ec4c9ac authored 9 years ago by Jeromy
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 0 deletions

exchange/bitswap/bitswap.go exchange/bitswap/bitswap.go +5 -0

No files found.
--- a/exchange/bitswap/bitswap.go
+++ b/exchange/bitswap/bitswap.go
@@ -295,6 +295,11 @@ func (bs *Bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg
 			bs.counterLk.Lock()
 			bs.blocksRecvd++
 			has, err := bs.blockstore.Has(b.Key())
+			if err != nil {
+				bs.counterLk.Unlock()
+				log.Noticef("blockstore.Has error: %s", err)
+				return
+			}
 			if err == nil && has {
 				bs.dupBlocksRecvd++
 			}