status-im/go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

remove peers with negative score from fanout

Browse Source
This commit is contained in:
vyzo 2020-03-02 20:51:51 +02:00
parent 80f3b8c45b
commit 712bab2c64
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
gossipsub.go
View File

@ -737,10 +737,11 @@ func (gs *GossipSubRouter) heartbeat() {
// maintain our fanout for topics we are publishing but we have not joined // maintain our fanout for topics we are publishing but we have not joined
for topic, peers := range gs.fanout { for topic, peers := range gs.fanout {
// check whether our peers are still in the topic // check whether our peers are still in the topic and don't have a negative score
for p := range peers { for p := range peers {
_, ok := gs.p.topics[topic][p] _, ok := gs.p.topics[topic][p]
if !ok { score := gs.score.Score(p)
if !ok || score < 0 {
delete(peers, p) delete(peers, p)
} }
} }