郁闷的select出错:Bad file descriptor

思一克

你同时监视几个fd?

应该成fd_set中取出来看。

原帖由 converse 于 2007-6-15 10:08 发表


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

converse

原帖由 思一克 于 2007-6-15 10:13 发表
你同时监视几个fd?

应该成fd_set中取出来看。

不好意思,我刚刚没有出错是因为没有传入stat参数给fstat,原来认为如果不关心这个值可以不用传,现在把这个参数传进去就报错了,同select一样是:bad file descriptor,是第一个接收过来的fd,但是我的程序中在处理这个fd发送的请求之前并没有关闭这个fd的操作啊.

修改过的Poll函数如下:

1. 
   
2. int CMsgServer::Poll()
   
3. {
   
4.     int nFdNum, nEvent, nFd, nRet;
   
5. 
   
6.     // 将server listen fd加入fdset中
   
7.     FD_SET(m_nListenFd, &m_ReadSet);
   
8.     //FD_SET(m_nListenFd, &m_ExpSet);
   
9. 
   
10.     LogMsg("nListenFd = %d", m_nListenFd);
    
11. 
    
12.     struct stat tStat;
    
13.     for(int i = 0; i < m_nMaxCon; ++i)
    
14.     {
    
15.         nFd = m_szConnections[i].nFd;
    
16.         if (-1 != nFd && FD_ISSET(nFd, &m_ReadSet))
    
17.         {
    
18.             printf("%d in readset\n", nFd);
    
19.             if (-1 == fstat(nFd, &tStat))
    
20.             {
    
21.                 printf("fstat %d error:%s", nFd, strerror(errno));
    
22.             }
    
23.             else
    
24.             {
    
25.                 if (!S_ISSOCK(tStat.st_mode))
    
26.                 {
    
27.                     printf("fd %d isnot socket", nFd);
    
28.                 }
    
29.             }
    
30.         }
    
31.     }
    
32.     if (-1 == fstat(m_nListenFd, &tStat))
    
33.     {
    
34.         printf("fstat %d error:%s", m_nListenFd, strerror(errno));
    
35.     }       
    
36.     if (!S_ISSOCK(tStat.st_mode))
    
37.     {
    
38.         printf("listen fd %d isnot socket", m_nListenFd);
    
39.     }
    
40.                                
    
41.     // 轮询fd集合
    
42.     while (true)
    
43.     {
    
44.         //if (0 > (nFdNum = select(m_nMaxFd + 1, &m_ReadSet, NULL, NULL, NULL)))
    
45.                 LogMsg("maxfd = %d, nListenFd = %d", m_nMaxFd, m_nListenFd);
    
46.                 printf("maxfd = %d, nListenFd = %d\n", m_nMaxFd, m_nListenFd);       
    
47. 
    
48.         if (0 > (nFdNum = select(m_nMaxFd + 1, &m_ReadSet, NULL, &m_ExpSet, NULL)))
    
49.         {
    
50.             if (EINTR == errno)
    
51.             {
    
52.                 continue;
    
53.             }
    
54.             else
    
55.             {
    
56.                 LogMsg("[%s] [%s] [%d]: select failed: %s, nListenFd = %d, nMaxFd = %d"
    
57.                         , __FILE__, __FUNCTION__, __LINE__
    
58.                         , strerror(errno)
    
59.                         , m_nListenFd
    
60.                         , m_nMaxFd);
    
61.                                
    
62.                 return -1;
    
63.             }
    
64.         }
    
65.         else
    
66.         {
    
67.             return 0;
    
68.         }
    
69.     }
    
70. }
    

复制代码

思一克

就是某个fd在给fd_set前已经被关闭了

converse

原帖由 思一克 于 2007-6-15 10:54 发表
就是某个fd在给fd_set前已经被关闭了

这就是最邪门的地方,accept之后我马上用fstat查看了状态是正确的fd,但是下一个server主循环开始的时候fstat就不对了,而我在每个调用关闭fd的地方都打了log,没有看到调用这些语句.

如果是我的测试客户端程序写的有问题也不应该,因为我换了别的方式是可以收到数据的.

思一克

是thread程序？

converse

目前还是单进程的,测试完毕之后改成多进程的.

飞灰橙

把log下来的信息给大家参考一下吧

converse

我终于明白问题出在哪里了,

我对struct onnection的定义如下:

1. 
   
2. typedef struct Connection
   
3. {
   
4.     int                 nFd;        // 连接套接字
   
5.     time_t              nStartTime; // 接收连接的时间
   
6. 
   
7.     Connection_State    nState;    // 连接状态
   
8.     bool                bReadable;  //
   
9.     bool                bWriteable; //
   
10.     string              strReq;     // 请求字符串
    
11.     string              strRet;     // 回复字符串
    
12. 
    
13.     Connection()
    
14.         : nFd(-1)
    
15.         , nState(CON_STATE_CLOSE)         
    
16.         , nStartTime(0)                                             
    
17.         , bReadable(false)                                                                     
    
18.         , bWriteable(false)                                                                     
    
19.     {
    
20.     }
    
21. 
    
22.     ~Connection()
    
23.     {
    
24.         if (-1 != nFd)
    
25.         {
    
26.             close(nFd);
    
27.             nFd = -1;
    
28.         }
    
29.         nState = CON_STATE_CLOSE;
    
30.     }
    
31. }Connection;
    

复制代码

而在Accept函数的处理中,有几段代码:

1. 
   
2.        Connection tCon;
   
3.         tCon.nFd = nFd;
   
4.         tCon.nStartTime = time(NULL);            
   
5. 
   
6.         m_listCon.push_back(tCon);
   

复制代码

我的本意是把连接上的fd存放进入这个list中,但是tCon是局部对象,出了这个函数调用自己的析构函数,把接收的fd给关闭了.
于是再去select的时候就出错了.

思一克

哈。

C++，和多thread都是棘手BUG的发源地。

你没有主动让它做的事情，他会在背后（偷偷地）给你做了。

原帖由 converse 于 2007-6-15 15:46 发表
我终于明白问题出在哪里了,

我对struct onnection的定义如下:
[code]
typedef struct Connection
{
    int                 nFd;        // 连接套接字
    time_t              nStartTime; // 接收连 ...

mengwg

估计是 select 出来事件后 在循环体内对句柄列表进行了 修改。
是逻辑问题