diff options
author | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2015-10-18 00:21:03 +0000 |
---|---|---|
committer | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2015-10-18 00:21:03 +0000 |
commit | aa6e12f8e1ae1cc841ff9cc414899041ac915759 (patch) | |
tree | f97359cbcf4592c7945a19f5c24407d8b011854d | |
parent | be36adb82e96f422e6096e819d51cf1c17686c8d (diff) | |
download | ruby-aa6e12f8e1ae1cc841ff9cc414899041ac915759.tar.gz |
* ruby.c (open_load_file): use rb_thread_wait_fd() instead of reopen.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@52157 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
-rw-r--r-- | ChangeLog | 4 | ||||
-rw-r--r-- | ruby.c | 20 |
2 files changed, 5 insertions, 19 deletions
@@ -1,3 +1,7 @@ +Sun Oct 18 09:20:17 2015 KOSAKI Motohiro <kosaki.motohiro@gmail.com> + + * ruby.c (open_load_file): use rb_thread_wait_fd() instead of reopen. + Sun Oct 18 05:11:22 2015 KOSAKI Motohiro <kosaki.motohiro@gmail.com> * ruby.c (open_load_file): reset O_NONBLOCK after open. @@ -1726,19 +1726,6 @@ load_file_internal(VALUE argp_v) return (VALUE)tree; } -#ifdef S_ISFIFO -static void * -loadopen_func(void *arg) -{ - int fd; - fd = rb_cloexec_open((const char *)arg, O_RDONLY, 0); - if (fd >= 0) - rb_update_max_fd(fd); - - return (void *)(VALUE)fd; -} -#endif - static VALUE open_load_file(VALUE fname_v, int *xflag) { @@ -1793,12 +1780,7 @@ open_load_file(VALUE fname_v, int *xflag) rb_load_fail(fname_v, strerror(e)); } if (S_ISFIFO(st.st_mode)) { - /* We need to wait if FIFO is empty. So, let's reopen it. */ - (void)close(fd); - fd = (int)(VALUE)rb_thread_call_without_gvl(loadopen_func, - (void *)fname, RUBY_UBF_IO, 0); - if (fd < 0) - rb_load_fail(fname_v, strerror(errno)); + rb_thread_wait_fd(fd); } } #endif |