diff options
| -rw-r--r-- | stream/stream.c | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/stream/stream.c b/stream/stream.c index 8068effc06..c318554feb 100644 --- a/stream/stream.c +++ b/stream/stream.c @@ -419,15 +419,18 @@ struct bstr stream_peek(stream_t *s, int len) int stream_write_buffer(stream_t *s, unsigned char *buf, int len) { - int rd; if (!s->write_buffer) return -1; - rd = s->write_buffer(s, buf, len); - if (rd < 0) - return -1; - s->pos += rd; - assert(rd == len && "stream_write_buffer(): unexpected short write"); - return rd; + int orig_len = len; + while (len) { + int w = s->write_buffer(s, buf, len); + if (w <= 0) + return -1; + s->pos += w; + buf += w; + len -= w; + } + return orig_len; } // Drop len bytes form input, possibly reading more until all is skipped. If |