fix: increase channel size, increase interval

topos-protocol · Apr 15, 2024 · cc2eb0e · cc2eb0e
1 parent d6673cb
commit cc2eb0e
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 3 deletions.
diff --git a/crates/topos-config/src/tce/synchronization.rs b/crates/topos-config/src/tce/synchronization.rs
@@ -23,7 +23,7 @@ impl Default for SynchronizationConfig {
 }
 
 impl SynchronizationConfig {
-    pub const INTERVAL_SECONDS: u64 = 10;
+    pub const INTERVAL_SECONDS: u64 = 2;
     pub const LIMIT_PER_SUBNET: usize = 100;
 
     const fn default_interval_seconds() -> u64 {

diff --git a/crates/topos-tce-synchronizer/src/builder.rs b/crates/topos-tce-synchronizer/src/builder.rs
@@ -29,7 +29,7 @@ impl Default for SynchronizerBuilder {
             network_client: None,
             store: None,
             config: SynchronizationConfig::default(),
-            event_channel_size: 100,
+            event_channel_size: 10_000,
             shutdown: None,
         }
     }

diff --git a/crates/topos-tce/src/app_context.rs b/crates/topos-tce/src/app_context.rs
@@ -100,6 +100,7 @@ impl AppContext {
     ) {
         loop {
             tokio::select! {
+                biased;
 
                 Some(delivery) = broadcast_stream.next() => {
                     let certificate_id = delivery.0.certificate.id;

diff --git a/crates/topos-tce/src/lib.rs b/crates/topos-tce/src/lib.rs
@@ -152,7 +152,6 @@ pub async fn run(
     debug!("P2P layer bootstrapped");
 
     debug!("Creating the Synchronizer");
-
     let (synchronizer_runtime, synchronizer_stream) =
         topos_tce_synchronizer::Synchronizer::builder()
             .with_config(config.synchronization.clone())
-Original file line number
+Diff line change
@@ Expand Up / @@ -100,6 +100,7 @@ impl AppContext { @@
         ) {
             loop {
                 tokio::select! {
+                    biased;
                     Some(delivery) = broadcast_stream.next() => {
                         let certificate_id = delivery.0.certificate.id;
@@ Expand Down @@