apollo::cyber::transport::ListenerHandler< MessageT > 模板类 参考

#include <listener_handler.h>

类 apollo::cyber::transport::ListenerHandler< MessageT > 继承关系图:

apollo::cyber::transport::ListenerHandler< MessageT > 的协作图:

Public 类型
using	Message = std::shared_ptr< MessageT >
using	MessageSignal = base::Signal< const Message &, const MessageInfo & >
using	Listener = std::function< void(const Message &, const MessageInfo &)>
using	MessageConnection = base::Connection< const Message &, const MessageInfo & >
using	ConnectionMap = std::unordered_map< uint64_t, MessageConnection >

Public 成员函数
	ListenerHandler ()
virtual	~ListenerHandler ()
void	Connect (uint64_t self_id, const Listener &listener)
void	Connect (uint64_t self_id, uint64_t oppo_id, const Listener &listener)
void	Disconnect (uint64_t self_id) override
void	Disconnect (uint64_t self_id, uint64_t oppo_id) override
void	Run (const Message &msg, const MessageInfo &msg_info)
void	RunFromString (const std::string &str, const MessageInfo &msg_info) override
	ListenerHandler ()
Public 成员函数 继承自 apollo::cyber::transport::ListenerHandlerBase
	ListenerHandlerBase ()
virtual	~ListenerHandlerBase ()
bool	IsRawMessage () const

额外继承的成员函数
Protected 属性 继承自 apollo::cyber::transport::ListenerHandlerBase
bool	is_raw_message_ = false

详细描述

template<typename MessageT>
class apollo::cyber::transport::ListenerHandler< MessageT >

在文件 listener_handler.h 第 60 行定义.

成员类型定义说明

ConnectionMap

template<typename MessageT >

using apollo::cyber::transport::ListenerHandler< MessageT >::ConnectionMap = std::unordered_map<uint64_t, MessageConnection>

在文件 listener_handler.h 第 68 行定义.

Listener

template<typename MessageT >

using apollo::cyber::transport::ListenerHandler< MessageT >::Listener = std::function<void(const Message&, const MessageInfo&)>

在文件 listener_handler.h 第 65 行定义.

Message

template<typename MessageT >

using apollo::cyber::transport::ListenerHandler< MessageT >::Message = std::shared_ptr<MessageT>

在文件 listener_handler.h 第 62 行定义.

MessageConnection

template<typename MessageT >

using apollo::cyber::transport::ListenerHandler< MessageT >::MessageConnection = base::Connection<const Message&, const MessageInfo&>

在文件 listener_handler.h 第 66 行定义.

MessageSignal

template<typename MessageT >

using apollo::cyber::transport::ListenerHandler< MessageT >::MessageSignal = base::Signal<const Message&, const MessageInfo&>

在文件 listener_handler.h 第 63 行定义.

构造及析构函数说明

ListenerHandler() [1/2]

template<typename MessageT >

apollo::cyber::transport::ListenerHandler< MessageT >::ListenerHandler ( )

inline

在文件 listener_handler.h 第 70 行定义.

{}

~ListenerHandler()

template<typename MessageT >

virtual apollo::cyber::transport::ListenerHandler< MessageT >::~ListenerHandler ( )

inlinevirtual

在文件 listener_handler.h 第 71 行定义.

{}

ListenerHandler() [2/2]

apollo::cyber::transport::ListenerHandler< message::RawMessage >::ListenerHandler ( )

inline

在文件 listener_handler.h 第 99 行定义.

                                                           {
  is_raw_message_ = true;
}

成员函数说明

Connect() [1/2]

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::Connect	(	uint64_t	self_id,
		const Listener &	listener
	)

在文件 listener_handler.h 第 104 行定义.

                                                                  {
  auto connection = signal_.Connect(listener);
  if (!connection.IsConnected()) {
    return;
  }
 
  WriteLockGuard<AtomicRWLock> lock(rw_lock_);
  signal_conns_[self_id] = connection;
}

Connect() [2/2]

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::Connect	(	uint64_t	self_id,
		uint64_t	oppo_id,
		const Listener &	listener
	)

在文件 listener_handler.h 第 116 行定义.

                                                                  {
  WriteLockGuard<AtomicRWLock> lock(rw_lock_);
  if (signals_.find(oppo_id) == signals_.end()) {
    signals_[oppo_id] = std::make_shared<MessageSignal>();
  }
 
  auto connection = signals_[oppo_id]->Connect(listener);
  if (!connection.IsConnected()) {
    AWARN << oppo_id << " " << self_id << " connect failed!";
    return;
  }
 
  if (signals_conns_.find(oppo_id) == signals_conns_.end()) {
    signals_conns_[oppo_id] = ConnectionMap();
  }
 
  signals_conns_[oppo_id][self_id] = connection;
}

Disconnect() [1/2]

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::Disconnect ( uint64_t  self_id )

overridevirtual

实现了 apollo::cyber::transport::ListenerHandlerBase.

在文件 listener_handler.h 第 137 行定义.

                                                           {
  WriteLockGuard<AtomicRWLock> lock(rw_lock_);
  if (signal_conns_.find(self_id) == signal_conns_.end()) {
    return;
  }
 
  signal_conns_[self_id].Disconnect();
  signal_conns_.erase(self_id);
}

Disconnect() [2/2]

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::Disconnect ( uint64_t  self_id, uint64_t  oppo_id  )

overridevirtual

实现了 apollo::cyber::transport::ListenerHandlerBase.

在文件 listener_handler.h 第 148 行定义.

                                                                             {
  WriteLockGuard<AtomicRWLock> lock(rw_lock_);
  if (signals_conns_.find(oppo_id) == signals_conns_.end()) {
    return;
  }
 
  if (signals_conns_[oppo_id].find(self_id) == signals_conns_[oppo_id].end()) {
    return;
  }
 
  signals_conns_[oppo_id][self_id].Disconnect();
  signals_conns_[oppo_id].erase(self_id);
}

Run()

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::Run	(	const Message &	msg,
		const MessageInfo &	msg_info
	)

在文件 listener_handler.h 第 163 行定义.

                                                                 {
  signal_(msg, msg_info);
  uint64_t oppo_id = msg_info.sender_id().HashValue();
  ReadLockGuard<AtomicRWLock> lock(rw_lock_);
  if (signals_.find(oppo_id) == signals_.end()) {
    return;
  }
 
  (*signals_[oppo_id])(msg, msg_info);
}

RunFromString()

template<typename MessageT >

void apollo::cyber::transport::ListenerHandler< MessageT >::RunFromString ( const std::string &  str, const MessageInfo &  msg_info  )

overridevirtual

实现了 apollo::cyber::transport::ListenerHandlerBase.

在文件 listener_handler.h 第 176 行定义.

                                                                           {
  auto msg = std::make_shared<MessageT>();
  if (message::ParseFromHC(str.data(), static_cast<int>(str.size()),
                           msg.get())) {
    Run(msg, msg_info);
  } else {
    AWARN << "Failed to parse message. Content: " << str;
  }
}

---

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

• cyber/transport/message/listener_handler.h