郁闷的select出错:Bad file descriptor

converse

第一次select的是server的socket,accept一个连接的fd之后加入select,再select就出错了...

在select之前清空fdset,重新把可用的fd 放入fdset,以及select时maxfd+1等问题我都查过了,仍然找不到出错的原因....

converse

1. 
   
2. int CMsgServer::Run()
   
3. {
   
4.     // 清空读fdset
   
5.     FD_ZERO(&m_ReadSet);
   
6. 
   
7.     // 获取当前的时间
   
8.     m_nCurrTime = time(NULL);
   
9. 
   
10.     // 查询超时的fd
    
11.     CheckTimeoutFd();
    
12. 
    
13.     // 轮询fdset
    
14.     if (0 != Poll())
    
15.     {
    
16.         return -1;
    
17.     }
    
18. 
    
19.     // 处理fdset
    
20.     ProcessFdSet();
    
21.    
    
22.     return 0;
    
23. }
    
24. 
    
25. void CMsgServer::CheckTimeoutFd()
    
26. {
    
27.     int nFd;
    
28. 
    
29.     m_nMaxFd = m_nListenFd;
    
30. 
    
31.     for (m_Iter1 = m_listCon.begin(), m_Iter2 = m_listCon.end(); m_Iter1 != m_Iter2;)
    
32.     {
    
33.         m_Iter3 = m_Iter1;
    
34.         nFd = m_Iter3->nFd;
    
35.         ++m_Iter1;
    
36.         if (m_nCurrTime - m_Iter3->nStartTime > m_nTimeOutSec)
    
37.         {
    
38.             // 删除超时连接
    
39.         close(nFd);
    
40.             m_listCon.erase(m_Iter3);
    
41.         }
    
42.         else
    
43.         {
    
44.             // 不超时的fd加入fdset中
    
45.             FD_SET(nFd, &m_ReadSet);
    
46.             if (nFd > m_nMaxFd)
    
47.             {
    
48.                 m_nMaxFd = nFd;
    
49.                 LogMsg("list size = %d, maxfd changed: %d", m_listCon.size(), m_nMaxFd);
    
50.             }
    
51.         }
    
52.     }
    
53. }
    
54. 
    
55. int CMsgServer::Poll()
    
56. {
    
57.     int nFdNum, nEvent, nFd, nRet;
    
58. 
    
59.     // 将server listen fd加入fdset中
    
60.     FD_SET(m_nListenFd, &m_ReadSet);
    
61. 
    
62.     // 轮询fd集合
    
63.     while (true)
    
64.     {
    
65.         if (0 > (nFdNum = select(m_nMaxFd + 1, &m_ReadSet, NULL, NULL, NULL)))
    
66.         {
    
67.             if (EINTR == errno)
    
68.             {
    
69.                 continue;
    
70.             }
    
71.             else
    
72.             {
    
73.                 LogMsg("[%s] [%s] [%d]: select failed: %s, nListenFd = %d, nMaxFd = %d"
    
74.                         , __FILE__, __FUNCTION__, __LINE__
    
75.                         , strerror(errno)
    
76.                         , m_nListenFd
    
77.                         , m_nMaxFd);
    
78. 
    
79.                 return -1;
    
80.             }
    
81.         }
    
82.         else
    
83.         {
    
84.             return 0;
    
85.         }
    
86.     }
    
87. }
    
88. 
    
89. void CMsgServer::ProcessFdSet()
    
90. {
    
91.     int nFd;
    
92. 
    
93.     for (m_Iter1 = m_listCon.begin(), m_Iter2 = m_listCon.end(); m_Iter1 != m_Iter2;)
    
94.     {
    
95.         m_Iter3 = m_Iter1;
    
96.         ++m_Iter1;
    
97.         nFd = m_Iter3->nFd;
    
98.         if (FD_ISSET(nFd, &m_ReadSet))
    
99.         {
    
100.             // 处理fd
     
101.             ProcessFd(nFd);
     
102. 
     
103.             //
     
104.             LogMsg("ProcessFd");
     
105. 
     
106.             // 关闭fd
     
107.             close(nFd);
     
108. 
     
109.             // 处理完了之后删除fd
     
110.             m_listCon.erase(m_Iter3);
     
111.         }
     
112.     }
     
113. 
     
114.     // 如果还可以接收连接 检查监听socket是否可读
     
115.     if (m_listCon.size() < m_nMaxCon && FD_ISSET(m_nListenFd, &m_ReadSet))
     
116.     {
     
117.         Accept();
     
118.     }
     
119. }
     
120. 
     
121. int CMsgServer::Accept()
     
