apollo::cyber::record::PlayTaskConsumer类 参考

#include <play_task_consumer.h>

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

Public 类型
using	ThreadPtr = std::unique_ptr< std::thread >
using	TaskBufferPtr = std::shared_ptr< PlayTaskBuffer >

Public 成员函数
	PlayTaskConsumer (const TaskBufferPtr &task_buffer, double play_rate=1.0)
virtual	~PlayTaskConsumer ()
void	Start (uint64_t begin_time_ns)
void	Stop ()
void	Pause ()
void	PlayOnce ()
void	Continue ()
uint64_t	base_msg_play_time_ns () const
uint64_t	base_msg_real_time_ns () const
uint64_t	last_played_msg_real_time_ns () const

详细描述

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

成员类型定义说明

TaskBufferPtr

using apollo::cyber::record::PlayTaskConsumer::TaskBufferPtr = std::shared_ptr<PlayTaskBuffer>

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

ThreadPtr

using apollo::cyber::record::PlayTaskConsumer::ThreadPtr = std::unique_ptr<std::thread>

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

构造及析构函数说明

PlayTaskConsumer()

apollo::cyber::record::PlayTaskConsumer::PlayTaskConsumer ( const TaskBufferPtr &  task_buffer, double  play_rate = 1.0  )

explicit

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

    : play_rate_(play_rate),
      consume_th_(nullptr),
      task_buffer_(task_buffer),
      is_stopped_(true),
      is_paused_(false),
      is_playonce_(false),
      base_msg_play_time_ns_(0),
      base_msg_real_time_ns_(0),
      last_played_msg_real_time_ns_(0) {
  if (play_rate_ <= 0) {
    AERROR << "invalid play rate: " << play_rate_
           << " , we will use default value(1.0).";
    play_rate_ = 1.0;
  }
}

~PlayTaskConsumer()

apollo::cyber::record::PlayTaskConsumer::~PlayTaskConsumer ( )

virtual

在文件 play_task_consumer.cc 第 48 行定义.

{ Stop(); }

成员函数说明

base_msg_play_time_ns()

uint64_t apollo::cyber::record::PlayTaskConsumer::base_msg_play_time_ns ( ) const

inline

在文件 play_task_consumer.h 第 46 行定义.

{ return base_msg_play_time_ns_; }

base_msg_real_time_ns()

uint64_t apollo::cyber::record::PlayTaskConsumer::base_msg_real_time_ns ( ) const

inline

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

{ return base_msg_real_time_ns_; }

Continue()

void apollo::cyber::record::PlayTaskConsumer::Continue ( )

inline

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

{ is_paused_.exchange(false); }

last_played_msg_real_time_ns()

uint64_t apollo::cyber::record::PlayTaskConsumer::last_played_msg_real_time_ns ( ) const

inline

在文件 play_task_consumer.h 第 48 行定义.

                                                {
    return last_played_msg_real_time_ns_;
  }

Pause()

void apollo::cyber::record::PlayTaskConsumer::Pause ( )

inline

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

{ is_paused_.exchange(true); }

PlayOnce()

void apollo::cyber::record::PlayTaskConsumer::PlayOnce ( )

inline

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

{ is_playonce_.exchange(true); }

Start()

void apollo::cyber::record::PlayTaskConsumer::Start

(

uint64_t

begin_time_ns

)

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

                                                   {
  if (!is_stopped_.exchange(false)) {
    return;
  }
  begin_time_ns_ = begin_time_ns;
  consume_th_.reset(new std::thread(&PlayTaskConsumer::ThreadFunc, this));
}

Stop()

void apollo::cyber::record::PlayTaskConsumer::Stop

(

)

在文件 play_task_consumer.cc 第 58 行定义.

                            {
  if (is_stopped_.exchange(true)) {
    return;
  }
  if (consume_th_ != nullptr && consume_th_->joinable()) {
    consume_th_->join();
    consume_th_ = nullptr;
  }
  // reset value for next use consumer
  base_msg_play_time_ns_ = 0;
  base_msg_real_time_ns_ = 0;
  last_played_msg_real_time_ns_ = 0;
}

---

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

• cyber/tools/cyber_recorder/player/play_task_consumer.h
• cyber/tools/cyber_recorder/player/play_task_consumer.cc