include the error in the warning
This commit is contained in:
parent
cf3d984548
commit
a8d2f3fe62
@ -160,24 +160,27 @@ impl StatBuffer {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
x = flush_receiver.recv_async() => {
|
x = flush_receiver.recv_async() => {
|
||||||
if let Ok(x) = x {
|
match x {
|
||||||
trace!("flush");
|
Ok(x) => {
|
||||||
|
trace!("flush");
|
||||||
|
|
||||||
let tsdb_count = self.save_tsdb_stats().await;
|
let tsdb_count = self.save_tsdb_stats().await;
|
||||||
if tsdb_count > 0 {
|
if tsdb_count > 0 {
|
||||||
trace!("Flushed {} stats to the tsdb", tsdb_count);
|
trace!("Flushed {} stats to the tsdb", tsdb_count);
|
||||||
}
|
}
|
||||||
|
|
||||||
let relational_count = self.save_relational_stats().await;
|
let relational_count = self.save_relational_stats().await;
|
||||||
if relational_count > 0 {
|
if relational_count > 0 {
|
||||||
trace!("Flushed {} stats to the relational db", relational_count);
|
trace!("Flushed {} stats to the relational db", relational_count);
|
||||||
}
|
}
|
||||||
|
|
||||||
if let Err(err) = x.send((tsdb_count, relational_count)) {
|
if let Err(err) = x.send((tsdb_count, relational_count)) {
|
||||||
warn!(%tsdb_count, %relational_count, ?err, "unable to notify about flushed stats");
|
warn!(%tsdb_count, %relational_count, ?err, "unable to notify about flushed stats");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
warn!(?err, "unable to flush stat buffer!");
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
warn!("unable to flush stat buffer!");
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
x = shutdown_receiver.recv() => {
|
x = shutdown_receiver.recv() => {
|
||||||
|
Loading…
Reference in New Issue
Block a user