apollo::monitor::ProcessMonitor类 参考

#include <process_monitor.h>

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

apollo::monitor::ProcessMonitor 的协作图:

Public 成员函数
	ProcessMonitor ()
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)

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

详细描述

在文件 process_monitor.h 第 29 行定义.

构造及析构函数说明

ProcessMonitor()

apollo::monitor::ProcessMonitor::ProcessMonitor

(

)

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

    : RecurrentRunner(FLAGS_process_monitor_name,
                      FLAGS_process_monitor_interval) {}

成员函数说明

RunOnce()

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

overridevirtual

实现了 apollo::monitor::RecurrentRunner.

在文件 process_monitor.cc 第 40 行定义.

                                                      {
  // Get running processes.
  std::vector<std::string> running_processes;
  for (const auto& cmd_file : cyber::common::Glob("/proc/*/cmdline")) {
    // Get process command string.
    std::string cmd_string;
    if (cyber::common::GetContent(cmd_file, &cmd_string) &&
        !cmd_string.empty()) {
      // In /proc/<PID>/cmdline, the parts are separated with \0, which will be
      // converted back to whitespaces here.
      std::replace(cmd_string.begin(), cmd_string.end(), '\0', ' ');
      running_processes.push_back(cmd_string);
    }
  }
 
  auto manager = MonitorManager::Instance();
  const auto& mode = manager->GetHMIMode();
 
  // Check HMI modules.
  auto* hmi_modules = manager->GetStatus()->mutable_hmi_modules();
  for (const auto& iter : mode.modules()) {
    const std::string& module_name = iter.first;
    const auto& config = iter.second.process_monitor_config();
    UpdateStatus(running_processes, config, &hmi_modules->at(module_name));
  }
 
  // Check monitored components.
  auto* components = manager->GetStatus()->mutable_components();
  for (const auto& iter : mode.monitored_components()) {
    const std::string& name = iter.first;
    if (iter.second.has_process() &&
        apollo::common::util::ContainsKey(*components, name)) {
      const auto& config = iter.second.process();
      auto* status = components->at(name).mutable_process_status();
      UpdateStatus(running_processes, config, status);
    }
  }
 
  // Check other components.
  auto* other_components = manager->GetStatus()->mutable_other_components();
  for (const auto& iter : mode.other_components()) {
    const std::string& name = iter.first;
    const auto& config = iter.second;
    UpdateStatus(running_processes, config, &other_components->at(name));
  }
 
  // Check global components.
  auto* global_components = manager->GetStatus()->mutable_global_components();
  for (const auto& iter : mode.global_components()) {
    const std::string& name = iter.first;
    if (iter.second.has_process() &&
        apollo::common::util::ContainsKey(*global_components, name)) {
      const auto& config = iter.second.process();
      auto* status = global_components->at(name).mutable_process_status();
      UpdateStatus(running_processes, config, status);
    }
  }
}

---

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

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