Cross Reference: /dovecot/src/lib/iostream-temp.c

Lines Matching defs:ostream
9 #include "ostream-private.h"
17 	struct ostream_private ostream;
74 	tstream->ostream.fd = tstream->fd;
80 int o_stream_temp_move_to_memory(struct ostream *output)
90 	while (offset < tstream->ostream.ostream.offset &&
92 		if ((size_t)ret > tstream->ostream.ostream.offset - offset)
93 			ret = tstream->ostream.ostream.offset - offset;
100 			o_stream_get_name(&tstream->ostream.ostream),
102 		tstream->ostream.ostream.stream_errno = EIO;
106 	tstream->ostream.fd = -1;
120 				o_stream_get_name(&tstream->ostream.ostream),
122 			if (o_stream_temp_move_to_memory(&tstream->ostream.ostream) < 0)
127 				tstream->ostream.ostream.offset += iov[i].iov_len;
133 		tstream->ostream.ostream.offset += iov[i].iov_len;
169 		stream->ostream.offset += iov[i].iov_len;
183 	tstream->ostream.ostream.offset = 0;
188 	*res_r = io_stream_copy(&tstream->ostream.ostream, input);
198 		tstream->ostream.ostream.stream_errno = input->stream_errno;
199 		io_stream_set_error(&tstream->ostream.iostream,
243 	outstream->ostream.ostream.offset =
261 	return io_stream_copy(&outstream->ostream.ostream, instream);
271 		i_assert(stream->ostream.offset == tstream->buf->used);
273 		stream->ostream.offset = tstream->buf->used;
276 			stream->ostream.stream_errno = errno;
288 	_stream->ostream.offset = offset;
292 struct ostream *iostream_temp_create(const char *temp_path_prefix,
298 struct ostream *iostream_temp_create_named(const char *temp_path_prefix,
306 struct ostream *iostream_temp_create_sized(const char *temp_path_prefix,
312 	struct ostream *output;
315 	tstream->ostream.ostream.blocking = TRUE;
316 	tstream->ostream.sendv = o_stream_temp_sendv;
317 	tstream->ostream.send_istream = o_stream_temp_send_istream;
318 	tstream->ostream.write_at = o_stream_temp_write_at;
319 	tstream->ostream.seek = o_stream_temp_seek;
320 	tstream->ostream.iostream.close = o_stream_temp_close;
327 	output = o_stream_create(&tstream->ostream, NULL, -1);
344 struct istream *iostream_temp_finish(struct ostream **output,