forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/pss: variable renamed

Browse source
This commit is contained in:
Vlad 2018-12-14 17:56:05 +04:00
parent 7cd148332e
commit f28c0ca439
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
swarm/pss/pss.go
View file

@ -948,21 +948,21 @@ func (p *Pss) forward(msg *PssMsg) error {
// proximity order function matching up to neighbourhoodDepth bits (po <= neighbourhoodDepth)
pof := pot.DefaultPof(neighbourhoodDepth)
// soft threshold of msg propagation
threshold, _ := pof(to, p.BaseAddr(), 0)
if threshold > luminosityRadius {
threshold = luminosityRadius
// soft threshold for msg broadcast
broadcastThreshold, _ := pof(to, p.BaseAddr(), 0)
if broadcastThreshold > luminosityRadius {
broadcastThreshold = luminosityRadius
}
// if measured from the recipient address as opposed to the base address (see Kademlia.EachConn
// call below), then peers that fall in the same proximity bin as recipient address will appear
// [at least] one bit closer, but only if these additional bits are given in the recipient address.
if threshold < luminosityRadius && threshold < neighbourhoodDepth {
threshold++
if broadcastThreshold < luminosityRadius && broadcastThreshold < neighbourhoodDepth {
broadcastThreshold++
}
p.Kademlia.EachConn(to, addressLength*8, func(sp *network.Peer, po int, _ bool) bool {
if po < threshold && sent > 0 {
if po < broadcastThreshold && sent > 0 {
return false // stop iterating
}
if sendMessage(p, sp, msg) {