blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Increase worker thread limits in quic streamer runtime (#24535)" 

This reverts commit f244a2e141.
This commit is contained in:
Justin Starry 2022-04-28 00:46:42 +08:00
parent b080352436
commit 2f62fb2031
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
streamer/src/quic.rs
View File

@ -31,7 +31,6 @@ use {
pub const MAX_STAKED_CONNECTIONS: usize = 2000; pub const MAX_STAKED_CONNECTIONS: usize = 2000;
pub const MAX_UNSTAKED_CONNECTIONS: usize = 500; 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. /// 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 #[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 { fn rt() -> Runtime {
Builder::new_multi_thread() Builder::new_multi_thread()
.worker_threads(NUM_QUIC_STREAMER_WORKER_THREADS) .worker_threads(1)
.enable_all() .enable_all()
.build() .build()
.unwrap() .unwrap()
@ -701,9 +700,8 @@ mod test {
let mut s1 = conn1.connection.open_uni().await.unwrap(); let mut s1 = conn1.connection.open_uni().await.unwrap();
let mut s2 = conn2.connection.open_uni().await.unwrap(); let mut s2 = conn2.connection.open_uni().await.unwrap();
s1.write_all(&[0u8]).await.unwrap(); s1.write_all(&[0u8]).await.unwrap();
s2.write_all(&[0u8]).await.unwrap();
s1.finish().await.unwrap(); s1.finish().await.unwrap();
s2.finish() s2.write_all(&[0u8])
.await .await
.expect_err("shouldn't be able to open 2 connections"); .expect_err("shouldn't be able to open 2 connections");
}); });