From 01c433b58ccdbde5b488901e2accda87d931abd9 Mon Sep 17 00:00:00 2001
From: akr <akr@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>
Date: Sun, 20 Apr 2008 04:59:04 +0000
Subject: * io.c (copy_stream_fallback): write directly (bypassing write
 method)   if possible.

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@16090 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
---
 io.c | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

(limited to 'io.c')

diff --git a/io.c b/io.c
index f1c3cd45d3..188c998f98 100644
--- a/io.c
+++ b/io.c
@@ -6579,7 +6579,7 @@ copy_stream_fallback_body(VALUE arg)
 
     while (1) {
         long numwrote;
-        long l = buflen < rest ? buflen : rest;
+        long l;
         if (stp->copy_length == (off_t)-1) {
             l = buflen;
         }
@@ -6604,9 +6604,18 @@ copy_stream_fallback_body(VALUE arg)
             if (off != (off_t)-1)
                 off += ss;
         }
-        n = rb_io_write(stp->dst, buf);
-        numwrote = NUM2LONG(n);
-        stp->total += numwrote;
+        if (stp->dst_fd == -1) {
+            n = rb_io_write(stp->dst, buf);
+            numwrote = NUM2LONG(n);
+            stp->total += numwrote;
+        }
+        else {
+            ssize_t ss;
+            numwrote = RSTRING_LEN(buf);
+            ss = copy_stream_write(stp, RSTRING_PTR(buf), numwrote);
+            if (ss == -1)
+                return Qnil;
+        }
         rest -= numwrote;
     }
 
-- 
cgit v1.2.3