linux socket recv 出现报错resource temporarily unavailable

liyandong106

求帮助、

1. nrecv = recv(fd, bp, data_len, 0);
   
2.                 //debug(255)("->%s\n", data);
   
3.                 printf("nrecv data_count = %d\n",nrecv);
   
4.                 if (nrecv == -1)
   
5.                 {
   
6.                         if( (errno == EAGAIN)||(errno==EWOULDBLOCK) )
   
7.                         {
   
8.                                 debug(255)("recv error1\n");
   
9.                                 //CloseConn(channel);
   
10.                                 //return -1;
    
11.                                 break;
    
12.                         }
    
13.                         else
    
14.                         {
    
15.                                 debug(255)("recv error2\n");
    
16.                                 CloseConn(channel);
    
17.                                 return -1;
    
18.                         }   
    
19.                 }      
    
20.                 else if (nrecv == 0 )
    
21.                 {   
    
22.                         CloseConn(channel);
    
23.                         return -1;
    
24.                 }
    
25. //                data_len-=nrecv;
    
26. //                bp+=nrecv;
    
27. //        }
    
28. 
    
29.                 if(virus == 1)
    
30.                 {
    
31.                         /*
    
32.                         if(check_buf_virus(data, nrecv, "TCP PROXY") == 0)
    
33.                         {
    
34.                                 CloseConn(channel);
    
35.                                 return -1;
    
36.                         }
    
37.                         */
    
38.                         if(clamav_scan_buf(data_count, count_len, "TCP PROXY") == 0)
    
39.                         {
    
40.                                 CloseConn(channel);
    
41.                                 return -1;
    
42.                         }
    
43.                 }
    
44.                 //sleep(30);
    
45.                 if(logo == 1)
    
46.                 {
    
47.                         printf("come in BDProtocolParse\n");
    
48.                         ret = BDProtocolParse(data_count,&count_len,&struBase26Info);
    
49.                         printf("ret = %d\n",ret);
    
50.                        
    
51.                
    
52.                         total_send = 0;
    
53.                         while (total_send!=count_len)
    
54.                         {
    
55.                                 nsend = send(other_fd, data_count+total_send, count_len-total_send, 0);
    
56.                         //        nsend = send(other_fd, data_count, count_len, 0);
    
57. 
    
58.                                 if (nsend <= 0)
    
59.                                 {
    
60.                                         if( errno == EAGAIN )
    
61.                                         {
    
62.                                                 continue;
    
63.                                         }
    
64.                                         perror("send");
    
65.                                         CloseConn(channel);
    
66.                                         return -1;
    
67.                                 }
    
68.                                 total_send += nsend;
    
69.                         }
    
70.                         printf("nsen = %d\n",nsend);
    
71.                 }
    
72.                 else
    
73.                 {
    
74.                                 //sleep(30);
    
75.                         total_send = 0;
    
76.                         while (total_send!=nrecv)
    
77.                         {
    
78.                                 nsend = send(other_fd, data_count+total_send, nrecv-total_send, 0);
    
79.                                 if (nsend <= 0)
    
80.                                 {
    
81.                                         if( errno == EAGAIN )
    
82.                                         {
    
83.                                                 continue;
    
84.                                         }
    
85.                                         perror("send");
    
86.                                         CloseConn(channel);
    
87.                                         return -1;
    
88.                                 }
    
89.                                 total_send += nsend;
    
90.                         }
    
91.                         printf("nsen = %d\n",nsend);
    
92.                 }
    
93.                 FD_ZERO(&rfds);
    
94.                 FD_SET(channel->conn_sd, &rfds);
    
95.                 FD_SET(channel->server_sd, &rfds);
    
96.                 sd_max = channel->conn_sd>channel->server_sd? channel->conn_sd : channel->server_sd ;
    
97. 
    
98.                 tv.tv_sec = 2;
    
99.                 tv.tv_usec = 0;
    
100. 
     
101.                 ret = select( sd_max+1, &rfds, NULL, NULL, &tv);
     
102. 
     
103.                 if (ret < 0)
     
104.                 {
     
105.                         perror("2. Select:");
     
106.                         debug(1)("2. select() error\n");
     
107.                         CloseConn(channel);
     
108.                         return -1;
     
109.                 }
     
110.                 else if(ret == 0)
     
111.                 {
     
112.                         debug(255)("timeout\n");
     
113.                         break;
     
114.                 }
     
115. 
     
116.                 if ( FD_ISSET(channel->conn_sd, &rfds) )
     
117.                 {
     
118.                         channel->status = ST_CLIENT_READ_READY;
     
119.                 }
     
120. 
     
121.                 if ( FD_ISSET(channel->server_sd, &rfds) )
     
122.                 {
     
123.                         channel->status = ST_SERVER_READ_READY;
     
124.                 }
     
125. 
     
126.         }
     
127.         free(data_count);
     
128.         notify.sd_local = channel->conn_sd;
     
129.         notify.sd_remote = channel->server_sd;
     
130.         notify.from = THREAD_WORK;
     
131.         notify.context = channel->context;
     
132.         move_to_spare_pool(channel);
     
133.         dispatch_local_ev(notify, thread_info);
     
134. 
     
135.         return 0;
     
136. }

复制代码

osmanthusgfy

你是把sockfd设为了nonblock了吧?

用while循环:
while( -1 == recv() && EAGAIN != errno )

liyandong106

回复 2# osmanthusgfy


    麻烦看一下代码 谢谢

osmanthusgfy

你在创建socket之后是否调用了fcntl设置sockfd为Nonblock模式?
如果是,解决办法请看之前的回复.


"resource temporarily unavailable"就是errno == EAGAIN对应的错误信息.

liyandong106

回复 4# osmanthusgfy


    你的意思是用fctl设置成非阻塞模式？

liyandong106

回复 2# osmanthusgfy


    但是错误是在 else
                        {
                                debug(255)("recv error2\n");
                                CloseConn(channel);
                                return -1;
                        }   里面打印出来的

osmanthusgfy

是的,如果sockfd设置为非阻塞模式,数据还没有发给接收端时,调用recv就会返回-1,并且errno会被设为EAGAIN.
所以你必须循环调用recv并且检测errno.

liyandong106

回复 7# osmanthusgfy


    但是我下面有select 可以控制描述符

hellioncu

回复  osmanthusgfy


    但是我下面有select 可以控制描述符
liyandong106 发表于 2011-04-17 20:33

    调用printf等函数都可能会改变errno的值

santai543

學習學習