kqueue example

@sky

               
               
                #include sys/types.h>
#include netinet/in.h>
#include sys/event.h>
#include sys/time.h>
#include sys/socket.h>
#include sys/types.h>
#include arpa/inet.h>
#include unistd.h>
#include stdlib.h>
#include string.h>
#include stdio.h>
#define err(msg) perror(msg)
#define SA struct sockaddr
struct event
{
        int fd;
        void (*handle)(struct event *);
};
static int tcp_listen(void)
{
        struct sockaddr_in addr;
        int fd;
        if ((fd = socket(PF_INET, SOCK_STREAM, 0)) == -1)
        {
                err("socket");
                return -1;
        }
        memset(&addr, '\0', sizeof(struct sockaddr_in));
        addr.sin_family = AF_INET;
        addr.sin_port = htons(8888);
        if (inet_pton(AF_INET, "0.0.0.0", &addr.sin_addr) = 0)
        {
                err("inet_pton");
                goto err;
        }
        if (bind(fd, (SA *)&addr, sizeof(struct sockaddr_in)) == -1)
        {
                err("bind");
                goto err;
        }
        if (listen(fd, 10) == -1)
        {
                err("listen");
                goto err;
        }
        return fd;
err:
        close(fd);
        return -1;
}
static void listen_readable(struct event *e)
{
        int connfd;
        connfd = accept(e->fd, NULL, NULL);
        printf("connfd = %d\n", connfd);
        close(connfd);
}
int main(void)
{
        int fd;
        int kq;
        int nfds;
        struct kevent ev, rev[2];
        if ((fd = tcp_listen()) == -1)
        {
                err("tcp_listen");
                return -1;
        }
        if ((kq = kqueue()) == -1)
        {
                err("kqueue");
                goto err;
        }
        struct event e;
        e.fd = fd;
        e.handle = listen_readable;
        EV_SET(&ev, fd, EVFILT_READ, EV_ADD, 0, 0, &e);
        while (1)
        {
                nfds = kevent(kq, &ev, 1, rev, 2, NULL);
                if (nfds = 0)
                {
                        err("kevent");
                        goto kevent_err;
                }
                for (int i = 0; i  nfds; i++)
                {
                        struct event *re = rev.udata;
                        if (re)
                                re->handle(re);
                }
        }
        return 0;
kevent_err:
        close(kq);
err:
        close(fd);
        return -1;
}


本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u2/63604/showart_2040386.html