apollo::monitor::LatencyMonitor类 参考

#include <latency_monitor.h>

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

apollo::monitor::LatencyMonitor 的协作图:

Public 成员函数
	LatencyMonitor ()
void	RunOnce (const double current_time) override
bool	GetFrequency (const std::string &channel_name, double *freq)
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

详细描述

在文件 latency_monitor.h 第 31 行定义.

构造及析构函数说明

LatencyMonitor()

apollo::monitor::LatencyMonitor::LatencyMonitor

(

)

在文件 latency_monitor.cc 第 89 行定义.

    : RecurrentRunner(FLAGS_latency_monitor_name,
                      FLAGS_latency_monitor_interval) {}

成员函数说明

GetFrequency()

bool apollo::monitor::LatencyMonitor::GetFrequency	(	const std::string &	channel_name,
		double *	freq
	)

在文件 latency_monitor.cc 第 216 行定义.

                                                {
  if (freq_map_.find(channel_name) == freq_map_.end()) {
    return false;
  }
  *freq = freq_map_[channel_name];
  return true;
}

RunOnce()

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

overridevirtual

实现了 apollo::monitor::RecurrentRunner.

在文件 latency_monitor.cc 第 93 行定义.

                                                      {
  static auto reader =
      MonitorManager::Instance()->CreateReader<LatencyRecordMap>(
          FLAGS_latency_recording_topic);
  reader->SetHistoryDepth(FLAGS_latency_reader_capacity);
  reader->Observe();
 
  static std::string last_processed_key;
  std::string first_key_of_current_round;
  for (auto it = reader->Begin(); it != reader->End(); ++it) {
    const std::string current_key =
        absl::StrCat((*it)->module_name(), (*it)->header().sequence_num());
    if (it == reader->Begin()) {
      first_key_of_current_round = current_key;
    }
    if (current_key == last_processed_key) {
      break;
    }
    UpdateStat(*it);
  }
  last_processed_key = first_key_of_current_round;
 
  if (current_time - flush_time_ > FLAGS_latency_report_interval) {
    flush_time_ = current_time;
    if (!track_map_.empty()) {
      PublishLatencyReport();
    }
  }
}

---

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

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