HealthCheck: added health check for logger to report if it's running (#22781)

This commit is contained in:
Jacob Dahl
2024-05-29 03:56:50 -06:00
committed by GitHub
parent b5627f487f
commit a4650fd70d
7 changed files with 130 additions and 6 deletions
+9 -6
View File
@@ -1037,6 +1037,12 @@ void Logger::publish_logger_status()
if (hrt_elapsed_time(&_logger_status_last) >= 1_s) {
for (int i = 0; i < (int)LogType::Count; ++i) {
logger_status_s status = {};
status.type = i;
status.backend = _writer.backend();
status.num_messages = _num_subscriptions;
status.timestamp = hrt_absolute_time();
const LogType log_type = static_cast<LogType>(i);
if (_writer.is_started(log_type)) {
@@ -1046,19 +1052,16 @@ void Logger::publish_logger_status()
const float kb_written = _writer.get_total_written_file(log_type) / 1024.0f;
const float seconds = hrt_elapsed_time(&_statistics[i].start_time_file) * 1e-6f;
logger_status_s status;
status.type = i;
status.backend = _writer.backend();
status.is_logging = true;
status.total_written_kb = kb_written;
status.write_rate_kb_s = kb_written / seconds;
status.dropouts = _statistics[i].write_dropouts;
status.message_gaps = _message_gaps;
status.buffer_used_bytes = buffer_fill_count_file;
status.buffer_size_bytes = _writer.get_buffer_size_file(log_type);
status.num_messages = _num_subscriptions;
status.timestamp = hrt_absolute_time();
_logger_status_pub[i].publish(status);
}
_logger_status_pub[i].publish(status);
}
_logger_status_last = hrt_absolute_time();