apollo::cyber::transport::MulticastNotifier类 参考

#include <multicast_notifier.h>

类 apollo::cyber::transport::MulticastNotifier 继承关系图:

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

Public 成员函数
virtual	~MulticastNotifier ()
void	Shutdown () override
bool	Notify (const ReadableInfo &info) override
bool	Listen (int timeout_ms, ReadableInfo *info) override
Public 成员函数 继承自 apollo::cyber::transport::NotifierBase
virtual	~NotifierBase ()=default

静态 Public 成员函数
static const char *	Type ()

详细描述

在文件 multicast_notifier.h 第 30 行定义.

构造及析构函数说明

~MulticastNotifier()

apollo::cyber::transport::MulticastNotifier::~MulticastNotifier ( )

virtual

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

{ Shutdown(); }

成员函数说明

Listen()

bool apollo::cyber::transport::MulticastNotifier::Listen ( int  timeout_ms, ReadableInfo *  info  )

overridevirtual

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

在文件 multicast_notifier.cc 第 76 行定义.

                                                                 {
  if (is_shutdown_.load()) {
    return false;
  }
 
  if (info == nullptr) {
    AERROR << "info nullptr.";
    return false;
  }
 
  struct pollfd fds;
  fds.fd = listen_fd_;
  fds.events = POLLIN;
  int ready_num = poll(&fds, 1, timeout_ms);
  if (ready_num > 0) {
    char buf[32] = {0};  // larger than ReadableInfo::kSize
    ssize_t nbytes = recvfrom(listen_fd_, buf, 32, 0, nullptr, nullptr);
    if (nbytes == -1) {
      AERROR << "fail to recvfrom, " << strerror(errno);
      return false;
    }
    return info->DeserializeFrom(buf, nbytes);
  } else if (ready_num == 0) {
    ADEBUG << "timeout, no readableinfo.";
  } else {
    if (errno == EINTR) {
      AINFO << "poll was interrupted.";
    } else {
      AERROR << "fail to poll, " << strerror(errno);
    }
  }
  return false;
}

Notify()

bool apollo::cyber::transport::MulticastNotifier::Notify ( const ReadableInfo &  info )

overridevirtual

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

在文件 multicast_notifier.cc 第 63 行定义.

                                                       {
  if (is_shutdown_.load()) {
    return false;
  }
 
  std::string info_str;
  info.SerializeTo(&info_str);
  ssize_t nbytes =
      sendto(notify_fd_, info_str.c_str(), info_str.size(), 0,
             (struct sockaddr*)&notify_addr_, sizeof(notify_addr_));
  return nbytes > 0;
}

Shutdown()

void apollo::cyber::transport::MulticastNotifier::Shutdown ( )

overridevirtual

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

在文件 multicast_notifier.cc 第 45 行定义.

                                 {
  if (is_shutdown_.exchange(true)) {
    return;
  }
 
  if (notify_fd_ != -1) {
    close(notify_fd_);
    notify_fd_ = -1;
  }
  memset(&notify_addr_, 0, sizeof(notify_addr_));
 
  if (listen_fd_ != -1) {
    close(listen_fd_);
    listen_fd_ = -1;
  }
  memset(&listen_addr_, 0, sizeof(listen_addr_));
}

Type()

static const char * apollo::cyber::transport::MulticastNotifier::Type ( )

inlinestatic

在文件 multicast_notifier.h 第 38 行定义.

{ return "multicast"; }

---

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

• cyber/transport/shm/multicast_notifier.h
• cyber/transport/shm/multicast_notifier.cc