From 475a74d37f095b0bcea25c4eca6ef7db889824ef Mon Sep 17 00:00:00 2001
From: Sagar Dhawan <sagar@solana.com>
Date: Thu, 18 Apr 2019 19:24:37 -0700
Subject: [PATCH] Reduce packet recv batches (#3894)

* Reduce packet recv batches

* Fix type
---
 core/src/streamer.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/core/src/streamer.rs b/core/src/streamer.rs
index 98c5379997..51a7f2e32e 100644
--- a/core/src/streamer.rs
+++ b/core/src/streamer.rs
@@ -19,6 +19,8 @@ pub type PacketSender = Sender<Packets>;
 pub type BlobSender = Sender<SharedBlobs>;
 pub type BlobReceiver = Receiver<SharedBlobs>;
 
+const RECV_BATCH_MAX: usize = 60_000;
+
 fn recv_loop(sock: &UdpSocket, exit: Arc<AtomicBool>, channel: &PacketSender) -> Result<()> {
     loop {
         let mut msgs = Packets::default();
@@ -73,7 +75,7 @@ pub fn recv_batch(recvr: &PacketReceiver) -> Result<(Vec<Packets>, usize, u64)>
         len += more.packets.len();
         batch.push(more);
 
-        if len > 100_000 {
+        if len > RECV_BATCH_MAX {
             break;
         }
     }