linux socket recv 出现报错resource temporarily unavailable

Question

本帖最后由 liyandong106 于 2011-04-17 20:19 编辑

求帮助、

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. //        }
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);
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 ;
98.                 tv.tv_sec = 2;
99.                 tv.tv_usec = 0;
101.                 ret = select( sd_max+1, &rfds, NULL, NULL, &tv);
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.                 }
116.                 if ( FD_ISSET(channel->conn_sd, &rfds) )
117.                 {
118.                         channel->status = ST_CLIENT_READ_READY;
119.                 }
121.                 if ( FD_ISSET(channel->server_sd, &rfds) )
122.                 {
123.                         channel->status = ST_SERVER_READ_READY;
124.                 }
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);
135.         return 0;
136. }

复制代码

Answer 1

你是把sockfd设为了nonblock了吧?

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

Answer 2

回复 2# osmanthusgfy

    麻烦看一下代码 谢谢

Answer 3

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

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

Answer 4

回复 4# osmanthusgfy

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

Answer 5

回复 2# osmanthusgfy

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

Answer 6

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

Answer 7

回复 7# osmanthusgfy

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

Answer 8

回复  osmanthusgfy

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

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

Answer 9

學習學習