fix: increase channel sizes and interval speed further

crates/topos-config/src/tce/synchronization.rs

@@ -23,7 +23,7 @@ impl Default for SynchronizationConfig {
 }
 
 impl SynchronizationConfig {
-    pub const INTERVAL_SECONDS: u64 = 30;
+    pub const INTERVAL_SECONDS: u64 = 60;
     pub const LIMIT_PER_SUBNET: usize = 100;
 
     const fn default_interval_seconds() -> u64 {

crates/topos-p2p/src/behaviour/gossip.rs

@@ -25,7 +25,7 @@ use crate::{constants, event::ComposedEvent, TOPOS_ECHO, TOPOS_GOSSIP, TOPOS_REA
 
 use super::HealthStatus;
 
-const MAX_BATCH_SIZE: usize = 1024;
+const MAX_BATCH_SIZE: usize = 2048;
 
 pub struct Behaviour {
     batch_size: usize,
@@ -76,7 +76,7 @@ impl Behaviour {
             .unwrap_or(Ok(MAX_BATCH_SIZE))
             .unwrap();
         let gossipsub = gossipsub::ConfigBuilder::default()
-            .max_transmit_size(2 * 2048 * 2048)
+            .max_transmit_size(5 * 2048 * 2048)
             .validation_mode(gossipsub::ValidationMode::Strict)
             .message_id_fn(|msg_id| {
                 // Content based id

crates/topos-sequencer-subnet-runtime/src/proxy.rs

@@ -68,7 +68,7 @@ impl SubnetRuntimeProxy {
              address: {}, ",
             &config.http_endpoint, &config.ws_endpoint, &config.subnet_contract_address
         );
-        let (command_sender, mut command_rcv) = mpsc::channel::<SubnetRuntimeProxyCommand>(1024);
+        let (command_sender, mut command_rcv) = mpsc::channel::<SubnetRuntimeProxyCommand>(5120);
         let ws_runtime_endpoint = config.ws_endpoint.clone();
         let http_runtime_endpoint = config.http_endpoint.clone();
         let subnet_contract_address = Arc::new(config.subnet_contract_address.clone());

crates/topos-tce-api/src/grpc/mod.rs

@@ -29,7 +29,7 @@ pub(crate) mod console;
 #[cfg(test)]
 mod tests;
 
-const DEFAULT_CHANNEL_STREAM_CAPACITY: usize = 1024;
+const DEFAULT_CHANNEL_STREAM_CAPACITY: usize = 5120;
 
 pub(crate) mod builder;
 pub(crate) mod messaging;

crates/topos-tce-broadcast/src/task_manager/mod.rs

@@ -107,7 +107,7 @@ impl TaskManager {
     }
 
     pub async fn run(mut self, shutdown_receiver: CancellationToken) {
-        let mut interval = tokio::time::interval(Duration::from_millis(15));
+        let mut interval = tokio::time::interval(Duration::from_millis(5));
 
         loop {
             tokio::select! {

crates/topos-tce-proxy/src/client.rs

@@ -22,9 +22,9 @@ use topos_core::{
 use tracing::{debug, error, info, info_span, warn, Instrument, Span};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 
-const CERTIFICATE_OUTBOUND_CHANNEL_SIZE: usize = 2048;
-const CERTIFICATE_INBOUND_CHANNEL_SIZE: usize = 2048;
-const TCE_PROXY_COMMAND_CHANNEL_SIZE: usize = 2048;
+const CERTIFICATE_OUTBOUND_CHANNEL_SIZE: usize = 5120;
+const CERTIFICATE_INBOUND_CHANNEL_SIZE: usize = 5120;
+const TCE_PROXY_COMMAND_CHANNEL_SIZE: usize = 5120;
 
 // Maximum backoff retry timeout in seconds (1 hour)
 const TCE_SUBMIT_CERTIFICATE_BACKOFF_TIMEOUT: Duration = Duration::from_secs(3600);

crates/topos-tce/src/app_context.rs

@@ -69,7 +69,7 @@ impl AppContext {
         validator_store: Arc<ValidatorStore>,
         api_context: RuntimeContext,
     ) -> (Self, mpsc::Receiver<Events>) {
-        let (events, receiver) = mpsc::channel(2048);
+        let (events, receiver) = mpsc::channel(5120);
         (
             Self {
                 is_validator,