select返回-1的问题

lewy7

描述符集合中监听多个socket，长连接。

当一个客户端的连接断掉后，

select会返回-1，errno=9  Bad file descriptor。

请问这种情况怎么处理？

如何判断是哪个socket断开了连接，从而在select监视的描述符集合中，将该断开的socket移除？

lxyscls

回复 1# lewy7


    客户端断掉应该是read = 0吧，在读事件里面close和fd_clr就可以了

lewy7

回复 2# lxyscls


    试了一下，当select返回-1时，FD_ISSET并不能得到断开连接的socket，这样我就不知道要去recv哪个socket了。

lxyscls

回复 3# lewy7


    在你的读事件里面处理recv = 0的情况，而不是select返回-1的时候

lewy7

回复 4# lxyscls


    socket集合里面都是长连接，select阻塞监听这些socket的事件，如果有可读的事件到来，才会去read有事件到来的socket；
    也就是说select阻塞直到有事件到来，否则不会主动去read集合里的socket的。

    现在的问题就是select返回-1后，找不到断开连接的socket。

lxyscls

回复 5# lewy7


    客户端关断，没有读事件上来吗？

lewy7

回复 6# lxyscls


    没有可读事件，select直接就返回-1，然后errno就是9了。

    ERRORS
       EBADF  An  invalid  file descriptor was given in one of the sets.  (Perhaps a file descriptor that was already closed, or one on which an error
              has occurred.)

lxyscls

回复 7# lewy7


    贴代码

lewy7

回复 8# lxyscls

1.         int    clientArray[256];
   
2.         int    clientConnected;
   
3.         int    listenFd ,clientFd;
   
4.         fd_set fds;
   
5.         listenFd = socket_listen(socketFile);
   
6.        
   
7.         while(1){
   
8.                 FD_ZERO(&fds);
   
9.                 FD_SET(listenFd, &fds);
   
10.                 maxfdsn = listenFd;
    
11.                
    
12.                 for( i=0;i<clientConnected;i++ ){
    
13.                         FD_SET(clientArray[i], &fds);
    
14.                         if( clientArray[i] > maxfdsn )
    
15.                                 maxfdsn = clientArray[i];
    
16.                 }
    
17.                
    
18.                 ret = select(maxfdsn+1, &fds, NULL, NULL, NULL);
    
19.                 if(ret<0){
    
20.                         //*********
    
21.                         for (i = 0; i < clientConnected; i++) {
    
22.             if (FD_ISSET(clientArray[i], &fds)) {
    
23.                     //返回-1的时候可读事件没有触发
    
24.                                         memset(&data,0,sizeof( jss_monitor_t ));
    
25.                                         recvLen = read(clientArray[i],&data,sizeof( jss_monitor_t));
    
26.                                         sprintf(sysBuf,  "select return error fd %d len {%d} \n",clientArray[i],recvLen);
    
27.                                         write(logFd,sysBuf,strlen(sysBuf));
    
28.             }
    
29.           }
    
30.                         continue;
    
31.                 }
    
32. 
    
33.                
    
34.                 if(FD_ISSET(listenFd,&fds)){
    
35.                         memset(&un,0,sizeof(struct sockaddr_un));
    
36.                         addrLen = sizeof(struct sockaddr_un);
    
37.                         clientFd = accept(listenFd,(struct sockaddr *)&un,  (socklen_t *)&addrLen);
    
38.                         if (clientFd <= 0) {
    
39.                                 continue;
    
40.                         }
    
41.                        
    
42.                         setsockopt(clientFd ,SOL_SOCKET,SO_RCVTIMEO,&timeout,sizeof(timeout));
    
43.                         //add to overlook array
    
44.                         clientArray[clientConnected] = clientFd;
    
45.                         clientConnected++;
    
46.                 }
    
47. 
    
48.                 // check every client fd in the set
    
49.         for (i = 0; i < clientConnected; i++) {
    
50.             if (FD_ISSET(clientArray[i], &fds)) {
    
51.                         memset(&data,0,sizeof( jss_monitor_t ));
    
52.                         recvLen = read(clientArray[i],&data,sizeof( jss_monitor_t));
    
53.                        
    
54.                         if (recvLen <= 0) {
    
55.                                         FD_CLR(clientArray[i], &fds);
    
56.                                         close(clientArray[i]);
    
57.                                         for( j=i;j<clientConnected;j++){
    
58.                                                         clientArray[ j ]=clientArray[ j+1 ];
    
59.                                         }
    
60.                                         close(clientArray[i]);
    
61.                                         clientConnected--;
    
62.                                         break;
    
63.                         }
    
64.                   }//end while read
    
65. 
    
66.         }
    
67.                
    
68.         }// end death loop

复制代码

lxyscls

回复 9# lewy7

1. 
   
2.         for (i = 0; i < clientConnected; i++) {
   
3.             if (FD_ISSET(clientArray[i], &fds)) {
   
4.                         memset(&data,0,sizeof( jss_monitor_t ));
   
5.                         recvLen = read(clientArray[i],&data,sizeof( jss_monitor_t));
   
6.                         
   
7.                         if (recvLen <= 0) {
   
8.                                         FD_CLR(clientArray[i], &fds);
   
9.                                         close(clientArray[i]);
   
10.                                         for( j=i;j<clientConnected;j++){
    
11.                                                         clientArray[ j ]=clientArray[ j+1 ];
    
12.                                         }
    
13.                                         close(clientArray[i]);
    
14.                                         clientConnected--;
    
15.                                         break;
    
16.                         }
    
17.                   }//end while read
    
18. 
    
19.         }
    
20.                
    
21.         }// end death loop

复制代码

你多close了一次，这次close了一个正确的fd，然后又去select，所以就bad file descriptor了