octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix verbose add_initial_peers logs (#3019) 

And update some function docs.
This commit is contained in:
teor 2021-11-08 08:21:51 +10:00 committed by GitHub
parent 88cdf0f832
commit 7d8240fac3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
zebra-network/src/peer_set/initialize.rs
View File

@ -228,7 +228,9 @@ where
/// Use the provided `outbound_connector` to connect to the configured initial peers, /// Use the provided `outbound_connector` to connect to the configured initial peers,
/// then send the resulting peer connections over `peerset_tx`. /// then send the resulting peer connections over `peerset_tx`.
#[instrument(skip(config, outbound_connector, peerset_tx))] ///
/// Sends any unused initial peers to the `address_book_updater`.
#[instrument(skip(config, outbound_connector, peerset_tx, address_book_updater))]
async fn add_initial_peers<S>( async fn add_initial_peers<S>(
config: Config, config: Config,
outbound_connector: S, outbound_connector: S,
@ -360,7 +362,9 @@ where
/// Limit the number of `initial_peers` addresses entries to the configured /// Limit the number of `initial_peers` addresses entries to the configured
/// `peerset_initial_target_size`. /// `peerset_initial_target_size`.
/// ///
/// The result is randomly chosen entries from the provided set of addresses. /// Returns randomly chosen entries from the provided set of addresses.
///
/// Sends any unused entries to the `address_book_updater`.
async fn limit_initial_peers( async fn limit_initial_peers(
config: &Config, config: &Config,
mut address_book_updater: mpsc::Sender<MetaAddrChange>, mut address_book_updater: mpsc::Sender<MetaAddrChange>,

2
zebra-state/src/service.rs
View File

@ -500,7 +500,7 @@ impl StateService {
.collect(); .collect();
res.reverse(); res.reverse();
tracing::info!( tracing::debug!(
?final_height, ?final_height,
response_len = ?res.len(), response_len = ?res.len(),
?chain_tip_height, ?chain_tip_height,