diff --git a/ChangeLog b/ChangeLog index 43332d48f2..da93ede475 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,13 @@ +Mon Nov 7 20:05:16 2011 NAKAMURA Usaku + + * io.c (io_fflush): remove fsync(). + + * io.c (rb_io_flush, rb_io_rewind): fsync() here. + + these changes reduces fsync() calls to improve performance. + first reported at [ruby-list:48515] by ak7 at mail.goo.ne.jp . + [Bug #5585] + Mon Nov 7 19:43:10 2011 Tanaka Akira * io.c (rb_close_before_exec): use F_MAXFD if available. diff --git a/io.c b/io.c index 307611f7a2..a191999942 100644 --- a/io.c +++ b/io.c @@ -837,11 +837,6 @@ io_fflush(rb_io_t *fptr) return -1; rb_io_check_closed(fptr); } -#ifdef _WIN32 - if (GetFileType((HANDLE)rb_w32_get_osfhandle(fptr->fd)) == FILE_TYPE_DISK) { - fsync(fptr->fd); - } -#endif return 0; } @@ -1223,6 +1218,11 @@ rb_io_flush(VALUE io) if (fptr->mode & FMODE_WRITABLE) { if (io_fflush(fptr) < 0) rb_sys_fail(0); +#ifdef _WIN32 + if (GetFileType((HANDLE)rb_w32_get_osfhandle(fptr->fd)) == FILE_TYPE_DISK) { + fsync(fptr->fd); + } +#endif } if (fptr->mode & FMODE_READABLE) { io_unread(fptr); @@ -1355,6 +1355,11 @@ rb_io_rewind(VALUE io) GetOpenFile(io, fptr); if (io_seek(fptr, 0L, 0) < 0 && errno) rb_sys_fail_path(fptr->pathv); +#ifdef _WIN32 + if (GetFileType((HANDLE)rb_w32_get_osfhandle(fptr->fd)) == FILE_TYPE_DISK) { + fsync(fptr->fd); + } +#endif if (io == ARGF.current_file) { ARGF.lineno -= fptr->lineno; }