apollo::cyber::ReceiverManager< MessageT > 模板类 参考

One Channel is related to one Receiver. 更多...

#include <reader_base.h>

apollo::cyber::ReceiverManager< MessageT > 的协作图:

Public 成员函数
	~ReceiverManager ()
auto	GetReceiver (const proto::RoleAttributes &role_attr) -> typename std::shared_ptr< transport::Receiver< MessageT > >
	Get the Receiver object

详细描述

template<typename MessageT>
class apollo::cyber::ReceiverManager< MessageT >

One Channel is related to one Receiver.

ReceiverManager is in charge of attaching one Receiver to its responding Channel. We pass a DataDispatcher's callback func to this Receiver so when a message is received, it will be push to the ChannelBuffer, and DataVisitor will Fetch data and pass to Reader's callback func

模板参数

MessageT

Message Type.

在文件 reader_base.h 第 168 行定义.

构造及析构函数说明

~ReceiverManager()

template<typename MessageT >

apollo::cyber::ReceiverManager< MessageT >::~ReceiverManager ( )

inline

在文件 reader_base.h 第 170 行定义.

{ receiver_map_.clear(); }

成员函数说明

GetReceiver()

template<typename MessageT >

auto apollo::cyber::ReceiverManager< MessageT >::GetReceiver

(

const proto::RoleAttributes &

role_attr

)

-> typename std::shared_ptr<transport::Receiver<MessageT>>

Get the Receiver object

参数

role_attr

the attribute that the Receiver has

返回

std::shared_ptr<transport::Receiver<MessageT>> result Receiver

在文件 reader_base.h 第 199 行定义.

                                                        {
  std::lock_guard<std::mutex> lock(receiver_map_mutex_);
  // because multi reader for one channel will write datacache multi times,
  // so reader for datacache we use map to keep one instance for per channel
  const std::string& channel_name = role_attr.channel_name();
  if (receiver_map_.count(channel_name) == 0) {
    receiver_map_[channel_name] =
        transport::Transport::Instance()->CreateReceiver<MessageT>(
            role_attr, [](const std::shared_ptr<MessageT>& msg,
                          const transport::MessageInfo& msg_info,
                          const proto::RoleAttributes& reader_attr) {
              (void)msg_info;
              (void)reader_attr;
              PerfEventCache::Instance()->AddTransportEvent(
                  TransPerf::DISPATCH, reader_attr.channel_id(),
                  msg_info.seq_num());
              data::DataDispatcher<MessageT>::Instance()->Dispatch(
                  reader_attr.channel_id(), msg);
              PerfEventCache::Instance()->AddTransportEvent(
                  TransPerf::NOTIFY, reader_attr.channel_id(),
                  msg_info.seq_num());
            });
  }
  return receiver_map_[channel_name];
}

---

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

• cyber/node/reader_base.h