adjust broadcast channel capacity to pow2

This commit is contained in:
GroovieGermanikus 2023-08-09 17:39:55 +02:00
parent c7a79ab6c0
commit f4deb51c49
1 changed files with 1 additions and 1 deletions

View File

@ -50,7 +50,7 @@ pub async fn tx_forwarder(
let endpoint = new_endpoint_with_validator_identity(validator_identity).await;
let (broadcast_in, _) = tokio::sync::broadcast::channel::<Arc<ForwardPacket>>(1000);
let (broadcast_in, _) = tokio::sync::broadcast::channel::<Arc<ForwardPacket>>(1024);
let mut agents: HashMap<SocketAddr, AgentHandle> = HashMap::new();
let agent_shutdown_debouncer = Debouncer::new(Duration::from_millis(200));