Searched defs:istream (Results 1 - 25 of 50) sorted by relevance

12

/dovecot/src/lib/
H A Distream-file-private.h4 #include "istream-private.h"
7 struct istream_private istream; member in struct:file_istream
16 struct istream *
H A Distream-failure-at.c4 #include "istream-private.h"
5 #include "istream-failure-at.h"
8 struct istream_private istream; member in struct:failure_at_istream
30 stream->istream.v_offset);
32 ret = i_stream_read_copy_from_parent(&stream->istream);
33 new_offset = stream->istream.v_offset + (stream->pos - stream->skip);
35 if (stream->istream.v_offset >= fstream->failure_offset) {
39 stream->istream.stream_errno = errno =
48 stream->istream.v_offset + stream->skip;
54 } else if (ret < 0 && stream->istream
[all...]
H A Distream-hash.c5 #include "istream-private.h"
6 #include "istream-hash.h"
9 struct istream_private istream; member in struct:hash_istream
26 stream->istream.v_offset);
28 ret = i_stream_read_copy_from_parent(&stream->istream);
30 data = i_stream_get_data(&stream->istream, &size);
33 i_assert(stream->istream.v_offset <= hstream->high_offset);
34 skip = hstream->high_offset - stream->istream.v_offset;
43 istream itself */
58 stream->istream
[all...]
H A Distream-limit.c4 #include "istream-private.h"
7 struct istream_private istream; member in struct:limit_istream
17 v_offset = lstream->istream.parent_start_offset +
18 lstream->istream.istream.v_offset;
19 if (lstream->istream.parent->seekable ||
20 v_offset > lstream->istream.parent->v_offset) {
22 i_stream_seek(lstream->istream.parent, v_offset);
33 i_stream_seek(stream->parent, lstream->istream.parent_start_offset +
34 stream->istream
[all...]
H A Distream-rawlog.c6 #include "istream-private.h"
7 #include "istream-rawlog.h"
10 struct istream_private istream; member in struct:rawlog_istream
21 i_stream_close(rstream->istream.parent);
29 v_offset = rstream->istream.parent_start_offset +
30 rstream->istream.istream.v_offset;
31 if (rstream->istream.parent->seekable ||
32 v_offset > rstream->istream.parent->v_offset) {
34 i_stream_seek(rstream->istream
[all...]
H A Dtest-istream-crlf.c5 #include "istream-private.h"
6 #include "istream-crlf.h"
15 struct istream *istream, *crlf_istream; local
20 istream = i_stream_create_from_data(input, input_len);
24 crlf_istream = i_stream_create_lf(istream);
34 crlf_istream = i_stream_create_crlf(istream);
46 i_stream_unref(&istream);
48 istream = i_stream_create_from_data(input,
51 i_stream_create_lf(istream)
[all...]
H A Distream-base64-decoder.c7 #include "istream-private.h"
8 #include "istream-base64.h"
11 struct istream_private istream; member in struct:base64_decoder_istream
27 stream->istream.stream_errno = stream->parent->stream_errno;
28 stream->istream.eof = stream->parent->eof;
39 struct istream_private *stream = &bstream->istream;
65 stream->istream.stream_errno = EINVAL;
89 stream->istream.stream_errno = EPIPE;
94 stream->istream.stream_errno = EINVAL;
108 if (ret < 0 && stream->istream
[all...]
H A Distream-base64-encoder.c6 #include "istream-private.h"
7 #include "istream-base64.h"
10 struct istream_private istream; member in struct:base64_encoder_istream
32 stream->istream.stream_errno = stream->parent->stream_errno;
33 stream->istream.eof = stream->parent->eof;
44 struct istream_private *stream = &bstream->istream;
134 if (v_offset < stream->istream.v_offset) {
139 stream->istream.v_offset = 0;
156 stream->istream.stream_errno = stream->parent->stream_errno;
177 struct istream *
[all...]
H A Distream-callback.c5 #include "istream-private.h"
6 #include "istream-callback.h"
9 struct istream_private istream; member in struct:callback_istream
31 stream->istream.eof = TRUE;
47 stream->istream.eof = TRUE;
50 stream->istream.stream_errno != 0)
66 struct istream *
70 struct istream *istream; local
79 cstream->istream
[all...]
H A Distream-crlf.c4 #include "istream-private.h"
5 #include "istream-crlf.h"
8 struct istream_private istream; member in struct:crlf_istream
16 struct istream_private *stream = &cstream->istream;
25 stream->istream.stream_errno =
27 stream->istream.eof = stream->parent->eof;
180 static struct istream *
181 i_stream_create_crlf_full(struct istream *input, bool crlf)
186 cstream->istream.max_buffer_size = input->real_stream->max_buffer_size;
187 cstream->istream
[all...]
H A Distream-timeout.c6 #include "istream-private.h"
7 #include "istream-timeout.h"
10 struct istream_private istream; member in struct:timeout_istream
27 i_stream_close(tstream->istream.parent);
41 struct iostream_private *iostream = &tstream->istream.iostream;
66 io_stream_set_error(&tstream->istream.iostream,
69 tstream->istream.istream.v_offset,
72 tstream->istream.istream
[all...]
H A Distream-try.c4 #include "istream-private.h"
5 #include "istream-try.h"
8 struct istream_private istream; member in struct:try_istream
11 struct istream **try_input;
14 struct istream *final_input;
33 if (tstream->istream.parent != NULL)
34 i_stream_close(tstream->istream.parent);
43 static bool i_stream_try_is_buffer_full(struct istream *try_input)
46 This is mainly intended to check with istream-tee whether its
51 return anything (e.g. istream
[all...]
H A Distream.h9 struct istream { struct
41 struct istream *i_stream_create_fd(int fd, size_t max_buffer_size);
43 struct istream *i_stream_create_fd_autoclose(int *fd, size_t max_buffer_size);
46 struct istream *i_stream_create_file(const char *path, size_t max_buffer_size);
47 struct istream *i_stream_create_mmap(int fd, size_t block_size,
52 struct istream *i_stream_create_from_data(const void *data, size_t size);
60 struct istream *
66 struct istream *i_stream_create_limit(struct istream *input, uoff_t v_size);
67 struct istream *i_stream_create_rang
[all...]
H A Distream-chain.c5 #include "istream-private.h"
6 #include "istream-chain.h"
13 struct istream *stream;
24 struct istream_private istream; member in struct:chain_istream
38 struct istream *stream)
57 chain->stream->istream.max_buffer_size);
61 if (cstream->istream.max_buffer_size < max_size)
62 cstream->istream.max_buffer_size = max_size;
72 void i_stream_chain_append(struct istream_chain *chain, struct istream *stream)
90 cstream->istream
[all...]
/dovecot/src/lib-fs/
H A Distream-fs-stats.c5 #include "istream-private.h"
6 #include "istream-fs-stats.h"
9 struct istream_private istream; member in struct:fs_stats_istream
20 stream->istream.v_offset);
22 ret = i_stream_read_copy_from_parent(&stream->istream);
33 struct istream *
34 i_stream_create_fs_stats(struct istream *input, struct fs_file *file)
40 sstream->istream.max_buffer_size = input->real_stream->max_buffer_size;
41 sstream->istream.stream_size_passthrough = TRUE;
42 sstream->istream
[all...]
H A Distream-fs-file.c4 #include "istream-private.h"
6 #include "istream-fs-file.h"
9 struct istream_private istream; member in struct:fs_file_istream
18 i_stream_destroy(&fstream->istream.parent);
25 struct istream *input;
27 if (fstream->istream.parent == NULL) {
29 i_stream_get_max_buffer_size(&stream->istream));
35 stream->istream.v_offset);
36 return i_stream_read_copy_from_parent(&stream->istream);
39 struct istream *
[all...]
H A Distream-metawrap.c4 #include "istream-private.h"
5 #include "istream-metawrap.h"
10 struct istream_private istream; member in struct:metawrap_istream
22 while ((line = i_stream_read_next_line(mstream->istream.parent)) != NULL) {
29 io_stream_set_error(&mstream->istream.iostream,
31 mstream->istream.istream.v_offset);
32 mstream->istream.istream.stream_errno = EINVAL;
38 if (mstream->istream
[all...]
/dovecot/src/lib-mail/
H A Distream-nonuls.c4 #include "istream-private.h"
5 #include "istream-nonuls.h"
8 struct istream_private istream; member in struct:nonuls_istream
21 stream->istream.stream_errno = stream->parent->stream_errno;
22 stream->istream.eof = stream->parent->eof;
63 struct istream *i_stream_create_nonuls(struct istream *input, char replace_chr)
68 nstream->istream.max_buffer_size = input->real_stream->max_buffer_size;
69 nstream->istream.stream_size_passthrough = TRUE;
71 nstream->istream
[all...]
H A Distream-qp-encoder.c7 #include "istream-private.h"
8 #include "istream-qp.h"
11 struct istream_private istream; member in struct:qp_encoder_istream
26 i_stream_close(bstream->istream.parent);
48 if (stream->pos >= bstream->istream.max_buffer_size) {
60 if (bstream->buf->used <= bstream->istream.max_buffer_size) {
63 stream->istream.eof = TRUE;
65 new_pos = bstream->istream.max_buffer_size;
78 stream->istream.stream_errno =
80 stream->istream
[all...]
H A Distream-dot.c4 #include "istream-private.h"
5 #include "istream-dot.h"
8 struct istream_private istream; member in struct:dot_istream
26 struct istream_private *stream = &dstream->istream;
36 stream->istream.stream_errno =
42 stream->istream.stream_errno = EPIPE;
57 struct istream_private *stream = &dstream->istream;
128 stream->istream.eof = TRUE;
135 if (stream->istream.stream_errno != 0)
219 struct istream *i_stream_create_do
[all...]
H A Distream-qp-decoder.c7 #include "istream-private.h"
8 #include "istream-qp.h"
11 struct istream_private istream; member in struct:qp_decoder_istream
26 i_stream_close(bstream->istream.parent);
38 max_buffer_size = i_stream_get_max_buffer_size(&stream->istream);
73 stream->istream.stream_errno = stream->parent->stream_errno;
74 stream->istream.eof = stream->parent->eof;
75 if (ret != -1 || stream->istream.stream_errno != 0)
85 stream->istream.stream_errno = EPIPE;
94 stream->istream
[all...]
/dovecot/src/lib-ssl-iostream/
H A Distream-openssl.c4 #include "istream-private.h"
8 struct istream_private istream; member in struct:ssl_istream
26 i_stream_free_buffer(&sstream->istream);
41 stream->istream.eof = TRUE;
53 stream->istream.stream_errno = errno;
73 stream->istream.stream_errno = errno;
74 stream->istream.eof = TRUE;
85 behave similarly for ssl-istream as file-istream. */
107 struct istream *openssl_i_stream_create_ss
[all...]
/dovecot/src/lib-storage/index/
H A Distream-mail.c5 #include "istream-private.h"
7 #include "istream-mail.h"
10 struct istream_private istream; member in struct:mail_istream
74 uoff_t cur_size = mstream->istream.istream.v_offset + size;
82 mstream->istream.istream.stream_errno = EINVAL;
87 mstream->istream.istream.stream_errno = EPIPE;
93 io_stream_set_error(&mstream->istream
[all...]
/dovecot/src/plugins/mail-filter/
H A Distream-ext-filter.c9 #include "istream-private.h"
10 #include "istream-ext-filter.h"
15 struct istream_private istream; member in struct:mail_filter_istream
18 struct istream *ext_in;
33 i_stream_close(mstream->istream.parent);
37 i_stream_read_copy_from(struct istream *istream, struct istream *source) argument
39 struct istream_private *stream = istream->real_stream;
53 stream->istream
[all...]
/dovecot/src/lib-test/
H A Dtest-istream.c5 #include "istream-private.h"
9 struct istream_private istream; member in struct:test_istream
30 if (stream->pos - stream->skip >= tstream->istream.max_buffer_size) {
93 stream->istream.eof = TRUE;
103 stream->istream.v_offset = v_offset;
108 struct istream *test_istream_create_data(const void *data, size_t size)
115 tstream->istream.read = test_read;
116 tstream->istream.seek = test_seek;
118 tstream->istream.istream
[all...]

Completed in 86 milliseconds

12