[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的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: PEAP接入流程
- 下一篇: C#调试中,在VS的输出窗口或即时窗口显