Read messages from cyber record. 更多...

#include <cyber_record_reader.h>

apollo::localization::msf::CyberRecordReader 的协作图:

Public 成员函数
	CyberRecordReader ()

	~CyberRecordReader ()

void	Subscribe (const std::string &topic, const std::function< void(const std::string &)> call_back)

void	Read (const std::string &file_name)

void	Read (const std::vector< std::string > &file_names)

详细描述

Read messages from cyber record.

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

构造及析构函数说明

◆ CyberRecordReader()

apollo::localization::msf::CyberRecordReader::CyberRecordReader ( )

在文件 cyber_record_reader.cc 第 28 行定义.

28{}

◆ ~CyberRecordReader()

apollo::localization::msf::CyberRecordReader::~CyberRecordReader ( )

在文件 cyber_record_reader.cc 第 30 行定义.

30{}

成员函数说明

◆ Read() [1/2]

void apollo::localization::msf::CyberRecordReader::Read ( const std::string & file_name )

在文件 cyber_record_reader.cc 第 39 行定义.

                                                       {
  RecordReader reader(file_name);
  cyber::record::RecordMessage message;
  while (reader.ReadMessage(&message)) {
    auto itr = call_back_map_.find(message.channel_name);
    if (itr != call_back_map_.end()) {
      itr->second(message.content);
    }
  }
}

◆ Read() [2/2]

void apollo::localization::msf::CyberRecordReader::Read ( const std::vector< std::string > & file_names )

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

                                                                   {
  for (const std::string &file_name : file_names) {
    Read(file_name);
  }
}

◆ Subscribe()

void apollo::localization::msf::CyberRecordReader::Subscribe	(	const std::string &	topic,
		const std::function< void(const std::string &)>	call_back
	)

在文件 cyber_record_reader.cc 第 32 行定义.

                                                          {
  call_back_map_[topic] = call_back;
  topics_.push_back(topic);
}

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

modules/localization/msf/local_tool/data_extraction/cyber_record_reader.h
modules/localization/msf/local_tool/data_extraction/cyber_record_reader.cc

Public 成员函数