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

minimize hash table accesses

This commit is contained in:
vyzo 2020-03-08 17:22:16 +02:00
parent 16eeacd798
commit 535c04481e
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
score.go
View File

@ -445,18 +445,20 @@ func (ps *peerScore) markFirstMessageDelivery(p peer.ID, msg *Message) {
continue
}
cap := ps.params.Topics[topic].FirstMessageDeliveriesCap
tstats.firstMessageDeliveries += 1
if tstats.firstMessageDeliveries > ps.params.Topics[topic].FirstMessageDeliveriesCap {
tstats.firstMessageDeliveries = ps.params.Topics[topic].FirstMessageDeliveriesCap
if tstats.firstMessageDeliveries > cap {
tstats.firstMessageDeliveries = cap
}
if !tstats.inMesh {
continue
}
cap = ps.params.Topics[topic].MeshMessageDeliveriesCap
tstats.meshMessageDeliveries += 1
if tstats.meshMessageDeliveries > ps.params.Topics[topic].MeshMessageDeliveriesCap {
tstats.meshMessageDeliveries = ps.params.Topics[topic].MeshMessageDeliveriesCap
if tstats.meshMessageDeliveries > cap {
tstats.meshMessageDeliveries = cap
}
}
}
@ -482,9 +484,10 @@ func (ps *peerScore) markDuplicateMessageDelivery(p peer.ID, msg *Message, first
continue
}
cap := ps.params.Topics[topic].MeshMessageDeliveriesCap
tstats.meshMessageDeliveries += 1
if tstats.meshMessageDeliveries > ps.params.Topics[topic].MeshMessageDeliveriesCap {
tstats.meshMessageDeliveries = ps.params.Topics[topic].MeshMessageDeliveriesCap
if tstats.meshMessageDeliveries > cap {
tstats.meshMessageDeliveries = cap
}
}
}