Mercurial > dovecot > core-2.2
changeset 10875:1473de6ba383 HEAD
Reverted recent istream-limit cleanup. It broke things.
author | Timo Sirainen <tss@iki.fi> |
---|---|
date | Tue, 09 Mar 2010 01:11:52 +0200 |
parents | 3a575415ce1a |
children | 370ee9717a6c |
files | src/lib/istream-limit.c |
diffstat | 1 files changed, 33 insertions(+), 14 deletions(-) [+] |
line wrap: on
line diff
--- a/src/lib/istream-limit.c Tue Mar 09 00:34:22 2010 +0200 +++ b/src/lib/istream-limit.c Tue Mar 09 01:11:52 2010 +0200 @@ -29,25 +29,45 @@ struct limit_istream *lstream = (struct limit_istream *) stream; uoff_t left; ssize_t ret; + size_t pos; - i_assert(stream->istream.v_offset + - (stream->pos - stream->skip) <= lstream->v_size); - left = lstream->v_size - - (stream->istream.v_offset + (stream->pos - stream->skip)); - if (left == 0) { + if (stream->istream.v_offset + + (stream->pos - stream->skip) >= lstream->v_size) { stream->istream.eof = TRUE; return -1; } - i_stream_skip(stream->parent, stream->skip); - ret = i_stream_read_copy_from_parent(&stream->istream); - i_assert(stream->skip == 0); - if (ret >= (off_t)left) { - stream->pos -= ret - left; - ret = left; - stream->istream.eof = TRUE; + i_stream_seek(stream->parent, lstream->istream.parent_start_offset + + stream->istream.v_offset); + + stream->pos -= stream->skip; + stream->skip = 0; + + stream->buffer = i_stream_get_data(stream->parent, &pos); + if (pos > stream->pos) + ret = 0; + else do { + if ((ret = i_stream_read(stream->parent)) == -2) + return -2; + + stream->istream.stream_errno = stream->parent->stream_errno; + stream->istream.eof = stream->parent->eof; + stream->buffer = i_stream_get_data(stream->parent, &pos); + } while (pos <= stream->pos && ret > 0); + + if (lstream->v_size != (uoff_t)-1) { + left = lstream->v_size - stream->istream.v_offset; + if (pos >= left) { + pos = left; + stream->istream.eof = TRUE; + } } - i_assert(stream->istream.v_offset + stream->pos <= lstream->v_size); + + ret = pos > stream->pos ? (ssize_t)(pos - stream->pos) : + (ret == 0 ? 0 : -1); + stream->pos = pos; + i_assert(ret != -1 || stream->istream.eof || + stream->istream.stream_errno != 0); return ret; } @@ -58,7 +78,6 @@ i_assert(v_offset <= lstream->v_size); - i_stream_seek(stream->parent, stream->parent_start_offset + v_offset); stream->istream.v_offset = v_offset; stream->skip = stream->pos = 0; }