122. {
     
123.     int nFd;
     
124.         //sock_addr tCntAddr;
     
125.         //socklen_t nCntAddrLen;
     
126. 
     
127.     //nCntAddrLen = sizeof(sock_addr);
     
128. 
     
129.     //if (-1 == (nFd = accept(m_nListenFd, (struct sockaddr*)&tCntAddr, &nCntAddrLen)))
     
130.     if (-1 == (nFd = accept(m_nListenFd, NULL, NULL)))
     
131.     {
     
132.         switch (errno) {
     
133.             case EAGAIN:
     
134. #if EWOULDBLOCK != EAGAIN
     
135.             case EWOULDBLOCK:
     
136. #endif
     
137.             case EINTR:
     
138.             case ECONNABORTED:
     
139.                 break;
     
140.             default:
     
141.                 LogMsg("[%s] [%s] [%d]accept failed: %s"
     
142.                         , __FILE__, __FUNCTION__, __LINE__
     
143.                         , strerror(errno));
     
144.         }
     
145.         return -1;
     
146.     }
     
147.     else
     
148.     {
     
149.         LogMsg("accept fd: %d", nFd);        
     
150. 
     
151.         Connection tCon;
     
152.         tCon.nFd = nFd;
     
153.         tCon.nStartTime = time(NULL);            
     
154. 
     
155.         m_listCon.push_back(tCon);
     
156.         //m_mapCon[nFd] = tCon;
     
157. 
     
158.         // 设置为非阻塞IO
     
159.         int nFdFl;
     
160.         if (-1 == (nFdFl = fcntl(nFd, F_GETFL, 0)))
     
161.         {
     
162.             LogMsg("[%s] [%s] [%d]: fcntl(...) error: %s\n"
     
163.                     , __FILE__
     
164.                     , __FUNCTION__
     
165.                     , __LINE__
     
166.                     , strerror(errno));
     
167.             return -1;
     
168.         }
     
169.         if (-1 == fcntl(nFd, F_SETFL, nFdFl | O_NONBLOCK))
     
170.         {
     
171.             LogMsg("[%s] [%s] [%d]: fcntl(...) error: %s\n"
     
172.                     , __FILE__
     
173.                     , __FUNCTION__
     
174.                     , __LINE__
     
175.                     , strerror(errno));
     
176.             return -1;
     
177.         }
     
178. 
     
179.         return 0;
     
180.     }
     
181. }
     
182. 
     
183. void CMsgServer::ProcessFd(int nFd)
     
184. {
     
185.     LogMsg("ProcessFd");
     
186. 
     
187.     ssize_t nLen = recv(nFd, m_szRecvBuf, BUFF_SIZE, 0);   
     
188. 
     
189.     if (0 < nLen)
     
190.     {
     
191.         m_szRecvBuf[nLen] = '\0';
     
192.     }
     
193.     else
     
194.     {
     
195.         LogMsg("[%s] [%s] [%d]recv failed: %s"
     
196.                 , __FILE__, __FUNCTION__, __LINE__
     
197.                 , strerror(errno));
     
198.         return;
     
199.     }
     
200. 
     
201.     LogMsg("recv = %s", m_szRecvBuf);
     
202. 
     
203.     int nRet = HandleRequest();
     
204. 
     
205.     send(nFd, "test", 4, 0);
     
206. }
     

复制代码

converse

server主循环在run函数中,外面调用这个类对象如果在run返回0的情况下就一直循环下去...

linternt

难道一个类中不能同时有两个SELECT？？？

xhl

原帖由 converse 于 2007-6-14 17:03 发表
第一次select的是server的socket,accept一个连接的fd之后加入select,再select就出错了...

在select之前清空fdset,重新把可用的fd 放入fdset,以及select时maxfd+1等问题我都查过了,仍然找不到出错的原因....

select 出错了返回什么， errno 是什么呢？

飞灰橙

楼主检查一下m_listCon用的stl类型，
如果用vector或deque,
先++m_Iter1，在m_listCon.erase(m_Iter3);后，m_Iter1指向的内容未必有效.

converse

原帖由 飞灰橙 于 2007-6-14 23:59 发表
楼主检查一下m_listCon用的stl类型，
如果用vector或deque,
先++m_Iter1，在m_listCon.erase(m_Iter3);后，m_Iter1指向的内容未必有效.

这个问题有人已经提到过了，确实是问题，但是貌似不是造成这个错误的原因。

我下一个改动要把list变成一般的动态分配的数组来作，方便多了。

飞灰橙

原帖由 converse 于 2007-6-15 00:02 发表


这个问题有人已经提到过了，确实是问题，但是貌似不是造成这个错误的原因。

我下一个改动要把list变成一般的动态分配的数组来作，方便多了。

也就是说现在出错误时用的已经是list ?

思一克

在select前用一个循环将所有要监视的fd打印出来，还可以fstat查看，就可以找到已经无效的那个。

converse

原帖由 思一克 于 2007-6-15 08:57 发表
在select前用一个循环将所有要监视的fd打印出来，还可以fstat查看，就可以找到已经无效的那个。

在select出错之后用了fstat查询fd,也是没有报错,fstat返回0.