apollo::cyber::event::PerfEventCache类 参考

#include <perf_event_cache.h>

apollo::cyber::event::PerfEventCache 的协作图:

Public 类型
using	EventBasePtr = std::shared_ptr< EventBase >

Public 成员函数
	~PerfEventCache ()
void	AddSchedEvent (const SchedPerf event_id, const uint64_t cr_id, const int proc_id, const int cr_state=-1)
void	AddTransportEvent (const TransPerf event_id, const uint64_t channel_id, const uint64_t msg_seq, const uint64_t stamp=0, const std::string &adder="-")
std::string	PerfFile ()
void	Shutdown ()

详细描述

在文件 perf_event_cache.h 第 36 行定义.

成员类型定义说明

EventBasePtr

using apollo::cyber::event::PerfEventCache::EventBasePtr = std::shared_ptr<EventBase>

在文件 perf_event_cache.h 第 38 行定义.

构造及析构函数说明

~PerfEventCache()

apollo::cyber::event::PerfEventCache::~PerfEventCache

(

)

在文件 perf_event_cache.cc 第 50 行定义.

{ Shutdown(); }

成员函数说明

AddSchedEvent()

void apollo::cyber::event::PerfEventCache::AddSchedEvent	(	const SchedPerf	event_id,
		const uint64_t	cr_id,
		const int	proc_id,
		const int	cr_state = -1
	)

在文件 perf_event_cache.cc 第 68 行定义.

                                                       {
  if (!enable_) {
    return;
  }
 
  if (perf_conf_.type() != PerfType::SCHED &&
      perf_conf_.type() != PerfType::ALL) {
    return;
  }
 
  EventBasePtr e = std::make_shared<SchedEvent>();
  e->set_eid(static_cast<int>(event_id));
  e->set_stamp(Time::Now().ToNanosecond());
  e->set_cr_state(cr_state);
  e->set_cr_id(cr_id);
  e->set_proc_id(proc_id);
 
  event_queue_.Enqueue(e);
}

AddTransportEvent()

void apollo::cyber::event::PerfEventCache::AddTransportEvent	(	const TransPerf	event_id,
		const uint64_t	channel_id,
		const uint64_t	msg_seq,
		const uint64_t	stamp = 0,
		const std::string &	adder = "-"
	)

在文件 perf_event_cache.cc 第 90 行定义.

                                                               {
  if (!enable_) {
    return;
  }
 
  if (perf_conf_.type() != PerfType::TRANSPORT &&
      perf_conf_.type() != PerfType::ALL) {
    return;
  }
 
  EventBasePtr e = std::make_shared<TransportEvent>();
  e->set_eid(static_cast<int>(event_id));
  e->set_channel_id(channel_id);
  e->set_msg_seq(msg_seq);
  e->set_adder(adder);
  auto t = stamp;
  if (stamp == 0) {
    t = Time::Now().ToNanosecond();
  }
  e->set_stamp(t);
 
  event_queue_.Enqueue(e);
}

PerfFile()

std::string apollo::cyber::event::PerfEventCache::PerfFile ( )

inline

在文件 perf_event_cache.h 第 47 行定义.

{ return perf_file_; }

Shutdown()

void apollo::cyber::event::PerfEventCache::Shutdown

(

)

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

                              {
  if (!enable_) {
    return;
  }
 
  shutdown_ = true;
  event_queue_.BreakAllWait();
  if (io_thread_.joinable()) {
    io_thread_.join();
  }
 
  of_ << cyber::Time::Now().ToNanosecond() << std::endl;
  of_.flush();
  of_.close();
}

---

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

• cyber/event/perf_event_cache.h
• cyber/event/perf_event_cache.cc