diff --git a/.github/workflows/local-testnet.yml b/.github/workflows/local-testnet.yml index f97b271c35..7f367821c3 100644 --- a/.github/workflows/local-testnet.yml +++ b/.github/workflows/local-testnet.yml @@ -34,7 +34,6 @@ jobs: key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }} - name: Install lighthouse - if: steps.cache-cargo.outputs.cache-hit != 'true' run: make && make install-lcli - name: Start local testnet diff --git a/beacon_node/lighthouse_network/src/peer_manager/mod.rs b/beacon_node/lighthouse_network/src/peer_manager/mod.rs index 48edd3abb6..437d05d474 100644 --- a/beacon_node/lighthouse_network/src/peer_manager/mod.rs +++ b/beacon_node/lighthouse_network/src/peer_manager/mod.rs @@ -10,7 +10,7 @@ use hashset_delay::HashSetDelay; use libp2p::identify::IdentifyInfo; use peerdb::{client::ClientKind, BanOperation, BanResult, ScoreUpdateResult}; use rand::seq::SliceRandom; -use slog::{debug, error, warn}; +use slog::{debug, error, trace, warn}; use smallvec::SmallVec; use std::{ sync::Arc, @@ -547,7 +547,7 @@ impl PeerManager { if let Some(peer_info) = self.network_globals.peers.read().peer_info(peer_id) { // received a ping // reset the to-ping timer for this peer - debug!(self.log, "Received a ping request"; "peer_id" => %peer_id, "seq_no" => seq); + trace!(self.log, "Received a ping request"; "peer_id" => %peer_id, "seq_no" => seq); match peer_info.connection_direction() { Some(ConnectionDirection::Incoming) => { self.inbound_ping_peers.insert(*peer_id); @@ -563,7 +563,7 @@ impl PeerManager { // if the sequence number is unknown send an update the meta data of the peer. if let Some(meta_data) = &peer_info.meta_data() { if *meta_data.seq_number() < seq { - debug!(self.log, "Requesting new metadata from peer"; + trace!(self.log, "Requesting new metadata from peer"; "peer_id" => %peer_id, "known_seq_no" => meta_data.seq_number(), "ping_seq_no" => seq); self.events.push(PeerManagerEvent::MetaData(*peer_id)); } @@ -587,13 +587,13 @@ impl PeerManager { // if the sequence number is unknown send update the meta data of the peer. if let Some(meta_data) = &peer_info.meta_data() { if *meta_data.seq_number() < seq { - debug!(self.log, "Requesting new metadata from peer"; + trace!(self.log, "Requesting new metadata from peer"; "peer_id" => %peer_id, "known_seq_no" => meta_data.seq_number(), "pong_seq_no" => seq); self.events.push(PeerManagerEvent::MetaData(*peer_id)); } } else { // if we don't know the meta-data, request it - debug!(self.log, "Requesting first metadata from peer"; + trace!(self.log, "Requesting first metadata from peer"; "peer_id" => %peer_id); self.events.push(PeerManagerEvent::MetaData(*peer_id)); } @@ -607,10 +607,10 @@ impl PeerManager { if let Some(peer_info) = self.network_globals.peers.write().peer_info_mut(peer_id) { if let Some(known_meta_data) = &peer_info.meta_data() { if *known_meta_data.seq_number() < *meta_data.seq_number() { - debug!(self.log, "Updating peer's metadata"; + trace!(self.log, "Updating peer's metadata"; "peer_id" => %peer_id, "known_seq_no" => known_meta_data.seq_number(), "new_seq_no" => meta_data.seq_number()); } else { - debug!(self.log, "Received old metadata"; + trace!(self.log, "Received old metadata"; "peer_id" => %peer_id, "known_seq_no" => known_meta_data.seq_number(), "new_seq_no" => meta_data.seq_number()); // Updating metadata even in this case to prevent storing // incorrect `attnets/syncnets` for a peer diff --git a/beacon_node/network/src/metrics.rs b/beacon_node/network/src/metrics.rs index a10d238764..446aa0a033 100644 --- a/beacon_node/network/src/metrics.rs +++ b/beacon_node/network/src/metrics.rs @@ -5,10 +5,12 @@ use beacon_chain::{ use fnv::FnvHashMap; pub use lighthouse_metrics::*; use lighthouse_network::{ - types::GossipKind, BandwidthSinks, GossipTopic, Gossipsub, NetworkGlobals, + peer_manager::peerdb::client::ClientKind, types::GossipKind, BandwidthSinks, GossipTopic, + Gossipsub, NetworkGlobals, }; use std::sync::Arc; use strum::AsStaticRef; +use strum::IntoEnumIterator; use types::EthSpec; lazy_static! { @@ -343,6 +345,20 @@ pub fn update_gossip_metrics( network_globals: &Arc>, ) { // Mesh peers per client + // Reset the gauges + for client_kind in ClientKind::iter() { + set_gauge_vec( + &BEACON_BLOCK_MESH_PEERS_PER_CLIENT, + &[&client_kind.to_string()], + 0_i64, + ); + set_gauge_vec( + &BEACON_AGGREGATE_AND_PROOF_MESH_PEERS_PER_CLIENT, + &[&client_kind.to_string()], + 0_i64, + ); + } + for topic_hash in gossipsub.topics() { if let Ok(topic) = GossipTopic::decode(topic_hash.as_str()) { match topic.kind() {