apollo::cyber::transport::ChannelChain类 参考

#include <intra_dispatcher.h>

apollo::cyber::transport::ChannelChain 的协作图:

Public 成员函数
template<typename MessageT >
bool	AddListener (uint64_t self_id, uint64_t channel_id, const std::string &message_type, const MessageListener< MessageT > &listener)
template<typename MessageT >
bool	AddListener (uint64_t self_id, uint64_t oppo_id, uint64_t channel_id, const std::string &message_type, const MessageListener< MessageT > &listener)
template<typename MessageT >
void	RemoveListener (uint64_t self_id, uint64_t channel_id, const std::string &message_type)
template<typename MessageT >
void	RemoveListener (uint64_t self_id, uint64_t oppo_id, uint64_t channel_id, const std::string &message_type)
template<typename MessageT >
void	Run (uint64_t self_id, uint64_t channel_id, const std::string &message_type, const std::shared_ptr< MessageT > &message, const MessageInfo &message_info)
template<typename MessageT >
void	Run (uint64_t self_id, uint64_t oppo_id, uint64_t channel_id, const std::string &message_type, const std::shared_ptr< MessageT > &message, const MessageInfo &message_info)

详细描述

在文件 intra_dispatcher.h 第 51 行定义.

成员函数说明

AddListener() [1/2]

template<typename MessageT >

bool apollo::cyber::transport::ChannelChain::AddListener ( uint64_t  self_id, uint64_t  channel_id, const std::string &  message_type, const MessageListener< MessageT > &  listener  )

inline

在文件 intra_dispatcher.h 第 57 行定义.

                                                              {
    WriteLockGuard<base::AtomicRWLock> lg(rw_lock_);
    auto ret = GetHandler<MessageT>(channel_id, message_type, &handlers_);
    auto handler = ret.first;
    if (handler == nullptr) {
      AERROR << "get handler failed. channel: "
             << GlobalData::GetChannelById(channel_id)
             << ", message type: " << message::GetMessageName<MessageT>();
      return ret.second;
    }
    handler->Connect(self_id, listener);
    return ret.second;
  }

AddListener() [2/2]

template<typename MessageT >

bool apollo::cyber::transport::ChannelChain::AddListener ( uint64_t  self_id, uint64_t  oppo_id, uint64_t  channel_id, const std::string &  message_type, const MessageListener< MessageT > &  listener  )

inline

在文件 intra_dispatcher.h 第 74 行定义.

                                                              {
    WriteLockGuard<base::AtomicRWLock> lg(oppo_rw_lock_);
    if (oppo_handlers_.find(oppo_id) == oppo_handlers_.end()) {
      oppo_handlers_[oppo_id] = BaseHandlersType();
    }
    BaseHandlersType& handlers = oppo_handlers_[oppo_id];
    auto ret = GetHandler<MessageT>(channel_id, message_type, &handlers);
    auto handler = ret.first;
    if (handler == nullptr) {
      AERROR << "get handler failed. channel: "
             << GlobalData::GetChannelById(channel_id)
             << ", message type: " << message_type;
      return ret.second;
    }
    handler->Connect(self_id, oppo_id, listener);
    return ret.second;
  }

RemoveListener() [1/2]

template<typename MessageT >

void apollo::cyber::transport::ChannelChain::RemoveListener ( uint64_t  self_id, uint64_t  channel_id, const std::string &  message_type  )

inline

在文件 intra_dispatcher.h 第 95 行定义.

                                                     {
    WriteLockGuard<base::AtomicRWLock> lg(rw_lock_);
    auto handler = RemoveHandler(channel_id, message_type, &handlers_);
    if (handler) {
      handler->Disconnect(self_id);
    }
  }

RemoveListener() [2/2]

template<typename MessageT >

void apollo::cyber::transport::ChannelChain::RemoveListener ( uint64_t  self_id, uint64_t  oppo_id, uint64_t  channel_id, const std::string &  message_type  )

inline

在文件 intra_dispatcher.h 第 105 行定义.

                                                     {
    WriteLockGuard<base::AtomicRWLock> lg(oppo_rw_lock_);
    if (oppo_handlers_.find(oppo_id) == oppo_handlers_.end()) {
      return;
    }
    BaseHandlersType& handlers = oppo_handlers_[oppo_id];
    auto handler = RemoveHandler(channel_id, message_type, &handlers);
    if (oppo_handlers_[oppo_id].empty()) {
      oppo_handlers_.erase(oppo_id);
    }
    if (handler) {
      handler->Disconnect(self_id, oppo_id);
    }
  }

Run() [1/2]

template<typename MessageT >

void apollo::cyber::transport::ChannelChain::Run ( uint64_t  self_id, uint64_t  channel_id, const std::string &  message_type, const std::shared_ptr< MessageT > &  message, const MessageInfo &  message_info  )

inline

在文件 intra_dispatcher.h 第 122 行定义.

                                            {
    ReadLockGuard<base::AtomicRWLock> lg(rw_lock_);
    Run(channel_id, message_type, handlers_, message, message_info);
  }

Run() [2/2]

template<typename MessageT >

void apollo::cyber::transport::ChannelChain::Run ( uint64_t  self_id, uint64_t  oppo_id, uint64_t  channel_id, const std::string &  message_type, const std::shared_ptr< MessageT > &  message, const MessageInfo &  message_info  )

inline

在文件 intra_dispatcher.h 第 131 行定义.

                                            {
    ReadLockGuard<base::AtomicRWLock> lg(oppo_rw_lock_);
    if (oppo_handlers_.find(oppo_id) == oppo_handlers_.end()) {
      return;
    }
    BaseHandlersType& handlers = oppo_handlers_[oppo_id];
    Run(channel_id, message_type, handlers, message, message_info);
  }

---

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

• cyber/transport/dispatcher/intra_dispatcher.h