apollo::dreamview::RecordPlayerFactory类 参考

#include <record_player_factory.h>

apollo::dreamview::RecordPlayerFactory 的协作图:

Public 成员函数
	~RecordPlayerFactory ()
Player *	GetRecordPlayer (const std::string &record_name)
bool	RegisterRecordPlayer (const std::string &record_namem, const std::string &record_file_path)
void	UnregisterRecordPlayer (const std::string &record_name)
void	Reset ()
void	GetAllRecords (std::vector< std::string > *records)
void	SetCurrentRecord (const std::string &record_name)
void	IncreaseRecordPriority (const std::string &record_name)
bool	RemoveLRURecord (std::string *remove_record_id)
std::string	GetCurrentRecord ()
int	GetLoadedRecordNum ()
bool	EnableContinuePreload ()
bool	EnableContinueLoad ()

详细描述

在文件 record_player_factory.h 第 35 行定义.

构造及析构函数说明

~RecordPlayerFactory()

apollo::dreamview::RecordPlayerFactory::~RecordPlayerFactory

(

)

在文件 record_player_factory.cc 第 38 行定义.

{ Reset(); }

成员函数说明

EnableContinueLoad()

bool apollo::dreamview::RecordPlayerFactory::EnableContinueLoad

(

)

在文件 record_player_factory.cc 第 127 行定义.

                                             {
  return GetLoadedRecordNum() < LOADED_RECORD_NUM;
}

EnableContinuePreload()

bool apollo::dreamview::RecordPlayerFactory::EnableContinuePreload

(

)

在文件 record_player_factory.cc 第 123 行定义.

                                                {
  return GetLoadedRecordNum() < PRELOAD_RECORD_NUM;
}

GetAllRecords()

void apollo::dreamview::RecordPlayerFactory::GetAllRecords

(

std::vector< std::string > *

records

)

在文件 record_player_factory.cc 第 95 行定义.

                                                                     {
  for (auto iter = s_record_player_map_.begin();
       iter != s_record_player_map_.end(); iter++) {
    records->push_back(iter->first);
  }
}

GetCurrentRecord()

std::string apollo::dreamview::RecordPlayerFactory::GetCurrentRecord

(

)

在文件 record_player_factory.cc 第 105 行定义.

{ return current_record_; }

GetLoadedRecordNum()

int apollo::dreamview::RecordPlayerFactory::GetLoadedRecordNum

(

)

在文件 record_player_factory.cc 第 116 行定义.

                                            {
  {
    RLock rlock(mutex_);
    return loaded_record_.size();
  }
}

GetRecordPlayer()

Player * apollo::dreamview::RecordPlayerFactory::GetRecordPlayer

(

const std::string &

record_name

)

在文件 record_player_factory.cc 第 107 行定义.

                                                                         {
  auto iter = s_record_player_map_.find(record_name);
  if (iter == s_record_player_map_.end()) {
    AERROR << "Failed to get " << record_name << " related player pointer.";
    return nullptr;
  }
  return iter->second.get();
}

IncreaseRecordPriority()

void apollo::dreamview::RecordPlayerFactory::IncreaseRecordPriority

(

const std::string &

record_name

)

在文件 record_player_factory.cc 第 131 行定义.

                                  {
  WLock wlock(mutex_);
  auto iter =
      std::find(loaded_record_.begin(), loaded_record_.end(), record_name);
  if (iter == loaded_record_.end()) {
    AERROR << "Current record is not loaded,invalid operation!";
    return;
  }
  loaded_record_.erase(iter);
  loaded_record_.push_back(record_name);
  return;
}

RegisterRecordPlayer()

bool apollo::dreamview::RecordPlayerFactory::RegisterRecordPlayer	(	const std::string &	record_namem,
		const std::string &	record_file_path
	)

在文件 record_player_factory.cc 第 60 行定义.

                                                                     {
  apollo::cyber::record::PlayParam play_param;
  play_param.is_play_all_channels = true;
  // use play_param struct default value
  // loop playback is not allowed
  play_param.is_loop_playback = false;
  std::vector<std::string> opt_black_channels;
  // When using DV play recorder, need to block some real-time channels
  // to avoid conflicts with real-time DV information.
  opt_black_channels.push_back("/apollo/hmi/status");
  opt_black_channels.push_back("/apollo/monitor/system_status");
  opt_black_channels.push_back("/apollo/cyber/record_info");
  play_param.black_channels.insert(opt_black_channels.begin(),
                                 opt_black_channels.end());
  // play_param.play_rate = 1.0f;
  // play_param.begin_time_ns = 0;
  // play_param.end_time_ns = std::numeric_limits<uint64_t>::max();
  // play_param.start_time_s = 0;
  // play_param.delay_time_s = 0;
  // preload time and delay time is no used when nohup player process
  play_param.preload_time_s = 1;
  play_param.record_id = record_name;
  play_param.files_to_play.insert(record_file_path);
  const std::string node_name = "record_player_factory_" + record_name;
  s_record_player_map_[record_name] = std::unique_ptr<Player>(
      new Player(play_param, apollo::cyber::CreateNode(node_name), true));
  s_record_player_map_[record_name]->Init();
  {
    WLock wlock(mutex_);
    loaded_record_.push_back(record_name);
  }
  return true;
}

RemoveLRURecord()

bool apollo::dreamview::RecordPlayerFactory::RemoveLRURecord

(

std::string *

remove_record_id

)

在文件 record_player_factory.cc 第 145 行定义.

                                                                     {
  if (EnableContinueLoad()) {
    AERROR << "No need to remove record.";
    return false;
  }
  {
    RLock rlock(mutex_);
    auto iter = loaded_record_.begin();
    *remove_record_id = *loaded_record_.begin();
    while (iter != loaded_record_.end()) {
      // Can not remove selected record
      if (*iter != current_record_) {
        *remove_record_id = *iter;
        break;
      }
      iter++;
    }
  }
  UnregisterRecordPlayer(*remove_record_id);
  return true;
}

Reset()

void apollo::dreamview::RecordPlayerFactory::Reset

(

)

在文件 record_player_factory.cc 第 29 行定义.

                                {
  for (auto iter = s_record_player_map_.begin();
       iter != s_record_player_map_.end();) {
    iter->second = nullptr;
    s_record_player_map_.erase(iter++);
  }
  current_record_ = "";
}

SetCurrentRecord()

void apollo::dreamview::RecordPlayerFactory::SetCurrentRecord

(

const std::string &

record_name

)

在文件 record_player_factory.cc 第 101 行定义.

                                                                       {
  current_record_ = record_name;
}

UnregisterRecordPlayer()

void apollo::dreamview::RecordPlayerFactory::UnregisterRecordPlayer

(

const std::string &

record_name

)

在文件 record_player_factory.cc 第 40 行定义.

                                  {
  auto iter = s_record_player_map_.find(record_name);
  if (iter == s_record_player_map_.end()) {
    AERROR << "Failed to get " << record_name << " related player pointer.";
    return;
  }
  iter->second = nullptr;
  s_record_player_map_.erase(record_name);
  {
    WLock wlock(mutex_);
    auto vec_iter =
        std::find(loaded_record_.begin(), loaded_record_.end(), record_name);
    if (vec_iter != loaded_record_.end()) {
      loaded_record_.erase(vec_iter);
    }
  }
  return;
}

---

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

• modules/dreamview_plus/backend/record_player/record_player_factory.h
• modules/dreamview_plus/backend/record_player/record_player_factory.cc