epoll

#include
#include
#include
#include
#include
#include
#include
#include
#include

#define SVRPORT 8888
#define LSNNEM 5
#define MAX_EVENTS 10

int setnonblocking(int sock);

int main()
{
        int sfd, cfd;
        struct sockaddr_in saddr;
        char buf[512];

    int nfds;
    int n;

    int epollfd;
    struct epoll_event ev, *evp;
    struct epoll_event events[MAX_EVENTS];

        memset(&saddr,0,sizeof(saddr));
        saddr.sin_family = AF_INET;
        saddr.sin_port = htons(SVRPORT);
        saddr.sin_addr.s_addr = htonl(INADDR_ANY);

        sfd = socket(AF_INET,SOCK_STREAM,0);
        bind(sfd,(struct sockaddr *)&saddr,sizeof(saddr));
        listen(sfd,LSNNEM);

    epollfd = epoll_create(10);
   
    ev.events = EPOLLIN;
    ev.data.fd = sfd;
    epoll_ctl(epollfd, EPOLL_CTL_ADD, sfd, &ev);

    while(1) {
        nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);

        for (n = 0; n < nfds; ++n) {
            evp = &events[n];
           
            if (evp->data.fd == sfd) {
                cfd = accept(sfd, NULL, NULL);

                setnonblocking(cfd);
                ev.events = EPOLLIN | EPOLLOUT | EPOLLET;
                ev.data.fd = cfd;
                epoll_ctl(epollfd, EPOLL_CTL_ADD, cfd, &ev);
            } else {
                if (evp->events == EPOLLOUT) {
                    memset(buf,'\0',strlen(buf));
                    strcpy(buf,"hello!\n");
                    send(evp->data.fd, buf,strlen(buf)+1,0);
                    epoll_ctl(epollfd, EPOLL_CTL_DEL, cfd, NULL);
                    close(evp->data.fd);
                }
            }
        }
    }
}

int setnonblocking(int sock)
{
    int opts;
    opts = fcntl(sock, F_GETFL);
    opts |= O_NONBLOCK;

    fcntl(sock, F_SETFL, opts);

    return 0;
}