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

Merge pull request #160 from blockworks-foundation/do_not_destroy_the_connection_with_exisiting_tpus 

Avoiding destroying connections with existing leaders
This commit is contained in:
Aniket Prajapati 2023-07-19 16:25:37 +05:30 committed by GitHub
parent 1834e9495a 48d26eac15
commit 807f84c1cf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lite-rpc/src/bridge.rs
View File

@ -104,7 +104,7 @@ impl LiteBridge {
max_number_of_connections: 10, max_number_of_connections: 10,
unistream_timeout: Duration::from_millis(500), unistream_timeout: Duration::from_millis(500),
write_timeout: Duration::from_secs(1), write_timeout: Duration::from_secs(1),
number_of_transactions_per_unistream: 10, number_of_transactions_per_unistream: 8,
}, },
}; };

8
services/src/tpu_utils/tpu_connection_manager.rs
View File

@ -146,20 +146,12 @@ impl ActiveConnection {
} }
} }
if txs.len() >= number_of_transactions_per_unistream - 1 {
// queue getting full and a connection poll is getting slower // queue getting full and a connection poll is getting slower
// add more connections to the pool // add more connections to the pool
if connection_pool.len() < max_number_of_connections { if connection_pool.len() < max_number_of_connections {
connection_pool.add_connection().await; connection_pool.add_connection().await;
NB_QUIC_CONNECTIONS.inc(); NB_QUIC_CONNECTIONS.inc();
} }
} else if txs.len() == 1 {
// low traffic / reduce connection till minimum 1
if connection_pool.len() > 1 {
connection_pool.remove_connection().await;
NB_QUIC_CONNECTIONS.dec();
}
}
let task_counter = task_counter.clone(); let task_counter = task_counter.clone();
let connection_pool = connection_pool.clone(); let connection_pool = connection_pool.clone();