blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reconnecing to block stream and slot stream incase of error

This commit is contained in:
godmodegalactus 2024-01-12 14:33:00 +01:00
parent 3f69de5247
commit 2498950583
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.env.example
View File

@ -11,7 +11,7 @@ WS_ADDR=ws://0.0.0.0:8900
# PROMETHEUS_ADDR=your_prometheus_address_here # PROMETHEUS_ADDR=your_prometheus_address_here
## Fanout size and retries configuration ## Fanout size and retries configuration
FANOUT_SIZE=18 FANOUT_SIZE=32
MAX_RETRIES=40 MAX_RETRIES=40
RETRY_TIMEOUT=3 RETRY_TIMEOUT=3

4
core/src/quic_connection_utils.rs
View File

@ -158,7 +158,7 @@ impl QuicConnectionUtils {
} }
} }
Err(_) => { Err(_) => {
warn!("timeout while writing transaction for {}", identity); log::debug!("timeout while writing transaction for {}", identity);
return Err(QuicConnectionError::TimeOut); return Err(QuicConnectionError::TimeOut);
} }
} }
@ -177,7 +177,7 @@ impl QuicConnectionUtils {
} }
} }
Err(_) => { Err(_) => {
warn!("timeout while finishing transaction for {}", identity); log::debug!("timeout while finishing transaction for {}", identity);
return Err(QuicConnectionError::TimeOut); return Err(QuicConnectionError::TimeOut);
} }
} }

3
lite-rpc/src/bridge.rs
View File

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