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

log GSO enable/disable

This commit is contained in:
GroovieGermanikus 2023-10-09 17:40:02 +02:00
parent 9f502e17d7
commit 7f7a931b5f
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
services/src/tpu_utils/tpu_service.rs
View File

@ -6,7 +6,7 @@ use super::tpu_connection_manager::TpuConnectionManager;
use crate::tpu_utils::quic_proxy_connection_manager::QuicProxyConnectionManager; use crate::tpu_utils::quic_proxy_connection_manager::QuicProxyConnectionManager;
use crate::tpu_utils::tpu_connection_path::TpuConnectionPath; use crate::tpu_utils::tpu_connection_path::TpuConnectionPath;
use crate::tpu_utils::tpu_service::ConnectionManager::{DirectTpu, QuicProxy}; use crate::tpu_utils::tpu_service::ConnectionManager::{DirectTpu, QuicProxy};
use solana_lite_rpc_core::quic_connection_utils::QuicConnectionParameters; use solana_lite_rpc_core::quic_connection_utils::{enable_gso, QuicConnectionParameters};
use solana_lite_rpc_core::stores::data_cache::DataCache; use solana_lite_rpc_core::stores::data_cache::DataCache;
use solana_lite_rpc_core::traits::leaders_fetcher_interface::LeaderFetcherInterface; use solana_lite_rpc_core::traits::leaders_fetcher_interface::LeaderFetcherInterface;
use solana_lite_rpc_core::types::SlotStream; use solana_lite_rpc_core::types::SlotStream;
@ -17,6 +17,7 @@ use std::{
net::{IpAddr, Ipv4Addr}, net::{IpAddr, Ipv4Addr},
sync::Arc, sync::Arc,
}; };
use log::info;
lazy_static::lazy_static! { lazy_static::lazy_static! {
static ref NB_CLUSTER_NODES: GenericGauge<prometheus::core::AtomicI64> = static ref NB_CLUSTER_NODES: GenericGauge<prometheus::core::AtomicI64> =
@ -73,6 +74,8 @@ impl TpuService {
) )
.expect("Failed to initialize QUIC client certificates"); .expect("Failed to initialize QUIC client certificates");
info!("GSO enabled? {}", enable_gso());
let connection_manager = match config.tpu_connection_path { let connection_manager = match config.tpu_connection_path {
TpuConnectionPath::QuicDirectPath => { TpuConnectionPath::QuicDirectPath => {
let tpu_connection_manager = let tpu_connection_manager =