status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-02-21 17:18:35 +00:00
Code Issues Projects Releases Wiki Activity

add constant

Browse Source
This commit is contained in:
Diego 2024-04-29 20:19:19 +02:00
parent 87110e551a
commit 8014a848a0
No known key found for this signature in database
GPG Key ID: C9DAC9BF68D1F806
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libp2p/protocols/pubsub/pubsubpeer.nim
View File

@ -37,6 +37,8 @@ when defined(pubsubpeer_queue_metrics):
const
DefaultMaxNumElementsInNonPriorityQueue* = 1024
BehaviourPenaltyFoNonPriorityQueueOverLimit = 0.0001 # this value is quite arbitrary and was found empirically
# to result in a behaviourPenalty around [0.1, 0.2] when the score is updated.
type
PeerRateLimitError* = object of CatchableError
@ -352,7 +354,7 @@ proc sendEncoded*(p: PubSubPeer, msg: seq[byte], isHighPriority: bool): Future[v
f
else:
if len(p.rpcmessagequeue.nonPriorityQueue) >= p.maxNumElementsInNonPriorityQueue:
p.behaviourPenalty += 0.0001
p.behaviourPenalty += BehaviourPenaltyFoNonPriorityQueueOverLimit
trace "Peer has reached maxNumElementsInNonPriorityQueue. Discarding message and applying behaviour penalty.", peer = p, score = p.score,
behaviourPenalty = p.behaviourPenalty, agent = p.getAgent()
Future[void].completed()