请教 EPOLL 使用问题

qinyd

使用EPOLL , 的TCP服务器
生成俩个epoll fd , 一个用于接收，一个用于发送 ,这样做是否正确

我使用下面的模型时发生过两种异常情况：
1。因为我的Send函数是给其他消息处理线程调用的，会发生处理线程挂住的情况，但是过一段时间(1,2小时，没具体看)又恢复了，经过跟踪，应该是挂在 Send函数这里
2. 程序运行了几天后，很多新连接上来，接受处理完第一个包后，调用Send返回时，socket 就收到 input/output error 的错误，然后关闭了socket。但是有少部分连接可以成功

1. 
   
2. epSendfd = epoll_create(1);
   
3. epRecvfd = epoll_create(MAX_SOCKET_NUM);
   
4. 
   
5. 每有一个新连接上来
   
6. struct epoll_event ev;
   
7. ev.data.fd=fd;
   
8. ev.events=EPOLLIN|EPOLLET;
   
9. epoll_ctl(epRecvfd,EPOLL_CTL_ADD,fd,&ev);
   
10. 
    
11. 接收是一个接收线程完成,做的事情就是
    
12. while(IsExit() == false)
    
13. {
    
14. 
    
15. int nfds=epoll_wait(epRecvfd,events,MAX_SOCKET_NUM,400);
    
16. ....
    
17. }
    
18. 
    
19. 发送只是提供一个函数，给其他处理线程调用
    
20. int CTTcpBase::Send(unsigned int id, const char* buffer, int length)
    
21. {
    
22. 。。。
    
23. struct epoll_event ev,events[1];
    
24. ev.data.fd=fd;
    
25. ev.events=EPOLLOUT|EPOLLET;
    
26. epoll_ctl(epSendfd,EPOLL_CTL_ADD,fd,&ev);
    
27. 
    
28. int nfds=epoll_wait(epSendfd,events,1,400);
    
29. ...
    
30. ret = ::send(fd, buffer + write, length - write, 0);
    
31. ...
    
32. epoll_ctl(epSendfd,EPOLL_CTL_DEL,fd,&ev);
    
33. }
    
34. 
    

复制代码

我想问问，当对于一个连接fd,同时发生
epoll_wait(epRecvfd,events,MAX_SOCKET_NUM,400);
和
epoll_wait(epSendfd,events,1,400);
会不会有问题

[ 本帖最后由 qinyd 于 2006-12-16 22:02 编辑 ]

qinyd

顺便问问 我的 send函数 这样写有没有问题

1. 
   
2. int CTTcpBase::Send(unsigned int id, const char* buffer, int length)
   
3. {
   
4.         SOCKET fd = m_pSocketSet->GetSocketID(id);
   
5.         if(fd == INVALID_SOCKET)
   
6.                 return -1;
   
7.        
   
8.         int ret = 0;
   
9.         int write = 0;
   
10.         //struct pollfd rset[1];
    
11.         struct epoll_event ev,events[1];
    
12. 
    
13.                
    
14.         ev.data.fd=fd;
    
15.         ev.events=EPOLLOUT|EPOLLET;
    
16.         epoll_ctl(epSendfd,EPOLL_CTL_ADD,fd,&ev);
    
17. 
    
18.         while(write < length)
    
19.         {
    
20.                
    
21.                 int nfds=epoll_wait(epSendfd,events,1,400);  
    
22.                 if(nfds < 0)
    
23.                 {
    
24.                         if(m_pLog)
    
25.                         {
    
26.                                 m_pLog->print("[TCP %d] WARN! select socket error while sending packet\n",
    
27.                                                           id);
    
28.                         }
    
29.                         DelListen(epRecvfd,fd);
    
30.                         m_pSocketSet->DeleteSocket(id);
    
31.                         return -1;               
    
32.                 }
    
33. 
    
34.                 ret = ::send(fd, buffer + write, length - write, 0);
    
35.                 if(ret == SOCKET_ERROR || ret == 0)
    
36.                 {
    
37.                         if(m_pLog)
    
38.                                 m_pLog->print("[TCP %d] WARN! send packet error!\n", id);
    
39.                         DelListen(epRecvfd,fd);
    
40.                         m_pSocketSet->DeleteSocket(id);
    
41.                         return -1;
    
42.                 }
    
43. 
    
44.                 write += ret;
    
45.         }
    
46.         epoll_ctl(epSendfd,EPOLL_CTL_DEL,fd,&ev);
    
47. 
    
48.         return 0;
    
49. }
    

复制代码

[ 本帖最后由 qinyd 于 2006-12-16 21:58 编辑 ]