互联网络程序设计第7章

epoll添加事件 添加事件
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); RETURN：0，成功；-1，出错 ： ，成功； ，
epfd为epoll_create创建的 为 创建的epoll描述符 创建的 描述符 epoll_ctl函数对 epoll_ctl函数对epoll进行op类型的操作，op选项为 函数对epoll进行 类型的操作，op选项为 进行op类型的操作
epoll的回调 的回调
这里有一个比较重要的问题： 返回的events 这里有一个比较重要的问题：从epoll_wait返回的 返回的 该如何知道是哪个描述符上的事件？ 中，该如何知道是哪个描述符上的事件？
typedef union epoll_data { void *ptr; int fd; uint32_t u32; uint64_t u64; } epoll_data_t; /* 64bit */
3. epoll客户端 客户端
ep.create(); events[0].events = EPOLLIN; events[0].data.fd = fileno(stdin); ep.registerEvent(fileno(stdin), events[0]); events[0].data.fd = sock.getFd(); ep.registerEvent(sock.getFd(), events[0]); while (true) { int ret, length; ret = ep.waitEvent(events, 2, -1);
– EPOLL_CTL_ADD，对fd描述符注册 描述符注册event事件 ， 描述符注册 事件 – EPOLL_CTL_MOD，对fd描述符的 描述符的event事件进行修改 ， 描述符的 事件进行修改 – EPOLL_CTL_DEL，删除已注册的event事件 ，删除已注册的 事件
epoll_event结构 结构
– Solaris的/dev/poll 的 – FreeBSD的kqueue 的 – Linux的epoll技术 的 技术
本章以epoll为例介绍高级 为例介绍高级polling技术 本章以 为例介绍高级 技术 epoll的特点 的特点
– – – epoll是对 是对poll的改进 是对 的改进 增量的事件添加与删除 支持边沿触发（ 支持边沿触发（edge trigger、ET）和水平触发（level trigger、 、 ）和水平触发（ 、 LT） ） – 同步的事件处理 – 基于文件描述操作
– – – – – – –
EPOLLIN，读事件 ， EPOLLOUT，写事件 ， EPOLLPRI，带外数据，与select的异常事件集合对应 ，带外数据， 的异常事件集合对应 EPOLLRDHUP，TCP连接对端至少写写半关闭 ， 连接对端至少写写半关闭 EPOLLERR，错误事件 ， EPOLLET，设置事件为边沿触发 ， EPOLLONESHOT，只触发一次，事件自动被删除 ，只触发一次，
epoll_wait
#include <sys/epoll.h> int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout); RETURN:>0，发生事件个数；=0，时间到；-1，出错 ，发生事件个数； ，时间到； ，
else if (events[i].data.fd == sock.getFd()) { if ((length = sock.read(rbuf, BUFFER_SIZE)) == 0) { ep.unregisterEvent(events[i].data.fd); goto BREAK; } length = sout.write(rbuf, length); } else throw EXCEPTION(); } }
ET与LT 与 – 在ET模式下，事件只在 模式下， 返回时通知应用程序。 模式下 事件只在epoll返回时通知应用程序。即 返回时通知应用程序 是说，如果一次不干净地处理完通知事件， 是说，如果一次不干净地处理完通知事件，以后该事 件再也不会通知应用程序 – 而在 模式下，应用程序可以只处理一部分事件，剩 而在LT模式下 应用程序可以只处理一部分事件， 模式下， 下的事件，在下次epoll返回后，仍然还会通知用户 返回后， 下的事件，在下次 返回后 – 例子 一个pipe，writer向其中写入 向其中写入4KB 一个 ， 向其中写入 reader只读取 只读取1KB 只读取 模式下， 在ET模式下，剩下的 模式下 剩下的3KB将不再通知 将不再通知 而在LT模式下 模式下， 而在 模式下，该事件仍然会通知应用程序 ET的效能更高，但是对程序员的要求也更高。在ET模式 的效能更高， 的效能更高 但是对程序员的要求也更高。 模式 下，我们必须一次干净而彻底地处理完所有事件
for (int i = 0; i < ret; ++i) { if (events[i].data.fd == fileno(stdin)) { if ((length = sin.read(sbuf, BUFFER_SIZE)) == 0) { sock.shutdown(); ep.unregisterEvent(events[i].data.fd); } else length = sock.write(sbuf, length); }
struct epoll_event { uint32_t events; /* Epoll events */ epoll_data_t data; /* User data variable */ } __attribute__ ((__packed__)); /* 12bytes */ typedef union epoll_data { void *ptr; int fd; uint32_t u32; uint64_t u64; } epoll_data_t; /* 64bit */
epoll_wait与select函数类似，同步地等待事件发生 与 函数类似， 函数类似 – epfd，标识 ，标识epoll的文件描述符 的文件描述符 – events，指向传入操作系统的一个 ，指向传入操作系统的一个epoll_event数组 数组 – maxevents，表示传入数组的大小，必须大于 ，表示传入数组的大小，必须大于0 当有事件发生，Linux会填写 当有事件发生， 会填写events结构，返回给应用程 结构， 会填写 结构 序 由于epoll_wait同步等待，有可能被信号中断，返回 同步等待， 由于 同步等待 有可能被信号中断， EINTR错误 错误
4. epoll服务器 服务器
5. 测试用例
按照第5章回归 按照第 章回归
作业
使用epoll实现 实现echo客户端与服务器 使用 实现 客户端与服务器
epoll在一个文件描述符上只能有一个事件，在一个描述 在一个文件描述符上只能有一个事件， 在一个文件描述符上只能有一个事件 符上添加多个事件，会产生EEXIST的错误 符上添加多个事件，会产生 的错误 同样，删除epoll的事件，只需描述符就够了 的事件， 同样，删除 的事件
epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL);
#define EPOLLWRBAND EPOLLWRBAND EPOLLMSG = 0x400, #define EPOLLMSG EPOLLMSG EPOLLERR = 0x008, #define EPOLLERR EPOLLERR EPOLLHUP = 0x010, #define EPOLLHUP EPOLLHUP EPOLLRDHUP = 0x2000, #define EPOLLRDHUP EPOLLRDHUP EPOLLONESHOT = (1 << 30), #define EPOLLONESHOT EPOLLONESHOT EPOLLET = (1 << 31) #define EPOLLET EPOLLET };
第七章、高级 复用技术 第七章、高级I/O复用技术
高级polling技术 技术 高级 epoll相关函数 相关函数 epoll客户端 客户端 epoll服务器 服务器 测试用例
1. 高级 高级polling技术 技术
select、poll、pselect函数存在的问题 、 、 函数存在的问题 高级polling技术没有标准，各个操纵系统的实现不一样 技术没有标准， 高级 技术没有标准
epoll的事件类型 的事件类型
enum EPOLL_EVENTS { EPOLLIN = 0x001, #define EPOLLIN EPOLLIN EPOLLPRI = 0x002, #define EPOLLPRI EPOLLPRI EPOLLOUT = 0x004, #define EPOLLOUT EPOLLOUT EPOLLRDNORM = 0x040, #define EPOLLRDNORM EPOLLRDNORM EPOLLRDBAND = 0x080, #define EPOLLRDBAND EPOLLRDBAND EPOLLWRNORM = 0x100, #define EPOLLWRNORM EPOLLWRNORM EPOLLWRBAND = 0x200,
在注册epoll事件的时候，一定要填写epoll_data，否则 事件的时候，一定要填写 在注册 事件的时候 ， 我们将分不清触发的是哪个描述符上的事件
Regular files do not support the linux ->poll() file operation. If you want to wait for events on regular files, you need to use AIO+eventfd+epoll. epoll不支持管道和重定向 不支持管道和重定向