We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8be3dec commit 42a8f13Copy full SHA for 42a8f13
src/persistence.rs
@@ -99,7 +99,11 @@ impl<L: Deref> GossipPersister<L> where L::Target: Logger {
99
while let Some(gossip_message) = &self.gossip_persistence_receiver.recv().await {
100
i += 1; // count the persisted gossip messages
101
102
- if latest_persistence_log.elapsed().as_secs() >= 60 {
+ let _should_log_message = latest_persistence_log.elapsed().as_secs() >= 60;
103
+ #[cfg(test)]
104
+ let _should_log_message = true; // we log every persistence message in test
105
+
106
+ if _should_log_message {
107
log_info!(self.logger, "Persisting gossip message #{}", i);
108
latest_persistence_log = Instant::now();
109
}
0 commit comments