From 7fbaa0bedf29d6c44a3e038ec6dd9d153e4c7479 Mon Sep 17 00:00:00 2001 From: kosaki Date: Sat, 15 Dec 2012 05:40:29 +0000 Subject: * io.c (finish_writeconv): uses rb_write_internal2 if fptr->write_lock have. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@38401 b2dd03c8-39d4-4d8f-98ff-823fe69b080e --- io.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'io.c') diff --git a/io.c b/io.c index 9103664412..bfafe636d8 100644 --- a/io.c +++ b/io.c @@ -3858,7 +3858,10 @@ finish_writeconv(rb_io_t *fptr, int noalloc) res = rb_econv_convert(fptr->writeconv, NULL, NULL, &dp, de, 0); while (dp-ds) { retry: - r = rb_write_internal(fptr->fd, ds, dp-ds); + if (fptr->write_lock && rb_mutex_owned_p(fptr->write_lock)) + r = rb_write_internal2(fptr->fd, ds, dp-ds); + else + r = rb_write_internal(fptr->fd, ds, dp-ds); if (r == dp-ds) break; if (0 <= r) { -- cgit v1.2.3