非阻塞socket转为阻塞后的问题

vafls_scott

socket连接成功后，由非阻塞转为阻塞之后，select得到可读，可是读的时候没有读到数据，这是什么原因呢？
代码如下：

1. 
   
2. #include <stdio.h>
   
3. #include <sys/types.h>
   
4. #include <sys/socket.h>
   
5. #include <sys/select.h>
   
6. #include <netinet/in.h>
   
7. #include <arpa/inet.h>
   
8. #include <netdb.h>
   
9. #include <errno.h>
   
10. #include <string.h>
    
11. #include <strings.h>
    
12. #include <unistd.h>
    
13. #include <fcntl.h>
    
14. 
    
15. #define STATUS_OOS                                0
    
16. #define STATUS_CONNECTING                1
    
17. #define STATUS_INSERVICE                2
    
18. int main()
    
19. {
    
20.         int status = STATUS_OOS;
    
21.         int sockfd = 0;
    
22.         int port = 8011;
    
23.         char host[] = "192.168.100.209";
    
24.        
    
25.         struct sockaddr_in serv_addr;
    
26.         struct hostent     *hp;
    
27.         int           setFlag;
    
28.         struct linger linger;
    
29.        
    
30.         int flags;
    
31. 
    
32.         if ( (hp = gethostbyname(host)) == NULL) {
    
33.                 //perror ("sockTcpConnect:gethostbyname error ");
    
34.                 printf("gethostbyname error host = '%s'\n",host);
    
35.                 return 0;
    
36.         }
    
37.         bcopy(hp->h_addr, (char *) &serv_addr.sin_addr, hp->h_length);
    
38. 
    
39.         if ( (sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0 ) {
    
40.                 perror ("generate socket error ");
    
41.                 return 0;
    
42.         }
    
43. 
    
44.         bzero((char *)&serv_addr, sizeof(serv_addr));
    
45.         serv_addr.sin_family      = AF_INET;
    
46.         memcpy (&serv_addr.sin_addr, hp->h_addr, hp->h_length);
    
47.         serv_addr.sin_port        = htons(port);
    
48. 
    
49.         setFlag = 1;
    
50.         if (setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE, &setFlag, sizeof(setFlag)) < 0) {
    
51.                 close(sockfd);
    
52.                 return 0;
    
53.         }
    
54. 
    
55.         linger.l_onoff = 1;
    
56.         linger.l_linger = 0;
    
57.           if (setsockopt(sockfd, SOL_SOCKET, SO_LINGER, (char *) &linger, sizeof(linger)) < 0) {
    
58.                 close(sockfd);
    
59.                 return 0;
    
60.         }
    
61. /***************************************************/  
    
62. //在connect之前，设成非阻塞模式
    
63.         flags = fcntl(sockfd, F_GETFL,0);
    
64.         fcntl(sockfd,F_SETFL, flags | O_NONBLOCK);
    
65. /***************************************************/  
    
66. 
    
67.         if (connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
    
68.                 if(errno != EINPROGRESS){
    
69.                         close(sockfd);
    
70.                         return 0;
    
71.                 }
    
72.                 status = STATUS_CONNECTING;
    
73.         }
    
74.         else {
    
75.                 status = STATUS_INSERVICE;
    
76.         }
    
77.         while(1) {
    
78.                 fd_set          fdread;
    
79.                 fd_set          fdwrite;
    
80.                 struct timeval  tvSelect;
    
81.                 int  n;
    
82.            
    
83.                 FD_ZERO(&fdread);
    
84.                 FD_ZERO(&fdwrite);
    
85.                 FD_SET(sockfd, &fdread);
    
86.                 tvSelect.tv_sec         = 0;
    
87.                 tvSelect.tv_usec         = 500;
    
88.                 if(STATUS_CONNECTING==status){
    
89.                         fdwrite = fdread;
    
90.                 }
    
91.            
    
92.                 int retval = select(sockfd + 1, &fdread, status==STATUS_CONNECTING?&fdwrite:NULL, NULL, &tvSelect);
    
93.                 if(retval < 0){
    
94.                         if ( errno == EINTR ){
    
95.                                 printf("select error\n");
    
96.                                 continue;
    
97.                         }
    
98.                         else{
    
99.                                 printf("error\n");
    
100.                                 close(sockfd);
     
101.                                 return 0;
     
102.                         }
     
103.                 }
     
104.                 else if(retval == 0){
     
105.                         if(status == STATUS_CONNECTING){
     
106.                                 printf("select timeout, state CONNECTING, still connecting...\n");
     
107.                                 continue;
     
108.                         }
     
109.                 }
     
110.                 else if((STATUS_CONNECTING==status) && ( FD_ISSET(sockfd, &fdread) || FD_ISSET(sockfd, &fdwrite) ) ){
     
111.                         printf("no-block connnect select return, check socket.\n");
     
112.                         int error;
     
113.                         socklen_t len = sizeof(error);
     
114.                         if(getsockopt(sockfd,SOL_SOCKET,SO_ERROR,&error,&len) < 0 || error != 0){
     
115.                                 printf("getsockopt return error, %d:%d\n", error, errno);
     
116.                                 close(sockfd);
     
117.                                 return 0;       
     
118.                         }
     
119.                         else{
     
120.                                 printf("no-block connnect ok, set socket to block mode.\n");
     
121. /***************************************************/  
     
122. //在connect成功之后，设成阻塞模式
     
123.                                 int flags = fcntl(sockfd, F_GETFL,0);
     
124.                                 flags &= ~O_NONBLOCK;
     
125.                                 fcntl(sockfd,F_SETFL, flags);
     
126. /***************************************************/  
     
127.                                 status = STATUS_INSERVICE;
     
128.                                 continue;
     
129.                         }
     
130.                 }
     
131.                 else if((STATUS_INSERVICE==status)&& FD_ISSET(sockfd, &fdread)) {
     
132.                         char recvbuf[10240];
     
133.                         bzero(recvbuf, sizeof(recvbuf));
     
134.                     n = read (sockfd, recvbuf, sizeof(recvbuf) - 1);
     
135.                     printf("read data length is %d\n", n);
     
136. //select返回可读，应该是不会读不到数据的，但收了几个消息之后，就会返回读取长度为0，不知道原因
     
137.                         if(n == 0){
     
138.                                 close(sockfd);
     
139.                                 return 0;
     
140.                         }
     
141.                         else if (n < 0) {
     
142.                                 printf("read return<0, errno is %d\n", errno);
     
143.                               if ( errno == EINTR ) {
     
144.                                       continue;
     
145.                               }
     
146.                                 else {
     
147.                                         close(sockfd);
     
148.                                         return 0;
     
149.                                 }
     
150.                         }
     
151.                         //proc data......
     
152.                 }
     
153.         }
     
154.         close(sockfd);
     
155.         return 1;
     
156. }
     
