Poller.h

#pragma once

#include<vector>
#include<unordered_map>

#include"noncopyable.h"
#include"Timestamp.h"
#include "EventLoop.h"

class Channel;

/**
 * @brief 多路事件分发器的核心IO复用模块
 * 
 */
class Poller : noncopyable {
 public:
  using ChannelList = std::vector<Channel*>;

  Poller(EventLoop *loop);
  virtual ~Poller();

  // 给所有IO复用保留统一的接口
  virtual Timestamp poll(int timeoutMS, ChannelList *activeChannel) = 0;
  virtual void updateChannel(Channel *channel) = 0;
  virtual void removeChannel(Channel *channel) = 0;
  
  // 判断参数channel是否在当前Poller中
  bool hasChannel(Channel *channel) const;

  // EventLoop可以通过该接口获取默认的IO复用的具体实现
  static Poller* newDefaultPoller(EventLoop *loop);
 protected:
  // map的key：sockfd ， value：socket所属的channel通道类型
  using ChannelMap = std::unordered_map<int, Channel*>;
  ChannelMap channels_;

 private: 
  EventLoop *ownerLoop_;  // 定义Poller所属的事件循环EventLoop

};