非堵塞socket下的send函数堵塞

notsureit

各位，我在设置非堵塞socket下使用send函数存在极小的几率被堵塞，下面是代码：

1. static int32_t SendDataPacket4Schedule(const uint8_t *data, const int32_t len)
   
2. {
   
3.         fd_set fdsWrite;
   
4.         struct timeval stTimeoutVal;
   
5.         int nRet, nSndBytes;
   
6. 
   
7.         FD_ZERO(&fdsWrite);
   
8.         FD_SET(GetDataInOutSocket(), &fdsWrite);
   
9.         stTimeoutVal.tv_sec = TIMEOUT_SOCKET_SEND;
   
10.         stTimeoutVal.tv_usec = 0;
    
11. 
    
12.         //TODO:这里的处理貌似是有问题的，参见下面的“不管”注释部分
    
13.         nRet = select(GetDataInOutSocket() + 1, NULL, &fdsWrite, NULL, &stTimeoutVal);
    
14.         if(nRet > 0)
    
15.         {
    
16.                 if(FD_ISSET(GetDataInOutSocket(), &fdsWrite))
    
17.                 {
    
18.                         //* 如果相等，表明发送成功，立即发送下一个报文
    
19.                         debug("[send prepare]SendDataPacket:[0x%x] length:%d.\r\n",
    
20.                                         GetDataInOutSocket(), len);
    
21.                         nSndBytes = send(GetDataInOutSocket(), data, len, MSG_NOSIGNAL);
    
22.                         if(len != nSndBytes)
    
23.                         {
    
24.                                 PERROR("tcp_output() send error");
    
25.                                 debuginfo("[send]SendDataPacket() send [0x%x]:%d, error:%s\r\n",
    
26.                                                 GetDataInOutSocket(), nSndBytes, strerror(errno));
    
27.                         }else{
    
28. #if 1
    
29.                                 debug("[send]SendDataPacket:[0x%x] length:%d.\r\n",
    
30.                                                 GetDataInOutSocket(), len);
    
31.                                 showhex((uint8_t *)data, len);
    
32.                                 alert("[send]SendDataPacket OK.");
    
33. #endif
    
34.                         }
    
35.                 }else{
    
36.                         nSndBytes = 0;
    
37.                 }
    
38.         }
    
39.         else if(nRet == 0)
    
40.         {
    
41.                 debuginfo("send Schedule Data Time Out: [0x%x]!\r\n", GetDataInOutSocket());
    
42.                 nSndBytes = -2;
    
43.         }
    
44.         else
    
45.         {
    
46.                 PERROR("tcp_output() select error");
    
47.                 debuginfo("tcp_output() select error [0x%x] :%s\r\n", GetDataInOutSocket(), strerror(errno));
    
48.                 nSndBytes = -1;
    
49.         }
    
50. 
    
51.         return nSndBytes;
    
52. }

复制代码

上面的send部分会被堵塞，我的日志输出显示：
debug("[send prepare]SendDataPacket:[0x%x] length:%d.\r\n",
                                        GetDataInOutSocket(), len);
成功执行之后被挂起，各位觉得有这种可能么？

SpringfieldKing

是靠这句话 len != nSndBytes  看出来它阻塞了吗？

notsureit

不是的，send成功与否，后续我都有打日志，但是后续的日志没有出来

wujiajia

send 返回发送成功的字节数，当返回的字节数不等于你要发送的字节时应当继续发送。并非堵塞了。

notsureit

应该是我发送线程异常退出导致，别的没有合理的解释了，但是此处线程是不应该退出的。。。

giantchen

回复 1# notsureit


    有使用 fcntl O_NONBLOCK 吗？

cdtits

你所说的阻塞是指：执行线程被短时间挂起？还是网络拥塞？

notsureit

回复 6# giantchen


    有的，这个问题应该是误问，最初的发送线程完全没有保护，应该是发送线程自身退出了，造成send堵塞的假象，但是在send之处确实不应该产生异常的

notsureit

回复 7# cdtits


    send函数不返回，堵塞在函数内