一个简单的sock i/o程序,客户端用epoll,陷入了死循环

donet8

一个程序里面，父进程是服务器端，创建一个子进程当客户端。
服务器端每隔1s钟发送一个消息，子进程接受并打印出来。

但我运行的结果却是:
Get EPOLLIN
Get EPOLLIN
Get EPOLLIN
Get EPOLLIN
Get EPOLLIN
Get EPOLLIN
Get EPOLLIN
不断打印。

代码的问题在哪儿? 我怀疑我epoll模型用的不对。网上说epoll_wait之后要重新epoll_ctl，这个是可选的还是必须做的?

1. 
   
2. #include<arpa/inet.h>
   
3. #include<signal.h>
   
4. #include<stdio.h>
   
5. #include<string.h>
   
6. #include<sys/epoll.h>
   
7. #include<sys/socket.h>
   
8. #include<sys/types.h>
   
9. #include<unistd.h>
   
10. void server(void)
    
11. {
    
12.     int sockSrv=socket(AF_INET,SOCK_STREAM,0);
    
13.     if(sockSrv==-1)return;
    
14.     sockaddr_in sAddr;
    
15.     sAddr.sin_family=AF_INET;
    
16.     sAddr.sin_port =htons(34567);
    
17.     sAddr.sin_addr.s_addr =htonl(INADDR_ANY);
    
18.     if(-1 == bind( sockSrv, (sockaddr*)&sAddr, sizeof( sockaddr )))return;
    
19.     if(-1 == listen(sockSrv,0))return;
    
20.     socklen_t cbAddr = sizeof(sockaddr);
    
21.     while(1){
    
22.         int iAccSock = accept(sockSrv, (sockaddr*)&sAddr, &cbAddr );
    
23.         if(iAccSock==-1)return;
    
24.         printf("Server: Accepted!\n");
    
25.         long i=0;
    
26.         while(1){
    
27.             char buf[6]={0};
    
28.             sprintf(buf,"%d",++i);
    
29.             if(-1 == send(iAccSock,buf,strlen(buf),0) ){
    
30.                 printf("Server: send error\n");
    
31.                 close(iAccSock);
    
32.                 break;
    
33.             }
    
34.             printf("Server: data sent=%s\n",buf);
    
35.             sleep(1);
    
36.         }
    
37.         close(iAccSock);
    
38.     }
    
39. }
    
40. int createPoll(int hClient)
    
41. {
    
42.     int fd_epoll = epoll_create(1);
    
43.     if(fd_epoll==-1)
    
44.     {
    
45.         printf("epoll_create failed\n");
    
46.         return 0;
    
47.     }
    
48.     epoll_event ee;
    
49.     ee.events=EPOLLIN;
    
50.     int ret=epoll_ctl(fd_epoll,EPOLL_CTL_ADD,hClient,&ee);
    
51.     if(ret==-1)
    
52.     {
    
53.         printf("epoll_ctl failed\n");
    
54.         return 0;
    
55.     }
    
56.     while(true)
    
57.     {
    
58.         int fd=epoll_wait(fd_epoll,&ee,1,-1);
    
59.         if(fd<0)
    
60.         {
    
61.             printf("epoll_wait error\n");
    
62.             continue;
    
63.         }
    
64.         if(ee.events&EPOLLIN)
    
65.         {
    
66.         printf("Got EPOLLIN\n");
    
67.             if(ee.data.fd==hClient)
    
68.             {
    
69.                 char buf[1024]={0};
    
70.                 if(0>=recv(hClient,buf,sizeof(buf),0)){
    
71.                     printf("Client: recv error\n");
    
72.                     break;
    
73.         }
    
74.                 printf("Client: recv=%s\n",buf);
    
75.             }
    
76.         }
    
77.     }//end while
    
78. }
    
79. 
    
80. void client(void)
    
81. {
    
82.     int hClient=socket(AF_INET,SOCK_STREAM,0);
    
83.     if(hClient==-1)return;
    
84.     sockaddr_in sAddr;
    
85.     sAddr.sin_family=AF_INET;
    
86.     sAddr.sin_port  =htons(34567);
    
87.     sAddr.sin_addr.s_addr=inet_addr("127.0.0.1");
    
88.     if( -1==connect( hClient, (sockaddr*)&sAddr, sizeof(sockaddr) ) )
    
89.     {
    
90.         printf("Client: Async connect error\n");
    
91.         return;
    
92.     }
    
93. 
    
94.     printf("Client: Connected\n");
    
95.     createPoll(hClient);
    
96.     close(hClient);
    
97.     return;
    
98. }
    
