Searched defs:rstream (Results 1 - 4 of 4) sorted by relevance

/dovecot/src/lib/
H A Distream-rawlog.c17 struct rawlog_istream *rstream = (struct rawlog_istream *)stream; local
19 iostream_rawlog_close(&rstream->riostream);
21 i_stream_close(rstream->istream.parent);
26 struct rawlog_istream *rstream = (struct rawlog_istream *)stream; local
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.parent, v_offset);
40 struct rawlog_istream *rstream local
98 struct rawlog_istream *rstream; local
[all...]
H A Dostream-rawlog.c16 struct rawlog_ostream *rstream = (struct rawlog_ostream *)stream; local
18 iostream_rawlog_close(&rstream->riostream);
20 o_stream_close(rstream->ostream.parent);
27 struct rawlog_ostream *rstream = (struct rawlog_ostream *)stream; local
38 iostream_rawlog_write(&rstream->riostream,
42 iostream_rawlog_write(&rstream->riostream,
76 struct rawlog_ostream *rstream; local
78 rstream = i_new(struct rawlog_ostream, 1);
79 rstream->ostream.sendv = o_stream_rawlog_sendv;
80 rstream
[all...]
H A Diostream-rawlog.c25 rawlog_write_timestamp(struct rawlog_iostream *rstream, bool line_ends) argument
30 if ((rstream->flags & IOSTREAM_RAWLOG_FLAG_TIMESTAMP) == 0)
37 if ((rstream->flags & IOSTREAM_RAWLOG_FLAG_BUFFERED) != 0) {
38 str_append_c(&buf, rstream->input ? 'I' : 'O');
42 o_stream_nsend(rstream->rawlog_output, buf.data, buf.used);
45 void iostream_rawlog_init(struct rawlog_iostream *rstream, argument
48 rstream->flags = flags;
49 rstream->input = input;
50 if ((rstream->flags & IOSTREAM_RAWLOG_FLAG_BUFFERED) != 0)
51 rstream
55 iostream_rawlog_write_buffered(struct rawlog_iostream *rstream, const unsigned char *data, size_t size) argument
90 iostream_rawlog_write_unbuffered(struct rawlog_iostream *rstream, const unsigned char *data, size_t size) argument
113 iostream_rawlog_write(struct rawlog_iostream *rstream, const unsigned char *data, size_t size) argument
136 iostream_rawlog_close(struct rawlog_iostream *rstream) argument
[all...]
/dovecot/src/lib-storage/index/mbox/
H A Distream-raw-mbox.c29 struct raw_mbox_istream *rstream = (struct raw_mbox_istream *)stream; local
31 i_free(rstream->sender);
32 i_free(rstream->next_sender);
34 i_stream_seek(rstream->istream.parent,
35 rstream->istream.istream.v_offset);
38 static int mbox_read_from_line(struct raw_mbox_istream *rstream) argument
48 buf = i_stream_get_data(rstream->istream.parent, &pos);
53 if (rstream->from_offset == 0)
62 ret = i_stream_read_memarea(rstream->istream.parent);
63 buf = i_stream_get_data(rstream
134 handle_end_of_mail(struct raw_mbox_istream *rstream, size_t pos) argument
162 struct raw_mbox_istream *rstream = (struct raw_mbox_istream *)stream; local
392 struct raw_mbox_istream *rstream = (struct raw_mbox_istream *)stream; local
404 struct raw_mbox_istream *rstream = (struct raw_mbox_istream *)stream; local
417 struct raw_mbox_istream *rstream = (struct raw_mbox_istream *)stream; local
433 struct raw_mbox_istream *rstream; local
458 istream_raw_mbox_is_valid_from(struct raw_mbox_istream *rstream) argument
506 struct raw_mbox_istream *rstream = local
517 struct raw_mbox_istream *rstream = local
541 struct raw_mbox_istream *rstream = local
579 struct raw_mbox_istream *rstream = local
645 struct raw_mbox_istream *rstream = local
657 struct raw_mbox_istream *rstream = local
669 struct raw_mbox_istream *rstream = local
679 struct raw_mbox_istream *rstream = local
711 struct raw_mbox_istream *rstream = local
762 struct raw_mbox_istream *rstream = local
773 struct raw_mbox_istream *rstream = local
781 struct raw_mbox_istream *rstream = local
789 struct raw_mbox_istream *rstream = local
797 struct raw_mbox_istream *rstream = local
[all...]

Completed in 8 milliseconds