logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-05 22:33:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

tweak probability threshold

Browse Source
This commit is contained in:
vyzo 2020-09-03 00:40:46 +03:00
parent ff1b1a9772
commit 955344bf9b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
peer_gater.go
View File

@ -165,12 +165,12 @@ func (pg *peerGater) AcceptFrom(p peer.ID) AcceptStatus {
} }
// we make a randomized decision based on the goodput of the peer // we make a randomized decision based on the goodput of the peer
goodput := st.deliver / total threshold := (1 + st.deliver) / (1 + total)
if rand.Float64() < goodput { if rand.Float64() < threshold {
return AcceptAll return AcceptAll
} }
log.Debugf("throttling peer %s with goodput %f", p, goodput) log.Debugf("throttling peer %s with threshold %f", p, threshold)
return AcceptControl return AcceptControl
} }