99. 
    
100. int main(void)
     
101. {
     
102.     pid_t pid=fork();
     
103.     if(pid==0)
     
104.     {//child
     
105.     sleep(1);
     
106.         client();
     
107.     }
     
108.     else//father
     
109.     {
     
110.         server();
     
111.     }
     
112.     return 0;
     
113. }
     

复制代码

五元

不了解怎么回事

但是
if ( ee.data.fd == hClient )
没有这个条件的时候可以正常输出

或者
struct epoll_event   ee;
ee.events = EPOLLIN;
ee.data.fd = hClient;
且
if ( ee.data.fd == hClient )
也可以正常输出。

ua

ee.data.fd = hClient;加入47行后边

ua

源码修改了一下，如下

#include<arpa/inet.h>
#include<signal.h>
#include<stdio.h>
#include<string.h>
#include<sys/epoll.h>
#include<sys/socket.h>
#include<sys/types.h>
#include<unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <sys/epoll.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>

void server(void)
{
    int sockSrv=socket(AF_INET,SOCK_STREAM,0);
    if(sockSrv==-1)return;
    struct sockaddr_in sAddr;
    sAddr.sin_family=AF_INET;
    sAddr.sin_port =htons(34567);
    sAddr.sin_addr.s_addr =htonl(INADDR_ANY);
    if(-1 == bind( sockSrv, (struct sockaddr*)&sAddr, sizeof( struct sockaddr )))return;
    if(-1 == listen(sockSrv,0))return;
    socklen_t cbAddr = sizeof(struct sockaddr);
    while(1){
        int iAccSock = accept(sockSrv, (struct sockaddr*)&sAddr, &cbAddr );
        if(iAccSock==-1)return;
        printf("Server: Accepted!\n");
        long i=0;
        while(1){
            char buf[6]={0};
            sprintf(buf,"%d",++i);
            if(-1 == send(iAccSock,buf,strlen(buf),0) ){
                printf("Server: send error\n");
                close(iAccSock);
                break;
            }
            printf("Server: data sent=%s\n",buf);
            sleep(1);
        }
        close(iAccSock);
    }
}
int createPoll(int hClient)
{
    printf("hClient = %d\n", hClient);
    int fd_epoll = epoll_create(1);
    if(fd_epoll==-1)
    {
        printf("epoll_create failed\n");
        return 0;
    }
    struct epoll_event ee;
    ee.data.fd = hClient;
    ee.events=EPOLLIN;
    printf("fd_epoll = %d\n", fd_epoll);
    int ret=epoll_ctl(fd_epoll,EPOLL_CTL_ADD,hClient,&ee);
    if(ret==-1)
    {
        printf("epoll_ctl failed\n");
        return 0;
    }
    while(1)
    {
        int fd=epoll_wait(fd_epoll,&ee,1,-1);
        if(fd<0)
        {
            printf("epoll_wait error\n");
            continue;
        }
        if(ee.events&EPOLLIN)
        {
            printf("Got EPOLLIN\n");
            printf("event.data.fd = %d\n", ee.data.fd);
            //if(ee.data.fd==hClient)
            {
                char buf[1024]={0};
                if(0>=recv(hClient,buf,sizeof(buf),0)){
                    printf("Client: recv error\n");
                    break;
                }
                printf("Client: recv=%s\n",buf);
            }
        }
    }//end while
}

void client(void)
{
    int hClient=socket(AF_INET,SOCK_STREAM,0);
    if(hClient==-1)return;
    struct sockaddr_in sAddr;
    sAddr.sin_family=AF_INET;
    sAddr.sin_port  =htons(34567);
    sAddr.sin_addr.s_addr=inet_addr("127.0.0.1");
    if( -1==connect( hClient, (struct sockaddr*)&sAddr, sizeof(struct sockaddr) ) )
    {
        printf("Client: Async connect error\n");
        return;
    }

    printf("Client: Connected\n");
    createPoll(hClient);
    close(hClient);
    return;
}

int main(void)
{
    pid_t pid=fork();
    if(pid==0)
    {//child
    sleep(1);
        client();
    }
    else//father
    {
        server();
    }
    return 0;
}

ua

:wink没有分