summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authornobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2008-06-20 03:40:02 +0000
committernobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2008-06-20 03:40:02 +0000
commit808fc9daa5538ae75ec06340a7c792dfdf72433e (patch)
tree2fccdbdeda98fd694db8b02a328ee9335570c040
parent75fb0d37b351d989959c87bd2b54fa7837050f3f (diff)
downloadruby-808fc9daa5538ae75ec06340a7c792dfdf72433e.tar.gz
ruby-808fc9daa5538ae75ec06340a7c792dfdf72433e.tar.xz
ruby-808fc9daa5538ae75ec06340a7c792dfdf72433e.zip
* process.c (rb_detach_process): store detached process ID in the
thread local storage. moved from lib/open3.rb. git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@17469 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
-rw-r--r--ChangeLog5
-rw-r--r--lib/open3.rb1
-rw-r--r--process.c19
3 files changed, 23 insertions, 2 deletions
diff --git a/ChangeLog b/ChangeLog
index 501d439e2..48e976557 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+Fri Jun 20 12:39:55 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
+
+ * process.c (rb_detach_process): store detached process ID in the
+ thread local storage. moved from lib/open3.rb.
+
Fri Jun 20 11:57:46 2008 Yukihiro Matsumoto <matz@ruby-lang.org>
* string.c (rb_str_sub_bang): should preserve replacement points
diff --git a/lib/open3.rb b/lib/open3.rb
index f707f5540..d776de744 100644
--- a/lib/open3.rb
+++ b/lib/open3.rb
@@ -66,7 +66,6 @@ module Open3
pid = spawn(*cmd, STDIN=>pw[0], STDOUT=>pr[1], STDERR=>pe[1])
wait_thr = Process.detach(pid)
- wait_thr[:pid] = pid
pw[0].close
pr[1].close
pe[1].close
diff --git a/process.c b/process.c
index ee0bbaf4d..94dc712c8 100644
--- a/process.c
+++ b/process.c
@@ -885,6 +885,20 @@ proc_waitall(void)
return result;
}
+static inline ID
+id_pid(void)
+{
+ ID pid;
+ CONST_ID(pid, "pid");
+ return pid;
+}
+
+static VALUE
+detach_process_pid(VALUE thread)
+{
+ return rb_thread_local_aref(thread, id_pid());
+}
+
static VALUE
detach_process_watcher(void *arg)
{
@@ -900,7 +914,10 @@ detach_process_watcher(void *arg)
VALUE
rb_detach_process(rb_pid_t pid)
{
- return rb_thread_create(detach_process_watcher, (void*)(VALUE)pid);
+ VALUE watcher = rb_thread_create(detach_process_watcher, (void*)(VALUE)pid);
+ rb_thread_local_aset(watcher, id_pid(), PIDT2NUM(pid));
+ rb_define_singleton_method(watcher, "pid", detach_process_pid, 0);
+ return watcher;
}