diff options
author | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-09-09 09:10:46 +0000 |
---|---|---|
committer | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-09-09 09:10:46 +0000 |
commit | 4b58f39dedfb3491aba7e39e5c2dba0876437cc4 (patch) | |
tree | bb3bcfee5027cf04320ad34808c099048ab501b9 /io.c | |
parent | 3df2fc2da8ee34ad0b923e42b3fcdc8daf391370 (diff) | |
download | ruby-4b58f39dedfb3491aba7e39e5c2dba0876437cc4.tar.gz |
* io.c (nogvl_close, maygvl_close, nogvl_fclose, maygvl_fclose):
new functions.
* io.c (fptr_finalize): release GVL if possible.
Patched by Eric Wong. [Feature #4570] [ruby-core:35711]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@36932 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'io.c')
-rw-r--r-- | io.c | 69 |
1 files changed, 56 insertions, 13 deletions
@@ -3853,10 +3853,51 @@ finish_writeconv_sync(VALUE arg) return finish_writeconv(p->fptr, p->noalloc); } +static void* +nogvl_close(void *ptr) +{ + int *fd = ptr; + + return (void*)close(*fd); +} + +static int +maygvl_close(int fd, int keepgvl) +{ + if (keepgvl) + return close(fd); + + /* + * close() may block for certain file types (NFS, SO_LINGER sockets, + * inotify), so let other threads run. + */ + return (int)rb_thread_call_without_gvl(nogvl_close, &fd, RUBY_UBF_IO, 0); +} + +static void* +nogvl_fclose(void *ptr) +{ + FILE *file = ptr; + + return (void*)fclose(file); +} + +static int +maygvl_fclose(FILE *file, int keepgvl) +{ + if (keepgvl) + return fclose(file); + + return (int)rb_thread_call_without_gvl(nogvl_fclose, file, RUBY_UBF_IO, 0); +} + static void fptr_finalize(rb_io_t *fptr, int noraise) { VALUE err = Qnil; + int fd = fptr->fd; + FILE *stdio_file = fptr->stdio_file; + if (fptr->writeconv) { if (fptr->write_lock && !noraise) { struct finish_writeconv_arg arg; @@ -3878,25 +3919,27 @@ fptr_finalize(rb_io_t *fptr, int noraise) err = INT2NUM(errno); } } - if (IS_PREP_STDIO(fptr) || fptr->fd <= 2) { - goto skip_fd_close; + + fptr->fd = -1; + fptr->stdio_file = 0; + if (!noraise) + rb_thread_fd_close(fd); + if (IS_PREP_STDIO(fptr) || fd <= 2) { + /* need to keep FILE objects of stdin, stdout and stderr */ } - if (fptr->stdio_file) { - /* fptr->stdio_file is deallocated anyway + else if (stdio_file) { + /* stdio_file is deallocated anyway * even if fclose failed. */ - if (fclose(fptr->stdio_file) < 0 && NIL_P(err)) - err = noraise ? Qtrue : INT2NUM(errno); + if ((maygvl_fclose(stdio_file, noraise) < 0) && NIL_P(err)) + err = noraise ? Qtrue : INT2NUM(errno); } - else if (0 <= fptr->fd) { - /* fptr->fd may be closed even if close fails. + else if (0 <= fd) { + /* fptr->fd may be closed even if close fails. * POSIX doesn't specify it. * We assumes it is closed. */ - if (close(fptr->fd) < 0 && NIL_P(err)) - err = noraise ? Qtrue : INT2NUM(errno); + if ((maygvl_close(fd, noraise) < 0) && NIL_P(err)) + err = noraise ? Qtrue : INT2NUM(errno); } - skip_fd_close: - fptr->fd = -1; - fptr->stdio_file = 0; fptr->mode &= ~(FMODE_READABLE|FMODE_WRITABLE); if (!NIL_P(err) && !noraise) { |