apollo::cyber::io::Poller类 参考

#include <poller.h>

apollo::cyber::io::Poller 的协作图:

Public 类型
using	RequestPtr = std::shared_ptr< PollRequest >
using	RequestMap = std::unordered_map< int, RequestPtr >
using	CtrlParamMap = std::unordered_map< int, PollCtrlParam >

Public 成员函数
virtual	~Poller ()
void	Shutdown ()
bool	Register (const PollRequest &req)
bool	Unregister (const PollRequest &req)

详细描述

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

成员类型定义说明

CtrlParamMap

using apollo::cyber::io::Poller::CtrlParamMap = std::unordered_map<int, PollCtrlParam>

在文件 poller.h 第 40 行定义.

RequestMap

using apollo::cyber::io::Poller::RequestMap = std::unordered_map<int, RequestPtr>

在文件 poller.h 第 39 行定义.

RequestPtr

using apollo::cyber::io::Poller::RequestPtr = std::shared_ptr<PollRequest>

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

构造及析构函数说明

~Poller()

apollo::cyber::io::Poller::~Poller ( )

virtual

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

{ Shutdown(); }

成员函数说明

Register()

bool apollo::cyber::io::Poller::Register

(

const PollRequest &

req

)

在文件 poller.cc 第 54 行定义.

                                            {
  if (is_shutdown_.load()) {
    return false;
  }
 
  if (req.fd < 0 || req.callback == nullptr) {
    AERROR << "input is invalid";
    return false;
  }
 
  PollCtrlParam ctrl_param{};
  ctrl_param.fd = req.fd;
  ctrl_param.event.data.fd = req.fd;
  ctrl_param.event.events = req.events;
 
  {
    WriteLockGuard<AtomicRWLock> lck(poll_data_lock_);
    if (requests_.count(req.fd) == 0) {
      ctrl_param.operation = EPOLL_CTL_ADD;
      requests_[req.fd] = std::make_shared<PollRequest>();
    } else {
      ctrl_param.operation = EPOLL_CTL_MOD;
    }
    *requests_[req.fd] = req;
    ctrl_params_[ctrl_param.fd] = ctrl_param;
  }
 
  Notify();
  return true;
}

Shutdown()

void apollo::cyber::io::Poller::Shutdown

(

)

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

                      {
  if (is_shutdown_.exchange(true)) {
    return;
  }
  Clear();
}

Unregister()

bool apollo::cyber::io::Poller::Unregister

(

const PollRequest &

req

)

在文件 poller.cc 第 85 行定义.

                                              {
  if (is_shutdown_.load()) {
    return false;
  }
 
  if (req.fd < 0 || req.callback == nullptr) {
    AERROR << "input is invalid";
    return false;
  }
 
  {
    WriteLockGuard<AtomicRWLock> lck(poll_data_lock_);
    auto size = requests_.erase(req.fd);
    if (size == 0) {
      AERROR << "unregister failed, can't find fd: " << req.fd;
      return false;
    }
 
    PollCtrlParam ctrl_param;
    ctrl_param.operation = EPOLL_CTL_DEL;
    ctrl_param.fd = req.fd;
    ctrl_params_[ctrl_param.fd] = ctrl_param;
  }
 
  Notify();
  return true;
}

---

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

• cyber/io/poller.h
• cyber/io/poller.cc