[ruby-dev:13764] Re: mswin32/ming32 system patch (experimental)

なかだです。

  えーと、もう二個。

  今win32.cのwaitpid()にpidとして-1を指定したとき、子プロセスの
どれかが終了するまでではなく、子プロセスのどれかを選んでそれが
終了するまで待つようになってしまってます。

$ ruby -e '3.times {|i|IO.popen("sleep #{3-i}")}' \
       -e 'loop{p Process.waitpid(-1)}'

とすると、linuxやcygwinなどでは間をおいてpidが出力されますが、
mingwとmswinでは最後に一気に出力されます。

  それから、waitpid()でChildRecordがすでに開放されているとその
後のmypclose()でfatal errorになってしまうので、とりあえず単な
るエラーということに。finalizerでmypclose()が呼ばれるまでとっ
ておくというのもありかも知れませんが、linuxで試したところでも
statusは得られないようなのでこんなところかなと。


--- win32/win32.c-	Sun Jul  8 02:54:09 2001
+++ win32/win32.c	Sun Jul  8 17:50:47 2001
@@ -523,5 +523,5 @@ mypclose(FILE *fp)
 
     if (!child) {
-	rb_fatal("Invalid file pointer passed to mypclose!\n");
+	return -1;		/* may closed in waitpid() */
     }
 
@@ -2267,22 +2267,32 @@ void setservent (int stayopen) {}
 #endif
 
-pid_t
-waitpid (pid_t pid, int *stat_loc, int options)
+static pid_t
+wait_child(struct ChildRecord *child, int *stat_loc, DWORD timeout)
 {
-    DWORD timeout;
     DWORD exitcode;
-    int ret;
-    struct ChildRecord* child;
 
-    if (pid == -1) {
-	child = FindFirstChildSlot();
-    }
-    else {
-	child = FindChildSlot(pid);
-    }
-    if (!child) {
-	errno = ECHILD;
+    if (!GetExitCodeProcess(child->hProcess, &exitcode)) {
+	/* If an error occured, return immediatly. */
+	errno = GetLastError();
+	if (errno == ERROR_INVALID_PARAMETER) {
+	    errno = ECHILD;
+	}
+	CloseChildHandle(child);
 	return -1;
     }
+    if (exitcode != STILL_ACTIVE) {
+	/* If already died, return immediatly. */
+	pid_t pid = child->pid;
+	CloseChildHandle(child);
+	if (stat_loc) *stat_loc = exitcode << 8;
+	return pid;
+    }
+    return 0;
+}
+
+pid_t
+waitpid (pid_t pid, int *stat_loc, int options)
+{
+    DWORD timeout;
 
     if (options == WNOHANG) {
@@ -2292,28 +2302,48 @@ waitpid (pid_t pid, int *stat_loc, int o
     }
 
-    for (;;) {
-	if (!GetExitCodeProcess(child->hProcess, &exitcode)) {
-	    /* If an error occured, return immediatly. */
+    if (pid == -1) {
+	int count = 0;
+	DWORD ret;
+	HANDLE events[MAXCHILDNUM + 1];
+
+	FOREACH_CHILD(child) {
+	    if (!child->pid || child->pid < 0) continue;
+	    if ((pid = wait_child(child, stat_loc, 0))) return pid;
+	    events[count++] = child->hProcess;
+	} END_FOREACH_CHILD;
+	if (!count) {
+	    errno = ECHILD;
+	    return -1;
+	}
+	events[count] = interrupted_event;
+
+	ret = WaitForMultipleEvents(count, events, FALSE, timeout, TRUE);
+	if (ret == WAIT_TIMEOUT) return 0;
+	if ((ret -= WAIT_OBJECT_0) == count) {
+	    ResetSignal(interrupted_event);
+	    errno = EINTR;
+	    return -1;
+	}
+	if (ret > count) {
 	    errno = GetLastError();
-	    if (errno == ERROR_INVALID_PARAMETER) {
-		errno = ECHILD;
-	    }
-	    CloseChildHandle(child);
-	    pid = -1;
-	    break;
+	    return -1;
 	}
-	else if (exitcode != STILL_ACTIVE) {
-	    /* If already died, return immediatly. */
-	    pid = child->pid;
-	    CloseChildHandle(child);
-	    if (stat_loc) *stat_loc = exitcode << 8;
-	    break;
+
+	return wait_child(ChildRecord + ret, stat_loc, 0);
+    }
+    else {
+	struct ChildRecord* child = FindChildSlot(pid);
+	if (!child) {
+	    errno = ECHILD;
+	    return -1;
 	}
 
-	/* wait... */
-	if (wait_events(child->hProcess, timeout) != WAIT_OBJECT_0) {
-	    /* still active */
-	    pid = 0;
-	    break;
+	while (!(pid = wait_child(child, stat_loc, timeout))) {
+	    /* wait... */
+	    if (wait_events(child->hProcess, timeout) != WAIT_OBJECT_0) {
+		/* still active */
+		pid = 0;
+		break;
+	    }
 	}
     }


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