diff options
| author | nobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2003-05-16 15:18:14 +0000 |
|---|---|---|
| committer | nobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2003-05-16 15:18:14 +0000 |
| commit | e9d1dd838844b1205b62918058d1d2fd0d62ddd5 (patch) | |
| tree | a505f08582e3ff7aa18e61177bf6907e5b93b178 /ext | |
| parent | 6cbcafb9b953308f62c9d54ed3283fe4ddf002d5 (diff) | |
* ext/socket/socket.c (ruby_connect): connect() after EINPROGRESS
returns EINVAL on some platforms, need to check true error
status. [ruby-core:01037]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@3809 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'ext')
| -rw-r--r-- | ext/socket/socket.c | 45 |
1 files changed, 33 insertions, 12 deletions
diff --git a/ext/socket/socket.c b/ext/socket/socket.c index 14fbe6feb6..039d7b006b 100644 --- a/ext/socket/socket.c +++ b/ext/socket/socket.c @@ -324,7 +324,7 @@ bsock_getsockopt(sock, lev, optname) static VALUE bsock_getsockname(sock) - VALUE sock; + VALUE sock; { char buf[1024]; socklen_t len = sizeof buf; @@ -338,7 +338,7 @@ bsock_getsockname(sock) static VALUE bsock_getpeername(sock) - VALUE sock; + VALUE sock; { char buf[1024]; socklen_t len = sizeof buf; @@ -724,6 +724,13 @@ thread_write_select(fd) rb_thread_select(fd+1, 0, &fds, 0, 0); } +#ifdef __CYGWIN__ +#define WAIT_IN_PROGRESS 10 +#endif +#ifdef __APPLE__ +#define WAIT_IN_PROGRESS 10 +#endif + static int ruby_connect(fd, sockaddr, len, socks) int fd; @@ -733,7 +740,7 @@ ruby_connect(fd, sockaddr, len, socks) { int status; int mode; -#if defined __CYGWIN__ +#ifdef WAIT_IN_PROGRESS int wait_in_progress = -1; #endif @@ -770,20 +777,34 @@ ruby_connect(fd, sockaddr, len, socks) case EAGAIN: #ifdef EINPROGRESS case EINPROGRESS: -#ifdef __CYGWIN__ +#endif +#ifdef EALREADY case EALREADY: - wait_in_progress = 10; #endif +#ifdef WAIT_IN_PROGRESS + wait_in_progress = WAIT_IN_PROGRESS; #endif thread_write_select(fd); continue; -#if defined __CYGWIN__ +#ifdef WAIT_IN_PROGRESS case EINVAL: if (wait_in_progress-- > 0) { - struct timeval tv = {0, 100000}; - rb_thread_wait_for(tv); - continue; + int sockerr, sockerrlen = sizeof(sockerr); + + /* + * connect() after EINPROGRESS returns EINVAL on + * some platforms, need to check true error + * status. + */ + status = getsockopt(fd, SOL_SOCKET, SO_ERROR, &sockerr, &sockerrlen); + if (!status && !sockerr) { + struct timeval tv = {0, 100000}; + rb_thread_wait_for(tv); + continue; + } + status = -1; + errno = sockerr; } break; #endif @@ -1891,7 +1912,7 @@ sock_bind(sock, addr) static VALUE sock_listen(sock, log) - VALUE sock, log; + VALUE sock, log; { OpenFile *fptr; @@ -1914,7 +1935,7 @@ sock_recvfrom(argc, argv, sock) static VALUE sock_accept(sock) - VALUE sock; + VALUE sock; { OpenFile *fptr; VALUE sock2; @@ -1929,7 +1950,7 @@ sock_accept(sock) static VALUE sock_sysaccept(sock) - VALUE sock; + VALUE sock; { OpenFile *fptr; VALUE sock2; |