epoll server, 客户端关闭时陷入死循环

akwhole

下午测试EPOLLIN、EPOLLOUT的用法.

服务端关键代码如下:

1. for(i=0; i < nfds; i++)
   
2. {
   
3.         fd = events[i].data.fd;
   
4.         printf("event is %d\n",events[i].events);
   
5. 
   
6.         if(fd == listen_fd)
   
7.         {
   
8.                         conn_sock = accept(listen_fd, (struct sockaddr *)&addr_client, &addrlen);
   
9.                         if(conn_sock < 0)
   
10.                         {
    
11.                                         perror("[main]accept error1");
    
12.                                         exit(1);
    
13.                         }
    
14.                         set_non_block(conn_sock);
    
15.                         ev.events = EPOLLET | EPOLLIN;
    
16.                         ev.data.fd = conn_sock;
    
17.                         if(-1 == epoll_ctl(epoll_fd, EPOLL_CTL_ADD, conn_sock, &ev))
    
18.                         {      
    
19.                                         perror("[main]epoll ctl failed!");
    
20.                                         exit(1);
    
21.                         }      
    
22.                         printf("client IP:%s Port:%d connect success!\n",inet_ntoa(addr_client.sin_addr),addr_client.sin_port);
    
23.         }  
    
24.         else if(events[i].events & EPOLLIN)
    
25.         {      
    
26.                 char buff[50] = {0};
    
27.                 read(fd, buff, 50);
    
28. 
    
29.                 printf("EPOLL EVENTS %d\n", events[i].events);
    
30.                 printf("EPOLLIN\n");
    
31.                 events[i].events = EPOLLOUT | EPOLLET;
    
32.                 epoll_ctl(epoll_fd, EPOLL_CTL_MOD, fd, &events[i]);
    
33. 
    
34.                 printf("%s\n",buff);
    
35.                 printf("change to EPOLLOUT\n");
    
36.                 /*      
    
37.                 if(strlen(buff) == 0)
    
38.                 {
    
39.                         close(fd);
    
40.                 }
    
41.                 */  
    
42.         }      
    
43.         else if(events[i].events & EPOLLOUT)
    
44.         {      
    
45.                 printf("EPOLL EVENTS %d\n", events[i].events);
    
46.                 printf("EPOLLOUT\n");
    
47.                 events[i].events = EPOLLIN | EPOLLET;
    
48.                 epoll_ctl(epoll_fd, EPOLL_CTL_MOD, fd, &events[i]);
    
49.                 printf("change to EPOLLIN\n");
    
50.         }
    
51.         printf("next chu fa\n");
    
52. }

复制代码

客户端代码比较简单

1. int main()
   
2. {
   
3.         int connect_fd;
   
4.         int ret;
   
5.         int port = 50105;
   
6.         struct sockaddr_in srv_addr;
   
7. 
   
8.         connect_fd = socket(AF_INET, SOCK_STREAM, 0);
   
9. 
   
10.         if(connect_fd < 0)
    
11.         {      
    
12.                         perror("cannot create communication socket");
    
13.                         return 1;
    
14.         }      
    
15.         memset(&srv_addr, 0, sizeof(srv_addr));
    
16.         srv_addr.sin_family = AF_INET;
    
17.         srv_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    
18.         srv_addr.sin_port = htons(port);
    
19.         ret = connect(connect_fd, (struct sockaddr*)&srv_addr, sizeof(srv_addr));
    
20. 
    
21.         if(-1 == ret)
    
22.         {      
    
23.                         perror("cannot connect to the server");
    
24.                         printf("[CONNECT_ERROR]%s\n",strerror(errno));
    
25.                         return 1;
    
26.         }      
    
27. 
    
28.         sleep(5);
    
29.         printf("try write\n");
    
30.         write(connect_fd, "hello server!", 13);
    
31.         printf("write orver\n");
    
32.         sleep(10);
    
33.         return 0;
    
34. }

复制代码

问题是:  客户端write操作后, EPOLLIN 、EPOLLOUT 各触发一次.
           但是客户端关闭时, 未将fd从epoll中清除,  这是EPOLLIN、EPOLLOUT 交替触发,陷入死循环.   
           
           没想明白为什么会陷入死循环? 恳请高手指点下,谢谢.

linux_c_py_php

你不检查read=0, 怎么知道何时关闭?

akwhole

对，如你所说.可以通过read到的大小判断客户端关闭.
我这里暂时不关心这个.
死循环的输出是在客户端退出后出现的.所以我知道是客户端关闭了.

主要关心, 产生死循环的原因.
回复 2# linux_c_py_php


   

linux_c_py_php

EOF始终可读啊, 当然死循环啊.

akwhole

谢谢，还有点疑问, 为什么write操作没有陷入死循环? 求指点.回复 4# linux_c_py_php


   

akwhole

我测试下, 是不是阻塞在read上了.

linux_c_py_php

因为你注册的ET啊, 通知一次就不通知了.

linux_c_py_php

这年头哪有人用ET啊, 用LT吧, ET要讲究一些不好弄.

netcos

楼主在ET模式下触发了EPOLLIN事件，但是并没有调用read将数据从缓冲区读出，由于已经监听过一次EPOLLIN，将不会再触发EPOLLIN事件，（ET模式下触发EPOLLIN事件必须将缓冲区的数据全部读完，否则以后将无法再次触发该事件）。但关闭客户端的时候，服务端检测到缓冲区中有数据未读完将再次触发EPOLLIN事件，但是楼主依然没有读出缓存的数据反而更改成EPOLLOUT状态，在EPOLLOUT事件中楼主再次更改成EPOLLIN事件，这样不断反复就变成死循环了

akwhole

首先谢谢楼上两位的帮忙.
linux_c_py_php 提醒了我, 缓冲区可读.

我测试了下.

修改服务端read 一次只读2个字符
read(fd, buff, 2);

服务端依次输出
he
ll
o
se
rv
er
!

然后阻塞在read调用上, 没有继续, 这也是没有陷入死循环的原因.   

总结的话:
1.EPOLLIN、EPOLLOUT  可以通过修改注册事件 进行触发.
  epoll_ctl(epoll_fd, EPOLL_CTL_MOD, fd, &ev);
2.这种交替切换事件的方式可以把缓冲区数据全部读完. (采用非阻塞读写,读到的内容长度少于预期时, 认为已经读完, 终止切换)

所贴代码纯粹是为了测试, 尤其是EPOLLIN中的read操作,采用阻塞读, 多个客户端进行请求时,  是有问题的.