apollo::monitor::SummaryMonitor类 参考

#include <summary_monitor.h>

类 apollo::monitor::SummaryMonitor 继承关系图:

apollo::monitor::SummaryMonitor 的协作图:

Public 成员函数
	SummaryMonitor ()
void	RunOnce (const double current_time) override
Public 成员函数 继承自 apollo::monitor::RecurrentRunner
	RecurrentRunner (const std::string &name, const double interval)
virtual	~RecurrentRunner ()=default
void	Tick (const double current_time)

静态 Public 成员函数
static void	EscalateStatus (const ComponentStatus::Status new_status, const std::string &message, ComponentStatus *current_status)

额外继承的成员函数
Protected 属性 继承自 apollo::monitor::RecurrentRunner
std::string	name_
unsigned int	round_count_ = 0

详细描述

在文件 summary_monitor.h 第 28 行定义.

构造及析构函数说明

SummaryMonitor()

apollo::monitor::SummaryMonitor::SummaryMonitor

(

)

在文件 summary_monitor.cc 第 48 行定义.

    : RecurrentRunner(FLAGS_summary_monitor_name, 0) {}

成员函数说明

EscalateStatus()

void apollo::monitor::SummaryMonitor::EscalateStatus ( const ComponentStatus::Status  new_status, const std::string &  message, ComponentStatus *  current_status  )

static

在文件 summary_monitor.cc 第 33 行定义.

                                                                     {
  // Overwrite priority: FATAL > ERROR > WARN > OK > UNKNOWN.
  if (new_status > current_status->status()) {
    current_status->set_status(new_status);
    if (!message.empty()) {
      current_status->set_message(message);
    } else {
      current_status->clear_message();
    }
  }
}

RunOnce()

void apollo::monitor::SummaryMonitor::RunOnce ( const double  current_time )

overridevirtual

实现了 apollo::monitor::RecurrentRunner.

在文件 summary_monitor.cc 第 51 行定义.

                                                      {
  auto manager = MonitorManager::Instance();
  auto* status = manager->GetStatus();
  // Escalate the summary status to the most severe one.
  for (auto& component : *status->mutable_components()) {
    auto* summary = component.second.mutable_summary();
    const auto& process_status = component.second.process_status();
    EscalateStatus(process_status.status(), process_status.message(), summary);
    const auto& module_status = component.second.module_status();
    EscalateStatus(module_status.status(), module_status.message(), summary);
    const auto& channel_status = component.second.channel_status();
    EscalateStatus(channel_status.status(), channel_status.message(), summary);
    const auto& resource_status = component.second.resource_status();
    EscalateStatus(resource_status.status(), resource_status.message(),
                   summary);
    const auto& other_status = component.second.other_status();
    EscalateStatus(other_status.status(), other_status.message(), summary);
  }
 
  // For global components
  for (auto& component : *status->mutable_global_components()) {
    auto* summary = component.second.mutable_summary();
    const auto& process_status = component.second.process_status();
    EscalateStatus(process_status.status(), process_status.message(), summary);
    const auto& resource_status = component.second.resource_status();
    EscalateStatus(resource_status.status(), resource_status.message(),
                   summary);
  }
 
  // Get fingerprint of current status.
  // Don't use DebugString() which has known bug on Map field. The string
  // doesn't change though the value has changed.
  static std::hash<std::string> hash_fn;
  std::string proto_bytes;
  status->SerializeToString(&proto_bytes);
  const size_t new_fp = hash_fn(proto_bytes);
 
  if (system_status_fp_ != new_fp ||
      current_time - last_broadcast_ > FLAGS_system_status_publish_interval) {
    static auto writer =
        manager->CreateWriter<SystemStatus>(FLAGS_system_status_topic);
 
    apollo::common::util::FillHeader("SystemMonitor", status);
    writer->Write(*status);
    status->clear_header();
    system_status_fp_ = new_fp;
    last_broadcast_ = current_time;
  }
}

---

该类的文档由以下文件生成:

• modules/monitor/software/summary_monitor.h
• modules/monitor/software/summary_monitor.cc