From 2f62fb20310b881cfb595d3d0e1c14389b934fdd Mon Sep 17 00:00:00 2001
From: Justin Starry <justin@solana.com>
Date: Thu, 28 Apr 2022 00:46:42 +0800
Subject: [PATCH] Revert "Increase worker thread limits in quic streamer
 runtime (#24535)"

This reverts commit f244a2e1413422e26aa6399e994260b378479cc7.
---
 streamer/src/quic.rs | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/streamer/src/quic.rs b/streamer/src/quic.rs
index 4cae513b6..cb1b678ac 100644
--- a/streamer/src/quic.rs
+++ b/streamer/src/quic.rs
@@ -31,7 +31,6 @@ use {
 
 pub const MAX_STAKED_CONNECTIONS: usize = 2000;
 pub const MAX_UNSTAKED_CONNECTIONS: usize = 500;
-const NUM_QUIC_STREAMER_WORKER_THREADS: usize = 4;
 
 /// Returns default server configuration along with its PEM certificate chain.
 #[allow(clippy::field_reassign_with_default)] // https://github.com/rust-lang/rust-clippy/issues/6527
@@ -132,7 +131,7 @@ fn new_cert_params(identity_keypair: &Keypair, san: IpAddr) -> CertificateParams
 
 fn rt() -> Runtime {
     Builder::new_multi_thread()
-        .worker_threads(NUM_QUIC_STREAMER_WORKER_THREADS)
+        .worker_threads(1)
         .enable_all()
         .build()
         .unwrap()
@@ -701,9 +700,8 @@ mod test {
             let mut s1 = conn1.connection.open_uni().await.unwrap();
             let mut s2 = conn2.connection.open_uni().await.unwrap();
             s1.write_all(&[0u8]).await.unwrap();
-            s2.write_all(&[0u8]).await.unwrap();
             s1.finish().await.unwrap();
-            s2.finish()
+            s2.write_all(&[0u8])
                 .await
                 .expect_err("shouldn't be able to open 2 connections");
         });