apollo::cyber::transport::ConditionNotifier类 参考

#include <condition_notifier.h>

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

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

Public 成员函数
virtual	~ConditionNotifier ()
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 ()

详细描述

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

构造及析构函数说明

~ConditionNotifier()

apollo::cyber::transport::ConditionNotifier::~ConditionNotifier ( )

virtual

在文件 condition_notifier.cc 第 46 行定义.

{ Shutdown(); }

成员函数说明

Listen()

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

overridevirtual

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

在文件 condition_notifier.cc 第 71 行定义.

                                                                 {
  if (info == nullptr) {
    AERROR << "info nullptr.";
    return false;
  }
 
  if (is_shutdown_.load()) {
    ADEBUG << "notifier is shutdown.";
    return false;
  }
 
  int timeout_us = timeout_ms * 1000;
  while (!is_shutdown_.load()) {
    uint64_t seq = indicator_->next_seq.load();
    if (seq != next_seq_) {
      auto idx = next_seq_ % kBufLength;
      auto actual_seq = indicator_->seqs[idx];
      if (actual_seq >= next_seq_) {
        next_seq_ = actual_seq;
        *info = indicator_->infos[idx];
        ++next_seq_;
        return true;
      } else {
        ADEBUG << "seq[" << next_seq_ << "] is writing, can not read now.";
      }
    }
 
    if (timeout_us > 0) {
      std::this_thread::sleep_for(std::chrono::microseconds(50));
      timeout_us -= 50;
    } else {
      return false;
    }
  }
  return false;
}

Notify()

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

overridevirtual

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

在文件 condition_notifier.cc 第 57 行定义.

                                                       {
  if (is_shutdown_.load()) {
    ADEBUG << "notifier is shutdown.";
    return false;
  }
 
  uint64_t seq = indicator_->next_seq.fetch_add(1);
  uint64_t idx = seq % kBufLength;
  indicator_->infos[idx] = info;
  indicator_->seqs[idx] = seq;
 
  return true;
}

Shutdown()

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

overridevirtual

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

在文件 condition_notifier.cc 第 48 行定义.

                                 {
  if (is_shutdown_.exchange(true)) {
    return;
  }
 
  std::this_thread::sleep_for(std::chrono::milliseconds(100));
  Reset();
}

Type()

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

inlinestatic

在文件 condition_notifier.h 第 47 行定义.

{ return "condition"; }

---

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

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