retrieval request propagated only to nodes that didnt ask (relevant in maxprox bin)

This commit is contained in:
zelig 2015-05-13 19:17:23 +02:00
parent 688f95ff5b
commit 53a00eeb41

View file

@ -197,7 +197,19 @@ func (self *NetStore) startSearch(chunk *Chunk, id int64, timeout *time.Time) {
}
for _, peer := range peers {
dpaLogger.Debugf("NetStore.startSearch: sending retrieveRequests to peer [%064x]", req.Key)
peer.retrieve(req)
var requester bool
OUT:
for _, recipients := range chunk.req.requesters {
for _, recipient := range recipients {
if recipient.peer.Addr() == peer.Addr() {
requester = true
break OUT
}
}
}
if !requester {
peer.retrieve(req)
}
}
}