From b062a682b072b52f6cd81edf7856d38336dc916d Mon Sep 17 00:00:00 2001 From: teor Date: Tue, 8 Sep 2020 19:25:16 +1000 Subject: [PATCH] Refactor "waiting for pending blocks" log --- zebrad/src/commands/start/sync.rs | 31 ++++++++++++++----------------- 1 file changed, 14 insertions(+), 17 deletions(-) diff --git a/zebrad/src/commands/start/sync.rs b/zebrad/src/commands/start/sync.rs index ecc0db45..644484e8 100644 --- a/zebrad/src/commands/start/sync.rs +++ b/zebrad/src/commands/start/sync.rs @@ -229,24 +229,21 @@ where // // Starting to wait is interesting, but logging each wait can be // very verbose. - let mut first_wait = true; + if self.pending_blocks.len() > LOOKAHEAD_LIMIT { + tracing::info!( + tips.len = self.prospective_tips.len(), + pending.len = self.pending_blocks.len(), + pending.limit = LOOKAHEAD_LIMIT, + "waiting for pending blocks", + ); + } while self.pending_blocks.len() > LOOKAHEAD_LIMIT { - if first_wait { - tracing::info!( - tips.len = self.prospective_tips.len(), - pending.len = self.pending_blocks.len(), - pending.limit = LOOKAHEAD_LIMIT, - "waiting for pending blocks", - ); - first_wait = false; - } else { - tracing::trace!( - tips.len = self.prospective_tips.len(), - pending.len = self.pending_blocks.len(), - pending.limit = LOOKAHEAD_LIMIT, - "continuing to wait for pending blocks", - ); - } + tracing::trace!( + tips.len = self.prospective_tips.len(), + pending.len = self.pending_blocks.len(), + pending.limit = LOOKAHEAD_LIMIT, + "continuing to wait for pending blocks", + ); match self .pending_blocks .next()