apollo::process_statistic::ProcessStatisticComponent类 参考

#include <process_statistic_component.h>

类 apollo::process_statistic::ProcessStatisticComponent 继承关系图:

apollo::process_statistic::ProcessStatisticComponent 的协作图:

Public 成员函数
bool	Init () override
bool	Proc () override
	The Proc logic of the component, which called by the CyberRT frame.
Public 成员函数 继承自 apollo::cyber::TimerComponent
	TimerComponent ()
	~TimerComponent () override
bool	Initialize (const TimerComponentConfig &config) override
	init the component by protobuf object.
void	Clear () override
bool	Process ()
uint32_t	GetInterval () const
Public 成员函数 继承自 apollo::cyber::ComponentBase
virtual	~ComponentBase ()
virtual bool	Initialize (const ComponentConfig &config)
virtual void	Shutdown ()
template<typename T >
bool	GetProtoConfig (T *config) const

额外继承的成员函数
Public 类型 继承自 apollo::cyber::ComponentBase
template<typename M >
using	Reader = cyber::Reader< M >
Protected 成员函数 继承自 apollo::cyber::ComponentBase
const std::string &	ConfigFilePath () const
void	LoadConfigFiles (const ComponentConfig &config)
void	LoadConfigFiles (const TimerComponentConfig &config)
Protected 属性 继承自 apollo::cyber::ComponentBase
std::atomic< bool >	is_shutdown_ = {false}
std::shared_ptr< Node >	node_ = nullptr
std::string	config_file_path_ = ""
std::vector< std::shared_ptr< ReaderBase > >	readers_

详细描述

在文件 process_statistic_component.h 第 48 行定义.

成员函数说明

Init()

bool apollo::process_statistic::ProcessStatisticComponent::Init ( )

overridevirtual

实现了 apollo::cyber::ComponentBase.

在文件 process_statistic_component.cc 第 26 行定义.

                                     {
    // hook: Apollo License Verification: v_apollo_park
    ProcessStatisticConf conf;
    if (!ComponentBase::GetProtoConfig(&conf)) {
        AERROR << "Unable to load process statistic conf file: " << ComponentBase::ConfigFilePath();
        return false;
    }
    AINFO << "read conf success.";
    LoadConf(conf);
    // create metric writer
    metric_writer_ = node_->CreateWriter<ProcessMetrics>(FLAGS_process_statistic_topic);
    return true;
}

Proc()

bool apollo::process_statistic::ProcessStatisticComponent::Proc ( )

overridevirtual

The Proc logic of the component, which called by the CyberRT frame.

返回

returns true if successful, otherwise returns false

实现了 apollo::cyber::TimerComponent.

在文件 process_statistic_component.cc 第 52 行定义.

                                     {
    auto metrics = std::make_shared<ProcessMetrics>();
    apollo::common::util::FillHeader(node_->Name(), metrics.get());
 
    for (const auto& cmd_file : cyber::common::Glob("/proc/[0-9]*/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', ' ');
 
            if (ParseFromCache(cmd_string, metrics)) {
                continue;
            }
            ParseCmd(cmd_string, metrics, cache_.at(cmd_string));
        }
    }
    // write metrics
    metric_writer_->Write(metrics);
 
    // clean cache
    if (++cycles % cache_clean_cycles == 0) {
        cycles = 0;
        CleanCache();
    }
    return true;
}

---

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

• modules/statistics/process/process_statistic_component.h
• modules/statistics/process/process_statistic_component.cc