fix: index bug

yxq · vipwzw · commit fd6a114b69aa · 2021-09-27T11:55:17.000+08:00
diff --git a/system/p2p/dht/protocol/p2pstore/handler.go b/system/p2p/dht/protocol/p2pstore/handler.go
@@ -398,7 +398,7 @@ func (p *Protocol) handleEventNotifyStoreChunk(m *queue.Message) {
 	//如果本节点是扩展路由表中距离该chunk最近的 `Percentage` 节点之一，则保存数据；否则不需要保存数据
 	extendRoutingTable := p.getExtendRoutingTable()
 	pids := extendRoutingTable.NearestPeers(genDHTID(req.ChunkHash), extendRoutingTable.Size())
-	if len(pids) > 0 && kb.Closer(pids[len(pids)*p.SubConfig.Percentage/100], p.Host.ID(), genChunkNameSpaceKey(req.ChunkHash)) {
+	if len(pids) > 0 && kb.Closer(pids[(len(pids)-1)*p.SubConfig.Percentage/100], p.Host.ID(), genChunkNameSpaceKey(req.ChunkHash)) {
 		return
 	}
 	log.Info("handleEventNotifyStoreChunk", "peers count", len(pids), "chunk hash", hex.EncodeToString(req.ChunkHash), "start", req.Start, "end", req.End)

Original file line number	Diff line number	Diff line change
`@@ -398,7 +398,7 @@ func (p Protocol) handleEventNotifyStoreChunk(m queue.Message) {`
`398`	`398`	//如果本节点是扩展路由表中距离该chunk最近的 `Percentage` 节点之一，则保存数据；否则不需要保存数据
`399`	`399`	`extendRoutingTable := p.getExtendRoutingTable()`
`400`	`400`	`pids := extendRoutingTable.NearestPeers(genDHTID(req.ChunkHash), extendRoutingTable.Size())`
`401`		`- if len(pids) > 0 && kb.Closer(pids[len(pids)*p.SubConfig.Percentage/100], p.Host.ID(), genChunkNameSpaceKey(req.ChunkHash)) {`
	`401`	`+ if len(pids) > 0 && kb.Closer(pids[(len(pids)-1)*p.SubConfig.Percentage/100], p.Host.ID(), genChunkNameSpaceKey(req.ChunkHash)) {`
`402`	`402`	`return`
`403`	`403`	`}`
`404`	`404`	`log.Info("handleEventNotifyStoreChunk", "peers count", len(pids), "chunk hash", hex.EncodeToString(req.ChunkHash), "start", req.Start, "end", req.End)`