请教，我的select函数的timeval不起作用?

jeanlove

自己写了一个socket客户端，没有任何服务器端的情况下，用fcntl设置非阻塞的socket fd来connect，然后调用connect函数
然后用select函数来监视它
问题:
1. 这个select函数的参数timeval里面我设置了10秒的相应时间，但是程序运行到这里select就立即返回了。
2. 再调用getsockopt函数，optval的大小应该设为多大比较合适(我给了一个int)，然后getsockopt的调用使得errno不为0，但是打印strerror确是Success。很奇怪。

源代码如下:
$ cat client.c
#include<sys/types.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<fcntl.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<sys/select.h>
int main(void){
int s,r,ret,len,error;
char buf[20];
struct sockaddr_in sock;
fd_set rset,wset;
struct timeval tv;
tv.tv_sec=10;
s=socket(AF_INET,SOCK_STREAM,0);
if(-1==s){ printf("socket() failed\n"); return 1; }

if(0>fcntl(s,F_SETFL,fcntl(s,F_GETFL,0)|/*O_NDELAY*/O_NONBLOCK)){/*非阻塞*/
   printf("fcntl failed\n");
   return 1;
}

sock.sin_family=PF_INET;
sock.sin_port  =htons(10080);
sock.sin_addr.s_addr=htons(INADDR_ANY);

if(-1==(ret=connect(s,(struct sockaddr*)&sock,sizeof(struct sockaddr_in)))){
  if(EINPROGRESS!=errno){/*if not fcntl->O_NDELAY, fall here*/
   printf("connect() failed:%s\n",strerror(errno));
   return 1; }
}
if(ret==0){ printf("connection ok at once\n"); close(s); return 0; }
FD_ZERO(&rset);
FD_SET(s,&rset);
wset=rset;
if(-1==(ret=select(s+1,&rset,&wset,NULL,&tv))){ /*设置timeval时间参数*/
  close(s);
  printf("select error\n");
  return 1;
}
if(0==ret){
   close(s);
   printf("timeout\n");
   return 1;
}
if(/*FD_ISSET(s,&rset)*/FD_ISSET(s,&wset)){
  len=sizeof(error);
  errno=0;
  if(0>(ret=getsockopt(s,SOL_SOCKET,SO_ERROR,(void*)&error,&len))){
   close(s);
   printf("getsockopt error:%s\n",strerror(errno));
   return 1;
  }
  if(error!=0){
    printf("getsockopt set error:%s\n",strerror(errno));
    close(s);
    return 1;
   }
  printf("getsockopt success\n");
}else{ close(s); printf("FD_ISSET error\n"); return 1; }
if(-1==(ret=read(s,buf,sizeof(buf)))){
  printf("read() failed\n");
  return 1;
}/*如果连接成功就从server读取点东西*/
printf("ret=%d\n",ret);
buf[ret-1]='\0';
printf("read:%s\n",buf);
close(s);
return 0;
}

运行结果:
$ gcc client.c && ./a.out
getsockopt set error:Success
程序立刻结束，并没有在select 那里等待。

环境: linux2.6.18+gcc4.1.2
还请 dx 指点。

[ 本帖最后由 jeanlove 于 2009-5-13 09:52 编辑 ]

li2002

学习备用

jeanlove

原帖由 win_hate 于 2009-5-13 16:59 发表
最初用你的地址 INADDR_ANY，会报地址错误

如果用合法地址，对方没有侦听，报连接被拒绝

如果对方在听了，但没有向你发送消息，select 认为文件描述符是不可读的

如果三路握手完成，则 select 认为文件 ...

我试试啊。

win_hate

最初用你的地址 INADDR_ANY，会报地址错误

如果用合法地址，对方没有侦听，报连接被拒绝

如果对方在听了，但没有向你发送消息，select 认为文件描述符是不可读的

如果三路握手完成，则 select 认为文件描述符是可写的。

你写一个服务去听，客户在 select 时把 *wset 参数 设 NULL  就可以观察到 timeout

jeanlove

原帖由 win_hate 于 2009-5-13 14:32 发表
我用 python 写了个小程序在本地听，但不 accept，然后用你的程序去连（改了连接地址），结果是 timeout



#!/usr/bin/python

import socket

ss=socket.socket(socket.AF_INET, socket.SOCK_STREAM) ...

嗯，也就是说必须存在服务器端已经listen了，客户端才能非阻塞的connect并且能用select定时。

win_hate

我用 python 写了个小程序在本地听，但不 accept，然后用你的程序去连（改了连接地址），结果是 timeout

1. 
   
2. #!/usr/bin/python
   
3. 
   
4. import socket
   
5. 
   
6. ss=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
   
7. ss.bind(('127.0.0.1',8080))
   
8. ss.listen(8080)
   
9. while True:
   
10.         None;
    

复制代码

