apollo::cyber::PyReader类 参考

#include <py_cyber.h>

apollo::cyber::PyReader 的协作图:

Public 成员函数
	PyReader (const std::string &channel, const std::string &type, Node *node)
void	register_func (int(*func)(const char *))
std::string	read (bool wait=false)

详细描述

在文件 py_cyber.h 第 109 行定义.

构造及析构函数说明

PyReader()

apollo::cyber::PyReader::PyReader ( const std::string &  channel, const std::string &  type, Node *  node  )

inline

在文件 py_cyber.h 第 111 行定义.

      : channel_name_(channel), data_type_(type), node_(node), func_(nullptr) {
    if (data_type_.compare(RAWDATATYPE) == 0) {
      auto f =
          [this](const std::shared_ptr<const message::PyMessageWrap>& request) {
            this->cb(request);
          };
      reader_ = node_->CreateReader<message::PyMessageWrap>(channel, f);
    } else {
      auto f =
          [this](const std::shared_ptr<const message::RawMessage>& request) {
            this->cb_rawmsg(request);
          };
      reader_rawmsg_ = node_->CreateReader<message::RawMessage>(channel, f);
    }
  }

成员函数说明

read()

std::string apollo::cyber::PyReader::read ( bool  wait = false )

inline

在文件 py_cyber.h 第 130 行定义.

                                    {
    std::string msg("");
    std::unique_lock<std::mutex> ul(msg_lock_);
    if (!cache_.empty()) {
      msg = std::move(cache_.front());
      cache_.pop_front();
    }
 
    if (!wait) {
      return msg;
    }
 
    msg_cond_.wait(ul, [this] { return !this->cache_.empty(); });
    if (!cache_.empty()) {
      msg = std::move(cache_.front());
      cache_.pop_front();
    }
 
    return msg;
  }

register_func()

void apollo::cyber::PyReader::register_func ( int(*)(const char *)  func )

inline

在文件 py_cyber.h 第 128 行定义.

{ func_ = func; }

---

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

• cyber/python/internal/py_cyber.h