[zz]struct epoll_event
转载自:http://hi.baidu.com/tianhua_sun/item/401166c90f874a03ad092f01
1. struct epoll_event
结构体epoll_event 被用于注册所感兴趣的事件和回传所发生待处理的事件,定义如下:
typedef union epoll_data {
void *ptr;
int fd;
__uint32_t u32;
__uint64_t u64;
} epoll_data_t;//保存触发事件的某个文件描述符相关的数据
struct epoll_event {
__uint32_t events; /* epoll event */
epoll_data_t data; /* User data variable */
};
其中events表示感兴趣的事件和被触发的事件,可能的取值为:
EPOLLIN :表示对应的文件描述符可以读;
EPOLLOUT:表示对应的文件描述符可以写;
EPOLLPRI: 表示对应的文件描述符有紧急的数可读;
EPOLLERR:表示对应的文件描述符发生错误;
EPOLLHUP:表示对应的文件描述符被挂断;
EPOLLET: ET的epoll工作模式;
所涉及到的函数有:
1、epoll_create函数
函数声明:int epoll_create(int size)
功能:该函数生成一个epoll专用的文件描述符,其中的参数是指定生成描述符的最大范围;这个参数自从Linux 2.6.8之后开始就没有使用了(被忽略了)
2、epoll_ctl函数
函数声明:int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)
功能:用于控制某个文件描述符上的事件,可以注册事件,修改事件,删除事件。
@epfd:由 epoll_create 生成的epoll专用的文件描述符;
@op:要进行的操作,EPOLL_CTL_ADD 注册、EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除;
@fd:关联的文件描述符;
@event:指向epoll_event的指针;
成功:0;失败:-1
3、epoll_wait函数
函数声明:int epoll_wait(int epfd,struct epoll_event * events,int maxevents,int timeout)
功能:该函数用于轮询I/O事件的发生;
@epfd:由epoll_create 生成的epoll专用的文件描述符;
@epoll_event:用于回传代处理事件的数组;
@maxevents:每次能处理的事件数;
@timeout:等待I/O事件发生的超时值;
成功:返回发生的事件数;失败:-1
应用举例:
1 #define SERV_PORT 4466 //服务端口号 2 const char *LOCAL_ADDR = "127.0.0.1";//绑定服务地址 3 4 bool setnonblocking(int sock)//设置socket为非阻塞方式 5 { 6 int opts; 7 8 opts=fcntl(sock,F_GETFL); 9 if(opts<0) 10 { 11 perror("fcntl(sock,GETFL)"); 12 return false; 13 } 14 opts = opts|O_NONBLOCK; 15 if(fcntl(sock,F_SETFL,opts)<0) 16 { 17 perror("fcntl(sock,SETFL,opts)"); 18 return false; 19 } 20 return true; 21 } 22 23 int main() 24 { 25 int i, maxi, listenfd, new_fd, sockfd,epfd,nfds; 26 ssize_t n; 27 char line[MAXLINE]; 28 socklen_t clilen; 29 struct epoll_event ev,events[20];//ev用于注册事件,数组用于回传要处理的事件 30 struct sockaddr_in clientaddr, serveraddr; 31 32 listenfd = socket(AF_INET, SOCK_STREAM, 0);//生成socket文件描述符 33 setnonblocking(listenfd);//把socket设置为非阻塞方式 34 35 epfd=epoll_create(256);//生成用于处理accept的epoll专用的文件描述符 36 ev.data.fd=listenfd;//设置与要处理的事件相关的文件描述符 37 ev.events=EPOLLIN|EPOLLET;//设置要处理的事件类型 38 epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,&ev);//注册epoll事件 39 40 //设置服务器端地址信息 41 bzero(&serveraddr, sizeof(serveraddr)); 42 serveraddr.sin_family = AF_INET; 43 char *local_addr= LOCAL_ADDR; 44 inet_aton(local_addr,&(serveraddr.sin_addr)); 45 serveraddr.sin_port=htons(SERV_PORT); 46 47 bind(listenfd,(sockaddr *)&serveraddr, sizeof(serveraddr));//绑定socket连接 48 listen(listenfd, LISTENQ);//监听 49 50 maxi = 0; 51 for ( ; ; ) 52 { 53 /* epoll_wait:等待epoll事件的发生,并将发生的sokct fd和事件类型放入到events数组中; 54 * nfds:为发生的事件的个数。 55 * 注:事件发生后,注册在epfd上的socket fd的事件类型会被清空,所以如果下一个循环你 56 * 还要关注这个socket fd的话,则需要用epoll_ctl(epfd,EPOLL_CTL_MOD,listenfd,&ev)来 57 * 重新设置socket fd的事件类型 58 */ 59 nfds=epoll_wait(epfd,events,20,500); 60 61 //处理所发生的所有事件 62 for(i=0;i<nfds;++i) 63 { 64 if(events[i].data.fd==listenfd)//事件发生在listenfd上 65 { 66 /* 获取发生事件端口信息,存于clientaddr中; 67 * new_fd:返回的新的socket描述符,用它来对该事件进行recv/send操作*/ 68 new_fd = accept(listenfd,(struct sockaddr *)&clientaddr, &clilen); 69 if(connfd<0) 70 { 71 perror("connfd<0"); 72 exit(1); 73 } 74 setnonblocking(connfd); 75 char *str = inet_ntoa(clientaddr.sin_addr); 76 ev.data.fd=connfd;//设置用于读操作的文件描述符 77 ev.events=EPOLLIN|EPOLLET;//设置用于注测的读操作事件 78 epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,&ev);//注册ev 79 } 80 else if(events[i].events&EPOLLIN) 81 { 82 if ( (sockfd = events[i].data.fd) < 0) 83 continue; 84 85 if ( (n = read(sockfd, line, MAXLINE)) < 0) 86 { 87 if (errno == ECONNRESET) 88 { 89 close(sockfd); 90 events[i].data.fd = -1; 91 } 92 else 93 std::cout<<"readline error"<<std::endl; 94 } 95 else if (n == 0) 96 { 97 close(sockfd); 98 events[i].data.fd = -1; 99 } 100 ev.data.fd=sockfd;//设置用于写操作的文件描述符 101 ev.events=EPOLLOUT|EPOLLET;//设置用于注测的写操作事件 102 epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);//修改sockfd上要处理的事件为EPOLLOUT 103 } 104 else if(events[i].events&EPOLLOUT) 105 { 106 sockfd = events[i].data.fd; 107 write(sockfd, line, n); 108 109 ev.data.fd=sockfd;//设置用于读操作的文件描述符 110 ev.events=EPOLLIN|EPOLLET;//设置用于注测的读操作事件 111 epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);//修改sockfd上要处理的事件为EPOLIN 112 } 113 } 114 } 115 }
转载于:https://www.cnblogs.com/zhangzhang/archive/2013/01/07/2849391.html
[zz]struct epoll_event相关推荐
- 【转】struct epoll_event
这两天在看项目的数据结构定义及关系,遇到一些关于socket的知识点,还有一些C++的知识点,下面总结下: 1. struct epoll_event结构体epoll_event被用于注册所感兴趣的事 ...
- 常见网络编程面试题答案征集与面试题(收集) ZZ 【网络编程】
http://www.cnblogs.com/wickedboy237/archive/2013/05/12/3074362.html 1:tcp和udp的区别 2:流量控制和拥塞控制的实现机制 3: ...
- android在framework层增加自己的service仿照GPS
不少公司在开发android产品的时候,都需要在android中增加自己的service,尤其是定制的工业用途的设备,我们公司的项目中就涉及到要增加一个service,是一个北斗通信service,具 ...
- android在framework层增加自己的service---仿照GPS
不少公司在开发android产品的时候,都需要在android中增加自己的service,尤其是定制的工业用途的设备,我们公司的项目中就涉及到要增加一个service,是一个北斗通信serv ...
- 华清远见嵌入式学习笔记
C高级笔记 符号含义 1.hqyj@ubuntu:~$ hqyj:用户名 @:分隔 ubuntu:主机名 ':':分隔 ~:文件路径---> ~:家目录 /:根目录 $:分隔 2.文件类型及标识 ...
- 【C语言 Linux系统开发 视频课程学习笔记】
学习的课程在b站:史上最强最细腻的linux嵌入式C语言学习教程[李慧芹老师] 感谢李老师!感谢up主! 本篇博客只是收集一下学习过程中遇到的函数和其他知识点,并不会详细展开.某个函数的具 ...
- 漫谈五种IO模型(主讲IO多路复用)
首先引用levin的回答让我们理清楚五种IO模型 1.阻塞I/O模型 老李去火车站买票,排队三天买到一张退票. 耗费:在车站吃喝拉撒睡 3天,其他事一件没干. 2.非阻塞I/O模型 老李去火车站买票, ...
- linux epoll用法
epoll 是 linux 特有的 I/O 复用函数.它是把用户关心的文件描述符事件放在内核的一个事件列表中,故而,无须像select和poll一样每次调用都重复传入文件描述符或事件集.但是, epo ...
- epoll监听文件_怎么理解把标准输入以ET模式加入epoll,监听EPOLLOUT事件时,epoll_wait多次返回?...
确实是后面的printf导致的,去掉后面的printf,增加计数器的判断, 可确认epoll_wait只返回了一次.但是为什么printf会影响到标准输入stdin?还是不理解. 修改后符合预期代码如 ...
最新文章
- Win64 驱动内核编程-4.内核里操作字符串
- pycharm在401跑程序需要每个py文件加一句
- Groovy 设计模式 -- 借贷
- Java获取网络IP
- win10下装黑苹果双系统_预算5000的黑苹果/WIN双系统台式电脑组装建议
- 社交网络与社会计算课程内容梳理总结
- mysql的脏数据_数据库的脏数据问题
- android不流畅,究其本质
- 【转】写给自学者的入门指南
- fatal: unable to access ‘https://github.com/NEGVS/the-economist-ebooks.git/‘: schannel: failed to re
- java中的arrayList(动态数组)与静态数组
- BIOS入知识枝桠——SMBIOS
- linux配置防火墙白名单(限制某个IP段)
- 永磁同步电机PMSM直接转矩滞环控制 采用三闭环控制:转速外环采用PI调节器,转矩环和磁链环经过滞环后得到PWM脉冲
- 汇川AM401与Pro-face连接
- Unity接入Google Play遇到Authentication canceled
- A side-by-side LYSOGAGG phoswich detector aiming for SPECT imaging
- MATLAB代码:基于多目标粒子群算法冷热电联供综合能源系统运行优化
- 世界新首富巴菲特的投资真经
- Host header attack漏洞验证测试
热门文章
- 检测到USB设备插入写法1
- boostrap 鼠标滚轮滑动图片_BootStrap 轮播插件(carousel)支持左右手势滑动的方法(三种)...
- ie8 script445: 对象不支持此操作_经验总结:上海增值税认证勾选安装和操作步骤...
- 网站服务器处理器计划怎么设置,服务器处理器计划
- 什么是Java序列化,如何实现java序列化
- 类型多种_五轴机床有很多种类型,你知道几种?
- csv 字符串_爬虫|python读写csv文件的方法完成生涯规划表
- JDK7 AIO介绍
- wpf创建xml随程序一起打包_Springboot,Java程序员必学
- 节能与新能源汽车技术路线图2.0_节能与新能源汽车技术路线图(2.0版)