From 5174f44bc9976e84a0a019b7ab8bc0dfdca6e5d8 Mon Sep 17 00:00:00 2001 From: AstaFrode Date: Thu, 6 Jul 2023 15:21:14 +0800 Subject: [PATCH] release v0.2.1 (#76) --- node/getHandle.go | 5 ++++- node/tracker.go | 9 ++++++--- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/node/getHandle.go b/node/getHandle.go index 6627578..b21b7f5 100644 --- a/node/getHandle.go +++ b/node/getHandle.go @@ -300,7 +300,10 @@ func (n *Node) fetchFiles(roothash, dir string) (string, error) { peerid := base58.Encode([]byte(string(miner.PeerId[:]))) addr, ok := n.GetPeer(peerid) if !ok { - continue + addr, err = n.DHTFindPeer(peerid) + if err != nil { + continue + } } err = n.Connect(n.GetRootCtx(), addr) if err != nil { diff --git a/node/tracker.go b/node/tracker.go index fc98d22..6dcef27 100644 --- a/node/tracker.go +++ b/node/tracker.go @@ -250,9 +250,12 @@ func (n *Node) storageData(roothash string, segment []pattern.SegmentDataInfo, m for i := 0; i < len(peerids); i++ { addr, ok := n.GetPeer(peerids[i]) if !ok { - failed = true - n.Track("err", fmt.Sprintf("[%s] No assigned miner found: [%s] [%s]", roothash, accs[i], peerids[i])) - continue + addr, err = n.DHTFindPeer(peerids[i]) + if err != nil { + failed = true + n.Track("err", fmt.Sprintf("[%s] No assigned miner found: [%s] [%s]", roothash, accs[i], peerids[i])) + continue + } } err = n.Connect(n.GetRootCtx(), addr) if err != nil {