[ruby-list:30577] Re: open errno EALREADY triggerd

なかだです。

At Tue, 10 Jul 2001 12:22:31 +0900,
[e-mail] (Yukihiro Matsumoto) wrote:
> で、このパッチを当てたらよいんですか？

  さて、私も確認できないのでこれで十分かどうかわからないんです
が、とりあえずEALREADYにも対処する必要はありそうな気がします。

  今EINPROGRESSのときにはwaitを入れるようになってますが、それで
も出るときは出るそうなので、やっぱり単純に0.1秒待つというだけで
は芳しくないようです。リトライしまくってみるというのも手かも知
れません。

>                             ぜんぜんわかってないヒト
>                             まつもと ゆきひろ /:|)

  かといって私がわかっているかというとそうでもないとゆー:P。


Index: socket.c
===================================================================
RCS file: /cvs/ruby/src/ruby/ext/socket/socket.c,v
retrieving revision 1.45
diff -u -2 -p -r1.45 socket.c
--- socket.c	2001/06/22 15:48:59	1.45
+++ socket.c	2001/07/10 07:52:45
@@ -701,4 +701,8 @@ thread_write_select(fd)
 }
 
+#if (defined EINPROGRESS || defined EALREADY) && defined __CYGWIN__
+# define RETRY_WINSOCK
+#endif
+
 static int
 ruby_connect(fd, sockaddr, len, socks)
@@ -710,4 +714,9 @@ ruby_connect(fd, sockaddr, len, socks)
     int status;
     int mode;
+    int wait_in_progress = -1;
+#ifdef RETRY_WINSOCK
+#   define MAX_WAIT_IN_PROGRESS 100
+#   define INTERVAL_IN_PROGRESS {0, 50000}
+#endif
 
 #if defined(HAVE_FCNTL)
@@ -744,16 +753,25 @@ ruby_connect(fd, sockaddr, len, socks)
 #ifdef EINPROGRESS
 	      case EINPROGRESS:
-#if defined __CYGWIN__
+#endif
+#ifdef EALREADY
+	      case EALREADY:
+#endif
+#ifdef RETRY_WINSOCK
+		wait_in_progress = MAX_WAIT_IN_PROGRESS;
+	      retry_winsock:
 		{
-		    struct timeval tv;
-		    tv.tv_sec = 0;
-		    tv.tv_usec = 100000;
+		    struct timeval tv = INTERVAL_IN_PROGRESS;
 		    rb_thread_wait_for(tv);
 		}
 #endif
-#endif
 		thread_write_select(fd);
 		continue;
 
+#ifdef RETRY_WINSOCK
+	      case EINVAL:
+		if (--wait_in_progress > 0) goto retry_winsock;
+		break;
+#endif
+
 #ifdef EISCONN
 	      case EISCONN:


-- 
--- 僕の前にBugはない。
--- 僕の後ろにBugはできる。
    中田 伸悦