diff options
author | wanabe <wanabe@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2009-11-16 05:06:16 +0000 |
---|---|---|
committer | wanabe <wanabe@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2009-11-16 05:06:16 +0000 |
commit | 7be6cbef51c76402295bb6638b1b53adde6e8e2d (patch) | |
tree | 3124c627df5d9c73e767e9c43df29c20dae042f7 /io.c | |
parent | 6e9e286b3cdb8dbbb0511e3e3f43cedb5d83ec09 (diff) | |
download | ruby-7be6cbef51c76402295bb6638b1b53adde6e8e2d.tar.gz ruby-7be6cbef51c76402295bb6638b1b53adde6e8e2d.tar.xz ruby-7be6cbef51c76402295bb6638b1b53adde6e8e2d.zip |
* io.c (read_all): shift read buffer if exception occured.
pointed out in [ruby-dev:39702].
git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@25795 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'io.c')
-rw-r--r-- | io.c | 9 |
1 files changed, 8 insertions, 1 deletions
@@ -1686,13 +1686,20 @@ read_all(rb_io_t *fptr, long siz, VALUE str) else rb_str_set_len(str, 0); make_readconv(fptr, 0); while (1) { + int fin, state = 0; + if (fptr->cbuf_len > fptr->cbuf_capa / 2) { io_shift_cbuf(fptr, fptr->cbuf_len, &str); } - if (more_char(fptr) == -1) { + + fin = rb_protect((VALUE (*)(VALUE))more_char, (VALUE)fptr, &state); + if (fin == -1 || state != 0) { if (fptr->cbuf_len) { io_shift_cbuf(fptr, fptr->cbuf_len, &str); } + if (state != 0) { + rb_jump_tag(state); + } clear_readconv(fptr); return io_enc_str(str, fptr); } |