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

changing number of stream to 96k and depile all the messages

This commit is contained in:
godmodegalactus 2024-05-30 15:17:19 +02:00
parent 07efb331cd
commit 5286d34a34
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/src/defaults.rs
View File

@ -1,4 +1,4 @@
pub const DEFAULT_MAX_STREAMS: u64 = 64 * 1024; pub const DEFAULT_MAX_STREAMS: u64 = 96 * 1024;
pub const MAX_ALLOWED_PARTIAL_RESPONSES: u64 = DEFAULT_MAX_STREAMS - 1; pub const MAX_ALLOWED_PARTIAL_RESPONSES: u64 = DEFAULT_MAX_STREAMS - 1;
pub const DEFAULT_MAX_RECIEVE_WINDOW_SIZE: u64 = 1024 * 1024; // 1 MBs pub const DEFAULT_MAX_RECIEVE_WINDOW_SIZE: u64 = 1024 * 1024; // 1 MBs
pub const DEFAULT_CONNECTION_TIMEOUT: u64 = 10; pub const DEFAULT_CONNECTION_TIMEOUT: u64 = 10;

8
server/src/quiche_server_loop.rs
View File

@ -367,9 +367,6 @@ fn create_client_task(
if !connection.is_closed() && connection.is_established() { if !connection.is_closed() && connection.is_established() {
while partial_responses.len() < max_allowed_partial_responses { while partial_responses.len() < max_allowed_partial_responses {
if connection.is_closed() || !connection.is_established() {
break;
}
let close = match message_channel.try_recv() { let close = match message_channel.try_recv() {
Ok((message, priority)) => { Ok((message, priority)) => {
message_count.fetch_sub(1, std::sync::atomic::Ordering::Relaxed); message_count.fetch_sub(1, std::sync::atomic::Ordering::Relaxed);
@ -386,6 +383,7 @@ fn create_client_task(
e e
); );
} }
break;
} }
send_message( send_message(
&mut connection, &mut connection,
@ -397,7 +395,9 @@ fn create_client_task(
} }
Err(e) => { Err(e) => {
match e { match e {
mpsc::TryRecvError::Empty => false, mpsc::TryRecvError::Empty => {
break;
}
mpsc::TryRecvError::Disconnected => { mpsc::TryRecvError::Disconnected => {
// too many message the connection is lagging // too many message the connection is lagging
true true