{"id":3509,"date":"2017-08-12T07:51:33","date_gmt":"2017-08-11T23:51:33","guid":{"rendered":"https:\/\/ixyzero.com\/blog\/?p=3509"},"modified":"2017-08-12T07:51:33","modified_gmt":"2017-08-11T23:51:33","slug":"linux%e4%b8%8b%e7%9a%84epoll%e7%9b%b8%e5%85%b3%e7%9f%a5%e8%af%86%e5%ad%a6%e4%b9%a0","status":"publish","type":"post","link":"https:\/\/ixyzero.com\/blog\/archives\/3509.html","title":{"rendered":"Linux\u4e0b\u7684epoll\u76f8\u5173\u77e5\u8bc6\u5b66\u4e60"},"content":{"rendered":"

=Start=<\/p>\n

\u7f18\u7531\uff1a<\/h4>\n

\u5b66\u4e60\u3001\u63d0\u9ad8\u9700\u8981<\/p>\n

\u6b63\u6587\uff1a<\/h4>\n

\u53c2\u8003\u89e3\u7b54\uff1a<\/h5>\n
epoll\u7f16\u7a0b\u63a5\u53e3\u4ecb\u7ecd<\/h6>\n

epoll\u5728\u7f16\u7a0b\u4e2d\u6709\u4e09\u4e2a\u63a5\u53e3\uff0c\u5206\u522b\u5982\u4e0b\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
\n
\n
int<\/code>\u00a0epoll_create(<\/code>int<\/code>\u00a0size);<\/code><\/div>\n
int<\/code>\u00a0epoll_ctl(<\/code>int<\/code>\u00a0epfd,\u00a0<\/code>int<\/code>\u00a0op,\u00a0<\/code>int<\/code>\u00a0fd, struct epoll_event *event)\uff1b<\/code><\/div>\n
int<\/code>\u00a0epoll_wait(<\/code>int<\/code>\u00a0epfd, struct epoll_event *events,\u00a0<\/code>int<\/code>\u00a0maxevents,\u00a0<\/code>int<\/code>\u00a0timeout);<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n

1. int epoll_create(int size);<\/strong><\/p>\n

\u521b\u5efa\u4e00\u4e2aepoll\u7684\u53e5\u67c4\uff0csize\u7528\u6765\u544a\u8bc9\u5185\u6838\u8fd9\u4e2a\u76d1\u542c\u7684\u6570\u76ee\u4e00\u5171\u6709\u591a\u5927\uff0c\u8fd9\u4e2a\u53c2\u6570\u4e0d\u540c\u4e8eselect()\u4e2d\u7684\u7b2c\u4e00\u4e2a\u53c2\u6570\uff0c\u7ed9\u51fa\u6700\u5927\u76d1\u542c\u7684fd+1\u7684\u503c\uff0c\u53c2\u6570size\u5e76\u4e0d\u662f\u9650\u5236\u4e86epoll\u6240\u80fd\u76d1\u542c\u7684\u63cf\u8ff0\u7b26\u6700\u5927\u4e2a\u6570\uff0c\u53ea\u662f\u5bf9\u5185\u6838\u521d\u59cb\u5206\u914d\u5185\u90e8\u6570\u636e\u7ed3\u6784\u7684\u4e00\u4e2a\u5efa\u8bae<\/span>\u3002<\/strong>\u5f53\u521b\u5efa\u597depoll\u53e5\u67c4\u540e\uff0c\u5b83\u5c31\u4f1a\u5360\u7528\u4e00\u4e2afd\u503c\uff0c\u5728Linux\u4e0b\u5982\u679c\u67e5\u770b\/proc\/$pid\/fd\/\uff0c\u662f\u80fd\u591f\u770b\u5230\u8fd9\u4e2afd\u7684\uff0c\u6240\u4ee5\u5728\u4f7f\u7528\u5b8cepoll\u540e\uff0c\u5fc5\u987b\u8c03\u7528close()\u5173\u95ed\uff0c\u5426\u5219\u53ef\u80fd\u5bfc\u81f4fd\u88ab\u8017\u5c3d\u3002<\/p>\n

2. int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);<\/strong><\/p>\n

\u51fd\u6570\u662f\u5bf9\u6307\u5b9a\u63cf\u8ff0\u7b26fd\u6267\u884cop\u64cd\u4f5c\u3002
\n– epfd\uff1a\u662fepoll_create()\u7684\u8fd4\u56de\u503c\u3002
\n– op\uff1a\u8868\u793a\u6dfb\u52a0\/\u5220\u9664\/\u4fee\u6539\u64cd\u4f5c\uff0c\u5206\u522b\u7528\u4e09\u4e2a\u5b8f\u6765\u8868\u793a\uff1a\u6dfb\u52a0EPOLL_CTL_ADD\uff0c\u5220\u9664EPOLL_CTL_DEL\uff0c\u4fee\u6539EPOLL_CTL_MOD\u3002\u8868\u793a\u6dfb\u52a0\u3001\u5220\u9664\u548c\u4fee\u6539\u5bf9fd\u7684\u76d1\u542c\u4e8b\u4ef6\u3002
\n– fd\uff1a\u662f\u9700\u8981\u76d1\u542c\u7684fd\uff08\u6587\u4ef6\u63cf\u8ff0\u7b26\uff09
\n– epoll_event\uff1a\u662f\u544a\u8bc9\u5185\u6838\u9700\u8981\u76d1\u542c\u4ec0\u4e48\u4e8b\uff0cstruct epoll_event\u7ed3\u6784\u5982\u4e0b\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
\n
\n
struct epoll_event {<\/code><\/div>\n
\u00a0\u00a0<\/code>__uint32_t events;\u00a0\u00a0<\/code>\/* Epoll events *\/<\/code><\/div>\n
\u00a0\u00a0<\/code>epoll_data_t data;\u00a0\u00a0<\/code>\/* User data variable *\/<\/code><\/div>\n
};<\/code><\/div>\n
<\/div>\n
\/\/events\u53ef\u4ee5\u662f\u4ee5\u4e0b\u51e0\u4e2a\u5b8f\u7684\u96c6\u5408\uff1a<\/code><\/div>\n
EPOLLIN \uff1a\u8868\u793a\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u53ef\u4ee5\u8bfb\uff08\u5305\u62ec\u5bf9\u7aefsocket\u6b63\u5e38\u5173\u95ed\uff09\uff1b<\/code><\/div>\n
EPOLLOUT\uff1a\u8868\u793a\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u53ef\u4ee5\u5199\uff1b<\/code><\/div>\n
EPOLLPRI\uff1a\u8868\u793a\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u6709\u7d27\u6025\u7684\u6570\u636e\u53ef\u8bfb\uff08\u8fd9\u91cc\u5e94\u8be5\u8868\u793a\u6709\u5e26\u5916\u6570\u636e\u5230\u6765\uff09\uff1b<\/code><\/div>\n
EPOLLERR\uff1a\u8868\u793a\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u53d1\u751f\u9519\u8bef\uff1b<\/code><\/div>\n
EPOLLHUP\uff1a\u8868\u793a\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u88ab\u6302\u65ad\uff1b<\/code><\/div>\n
EPOLLET\uff1a \u5c06EPOLL\u8bbe\u4e3a\u8fb9\u7f18\u89e6\u53d1(Edge Triggered)\u6a21\u5f0f\uff0c\u8fd9\u662f\u76f8\u5bf9\u4e8e\u9ed8\u8ba4\u7684\u6c34\u5e73\u89e6\u53d1(Level Triggered)\u6a21\u5f0f\u6765\u8bf4\u7684\u3002<\/code><\/div>\n
EPOLLONESHOT\uff1a\u53ea\u76d1\u542c\u4e00\u6b21\u4e8b\u4ef6\uff0c\u5f53\u76d1\u542c\u5b8c\u8fd9\u6b21\u4e8b\u4ef6\u4e4b\u540e\uff0c\u5982\u679c\u8fd8\u9700\u8981\u7ee7\u7eed\u76d1\u542c\u8fd9\u4e2asocket\u7684\u8bdd\uff0c\u9700\u8981\u518d\u6b21\u628a\u8fd9\u4e2asocket\u52a0\u5165\u5230EPOLL\u961f\u5217\u91cc<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n

3. int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);<\/strong><\/p>\n

\u7b49\u5f85epfd\u4e0a\u7684io\u4e8b\u4ef6\uff0c\u6700\u591a\u8fd4\u56demaxevents\u4e2a\u4e8b\u4ef6\u3002<\/p>\n

\u53c2\u6570events\u7528\u6765\u4ece\u5185\u6838\u5f97\u5230\u4e8b\u4ef6\u7684\u96c6\u5408\uff0cmaxevents\u544a\u4e4b\u5185\u6838\u8fd9\u4e2aevents\u6709\u591a\u5927\uff0c\u8fd9\u4e2amaxevents\u7684\u503c\u4e0d\u80fd\u5927\u4e8e\u521b\u5efaepoll_create()\u65f6\u7684size\uff0c\u53c2\u6570timeout\u662f\u8d85\u65f6\u65f6\u95f4\uff08\u6beb\u79d2\uff0c0\u4f1a\u7acb\u5373\u8fd4\u56de\uff0c-1\u5c06\u4e0d\u786e\u5b9a\uff0c\u4e5f\u6709\u8bf4\u6cd5\u8bf4\u662f\u6c38\u4e45\u963b\u585e\uff09\u3002\u8be5\u51fd\u6570\u8fd4\u56de\u9700\u8981\u5904\u7406\u7684\u4e8b\u4ef6\u6570\u76ee\uff0c\u5982\u8fd4\u56de0\u8868\u793a\u5df2\u8d85\u65f6\u3002<\/p>\n

\n
\n
\n
\n
\n\n\n\n
\n
\n
#include <stdio.h><\/code><\/div>\n
#include <stdlib.h><\/code><\/div>\n
#include <string.h><\/code><\/div>\n
#include <sys\/types.h><\/code><\/div>\n
#include <sys\/socket.h><\/code><\/div>\n
#include <netdb.h><\/code><\/div>\n
#include <unistd.h><\/code><\/div>\n
#include <fcntl.h><\/code><\/div>\n
#include <sys\/epoll.h><\/code><\/div>\n
#include <errno.h><\/code><\/div>\n
<\/div>\n
#define MAXEVENTS\u00a0<\/code>64<\/code><\/div>\n
<\/div>\n
static<\/code>\u00a0int<\/code>\u00a0make_socket_non_blocking (<\/code>int<\/code>\u00a0sfd)<\/code><\/div>\n
{<\/code><\/div>\n
\u00a0\u00a0<\/code>int<\/code>\u00a0flags, s;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>flags = fcntl (sfd, F_GETFL,\u00a0<\/code>0<\/code>);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(flags == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"fcntl\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>return<\/code>\u00a0-<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>flags |= O_NONBLOCK;<\/code><\/div>\n
\u00a0\u00a0<\/code>s = fcntl (sfd, F_SETFL, flags);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"fcntl\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>return<\/code>\u00a0-<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>return<\/code>\u00a00<\/code>;<\/code><\/div>\n
}<\/code><\/div>\n
<\/div>\n
static<\/code>\u00a0int<\/code>\u00a0create_and_bind (<\/code>char<\/code>\u00a0*port)<\/code><\/div>\n
{<\/code><\/div>\n
\u00a0\u00a0<\/code>struct addrinfo hints;<\/code><\/div>\n
\u00a0\u00a0<\/code>struct addrinfo *result, *rp;<\/code><\/div>\n
\u00a0\u00a0<\/code>int<\/code>\u00a0s, sfd;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>memset (&hints,\u00a0<\/code>0<\/code>, sizeof (struct addrinfo));<\/code><\/div>\n
\u00a0\u00a0<\/code>hints.ai_family = AF_UNSPEC;\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* Return IPv4 and IPv6 choices *\/<\/code><\/div>\n
\u00a0\u00a0<\/code>hints.ai_socktype = SOCK_STREAM;\u00a0<\/code>\/* We want a TCP socket *\/<\/code><\/div>\n
\u00a0\u00a0<\/code>hints.ai_flags = AI_PASSIVE;\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* All interfaces *\/<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>s = getaddrinfo (NULL, port, &hints, &result);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(s !=\u00a0<\/code>0<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>fprintf (stderr,\u00a0<\/code>\"getaddrinfo: %s\\n\"<\/code>, gai_strerror (s));<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>return<\/code>\u00a0-<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>for<\/code>\u00a0(rp = result; rp != NULL; rp = rp->ai_next)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>sfd = socket (rp->ai_family, rp->ai_socktype, rp->ai_protocol);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(sfd == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>continue<\/code>;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>s = bind (sfd, rp->ai_addr, rp->ai_addrlen);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(s ==\u00a0<\/code>0<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* We managed to bind successfully! *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>break<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>close (sfd);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(rp == NULL)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>fprintf (stderr,\u00a0<\/code>\"Could not bind\\n\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>return<\/code>\u00a0-<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>freeaddrinfo (result);<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>return<\/code>\u00a0sfd;<\/code><\/div>\n
}<\/code><\/div>\n
<\/div>\n
int<\/code>\u00a0main (<\/code>int<\/code>\u00a0argc,\u00a0<\/code>char<\/code>\u00a0*argv[])<\/code><\/div>\n
{<\/code><\/div>\n
\u00a0\u00a0<\/code>int<\/code>\u00a0sfd, s;<\/code><\/div>\n
\u00a0\u00a0<\/code>int<\/code>\u00a0efd;<\/code><\/div>\n
\u00a0\u00a0<\/code>struct epoll_event event;<\/code><\/div>\n
\u00a0\u00a0<\/code>struct epoll_event *events;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(argc !=\u00a0<\/code>2<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>fprintf (stderr,\u00a0<\/code>\"Usage: %s [port]\\n\"<\/code>, argv[<\/code>0<\/code>]);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>exit (EXIT_FAILURE);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>sfd = create_and_bind (argv[<\/code>1<\/code>]);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(sfd == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>s = make_socket_non_blocking (sfd);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>s = listen (sfd, SOMAXCONN);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"listen\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>efd = epoll_create1 (<\/code>0<\/code>);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(efd == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"epoll_create\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>event.data.fd = sfd;<\/code><\/div>\n
\u00a0\u00a0<\/code>event.events = EPOLLIN | EPOLLET;<\/code><\/div>\n
\u00a0\u00a0<\/code>s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);<\/code><\/div>\n
\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"epoll_ctl\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>\/* Buffer where events are returned *\/<\/code><\/div>\n
\u00a0\u00a0<\/code>events = calloc (MAXEVENTS, sizeof event);<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>\/* The event loop *\/<\/code><\/div>\n
\u00a0\u00a0<\/code>while<\/code>\u00a0(<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>int<\/code>\u00a0n, i;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>n = epoll_wait (efd, events, MAXEVENTS, -<\/code>1<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>for<\/code>\u00a0(i =\u00a0<\/code>0<\/code>; i < n; i++)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0((events[i].events & EPOLLERR) ||<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>(events[i].events & EPOLLHUP) ||<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>(!(events[i].events & EPOLLIN)))<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* An error has occured on this fd, or the socket is not<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>ready for reading (why were we notified then?) *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>fprintf (stderr,\u00a0<\/code>\"epoll error\\n\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>close (events[i].data.fd);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>continue<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>else<\/code>\u00a0if<\/code>\u00a0(sfd == events[i].data.fd)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* We have a notification on the listening socket, which<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>means one or more incoming connections. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>while<\/code>\u00a0(<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>struct sockaddr in_addr;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>socklen_t in_len;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>int<\/code>\u00a0infd;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>char<\/code>\u00a0hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>in_len = sizeof in_addr;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>infd = accept (sfd, &in_addr, &in_len);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(infd == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0((errno == EAGAIN) ||<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>(errno == EWOULDBLOCK))<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* We have processed all incoming<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>connections. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>break<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>else<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"accept\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>break<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>s = getnameinfo (&in_addr, in_len,<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>hbuf, sizeof hbuf,<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>sbuf, sizeof sbuf,<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>NI_NUMERICHOST | NI_NUMERICSERV);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(s ==\u00a0<\/code>0<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>printf(<\/code>\"Accepted connection on descriptor %d \"<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\"(host=%s, port=%s)\\n\"<\/code>, infd, hbuf, sbuf);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* Make the incoming socket non-blocking and add it to the<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>list of fds to monitor. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>s = make_socket_non_blocking (infd);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>event.data.fd = infd;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>event.events = EPOLLIN | EPOLLET;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"epoll_ctl\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>continue<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>else<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* We have data on the fd waiting to be read. Read and<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>display it. We must read whatever data is available<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>completely, as we are running in edge-triggered mode<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>and won't get a notification again for the same<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>data. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>int<\/code>\u00a0done =\u00a0<\/code>0<\/code>;<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>while<\/code>\u00a0(<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>ssize_t count;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>char<\/code>\u00a0buf[<\/code>512<\/code>];<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>count = read (events[i].data.fd, buf, sizeof buf);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(count == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* If errno == EAGAIN, that means we have read all<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>data. So go back to the main loop. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(errno != EAGAIN)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"read\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>done =\u00a0<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>break<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>else<\/code>\u00a0if<\/code>\u00a0(count ==\u00a0<\/code>0<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* End of file. The remote has closed the<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>connection. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>done =\u00a0<\/code>1<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>break<\/code>;<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* Write the buffer to standard output *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>s = write (<\/code>1<\/code>, buf, count);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(s == -<\/code>1<\/code>)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>perror (<\/code>\"write\"<\/code>);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>abort ();<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>if<\/code>\u00a0(done)<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>{<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>printf (<\/code>\"Closed connection on descriptor %d\\n\"<\/code>,<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>events[i].data.fd);<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>\/* Closing the descriptor will make epoll remove it<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>from the set of descriptors which are monitored. *\/<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>close (events[i].data.fd);<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
\u00a0\u00a0\u00a0\u00a0<\/code>}<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>free (events);<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>close (sfd);<\/code><\/div>\n
<\/div>\n
\u00a0\u00a0<\/code>return<\/code>\u00a0EXIT_SUCCESS;<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n
\u53c2\u8003\u94fe\u63a5\uff1a<\/h5>\n

https:\/\/banu.com\/blog\/2\/how-to-use-epoll-a-complete-example-in-c\/<\/a><\/p>\n

epoll \u4f7f\u7528\u8be6\u89e3
\nhttp:\/\/www.cnblogs.com\/haippy\/archive\/2012\/01\/09\/2317269.html<\/a><\/p>\n

linux \u7f51\u7edc\u7f16\u7a0b\uff1aepoll \u7684\u5b9e\u4f8b
\nhttp:\/\/blog.csdn.net\/shanshanpt\/article\/details\/7383400<\/a><\/p>\n

\u5982\u4f55\u4f7f\u7528epoll\uff1f\u4e00\u4e2a\u5b8c\u6574\u7684C\u4f8b\u5b50
\nhttp:\/\/www.yeolar.com\/note\/2012\/07\/02\/epoll-example\/<\/a><\/p>\n

\u901a\u8fc7\u5b8c\u6574\u793a\u4f8b\u6765\u7406\u89e3\u5982\u4f55\u4f7f\u7528 epoll
\nhttp:\/\/blog.jobbole.com\/93566\/<\/a><\/p>\n

\u6211\u8bfb\u8fc7\u7684\u6700\u597d\u7684epoll\u8bb2\u89e3–\u8f6c\u81ea\u201c\u77e5\u4e4e\u201d
\nhttp:\/\/yaocoder.blog.51cto.com\/2668309\/888374<\/a>
\nhttps:\/\/www.zhihu.com\/question\/20122137\/answer\/14049112<\/a><\/p>\n

http:\/\/man7.org\/linux\/man-pages\/man7\/epoll.7.html<\/a>
\nhttp:\/\/man7.org\/linux\/man-pages\/man2\/epoll_create.2.html<\/a>
\nhttp:\/\/man7.org\/linux\/man-pages\/man2\/epoll_ctl.2.html<\/a>
\nhttp:\/\/man7.org\/linux\/man-pages\/man2\/epoll_wait.2.html<\/a><\/p>\n

=END=<\/p>\n","protected":false},"excerpt":{"rendered":"

=Start= \u7f18\u7531\uff1a \u5b66\u4e60\u3001\u63d0\u9ad8\u9700\u8981 \u6b63\u6587\uff1a \u53c2\u8003\u89e3\u7b54\uff1a epoll\u7f16\u7a0b\u63a5\u53e3\u4ecb\u7ecd epoll\u5728\u7f16\u7a0b\u4e2d\u6709\u4e09\u4e2a\u63a5 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[23,11,7],"tags":[100,906,30],"class_list":["post-3509","post","type-post","status-publish","format-standard","hentry","category-knowledgebase-2","category-linux","category-programing","tag-c","tag-epoll","tag-linux"],"views":3563,"_links":{"self":[{"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/posts\/3509","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/comments?post=3509"}],"version-history":[{"count":1,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/posts\/3509\/revisions"}],"predecessor-version":[{"id":3510,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/posts\/3509\/revisions\/3510"}],"wp:attachment":[{"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/media?parent=3509"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/categories?post=3509"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/ixyzero.com\/blog\/wp-json\/wp\/v2\/tags?post=3509"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}