Lines Matching refs:bstream
19 struct qp_encoder_istream *bstream =
22 if (bstream->qp != NULL)
23 qp_encoder_deinit(&bstream->qp);
24 buffer_free(&bstream->buf);
26 i_stream_close(bstream->istream.parent);
31 struct qp_encoder_istream *bstream =
39 i_assert(stream->skip <= bstream->buf->used);
40 buffer_delete(bstream->buf, 0, stream->skip);
45 stream->buffer = bstream->buf->data;
46 i_assert(stream->pos <= bstream->buf->used);
48 if (stream->pos >= bstream->istream.max_buffer_size) {
55 if (bstream->buf->used > 0) {
60 if (bstream->buf->used <= bstream->istream.max_buffer_size) {
61 new_pos = bstream->buf->used;
65 new_pos = bstream->istream.max_buffer_size;
83 qp_encoder_more(bstream->qp, data, size);
92 struct qp_encoder_istream *bstream =
102 qp_encoder_finish(bstream->qp);
103 buffer_set_used_size(bstream->buf, 0);
111 struct qp_encoder_istream *bstream;
113 bstream = i_new(struct qp_encoder_istream, 1);
114 bstream->istream.max_buffer_size = input->real_stream->max_buffer_size;
115 bstream->buf = buffer_create_dynamic(default_pool, 128);
116 bstream->qp = qp_encoder_init(bstream->buf, ISTREAM_QP_ENCODER_MAX_LINE_LENGTH, flags);
118 bstream->istream.iostream.close = i_stream_qp_encoder_close;
119 bstream->istream.read = i_stream_qp_encoder_read;
120 bstream->istream.seek = i_stream_qp_encoder_seek;
122 bstream->istream.istream.readable_fd = FALSE;
123 bstream->istream.istream.blocking = input->blocking;
124 bstream->istream.istream.seekable = input->seekable;
125 return i_stream_create(&bstream->istream, input,