diff --git a/blockservice_test.go b/blockservice_test.go index a94b672cfe00df54c04e361d99a3a2f8166eb03a..dfd12fc437b8c32883d99d3e8932ba3e40d5a79e 100644 --- a/blockservice_test.go +++ b/blockservice_test.go @@ -26,12 +26,18 @@ func TestWriteThroughWorks(t *testing.T) { block := bgen.Next() t.Logf("PutCounter: %d", bstore.PutCounter) - bserv.AddBlock(block) + err := bserv.AddBlock(block) + if err != nil { + t.Fatal(err) + } if bstore.PutCounter != 1 { t.Fatalf("expected just one Put call, have: %d", bstore.PutCounter) } - bserv.AddBlock(block) + err = bserv.AddBlock(block) + if err != nil { + t.Fatal(err) + } if bstore.PutCounter != 2 { t.Fatalf("Put should have called again, should be 2 is: %d", bstore.PutCounter) } @@ -52,10 +58,15 @@ func TestLazySessionInitialization(t *testing.T) { bgen := butil.NewBlockGenerator() block := bgen.Next() - bstore.Put(block) - + err := bstore.Put(block) + if err != nil { + t.Fatal(err) + } block2 := bgen.Next() - session.HasBlock(block2) + err = session.HasBlock(block2) + if err != nil { + t.Fatal(err) + } bsession := NewSession(ctx, bservSessEx) if bsession.ses != nil { diff --git a/test/blocks_test.go b/test/blocks_test.go index 95f552d21eb457a9d215282ec64d49dcabb31145..ee808e66e8573295d29c4d703894eb615089782c 100644 --- a/test/blocks_test.go +++ b/test/blocks_test.go @@ -74,7 +74,10 @@ func TestGetBlocksSequential(t *testing.T) { var cids []cid.Cid for _, o := range objs { cids = append(cids, o.Cid()) - servs[0].AddBlock(o) + err := servs[0].AddBlock(o) + if err != nil { + t.Fatal(err) + } } t.Log("one instance at a time, get blocks concurrently")