select返回-1的問(wèn)題

lewy7

描述符集合中監(jiān)聽(tīng)多個(gè)socket，長(zhǎng)連接。

當(dāng)一個(gè)客戶(hù)端的連接斷掉后，

select會(huì)返回-1，errno=9  Bad file descriptor。

請(qǐng)問(wèn)這種情況怎么處理？

如何判斷是哪個(gè)socket斷開(kāi)了連接，從而在select監(jiān)視的描述符集合中，將該斷開(kāi)的socket移除？

lxyscls

回復(fù) 1# lewy7


    客戶(hù)端斷掉應(yīng)該是read = 0吧，在讀事件里面close和fd_clr就可以了

lewy7

回復(fù) 2# lxyscls


    試了一下，當(dāng)select返回-1時(shí)，F(xiàn)D_ISSET并不能得到斷開(kāi)連接的socket，這樣我就不知道要去recv哪個(gè)socket了。

lxyscls

回復(fù) 3# lewy7


    在你的讀事件里面處理recv = 0的情況，而不是select返回-1的時(shí)候

lewy7

回復(fù) 4# lxyscls


    socket集合里面都是長(zhǎng)連接，select阻塞監(jiān)聽(tīng)這些socket的事件，如果有可讀的事件到來(lái)，才會(huì)去read有事件到來(lái)的socket；
    也就是說(shuō)select阻塞直到有事件到來(lái)，否則不會(huì)主動(dòng)去read集合里的socket的。

    現(xiàn)在的問(wèn)題就是select返回-1后，找不到斷開(kāi)連接的socket。

lxyscls

回復(fù) 5# lewy7


    客戶(hù)端關(guān)斷，沒(méi)有讀事件上來(lái)嗎？

lewy7

回復(fù) 6# lxyscls


    沒(méi)有可讀事件，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

回復(fù) 7# lewy7


    貼代碼

lewy7

回復(fù) 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的時(shí)候可讀事件沒(méi)有觸發(fā)
    
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

復(fù)制代碼

lxyscls

回復(fù) 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

復(fù)制代碼

你多close了一次，這次close了一個(gè)正確的fd，然后又去select，所以就bad file descriptor了