| /dovecot/src/lib/ |
| H A D | ostream-hash.c | 5 #include "ostream-private.h"
6 #include "ostream-hash.h"
9 struct ostream_private ostream; member in struct:hash_ostream
38 stream->ostream.offset += ret;
42 struct ostream *
43 o_stream_create_hash(struct ostream *output, const struct hash_method *method,
49 hstream->ostream.sendv = o_stream_hash_sendv;
53 return o_stream_create(&hstream->ostream, output,
|
| H A D | ostream-file-private.h | 4 #include "ostream-private.h"
7 struct ostream_private ostream; member in struct:file_ostream
31 struct ostream *
|
| H A D | ostream.h | 7 /* All of the istream was successfully sent to ostream. */
11 /* Caller needs to wait for output to non-blocking ostream.
16 /* Write to ostream failed. See ostream->stream_errno. */
20 struct ostream { struct
23 ostream this is counting the uncompressed bytes. The compressed
24 bytes could be counted from the parent ostream's offset.
37 ostream code. */
54 struct ostream *o_stream_create_fd(int fd, size_t max_buffer_size);
56 struct ostream *o_stream_create_fd_autoclos
[all...] |
| H A D | ostream-buffer.c | 5 #include "ostream-private.h"
8 struct ostream_private ostream; member in struct:buffer_ostream
18 stream->ostream.offset = offset;
41 offset = bstream->seeked ? stream->ostream.offset : bstream->buf->used;
44 left = bstream->ostream.max_buffer_size -
45 stream->ostream.offset;
48 stream->ostream.offset += n; offset += n;
64 struct ostream *o_stream_create_buffer(buffer_t *buf)
67 struct ostream *output;
73 bstream->ostream
[all...] |
| H A D | ostream-escaped.c | 5 #include "ostream.h"
6 #include "ostream-private.h"
7 #include "ostream-escaped.h"
10 struct ostream_private ostream; member in struct:escaped_ostream
24 ret = o_stream_send(estream->ostream.parent, str_data(estream->buf), str_len(estream->buf));
26 o_stream_copy_error_from_parent(&estream->ostream);
46 max_buffer_size = I_MIN(o_stream_get_max_buffer_size(estream->ostream.parent),
47 estream->ostream.max_buffer_size);
57 estream->ostream.ostream
[all...] |
| H A D | ostream-failure-at.c | 5 #include "ostream-private.h"
6 #include "ostream-failure-at.h"
9 struct ostream_private ostream; member in struct:failure_at_ostream
21 o_stream_unref(&fstream->ostream.parent);
36 if (stream->ostream.blocking) {
37 /* blocking ostream must return either a full success or a
49 if (fstream->failure_offset <= stream->ostream.offset + blocking_bytes_count) {
52 stream->ostream.stream_errno = errno = EIO;
56 bytes_until_failure = fstream->failure_offset - stream->ostream.offset;
75 stream->ostream
[all...] |
| H A D | ostream-private.h | 4 #include "ostream.h"
32 struct ostream ostream; member in struct:ostream_private
35 struct ostream *parent; /* for filter streams */
53 struct ostream *
54 o_stream_create(struct ostream_private *_stream, struct ostream *parent, int fd)
58 io_stream_copy(struct ostream *outstream, struct istream *instream);
|
| H A D | ostream-rawlog.c | 5 #include "ostream-private.h"
6 #include "ostream-rawlog.h"
9 struct ostream_private ostream; member in struct:rawlog_ostream
20 o_stream_close(rstream->ostream.parent);
48 stream->ostream.offset += ret;
52 struct ostream *
53 o_stream_create_rawlog(struct ostream *output, const char *rawlog_path,
56 struct ostream *rawlog_output;
71 struct ostream *
72 o_stream_create_rawlog_from_stream(struct ostream *outpu
[all...] |
| H A D | iostream-temp.c | 9 #include "ostream-private.h"
17 struct ostream_private ostream; member in struct:temp_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
[all...] |
| H A D | ostream-multiplex.c | 6 #include "ostream-private.h"
7 #include "ostream-multiplex.h"
14 struct ostream_private ostream; member in struct:multiplex_ochannel
23 struct ostream *parent;
52 (*channelp)->ostream.ostream.stream_errno = stream_errno;
121 stream->ostream.offset += total;
161 o_stream_unref(&channel->ostream.parent);
174 static struct ostream *
181 channel->ostream
[all...] |
| H A D | ostream-file.c | 12 #include "ostream-file-private.h"
32 static struct ostream * o_stream_create_fd_common(int fd,
42 o_stream_get_name(&fstream->ostream.ostream));
47 fstream->ostream.ostream.closed = TRUE;
114 if (fstream->ostream.corked && !fstream->socket_cork_set) {
133 io_stream_set_error(&fstream->ostream.iostream,
135 fstream->ostream.ostream
466 struct ostream *ostream = &fstream->ostream.ostream; local
952 struct ostream *ostream; local
1007 struct ostream *ostream; local
1039 struct ostream *ostream = o_stream_create_fd_common(*fd, local
1049 struct ostream *ostream; local
[all...] |
| /dovecot/src/lib-fs/ |
| H A D | ostream-metawrap.c | 5 #include "ostream-private.h"
6 #include "ostream-metawrap.h"
9 struct ostream_private ostream; member in struct:metawrap_ostream
22 mstream->ostream.ostream.offset = 0;
37 stream->ostream.offset += ret;
53 _outstream->ostream.offset += instream->v_offset - orig_instream_offset;
57 struct ostream *
58 o_stream_create_metawrap(struct ostream *output,
64 mstream->ostream
[all...] |
| H A D | ostream-cmp.c | 5 #include "ostream-private.h"
6 #include "ostream-cmp.h"
9 struct ostream_private ostream; member in struct:cmp_ostream
25 o_stream_close(cstream->ostream.parent);
69 stream->ostream.offset += ret;
73 struct ostream *
74 o_stream_create_cmp(struct ostream *output, struct istream *input)
79 cstream->ostream.sendv = o_stream_cmp_sendv;
80 cstream->ostream.iostream.close = o_stream_cmp_close;
85 return o_stream_create(&cstream->ostream, outpu
[all...] |
| /dovecot/src/plugins/mail-filter/ |
| H A D | ostream-ext-filter.c | 9 #include "ostream-private.h"
10 #include "ostream-ext-filter.h"
15 struct ostream_private ostream; member in struct:mail_filter_ostream
19 struct ostream *ext_out;
33 o_stream_close(mstream->ostream.parent);
47 mstream->ostream.ostream.stream_errno = EIO;
56 stream->ostream.stream_errno =
60 stream->ostream.offset += ret;
99 stream->ostream
[all...] |
| /dovecot/src/lib-mail/ |
| H A D | ostream-dot.c | 5 #include "ostream-private.h"
6 #include "ostream-dot.h"
17 struct ostream_private ostream; member in struct:dot_ostream
71 o_stream_close(dstream->ostream.parent);
210 stream->ostream.offset += sent;
214 struct ostream *
215 o_stream_create_dot(struct ostream *output, bool force_extra_crlf)
220 dstream->ostream.sendv = o_stream_dot_sendv;
221 dstream->ostream.iostream.close = o_stream_dot_close;
222 dstream->ostream
[all...] |
| /dovecot/src/lib-ssl-iostream/ |
| H A D | ostream-openssl.c | 5 #include "ostream-private.h"
9 struct ostream_private ostream; member in struct:ssl_ostream
49 if (sstream->ostream.max_buffer_size == 0) {
54 avail = sstream->ostream.max_buffer_size > sstream->buffer->used ?
55 sstream->ostream.max_buffer_size - sstream->buffer->used : 0;
80 sstream->ostream.ostream.offset += bytes_sent;
100 io_stream_set_error(&sstream->ostream.iostream,
102 sstream->ostream.ostream
178 struct ostream *ostream = &sstream->ostream.ostream; local
[all...] |
| /dovecot/src/lib-test/ |
| H A D | test-ostream.c | 5 #include "ostream-private.h"
9 struct ostream_private ostream; member in struct:test_ostream
62 stream->ostream.offset += n;
75 left = tstream->ostream.max_buffer_size -
79 stream->ostream.offset += n;
93 struct ostream *ostream = &tstream->ostream.ostream; local
96 o_stream_ref(ostream);
145 struct ostream *ostream; local
[all...] |
| /dovecot/src/lib-compression/ |
| H A D | ostream-bzlib.c | 7 #include "ostream-private.h"
8 #include "ostream-zlib.h"
14 struct ostream_private ostream; member in struct:bzlib_ostream
30 o_stream_close(zstream->ostream.parent);
43 ret = o_stream_send(zstream->ostream.parent,
46 o_stream_copy_error_from_parent(&zstream->ostream);
110 if ((ret = o_stream_flush_parent_if_needed(&zstream->ostream)) <= 0)
178 stream->ostream.offset += bytes;
186 struct ostream *o_stream_create_bz2(struct ostream *outpu
[all...] |
| H A D | ostream-lz4.c | 7 #include "ostream-private.h"
8 #include "ostream-zlib.h"
15 struct ostream_private ostream; member in struct:lz4_ostream
32 o_stream_close(zstream->ostream.parent);
45 ret = o_stream_send(zstream->ostream.parent,
48 o_stream_copy_error_from_parent(&zstream->ostream);
77 io_stream_set_error(&zstream->ostream.iostream,
80 zstream->ostream.ostream.stream_errno = EINVAL;
172 stream->ostream
[all...] |
| H A D | ostream-lzma.c | 7 #include "ostream-private.h"
8 #include "ostream-zlib.h"
14 struct ostream_private ostream; member in struct:lzma_ostream
30 o_stream_close(zstream->ostream.parent);
43 ret = o_stream_send(zstream->ostream.parent,
46 o_stream_copy_error_from_parent(&zstream->ostream);
92 o_stream_get_name(&zstream->ostream.ostream));
95 o_stream_get_name(&zstream->ostream.ostream), re
[all...] |
| H A D | ostream-zlib.c | 8 #include "ostream-private.h"
9 #include "ostream-zlib.h"
16 struct ostream_private ostream; member in struct:zlib_ostream
35 i_assert(zstream->ostream.finished ||
36 zstream->ostream.ostream.stream_errno != 0 ||
37 zstream->ostream.error_handling_disabled);
40 o_stream_close(zstream->ostream.parent);
47 ret = o_stream_send(zstream->ostream.parent, zstream->gz_header,
50 o_stream_copy_error_from_parent(&zstream->ostream);
[all...] |
| /dovecot/src/lib-dcrypt/ |
| H A D | ostream-encrypt.c | 20 #include "ostream-encrypt.h"
21 #include "ostream-private.h"
33 struct ostream_private ostream; member in struct:encrypt_ostream
59 ec = o_stream_send(stream->ostream.parent, data, size);
63 o_stream_copy_error_from_parent(&stream->ostream);
66 io_stream_set_error(&stream->ostream.iostream,
67 "ostream-encrypt: Unexpectedly short write to parent stream");
68 stream->ostream.ostream.stream_errno = EINVAL;
150 io_stream_set_error(&stream->ostream
[all...] |
| /dovecot/src/lib-http/ |
| H A D | http-server-response.c | 7 #include "ostream-private.h"
275 struct ostream *output = resp->payload_output;
490 struct ostream *output = resp->payload_output;
500 /* chunked ostream needs to write to the parent stream's buffer */
711 struct ostream_private ostream; member in struct:http_server_ostream
732 stream->ostream.stream_errno = EIO;
740 stream->ostream.offset += ret;
749 struct ostream_private *ostream = &hsostream->ostream; local
757 if (ostream
[all...] |
| H A D | http-transfer-chunked.c | 5 #include "ostream-private.h"
528 struct ostream_private ostream; member in struct:http_transfer_chunked_ostream
568 (void)o_stream_send(tcstream->ostream.parent, "0\r\n\r\n", 5);
569 (void)o_stream_flush(&tcstream->ostream.ostream);
571 o_stream_close(tcstream->ostream.parent);
641 stream->ostream.offset += tcstream->chunk_size;
645 struct ostream *
646 http_transfer_chunked_ostream_create(struct ostream *output)
652 tcstream->ostream
[all...] |