[ruby-dev:12720] Re: Process.waitall (Re: [BUG] Process::Status)

新井です。

In message "[ruby-dev:12719] Process.waitall (Re:  [BUG] Process::Status)"
  on 02 Apr 2001 01:59:17 +0900,
  Koji Arai <[e-mail]> wrote:
> 新井です。
> 
> Process.waitall が ステータス値を返していたので 
> Process::Status を返すようにしました．
> 
> また、以前、提案したように waktall がブロックを持てるように
> してみました．(そうしなかった理由がありました？)

NO_WAITPID の部分に間違いがあったのでパッチ出し直します。

# pid_tbl に要素があったら即 return してましたが wait()
# が ECHILD を返すまで return しては行けませんよね？

> ブロックを伴う場合の waitall の戻り値を各ブロックの戻り値の
> 配列にしましたが、これは余計だったような気が今はしてます。

常に pid, status の組の配列を返すようにしてみました。

ところで、NO_WAITPID の部分は rb_waitpid() が吸収していると
思うのでいらないような気がするのですが。。。勘違いしてますか？


Index: process.c
===================================================================
RCS file: /src/ruby/process.c,v
retrieving revision 1.33
diff -u -r1.33 process.c
--- process.c	2001/03/28 08:43:25	1.33
+++ process.c	2001/04/01 17:47:18
@@ -170,7 +170,7 @@
 {
     int status = NUM2INT(st);
 
-    if (WIFSIGNALED(st))
+    if (WIFSIGNALED(status))
 	return Qtrue;
     else
 	return Qfalse;
@@ -418,15 +418,20 @@
 {
     VALUE pid_status_ary, pid_status_member;
     int pid, status;
+
 #ifdef NO_WAITPID
     struct waitall_data data;
 
     data.ary = pid_status_ary = rb_ary_new();
     data.status = -1;
     st_foreach(pid_tbl, waitall_each, &data);
-    if (data.status != -1) {
-	last_status_set(data.status);
-	return pid_status_ary;
+    if (data.status != -1 && rb_block_given_p()) {
+        long i;
+        for (i = 0; i < RARRAY(pid_status_ary)->len; i++) {
+            pid_status_member = RARRAY(pid_status_ary)->ptr[i];
+            last_status_set(RARRAY(pid_status_member)->ptr[1]);
+            rb_yield(pid_status_member);
+        }
     }
 
     for (pid = -1;;) {
@@ -440,14 +445,14 @@
 	    }
 	    rb_sys_fail(0);
 	}
-	pid_status_member = rb_ary_new2(2);
-	rb_ary_push(pid_status_member, INT2NUM(pid));
-	rb_ary_push(pid_status_member, INT2NUM(status));
-	rb_ary_push(pid_status_ary, pid_status_member);
+        last_status_set(status);
+        pid_status_member = rb_assoc_new(INT2NUM(pid), rb_last_status);
+        rb_ary_push(pid_status_ary, pid_status_member);
+        if (rb_block_given_p())
+            rb_yield(pid_status_member);
     }
-    if (RARRAY(pid_status_ary)->len != 0)
-	last_status_set(status);
 #else
+    rb_last_status = Qnil;
     pid_status_ary = rb_ary_new();
     for (pid = -1;;) {
 	pid = rb_waitpid(-1, 0, &status);
@@ -456,10 +461,11 @@
 		break;
 	    rb_sys_fail(0);
 	}
-	pid_status_member = rb_ary_new2(2);
-	rb_ary_push(pid_status_member, INT2NUM(pid));
-	rb_ary_push(pid_status_member, INT2NUM(status));
-	rb_ary_push(pid_status_ary, pid_status_member);
+        last_status_set(status);
+        pid_status_member = rb_assoc_new(INT2NUM(pid), rb_last_status);
+        rb_ary_push(pid_status_ary, pid_status_member);
+        if (rb_block_given_p())
+            rb_ary_push(pid_status_ary, rb_yield(pid_status_member));
     }
 #endif
     return pid_status_ary;

--
新井康司 (Koji Arai)