https://git.ruby-lang.org/ruby.git/commit/?id=b419f90a8b

From b419f90a8bc3e472635a813e56cc2153b3125b41 Mon Sep 17 00:00:00 2001
From: Nobuyoshi Nakada <nobu@r...>
Date: Wed, 9 Dec 2020 11:49:20 +0900
Subject: Tweaked `Process::Status.wait`

* revert `rb_last_status_set`
* renamed the new function as `rb_process_status_new`
* `rb_process_status_new` always freezes the return value
* marked `Process::Status.wait` as EXPERIMENTAL, as it has not
  been discussed totally yet.

diff --git a/include/ruby/internal/intern/process.h b/include/ruby/internal/intern/process.h
index 8c7570e..2b1005a 100644
--- a/include/ruby/internal/intern/process.h
+++ b/include/ruby/internal/intern/process.h
@@ -28,7 +28,7 @@ https://github.com/ruby/ruby/blob/trunk/include/ruby/internal/intern/process.h#L28
 RBIMPL_SYMBOL_EXPORT_BEGIN()
 
 /* process.c */
-void rb_last_status_set(rb_pid_t pid, int status, int error);
+void rb_last_status_set(int status, rb_pid_t pid);
 VALUE rb_last_status_get(void);
 int rb_proc_exec(const char*);
 
diff --git a/io.c b/io.c
index b5553b5..15032d7 100644
--- a/io.c
+++ b/io.c
@@ -6437,7 +6437,7 @@ pipe_finalize(rb_io_t *fptr, int noraise) https://github.com/ruby/ruby/blob/trunk/io.c#L6437
     }
     fptr->fd = -1;
     fptr->stdio_file = 0;
-    rb_last_status_set(fptr->pid, status, 0);
+    rb_last_status_set(status, fptr->pid);
 #else
     fptr_finalize(fptr, noraise);
 #endif
diff --git a/process.c b/process.c
index acc9de1..0c59fcd 100644
--- a/process.c
+++ b/process.c
@@ -584,7 +584,9 @@ static const rb_data_type_t rb_process_status_type = { https://github.com/ruby/ruby/blob/trunk/process.c#L584
     .flags = RUBY_TYPED_FREE_IMMEDIATELY,
 };
 
-static VALUE rb_process_status_allocate(VALUE klass) {
+static VALUE
+rb_process_status_allocate(VALUE klass)
+{
     struct rb_process_status *data = NULL;
 
     return TypedData_Make_Struct(klass, struct rb_process_status, &rb_process_status_type, data);
@@ -617,11 +619,9 @@ proc_s_last_status(VALUE mod) https://github.com/ruby/ruby/blob/trunk/process.c#L619
     return rb_last_status_get();
 }
 
-void
-rb_last_status_set(rb_pid_t pid, int status, int error)
+VALUE
+rb_process_status_new(rb_pid_t pid, int status, int error)
 {
-    rb_thread_t *th = GET_THREAD();
-
     VALUE last_status = rb_process_status_allocate(rb_cProcessStatus);
 
     struct rb_process_status *data = RTYPEDDATA_DATA(last_status);
@@ -630,8 +630,19 @@ rb_last_status_set(rb_pid_t pid, int status, int error) https://github.com/ruby/ruby/blob/trunk/process.c#L630
     data->error = error;
 
     rb_obj_freeze(last_status);
+    return last_status;
+}
+
+static void
+process_status_set(rb_pid_t pid, int status, int error)
+{
+    GET_THREAD()->last_status = rb_process_status_new(pid, status, error);
+}
 
-    th->last_status = last_status;
+void
+rb_last_status_set(int status, rb_pid_t pid)
+{
+    process_status_set(pid, status, 0);
 }
 
 void
@@ -1340,8 +1351,11 @@ waitpid_no_SIGCHLD(struct waitpid_state *w) https://github.com/ruby/ruby/blob/trunk/process.c#L1351
  *     Time.now                                      #=> 2008-03-08 19:56:16 +0900
  *     Process::Status.wait(pid, 0)                  #=> pid 27440 exit 99
  *     Time.now                                      #=> 2008-03-08 19:56:19 +0900
+ *
+ * EXPERIMENTAL FEATURE
  */
-VALUE rb_process_status_wait(rb_pid_t pid, int flags)
+VALUE
+rb_process_status_wait(rb_pid_t pid, int flags)
 {
     // We only enter the scheduler if we are "blocking":
     if (!(flags & WNOHANG)) {
@@ -1370,12 +1384,7 @@ VALUE rb_process_status_wait(rb_pid_t pid, int flags) https://github.com/ruby/ruby/blob/trunk/process.c#L1384
         }
     }
 
-    VALUE status = rb_process_status_allocate(rb_cProcessStatus);
-
-    struct rb_process_status *data = RTYPEDDATA_DATA(status);
-    data->pid = w->ret;
-    data->status = w->status;
-    data->error = w->errnum;
+    VALUE status = rb_process_status_new(w->ret, w->status, w->errnum);
 
     COROUTINE_STACK_FREE(w);
 
@@ -1413,7 +1422,6 @@ rb_waitpid(rb_pid_t pid, int *st, int flags) https://github.com/ruby/ruby/blob/trunk/process.c#L1422
         errno = data->error;
     }
     else {
-        rb_obj_freeze(status);
         GET_THREAD()->last_status = status;
     }
 
@@ -4562,12 +4570,12 @@ rb_spawn_process(struct rb_execarg *eargp, char *errmsg, size_t errmsg_buflen) https://github.com/ruby/ruby/blob/trunk/process.c#L4570
     }
 
     if (pid == -1) {
-        rb_last_status_set(pid, 0x7f << 8, 0);
+        rb_last_status_set(0x7f << 8, pid);
     }
 # else
     status = system(rb_execarg_commandline(eargp, &prog));
     pid = 1;			/* dummy */
-    rb_last_status_set(pid, (status & 0xff) << 8, 0);
+    rb_last_status_set((status & 0xff) << 8, pid);
 # endif
 
     if (eargp->waitpid_state && eargp->waitpid_state != WAITPID_LOCK_ONLY) {
@@ -4720,7 +4728,7 @@ rb_f_system(int argc, VALUE *argv, VALUE _) https://github.com/ruby/ruby/blob/trunk/process.c#L4728
         else {
             waitpid_no_SIGCHLD(w);
         }
-        rb_last_status_set(w->ret, w->status, 0);
+        rb_last_status_set(w->status, w->ret);
     }
 #endif
     if (w->pid < 0 /* fork failure */ || pid < 0 /* exec failure */) {
-- 
cgit v0.10.2


--
ML: ruby-changes@q...
Info: http://www.atdot.net/~ko1/quickml/