2.4 epoll API

2.4.1 创建EPOLL

  1. /**
  2.  * @param size 告诉内核监听的数目
  3.  *
  4.  * @returns 返回一个epoll句柄（即一个文件描述符）
  5.  */
  6. int epoll_create(int size);
  1. int epfd = epoll_create(1000);

2.4 epollAPI - 图1

2.4.2 控制EPOLL

  1. /**
  2.  * @param epfd 用epoll_create所创建的epoll句柄
  3.  * @param op 表示对epoll监控描述符控制的动作
  4.  *
  5.  * EPOLL_CTL_ADD(注册新的fd到epfd)
  6.  * EPOLL_CTL_MOD(修改已经注册的fd的监听事件)
  7.  * EPOLL_CTL_DEL(epfd删除一个fd)
  8.  *
  9.  * @param fd 需要监听的文件描述符
  10.  * @param event 告诉内核需要监听的事件
  11.  *
  12.  * @returns 成功返回0，失败返回-1, errno查看错误信息
  13.  */
  14. int epoll_ctl(int epfd, int op, int fd, 
  15.             struct epoll_event *event);
  18. struct epoll_event {
  19.  __uint32_t events; /* epoll 事件 */
  20.  epoll_data_t data; /* 用户传递的数据 */
  21. }
  23. /*
  24.  * events : {EPOLLIN, EPOLLOUT, EPOLLPRI, 
  25.             EPOLLHUP, EPOLLET, EPOLLONESHOT}
  26.  */
  28. typedef union epoll_data {
  29.     void *ptr;
  30.     int fd;
  31.     uint32_t u32;
  32.     uint64_t u64;
  33. } epoll_data_t;
  1. struct epoll_event new_event;
  3. new_event.events = EPOLLIN | EPOLLOUT;
  4. new_event.data.fd = 5;
  6. epoll_ctl(epfd, EPOLL_CTL_ADD, 5, &new_event);

2.4 epollAPI - 图2

2.4.3 等待EPOLL

  2. /**
  3.  *
  4.  * @param epfd 用epoll_create所创建的epoll句柄
  5.  * @param event 从内核得到的事件集合
  6.  * @param maxevents 告知内核这个events有多大,
  7.  *             注意: 值 不能大于创建epoll_create()时的size.
  8.  * @param timeout 超时时间
  9.  *     -1: 永久阻塞
  10.  *     0: 立即返回，非阻塞
  11.  *     >0: 指定微秒
  12.  *
  13.  * @returns 成功: 有多少文件描述符就绪,时间到时返回0
  14.  *          失败: -1, errno 查看错误
  15.  */
  16. int epoll_wait(int epfd, struct epoll_event *event, 
  17.             int maxevents, int timeout);
  1. struct epoll_event my_event[1000];
  3. int event_cnt = epoll_wait(epfd, my_event, 1000, -1);

2.4 epollAPI - 图3

2.4.4 epoll编程框架

  1. //创建 epoll
  2. int epfd = epoll_crete(1000);
  4. //将 listen_fd 添加进 epoll 中
  5. epoll_ctl(epfd, EPOLL_CTL_ADD, listen_fd,&listen_event);
  7. while (1) {
  8.     //阻塞等待 epoll 中 的fd 触发
  9.     int active_cnt = epoll_wait(epfd, events, 1000, -1);
  11.     for (i = 0 ; i < active_cnt; i++) {
  12.         if (evnets[i].data.fd == listen_fd) {
  13.             //accept. 并且将新accept 的fd 加进epoll中.
  14.         }
  15.         else if (events[i].events & EPOLLIN) {
  16.             //对此fd 进行读操作
  17.         }
  18.         else if (events[i].events & EPOLLOUT) {
  19.             //对此fd 进行写操作
  20.         }
  21.     }
  22. }