handle error

8cd12955 · Jeromy · bc186b26 · 8cd12955
Commit 8cd12955 authored May 27, 2015 by Jeromy
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 0 deletions

bitswap.go bitswap.go +5 -0

No files found.
--- a/bitswap.go
+++ b/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++
 			}