clear non priority queue when score is negative

2024-04-09 23:45:09 +02:00 · 2024-04-09 23:45:09 +02:00 · a6237bd1c1
parent d9a60f339e
commit a6237bd1c1
1 changed files with 1 additions and 0 deletions
--- a/libp2p/protocols/pubsub/gossipsub/behavior.nim
+++ b/libp2p/protocols/pubsub/gossipsub/behavior.nim
@ -663,6 +663,7 @@ proc onHeartbeat(g: GossipSub) {.raises: [].} =
          g.pruned(peer, t)
          g.mesh.removePeer(t, peer)
          prunes &= peer
+          peer.clearNonPriorityQueue()
      if prunes.len > 0:
        let prune = RPCMsg(control: some(ControlMessage(
          prune: @[ControlPrune(