157. 
     

复制代码

[ 本帖最后由 vafls_scott 于 2007-1-31 16:33 编辑 ]

vafls_scott

急啊，顶一下

思一克

你再次SELECT 看看。

vafls_scott

还是能select到，但read的时候还是0。真奇怪

JohnBull

man 7 socket

套接字对端关闭时select认为是可读。

别用select了，多恶心的函数啊！！

langue

原帖由 JohnBull 于 2007-1-31 19:18 发表
man 7 socket

套接字对端关闭时select认为是可读。

别用select了，多恶心的函数啊！！

请教一下，这个时候应该用什么函数呢？

--

JohnBull

原帖由 langue 于 2007-1-31 19:21 发表


请教一下，这个时候应该用什么函数呢？

--

poll啊，poll能区分数据到达和连接状态改变（POLLHUP和POLLIN）

醉卧水云间

select 恶心？没听说过！用epoll移植到windows下试试！

langue

原帖由 JohnBull 于 2007-1-31 19:28 发表


poll啊，poll能区分数据到达和连接状态改变（POLLHUP和POLLIN）

原来是这样。谢谢。但我觉得 select() 还行，个人意见

--

JohnBull

原帖由 醉卧水云间 于 2007-1-31 19:30 发表
select 恶心？没听说过！用epoll移植到windows下试试！

且不说select把描述符集简单武断地分成了“read/write/exception”而限制了其表达能力、每次监测之前都要重写描述符集，单就select的第一个参数就够滑稽的了－－请求监视描述符最大值+1 :wink::wink:

在有poll可以用的场合，我决不用select！