#include <subscriber_listener.h>

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

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

Public 成员函数
	SubscriberListener (const transport::rtps::subsciber_callback &callback)

virtual	~SubscriberListener ()

void	on_data_available (eprosima::fastdds::dds::DataReader *reader) override

void	on_subscription_matched (eprosima::fastdds::dds::DataReader *reader, const eprosima::fastdds::dds::SubscriptionMatchedStatus &info) override

详细描述

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

构造及析构函数说明

◆ SubscriberListener()

apollo::cyber::service_discovery::SubscriberListener::SubscriberListener ( const transport::rtps::subsciber_callback & callback )

explicit

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

36 : callback_(callback) {}

◆ ~SubscriberListener()

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

virtual

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

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

成员函数说明

◆ on_data_available()

void apollo::cyber::service_discovery::SubscriberListener::on_data_available ( eprosima::fastdds::dds::DataReader * reader )

override

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

                                          {
  RETURN_IF_NULL(callback_);
 
  eprosima::fastdds::dds::SampleInfo m_info;
  cyber::transport::UnderlayMessage m;
  while (reader->take_next_sample(reinterpret_cast<void*>(&m), &m_info) ==
         eprosima::fastrtps::types::ReturnCode_t::RETCODE_OK) {
    if (m_info.valid_data) {
      // parameter 1 and 2 are not used
      callback_(std::make_shared<std::string>(m.data()), 0, msg_info_);
    } else {
      AERROR << "Remote writer for topic "
             << reader->get_topicdescription()->get_name() << " is dead";
    }
  }
}

◆ on_subscription_matched()

void apollo::cyber::service_discovery::SubscriberListener::on_subscription_matched	(	eprosima::fastdds::dds::DataReader *	reader,
		const eprosima::fastdds::dds::SubscriptionMatchedStatus &	info
	)