Lines Matching refs:bstream
19 struct qp_decoder_istream *bstream =
22 if (bstream->qp != NULL)
23 qp_decoder_deinit(&bstream->qp);
24 buffer_free(&bstream->buf);
26 i_stream_close(bstream->istream.parent);
31 struct qp_decoder_istream *bstream =
42 i_assert(stream->skip <= bstream->buf->used);
43 buffer_delete(bstream->buf, 0, stream->skip);
48 stream->buffer = bstream->buf->data;
50 i_assert(stream->pos <= bstream->buf->used);
58 if (bstream->buf->used > 0) {
63 new_pos = I_MIN(bstream->buf->used, max_buffer_size);
79 if (qp_decoder_finish(bstream->qp, &error) == 0) {
80 i_assert(bstream->buf->used == 0);
88 if (qp_decoder_more(bstream->qp, data, size,
105 struct qp_decoder_istream *bstream =
116 (void)qp_decoder_finish(bstream->qp, &error);
117 buffer_set_used_size(bstream->buf, 0);
124 struct qp_decoder_istream *bstream;
126 bstream = i_new(struct qp_decoder_istream, 1);
127 bstream->istream.max_buffer_size = input->real_stream->max_buffer_size;
128 bstream->buf = buffer_create_dynamic(default_pool, 128);
129 bstream->qp = qp_decoder_init(bstream->buf);
131 bstream->istream.iostream.close = i_stream_qp_decoder_close;
132 bstream->istream.read = i_stream_qp_decoder_read;
133 bstream->istream.seek = i_stream_qp_decoder_seek;
135 bstream->istream.istream.readable_fd = FALSE;
136 bstream->istream.istream.blocking = input->blocking;
137 bstream->istream.istream.seekable = input->seekable;
138 return i_stream_create(&bstream->istream, input,