Process sync objects with concurrency (#2906)

ChainSafe · Jul 29, 2021 · 0b01245 · 0b01245
1 parent b90577d
commit 0b01245
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/lodestar/src/network/gossip/validation/queue.ts b/packages/lodestar/src/network/gossip/validation/queue.ts
@@ -16,8 +16,8 @@ const gossipQueueOpts: {[K in GossipType]: Pick<JobQueueOpts, "maxLength" | "typ
   [GossipType.voluntary_exit]: {maxLength: 4096, type: QueueType.FIFO},
   [GossipType.proposer_slashing]: {maxLength: 4096, type: QueueType.FIFO},
   [GossipType.attester_slashing]: {maxLength: 4096, type: QueueType.FIFO},
-  [GossipType.sync_committee_contribution_and_proof]: {maxLength: 4096, type: QueueType.LIFO},
-  [GossipType.sync_committee]: {maxLength: 4096, type: QueueType.LIFO},
+  [GossipType.sync_committee_contribution_and_proof]: {maxLength: 4096, type: QueueType.LIFO, maxConcurrency: 16},
+  [GossipType.sync_committee]: {maxLength: 4096, type: QueueType.LIFO, maxConcurrency: 64},
 };
 
 /**