#include <play_task.h>

apollo::cyber::record::PlayTask 的协作图:

Public 类型
using	MessagePtr = std::shared_ptr< message::RawMessage >

using	WriterPtr = std::shared_ptr< Writer< message::RawMessage > >

Public 成员函数
	PlayTask (const MessagePtr &msg, const WriterPtr &writer, uint64_t msg_real_time_ns, uint64_t msg_play_time_ns)

virtual	~PlayTask ()

void	Play ()

uint64_t	msg_real_time_ns () const

uint64_t	msg_play_time_ns () const

静态 Public 成员函数
static uint64_t	played_msg_num ()

详细描述

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

成员类型定义说明

◆ MessagePtr

using apollo::cyber::record::PlayTask::MessagePtr = std::shared_ptr<message::RawMessage>

在文件 play_task.h 第 33 行定义.

◆ WriterPtr

using apollo::cyber::record::PlayTask::WriterPtr = std::shared_ptr<Writer<message::RawMessage> >

在文件 play_task.h 第 34 行定义.

构造及析构函数说明

◆ PlayTask()

apollo::cyber::record::PlayTask::PlayTask	(	const MessagePtr &	msg,
		const WriterPtr &	writer,
		uint64_t	msg_real_time_ns,
		uint64_t	msg_play_time_ns
	)

在文件 play_task.cc 第 27 行定义.

    : msg_(msg),
      writer_(writer),
      msg_real_time_ns_(msg_real_time_ns),
      msg_play_time_ns_(msg_play_time_ns) {}

◆ ~PlayTask()

virtual apollo::cyber::record::PlayTask::~PlayTask ( )

inlinevirtual

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

38{}

成员函数说明

◆ msg_play_time_ns()

uint64_t apollo::cyber::record::PlayTask::msg_play_time_ns ( ) const

inline

在文件 play_task.h 第 43 行定义.

43{ return msg_play_time_ns_; }

◆ msg_real_time_ns()

uint64_t apollo::cyber::record::PlayTask::msg_real_time_ns ( ) const

inline

在文件 play_task.h 第 42 行定义.

42{ return msg_real_time_ns_; }

◆ Play()

void apollo::cyber::record::PlayTask::Play ( )

在文件 play_task.cc 第 34 行定义.

                    {
  if (writer_ == nullptr) {
    AERROR << "writer is nullptr, can't write message.";
    return;
  }
 
  if (!writer_->Write(msg_)) {
    AERROR << "write message failed, played num: " << played_msg_num_.load()
           << ", real time: " << msg_real_time_ns_
           << ", play time: " << msg_play_time_ns_;
    return;
  }
 
  played_msg_num_.fetch_add(1);
 
  ADEBUG << "write message succ, played num: " << played_msg_num_.load()
         << ", real time: " << msg_real_time_ns_
         << ", play time: " << msg_play_time_ns_;
}

◆ played_msg_num()

static uint64_t apollo::cyber::record::PlayTask::played_msg_num ( )

inlinestatic

在文件 play_task.h 第 44 行定义.

44{ return played_msg_num_.load(); }

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

cyber/tools/cyber_recorder/player/play_task.h
cyber/tools/cyber_recorder/player/play_task.cc

Public 类型

Public 成员函数

静态 Public 成员函数