请教一个EPOLL有关的问题。监听多个端口

Marsduan

最近看了下epoll，按照epoll模型写了一个测试程序。监听一个端口，处理大量链接 。
接下来，我就想，同时监听多个端口。
我将创建好的socket_fd存储在数组sock_fd[]中。
我想请教一下，接下来我该怎么做呢。

ruchong

把每个监听的套接字调用
struct epoll_event ev;
    bzero(&ev , sizeof(ev));
    ev.events = EPOLLIN | EPOLLET | EPOLLPRI | EPOLLERR;
    ev.data.fd = fd;

    if(epoll_ctl(epfd , EPOLL_CTL_ADD , fd , &ev)<0)
    {
        return false;
    }

然后再epoll_wait() 等代client的连接...........

Marsduan

原帖由 ruchong 于 2008-7-10 11:43 发表
把每个监听的套接字调用
struct epoll_event ev;
    bzero(&ev , sizeof(ev));
    ev.events = EPOLLIN | EPOLLET | EPOLLPRI | EPOLLERR;
    ev.data.fd = fd;

    if(epoll_ctl(epfd , EPOLL_CTL_ ...

我现在是这么做了一下
sock_fd[max]
for(i=0;i<count;i++)
{
    ev.events=EPOLLIN|EPOLLET;
    if(epoll_ctl(epfd,EPOLL_CTL_ADD,sock_fd,&ev)<0)
    {
         perror("epoll_ctl";
         return -1;
    }
}

for(;
{
    nfds=epoll_wait(epfd,events,256,500);
    for(n=0;n<nfds;++n)
    {
            //在这里我该如何处理已经加入ev的fd呢
            //
     }
}

aoegiss

epoll_event 里面有个64位东西，拆开用 32位保存fd  32位保存标识.....
还可以 Per IO Data

我的Smarthttpd里面就是这么用的，可以Listen多个端口

ruchong

int nfds = epoll_wait(epfd , events , 100 , -1);
    for(int i=0; i<nfds; i++)
    {
        for(int j=0; j<queSockfd.size(); j++)
        {
            fd = queSockfd[j];
            if(fd == events.data.fd)
            {
                ///指定套接口上的连接
                break;
            }
        }

aoegiss

不用遍历啊

ruchong

不遍历好像不知道那个套接字上的连接.....

Marsduan

原帖由 aoegiss 于 2008-7-10 12:15 发表
epoll_event 里面有个64位东西，拆开用 32位保存fd  32位保存标识.....
还可以 Per IO Data

我的Smarthttpd里面就是这么用的，可以Listen多个端口

typedef union epoll_data {
void *ptr;
int fd;
__uint32_t u32;
__uint64_t u64;
} epoll_data_t;

你说的是__uint32_t u32吗？
具体怎么做的呢？

Marsduan

我现在这样做的
sock_fd[max]
for(i=0;i<count;i++)
{
    ev.events=EPOLLIN|EPOLLET;
    if(epoll_ctl(epfd,EPOLL_CTL_ADD,sock_fd,&ev)<0)
    {
         perror("epoll_ctl";
         return -1;
    }
}

for(;
{
    nfds=epoll_wait(epfd,events,256,500);
    for(n=0;n<nfds;++n)
    {
           for(int j =0;j<count;j++)
           {
                 new_fd=sock_fd;
                 if(new_fd==events[n].data.fd)
                  {
                        int test_fd=accept(new_fd,(struct sockaddr *)&CLI,&len);
                         ev.events=EPOLLIN|EPOLLET;
                           setnonblock(new_fd);
                          ev.data.fd=test_fd;
                         epoll_ctl(epfd,EPOLL_CTL_ADD,test_fd,&ev);
                    }
                   else if(events.events & EPOLLIN)
                  {
                          int ret=recv(events[n].data.fd,buf,MAXBUFF,0);
                          if(ret < 0 )
                              perror("recv");
                         if(ret》0)
                      …………
                 if(ret == 0)
                            ………………
                  }
            }
     }
}


运行测试，报错，recv： socket operation on non-socket

ruchong

应该是
new_fd=sock_fd[j]