1. 
   
2. #include<sys/types.h>
   
3. #include<sys/socket.h>
   
4. #include<arpa/inet.h>
   
5. #include<fcntl.h>
   
6. #include<stdio.h>
   
7. #include<errno.h>
   
8. #include<string.h>
   
9. #include<sys/select.h>
   
10. int
    
11. main (void)
    
12. {
    
13.   int s, r, ret, len, error;
    
14.   char buf[20];
    
15.   struct sockaddr_in sock;
    
16.   fd_set rset, wset;
    
17.   struct timeval tv;
    
18.   tv.tv_sec = 10;
    
19.   s = socket (AF_INET, SOCK_STREAM, 0);
    
20.   if (-1 == s)
    
21.     {
    
22.       printf ("socket() failed\n");
    
23.       return 1;
    
24.     }
    
25.   if (0 >
    
26.         fcntl (s, F_SETFL, fcntl (s, F_GETFL, 0) | /*O_NDELAY */ O_NONBLOCK))
    
27.     {                                /*非阻塞 */
    
28.       printf ("fcntl failed\n");
    
29.       return 1;
    
30.     }
    
31.   sock.sin_family = PF_INET;
    
32.   sock.sin_port = htons (8080);
    
33.   sock.sin_addr.s_addr =inet_addr("127.0.0.1");
    
34.   if (-1 ==
    
35.         (ret =
    
36.          connect (s, (struct sockaddr *) &sock, sizeof (struct sockaddr_in))))
    
37.     {
    
38.       if (EINPROGRESS != errno)
    
39.         {                        /*if not fcntl->O_NDELAY, fall here */
    
40.           printf ("connect() failed:%s\n", strerror (errno));
    
41.           return 1;
    
42.         }
    
43.     }
    
44.   if (ret == 0)
    
45.     {
    
46.       printf ("connection ok at once\n");
    
47.       close (s);
    
48.       return 0;
    
49.     }
    
50.   FD_ZERO (&rset);
    
51.   FD_SET (s, &rset);
    
52.   wset = rset;
    
53.   if (-1 == (ret = select (s + 1, &rset, &wset, NULL, &tv)))
    
54.     {                                /*设置timeval时间参数 */
    
55.       close (s);
    
56.       printf ("select error\n");
    
57.       return 1;
    
58.     }
    
59.   if (0 == ret)
    
60.     {
    
61.       close (s);
    
62.       printf ("timeout\n");
    
63.       return 1;
    
64.     }
    
65.   if ( /*FD_ISSET(s,&rset) */ FD_ISSET (s, &wset))
    
66.     {
    
67.       len = sizeof (error);
    
68.       errno = 0;
    
69.       if (0 >
    
70.            (ret =
    
71.             getsockopt (s, SOL_SOCKET, SO_ERROR, (void *) &error, &len)))
    
72.         {
    
73.           close (s);
    
74.           printf ("getsockopt error:%s\n", strerror (errno));
    
75.           return 1;
    
76.         }
    
77.       if (error != 0)
    
78.         {
    
79.           printf ("getsockopt set error:%s\n", strerror (errno));
    
80.           close (s);
    
81.           return 1;
    
82.         }
    
83.       printf ("getsockopt success\n");
    
84.     }
    
85.   else
    
86.     {
    
87.       close (s);
    
88.       printf ("FD_ISSET error\n");
    
89.       return 1;
    
90.     }
    
91.   if (-1 == (ret = read (s, buf, sizeof (buf))))
    
92.     {
    
93.       printf ("read() failed\n");
    
94.       return 1;
    
95.     }                                /*如果连接成功就从server读取点东西 */
    
96.   printf ("ret=%d\n", ret);
    
97.   buf[ret - 1] = '\0';
    
98.   printf ("read:%s\n", buf);
    
99.   close (s);
    
100.   return 0;
     
101. }
     

复制代码

[ 本帖最后由 win_hate 于 2009-5-13 15:06 编辑 ]

xp5211314

timeval参数应该在每次循环的时候重置，不然不会起作用

jeanlove

原帖由 kinwin 于 2009-5-13 11:50 发表

如果只检测读端的话，会一直等待到返回错误


重连+定时。

谢谢，很好的纠正。

jeanlove

原帖由 urapple 于 2009-5-13 11:42 发表
楼主大大
select的作用是检查描述符的状态，是否有数据过来，比如
要查读描述符，那就检查读描述符的状态，有数据来，就会返回，否则，一直等待，知道你设定的超时时间退出。
而你上面的connect的问题，不是 ...

谢谢，越说越明白了。

jeanlove

原帖由 ideawu 于 2009-5-13 11:05 发表

正是这样的.

不能随便地得出这种推论.

对于你的问题的解决方法: 检测到连接失败, 重新connect.

嗯，也就是说我的这种情况得重连，而不是用select。