apollo::monitor::ModuleMonitor类 参考

#include <module_monitor.h>

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

apollo::monitor::ModuleMonitor 的协作图:

Public 类型
using	NodeManagerPtr = std::shared_ptr< cyber::service_discovery::NodeManager >

Public 成员函数
	ModuleMonitor ()
void	RunOnce (const double current_time) override
void	UpdateStatus (const apollo::dreamview::ModuleMonitorConfig &config, const std::string &module_name, ComponentStatus *status)
Public 成员函数 继承自 apollo::monitor::RecurrentRunner
	RecurrentRunner (const std::string &name, const double interval)
virtual	~RecurrentRunner ()=default
void	Tick (const double current_time)

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

详细描述

在文件 module_monitor.h 第 30 行定义.

成员类型定义说明

NodeManagerPtr

using apollo::monitor::ModuleMonitor::NodeManagerPtr = std::shared_ptr<cyber::service_discovery::NodeManager>

在文件 module_monitor.h 第 32 行定义.

构造及析构函数说明

ModuleMonitor()

apollo::monitor::ModuleMonitor::ModuleMonitor

(

)

在文件 module_monitor.cc 第 36 行定义.

    : RecurrentRunner(absl::GetFlag(FLAGS_module_monitor_name),
                      absl::GetFlag(FLAGS_module_monitor_interval)) {
  node_manager_ =
      cyber::service_discovery::TopologyManager::Instance()->node_manager();
}

成员函数说明

RunOnce()

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

overridevirtual

实现了 apollo::monitor::RecurrentRunner.

在文件 module_monitor.cc 第 43 行定义.

                                                     {
  auto manager = MonitorManager::Instance();
  const auto& mode = manager->GetHMIMode();
 
  // Check monitored components.
  auto* components = manager->GetStatus()->mutable_components();
  for (const auto& iter : mode.monitored_components()) {
    const std::string& name = iter.first;
    const auto& monitored_component = iter.second;
    if (monitored_component.has_module() &&
        apollo::common::util::ContainsKey(*components, name)) {
      const auto& config = monitored_component.module();
      auto* status = components->at(name).mutable_module_status();
      UpdateStatus(config, name, status);
    }
  }
}

UpdateStatus()

void apollo::monitor::ModuleMonitor::UpdateStatus	(	const apollo::dreamview::ModuleMonitorConfig &	config,
		const std::string &	module_name,
		ComponentStatus *	status
	)

在文件 module_monitor.cc 第 61 行定义.

                                                           {
  status->clear_status();
 
  bool all_nodes_matched = true;
  for (const std::string& name : config.node_name()) {
    if (!node_manager_->HasNode(name)) {
      all_nodes_matched = false;
      break;
    }
  }
  if (all_nodes_matched) {
    // Working nodes are all matched. The module is running.
    SummaryMonitor::EscalateStatus(ComponentStatus::OK, module_name, status);
    return;
  }
 
  SummaryMonitor::EscalateStatus(ComponentStatus::FATAL, "", status);
}

---

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

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