Incraesing number of streams

common/src/quic/configure_client.rs

@@ -2,7 +2,7 @@ use crate::quic::configure_server::ALPN_GEYSER_PROTOCOL_ID;
 
 use super::configure_server::MAX_DATAGRAM_SIZE;
 
-pub const DEFAULT_MAX_STREAMS: u32 = 32 * 1024;
+pub const DEFAULT_MAX_STREAMS: u32 = 64 * 1024;
 pub const DEFAULT_MAX_RECIEVE_WINDOW_SIZE: u64 = 64_000_000; // 64 MBs
 
 pub fn configure_client(

examples/tester-client/src/main.rs

@@ -7,7 +7,10 @@ use std::{
 use clap::Parser;
 use cli::Args;
 use quic_geyser_client::client::Client;
-use quic_geyser_common::{filters::Filter, types::connections_parameters::ConnectionParameters};
+use quic_geyser_common::{
+    filters::Filter, quic::configure_client::DEFAULT_MAX_RECIEVE_WINDOW_SIZE,
+    types::connections_parameters::ConnectionParameters,
+};
 use solana_rpc_client::rpc_client::RpcClient;
 use solana_sdk::commitment_config::CommitmentConfig;
 
@@ -38,7 +41,15 @@ pub mod cli;
 pub fn main() {
     let args = Args::parse();
     println!("Connecting");
-    let (client, reciever) = Client::new(args.url, ConnectionParameters::default()).unwrap();
+    let (client, reciever) = Client::new(
+        args.url,
+        ConnectionParameters {
+            max_number_of_streams: 1024 * 1024,
+            recieve_window_size: DEFAULT_MAX_RECIEVE_WINDOW_SIZE,
+            timeout_in_seconds: 30,
+        },
+    )
+    .unwrap();
     println!("Connected");
 
     let bytes_transfered = Arc::new(AtomicU64::new(0));

examples/tester-server/src/main.rs

@@ -10,7 +10,7 @@ use itertools::Itertools;
 use quic_geyser_common::{
     channel_message::{AccountData, ChannelMessage},
     config::{CompressionParameters, ConfigQuicPlugin, QuicParameters},
-    quic::quic_server::QuicServer,
+    quic::{configure_client::DEFAULT_MAX_RECIEVE_WINDOW_SIZE, quic_server::QuicServer},
 };
 use rand::{thread_rng, Rng};
 use solana_sdk::{account::Account, pubkey::Pubkey};
@@ -22,7 +22,11 @@ pub fn main() {
 
     let config = ConfigQuicPlugin {
         address: SocketAddr::from_str(format!("0.0.0.0:{}", args.port).as_str()).unwrap(),
-        quic_parameters: QuicParameters::default(),
+        quic_parameters: QuicParameters {
+            max_number_of_streams_per_client: 1024 * 1024,
+            recieve_window_size: DEFAULT_MAX_RECIEVE_WINDOW_SIZE,
+            connection_timeout: 60,
+        },
         compression_parameters: CompressionParameters {
             compression_type: quic_geyser_common::compression::CompressionType::None,
         },