fix: query chunk records from peers in routing tableif there is no gi…

…ven peer
33cn · Jul 14, 2021 · 5362c0a · 5362c0a
1 parent 6371fcf
commit 5362c0a
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/system/p2p/dht/protocol/p2pstore/query.go b/system/p2p/dht/protocol/p2pstore/query.go
@@ -354,6 +354,16 @@ func (p *Protocol) getChunkRecords(param *types.ReqChunkRecords) *types.ChunkRec
 		log.Info("getChunkRecords", "peer", pid, "error", err, "start", param.Start, "end", param.End)
 		return records
 	}
+
+	for _, pid := range p.RoutingTable.ListPeers() {
+		records, err := p.getChunkRecordsFromPeer(param, pid)
+		if err != nil {
+			log.Error("getChunkRecords", "peer", pid, "error", err, "start", param.Start, "end", param.End)
+			continue
+		}
+		log.Info("getChunkRecords", "peer", pid, "error", err, "start", param.Start, "end", param.End)
+		return records
+	}
 	return nil
 }