tmp

pkg/internal/itest/trustless_fetch_test.go

@@ -16,6 +16,7 @@ import (
 	"github.com/filecoin-project/lassie/pkg/lassie"
 	httpserver "github.com/filecoin-project/lassie/pkg/server/http"
 	"github.com/google/uuid"
+	"github.com/ipfs/go-log/v2"
 	"github.com/ipfs/go-unixfsnode"
 	"github.com/ipld/go-car/v2"
 	cidlink "github.com/ipld/go-ipld-prime/linking/cid"
@@ -26,6 +27,12 @@ import (
 func TestTrustlessUnixfsFetch(t *testing.T) {
 	req := require.New(t)
 
+	lvl, err := log.LevelFromString("debug")
+	if err != nil {
+		panic(err)
+	}
+	log.SetAllLoggers(lvl)
+
 	testCases, err := trustlesspathing.Unixfs20mVarietyCases()
 	req.NoError(err)
 	storage, closer, err := trustlesspathing.Unixfs20mVarietyReadableStorage()

pkg/retriever/bitswapretriever.go

@@ -284,6 +284,7 @@ func (br *bitswapRetrieval) RetrieveFromAsyncCandidates(ayncCandidates types.Inb
 
 func loaderForSession(retrievalID types.RetrievalID, inProgressCids InProgressCids, bs blockservice.BlockGetter) linking.BlockReadOpener {
 	return func(lctx linking.LinkContext, lnk datamodel.Link) (io.Reader, error) {
+		fmt.Println("loaderForSession", lnk.String())
 		cidLink, ok := lnk.(cidlink.Link)
 		if !ok {
 			return nil, fmt.Errorf("invalid link type for loading: %v", lnk)
@@ -294,7 +295,9 @@ func loaderForSession(retrievalID types.RetrievalID, inProgressCids InProgressCi
 			return nil, lctx.Ctx.Err()
 		default:
 		}
+		fmt.Println("bs.GetBlock()", cidLink.Cid.String())
 		blk, err := bs.GetBlock(lctx.Ctx, cidLink.Cid)
+		fmt.Println("bs.GetBlock() done", cidLink.Cid.String(), err)
 		inProgressCids.Dec(cidLink.Cid, retrievalID)
 		if err != nil {
 			return nil, err