博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
[zz]struct epoll_event
阅读量:6291 次
发布时间:2019-06-22

本文共 3403 字,大约阅读时间需要 11 分钟。

转载自:

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
< 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"<
你可能感兴趣的文章