From 24989505832af57f7d13e6f9c9b98e3257d16ec5 Mon Sep 17 00:00:00 2001
From: godmodegalactus <godmodegalactus@gmail.com>
Date: Fri, 12 Jan 2024 14:33:00 +0100
Subject: [PATCH] Reconnecing to block stream and slot stream incase of error

---
 .env.example                      | 2 +-
 core/src/quic_connection_utils.rs | 4 ++--
 lite-rpc/src/bridge.rs            | 3 +--
 3 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/.env.example b/.env.example
index d777fe6e..2f0ac619 100644
--- 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
index 4f3c7400..a5c40b5a 100644
--- 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
index f91bd591..e301feb6 100644
--- 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 {