Reconnecing to block stream and slot stream incase of error

blockworks-foundation · Jan 12, 2024 · 2498950 · 2498950
1 parent 3f69de5
commit 2498950
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/.env.example b/.env.example
@@ -11,7 +11,7 @@ WS_ADDR=ws://0.0.0.0:8900
 # PROMETHEUS_ADDR=your_prometheus_address_here
 
 ## Fanout size and retries configuration
-FANOUT_SIZE=18
+FANOUT_SIZE=32
 MAX_RETRIES=40
 RETRY_TIMEOUT=3
 

diff --git a/core/src/quic_connection_utils.rs b/core/src/quic_connection_utils.rs
@@ -158,7 +158,7 @@ impl QuicConnectionUtils {
                 }
             }
             Err(_) => {
-                warn!("timeout while writing transaction for {}", identity);
+                log::debug!("timeout while writing transaction for {}", identity);
                 return Err(QuicConnectionError::TimeOut);
             }
         }
@@ -177,7 +177,7 @@ impl QuicConnectionUtils {
                 }
             }
             Err(_) => {
-                warn!("timeout while finishing transaction for {}", identity);
+                log::debug!("timeout while finishing transaction for {}", identity);
                 return Err(QuicConnectionError::TimeOut);
             }
         }

diff --git a/lite-rpc/src/bridge.rs b/lite-rpc/src/bridge.rs
@@ -12,7 +12,6 @@ use solana_lite_rpc_services::{
 
 use anyhow::Context;
 use jsonrpsee::{core::SubscriptionResult, server::ServerBuilder, PendingSubscriptionSink};
-use log::info;
 use prometheus::{opts, register_int_counter, IntCounter};
 use solana_lite_rpc_core::{
     stores::{block_information_store::BlockInformation, data_cache::DataCache, tx_store::TxProps},
@@ -207,7 +206,7 @@ impl LiteRpcServer for LiteBridge {
             .get_latest_block(commitment_config)
             .await;
 
-        info!("glb {blockhash} {slot} {block_height}");
+        log::trace!("glb {blockhash} {slot} {block_height}");
 
         Ok(RpcResponse {
             context: RpcResponseContext {