Call deliverMessage before gossip queue (#3812)

ChainSafe · Feb 28, 2022 · 4b62955 · 4b62955
1 parent 62b2092
commit 4b62955
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/packages/lodestar/src/network/gossip/gossipsub.ts b/packages/lodestar/src/network/gossip/gossipsub.ts
@@ -230,6 +230,11 @@ export class Eth2Gossipsub extends Gossipsub {
    */
   async validate(message: InMessage): Promise<void> {
     try {
+      // Resolve IWANT promise before sending message to the queue. Attestations and aggregates can remain in the
+      // validation queue for > 1 min. Metrics show that peers are severly penalized with P7 due to broken promises,
+      // which they fullfil but _publish() is not called in time.
+      await this.gossipTracer.deliverMessage(message);
+
       // messages must have a single topicID
       const topicStr = Array.isArray(message.topicIDs) ? message.topicIDs[0] : undefined;