[ruby-dev:14513] Re: recursive malloc (Re: supportedplatforms/ K&R)

新井です。

In message "[ruby-dev:14493] Re: recursive malloc (Re: supportedplatforms/ K&R)"
  on 16 Aug 2001 06:06:38 +0900,
  [e-mail] wrote:
> なかだです。
> 
> At Thu, 16 Aug 2001 05:24:12 +0900,
> Koji Arai <[e-mail]> wrote:
> > Posix.1g の定義だと、accept()は、ECONNABORTED
> > 「SVR4インプリメンテーション」だと、accept()は、EPROTO
> 
>   ということは、逆に言えばPosix互換かSVR4なシステムならselect()
> の後のRSTによってブロックすることはないということでしょうか。

そうです。あっ、そうか。

#ifdef SYSV
    fd2 = accept(fd, 0, 0);
#else
    TRAP_BEG;
    fd2 = accept(fd, sockaddr, len);
    TRAP_END;
#endif

のようなコードでいいのか

recvfrom() にも同じ対処がいるのかもと思って再現させようとし
たのですが、(たぶん)別件でcore吐いてしまいました。またバック
トレースを持って帰ってないのですが、coreが膨れあがってたこと
とからメモリリークだと思われます(来週以降に追試)。

>   やっぱり[ruby-dev:14477]のgetpeername()を使う方法でしょうか。
> デメリットとしてはSysV以外でシステムコールが増えるくらい?

前のメールでは、あまりにも想像で書きすぎました。ごめんなさい。
getpeername() は、効果ありませんでした。

/etc/nsswitch.conf といってたのは、/etc/netconfig というファ
イルで(おお違い)。tcp などのプロトコルに対応するドライバは何
かとか、名前解決に DNSを使うかNIS を使うかといったことが定義
されているファイルです。(まあ役割は nsswitch.conf と大体一緒
ですね)

で、accept()実行時にこのファイルが読み込まれているのは確かで、
(truss コマンド(Linuxでいうstrace)でaccept()実行時のシステム
コールを見たところ、しっかり open()されてました)、これは、
accept() の引数を変えても同じでした。

そういうわけで、今回の件は、結局添付のパッチで良いのではなか
ろうかと思います。
# rb_thread_wait_fd(fd) の呼び出しが retry でかぶるのが気になって
# ちょっとイジってますが、これは余計ですか？


Thu Aug 16 23:03:40 2001  Koji Arai  <[e-mail]>

	* io.c: prevent recursive malloc calls on NEC UX/4800.

	* ext/socket/socket.c: ditto.

Index: io.c
===================================================================
RCS file: /usr/local/cvsup/ruby/ruby/io.c,v
retrieving revision 1.92
diff -u -r1.92 io.c
--- io.c	2001/08/06 03:05:13	1.92
+++ io.c	2001/08/14 20:31:21
@@ -27,7 +27,7 @@
 # define NO_LONG_FNAME
 #endif
 
-#if defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(sun)
+#if defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__) || defined(sun) || defined(_nec_ews)
 # define USE_SETVBUF
 #endif
 
Index: ext/socket/socket.c
===================================================================
RCS file: /usr/local/cvsup/ruby/ruby/ext/socket/socket.c,v
retrieving revision 1.50
diff -u -r1.50 socket.c
--- ext/socket/socket.c	2001/08/06 06:10:10	1.50
+++ ext/socket/socket.c	2001/08/16 13:37:20
@@ -437,8 +437,8 @@
 
     str = rb_tainted_str_new(0, NUM2INT(len));
 
-    rb_thread_wait_fd(fd);
   retry:
+    rb_thread_wait_fd(fd);
     TRAP_BEG;
     RSTRING(str)->len = recvfrom(fd, RSTRING(str)->ptr, RSTRING(str)->len, flags,
 				 (struct sockaddr*)buf, &alen);
@@ -454,7 +454,6 @@
 #if EAGAIN != EWOULDBLOCK
 	  case EAGAIN:
 #endif
-	    rb_thread_wait_fd(fd);
 	    goto retry;
 	}
 	rb_sys_fail("recvfrom(2)");
@@ -1100,9 +1099,13 @@
     rb_secure(3);
   retry:
     rb_thread_wait_fd(fd);
+#if defined(_nec_ews)
+    fd2 = accept(fd, sockaddr, len);
+#else
     TRAP_BEG;
     fd2 = accept(fd, sockaddr, len);
     TRAP_END;
+#endif
     if (fd2 < 0) {
 	switch (errno) {
 	  case EMFILE:
@@ -1119,7 +1122,6 @@
 #if EAGAIN != EWOULDBLOCK
 	  case EAGAIN:
 #endif
-	    rb_thread_wait_fd(fd);
 	    goto retry;
 	}
 	rb_sys_fail(0);

--
新井康司 (Koji Arai)