关于select返回值的问题！

xujian6462

在服务器侧，使用select检查新建的socket是否可读写，超时时间设置为5秒，
但由于采用了多线程，如果在接收线程进入到select后，其他线程中shutdown和close掉这个建立的socket后，
select没有立即返回，请问是怎么回事？
谢谢了

pagx

是windows的程序吧。window socket的实现就是这样的。

xujian6462

1.                         int resultS = ::select(fd + 1, &fdSet, 0, 0, &tv);//使用select()防止拒绝服务型攻击
   
2.                        
   
3.                         if(resultS == 0)
   
4.                         {
   
5.                                 //cout <<"1111"<<endl;
   
6.                                
   
7.                                
   
8.                                 if (lenLeft > 0)
   
9.                                 {//部分接收, 超时
   
10.                                         ret_code = COMMON_BSAE_ERROR_NO - 121;
    
11.                                         //printf("In CTransCommonSocket::RecvFromNet, select(%d) timeout error number = %d...\n", fd, ret_code);
    
12.                                         cout <<"In CTransCommonSocket::RecvFromNet, select("<<fd<<") timeout error number = " <<ret_code<<"..."<<endl;
    
13.                                        
    
14. 
    
15.                                        
    
16.                
    
17.                                         return ret_code;
    
18.                                 }
    
19.                                 else
    
20.                                 {
    
21.                                         //cout <<"222"<<endl;
    
22.                                         //如果强制无限等待，不进行超时返回
    
23.                                         if( timeout != WAITINFINE )                        //一直等待标志
    
24.                                         {
    
25.                                                
    
26.                                                 cout <<"timeout"<<timeout<<endl;
    
27.                                                 return 0;  //未接收, timeout
    
28.                                         }
    
29.                                         else
    
30.                                         {
    
31.                                                 //cout <<"In CTransCommonSocket::RecvFromNet, timeout is waitting..."<<endl;
    
32.                                                 continue;
    
33.                                         }
    
34.                                        
    
35.                                        
    
36.                                 }
    
37.                         }                       
    
38.                         else if(resultS == -1)
    
39.                         {
    
40.                                 if(IsInterrupted())
    
41.                                     continue;
    
42.                                 int err=GetError();
    
43.                                
    
44.                                 ret_code = COMMON_BSAE_ERROR_NO - 122;
    
45.                                 //printf("In CTransCommonSocket::RecvFromNet, select() error number = %d...\n", ret_code);
    
46.                                 cout <<"In CTransCommonSocket::RecvFromNet, select("<<fd<<") error number = " <<ret_code<<",GetError():"<<GetError()<<"..."<<endl;
    
47.                                 return ret_code;
    
48.                         }
    
49. 
    
50. int result = ::recv(fd_, (char*)(buf + lenLeft), sizeOfPacket, 0);
    
51.                 if(result == 0)//false, connection closed
    
52.                 {
    
53.                         int err=GetError();
    
54.                        
    
55.                         ret_code = COMMON_BSAE_ERROR_NO - 123;
    
56.                         //printf("CTransCommonSocket::RecvFromNet, recv(%d) error number = %d...\n", fd_, ret_code);
    
57.                         return ret_code;
    
58.                 }
    
59.                 else if(result == -1)
    
60.                 {
    
61.                         if(NoBufs() && sizeOfPacket > 1024)
    
62.                         {
    
63.                                 sizeOfPacket /= 2;
    
64.                                 continue;
    
65.                         }
    
66.                        
    
67.                         if(IsInterrupted())
    
68.                                 continue;
    
69. 
    
70.                         if(fd_ == -1 || ConnectionDown())
    
71.                         {//false, connection loss
    
72.                                
    
73.                                 int err=GetError();
    
74.                                
    
75.                        
    
76.                                 ret_code = COMMON_BSAE_ERROR_NO - 124;
    
77.                                 printf("In CTransCommonSocket::RecvFromNet, recv() error number = %d, fd = %d...\n", ret_code, fd_);
    
78.                                 return ret_code;
    
79.                         }
    
80.                         if(WouldBlock())
    
81.                                 continue;
    
82.                        
    
83.                         int err=GetError();
    
84.                        
    
85.                                
    
86.                         ret_code = COMMON_BSAE_ERROR_NO - 125;
    
87.                         printf("In CTransCommonSocket::RecvFromNet, recv() error number = %d...\n", ret_code);
    
88.                         return ret_code;
    
89.                 }

复制代码

不是windows的，标准C下面的

pagx

你测试过 linux 下的确是这样子？

xujian6462

确定，select一直都是超时才能退出