Apollo 10.0
自动驾驶开放平台
apollo::cyber::record::PlayTask类 参考

#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.h31 行定义.

成员类型定义说明

◆ MessagePtr

在文件 play_task.h33 行定义.

◆ WriterPtr

在文件 play_task.h34 行定义.

构造及析构函数说明

◆ 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.cc27 行定义.

29 : msg_(msg),
30 writer_(writer),
31 msg_real_time_ns_(msg_real_time_ns),
32 msg_play_time_ns_(msg_play_time_ns) {}
uint64_t msg_real_time_ns() const
Definition play_task.h:42
uint64_t msg_play_time_ns() const
Definition play_task.h:43

◆ ~PlayTask()

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

在文件 play_task.h38 行定义.

38{}

成员函数说明

◆ msg_play_time_ns()

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

在文件 play_task.h43 行定义.

43{ return msg_play_time_ns_; }

◆ msg_real_time_ns()

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

在文件 play_task.h42 行定义.

42{ return msg_real_time_ns_; }

◆ Play()

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

在文件 play_task.cc34 行定义.

34 {
35 if (writer_ == nullptr) {
36 AERROR << "writer is nullptr, can't write message.";
37 return;
38 }
39
40 if (!writer_->Write(msg_)) {
41 AERROR << "write message failed, played num: " << played_msg_num_.load()
42 << ", real time: " << msg_real_time_ns_
43 << ", play time: " << msg_play_time_ns_;
44 return;
45 }
46
47 played_msg_num_.fetch_add(1);
48
49 ADEBUG << "write message succ, played num: " << played_msg_num_.load()
50 << ", real time: " << msg_real_time_ns_
51 << ", play time: " << msg_play_time_ns_;
52}
#define ADEBUG
Definition log.h:41
#define AERROR
Definition log.h:44

◆ played_msg_num()

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

在文件 play_task.h44 行定义.

44{ return played_msg_num_.load(); }

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