From 3313b2ff588a5c324a2a59f07d122075dfb836de Mon Sep 17 00:00:00 2001
From: Pankaj Garg <pankaj@solana.com>
Date: Mon, 14 Oct 2019 13:32:29 -0700
Subject: [PATCH] Fetch stage batching of forwarded txs (#6349)

automerge
---
 core/src/fetch_stage.rs | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/core/src/fetch_stage.rs b/core/src/fetch_stage.rs
index 7c043248cb..9b70f5a3f0 100644
--- a/core/src/fetch_stage.rs
+++ b/core/src/fetch_stage.rs
@@ -61,6 +61,10 @@ impl FetchStage {
         while let Ok(more) = recvr.try_recv() {
             len += more.packets.len();
             batch.push(more);
+            // Read at most 1K transactions in a loop
+            if len > 1024 {
+                break;
+            }
         }
 
         if poh_recorder.lock().unwrap().would_be_leader(