tmp

pkg/internal/itest/mocknet/mocknet.go

@@ -3,6 +3,7 @@ package mocknet
 import (
 	"context"
 	"errors"
+	"fmt"
 	"sync"
 	"testing"
 	"time"
@@ -162,6 +163,10 @@ func (mcf *mockCandidateFinder) FindCandidates(ctx context.Context, cid cid.Cid)
 			candidates = append(candidates, types.RetrievalCandidate{MinerPeer: *h.AddrInfo(), RootCid: cid, Metadata: md})
 		}
 	}
+	fmt.Println("Returning candidates:", len(candidates))
+	for _, c := range candidates {
+		fmt.Println("\tCandidate:", c.MinerPeer.Addrs[0])
+	}
 	return candidates, nil
 }
 

pkg/internal/itest/trustless_fetch_test.go

@@ -54,14 +54,14 @@ func TestTrustlessUnixfsFetch(t *testing.T) {
 				case "bitswap":
 					mrn.AddBitswapPeers(1)
 				}
-				require.NoError(t, mrn.MN.LinkAll())
 				var finishedChan chan []datatransfer.Event
 				if proto == "graphsync" {
 					finishedChan = mocknet.SetupRetrieval(t, mrn.Remotes[0])
 				}
 
 				mrn.Remotes[0].Blockstore().UseLinkSystem(lsys)
 				mrn.Remotes[0].Cids[tc.Root] = struct{}{}
+				require.NoError(t, mrn.MN.LinkAll())
 
 				lassie, err := lassie.NewLassie(
 					ctx,

pkg/retriever/bitswapretriever.go

@@ -162,6 +162,10 @@ func (br *bitswapRetrieval) RetrieveFromAsyncCandidates(ayncCandidates types.Inb
 		return nil, nil
 	}
 
+	fmt.Println("hasCandidates", hasCandidates, "nextCandidates", len(nextCandidates))
+	for _, c := range nextCandidates {
+		fmt.Println("\tnextCandidates", c.MinerPeer.Addrs)
+	}
 	br.events(events.StartedRetrieval(br.clock.Now(), br.request.RetrievalID, bitswapCandidate, multicodec.TransportBitswap))
 
 	// set initial providers, then start a goroutine to add more as they come in