apollo::cyber::service_discovery::SubscriberListener类 参考

#include <subscriber_listener.h>

类 apollo::cyber::service_discovery::SubscriberListener 继承关系图:

apollo::cyber::service_discovery::SubscriberListener 的协作图:

Public 类型
using	NewMsgCallback = std::function< void(const std::string &)>

Public 成员函数
	SubscriberListener (const NewMsgCallback &callback)
virtual	~SubscriberListener ()
void	onNewDataMessage (eprosima::fastrtps::Subscriber *sub)
void	onSubscriptionMatched (eprosima::fastrtps::Subscriber *sub, eprosima::fastrtps::MatchingInfo &info)

详细描述

在文件 subscriber_listener.h 第 33 行定义.

成员类型定义说明

NewMsgCallback

using apollo::cyber::service_discovery::SubscriberListener::NewMsgCallback = std::function<void(const std::string&)>

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

构造及析构函数说明

SubscriberListener()

apollo::cyber::service_discovery::SubscriberListener::SubscriberListener ( const NewMsgCallback &  callback )

explicit

在文件 subscriber_listener.cc 第 27 行定义.

    : callback_(callback) {}

~SubscriberListener()

apollo::cyber::service_discovery::SubscriberListener::~SubscriberListener ( )

virtual

在文件 subscriber_listener.cc 第 30 行定义.

                                        {
  std::lock_guard<std::mutex> lck(mutex_);
  callback_ = nullptr;
}

成员函数说明

onNewDataMessage()

void apollo::cyber::service_discovery::SubscriberListener::onNewDataMessage

(

eprosima::fastrtps::Subscriber *

sub

)

在文件 subscriber_listener.cc 第 35 行定义.

                                                                         {
  RETURN_IF_NULL(callback_);
 
  std::lock_guard<std::mutex> lock(mutex_);
  eprosima::fastrtps::SampleInfo_t m_info;
  cyber::transport::UnderlayMessage m;
  RETURN_IF(!sub->takeNextData(reinterpret_cast<void*>(&m), &m_info));
  RETURN_IF(m_info.sampleKind != eprosima::fastrtps::ALIVE);
 
  callback_(m.data());
}

onSubscriptionMatched()

void apollo::cyber::service_discovery::SubscriberListener::onSubscriptionMatched	(	eprosima::fastrtps::Subscriber *	sub,
		eprosima::fastrtps::MatchingInfo &	info
	)

在文件 subscriber_listener.cc 第 47 行定义.

                                        {
  (void)sub;
  (void)info;
}

---

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

• cyber/service_discovery/communication/subscriber_listener.h
• cyber/service_discovery/communication/subscriber_listener.cc