Hello.

My callback for get_stream is called from mail_get_stream in
mail_storage_copy. Further, mbox_save_init is called and it called
mbox_save_get_input_stream.

backtrace (A) for my callback: #0 i_stream_header_filter_read (stream=0x8147e00) at istream-header- filter.c:314 #1 0x080cdbaa in parse_header (mstream=0x8147e00) at istream-header- filter.c:356 #2 0x080cdc0c in i_stream_header_filter_seek (stream=0x8147e00,
v_offset=0, mark=false) at istream-header-filter.c:370 #3 0x080dea5b in i_stream_seek (stream=0x8147e28, v_offset=0) at
istream.c:155 #4 0x080dfeae in i_stream_create_concat (input=0x8115528) at istream- concat.c:260 #5 0x2831e03d in rarules_get_stream (mail=0x8141860, hdr_size=0x0,
body_size=0x0, stream_r=0xbfbfe920) at /home/pitman/work/rarules/src/rarules-plugin.c:181 #6 0x0809d830 in mail_get_stream (mail=0x8141860, hdr_size=0x0,
body_size=0x0, stream_r=0xbfbfe920) at mail.c:149 #7 0x0809d936 in mail_storage_copy (t=0x811b980, mail=0x8141860,
flags=0, keywords=0x0, dest_mail=0x0) at mail-copy.c:17 #8 0x080a0632 in mailbox_copy (t=0x811b980, mail=0x8141860, flags=0,
keywords=0x0, dest_mail=0x0) at mail-storage.c:763 #9 0x0805960d in deliver_save (namespaces=0x8121c68,
storage_r=0xbfbfeb94, mailbox=0x811a360 "Draft", mail=0x8141860, flags=0, keywords=0x0) at deliver.c:234 ...

backtrace (B) for mbox_save_init: #0 mbox_save_get_input_stream (ctx=0x811bb00, input=0x814c728) at
mbox-save.c:384 #1 0x08078165 in mbox_save_init (_t=0x811b980, flags=0, keywords=0x0,
received_date=1239634649, timezone_offset=0, from_envelope=0x80f292b "MAILER-DAEMON", input=0x814c728,
dest_mail=0x8150060, ctx_r=0xbfbfe924) at mbox-save.c:512 #2 0x080a0560 in mailbox_save_init (t=0x811b980, flags=0,
keywords=0x0, received_date=-1, timezone_offset=0, from_envelope=0x80f292b "MAILER-DAEMON", input=0x814c728,
dest_mail=0x0, ctx_r=0xbfbfe924) at mail-storage.c:728 #3 0x0809d9c4 in mail_storage_copy (t=0x811b980, mail=0x8141860,
flags=0, keywords=0x0, dest_mail=0x0) at mail-copy.c:28 #4 0x080a0632 in mailbox_copy (t=0x811b980, mail=0x8141860, flags=0,
keywords=0x0, dest_mail=0x0) at mail-storage.c:763 #5 0x0805960d in deliver_save (namespaces=0x8121c68,
storage_r=0xbfbfeb94, mailbox=0x80f2af9 "INBOX", mail=0x8141860, flags=0, keywords=0x0) at deliver.c:234 ...

The function mbox_save_get_input_stream calls
i_stream_create_header_filter and i_stream_create_concat. The function read_header (istream-header-filter.c) finds EOH for call
of i_stream_seek (backtrace B), but my calls of
i_stream_create_header_filter and i_stream_create_concat doesn't find
EOH (backtrace A). Why? I don't understand.

I want to call rarules_header_callback for disable eoh so as to add my
headers.

Thanks

P.S. Sorry for my bad english :-(

It's mbox_save_get_input_stream:

mbox_save_get_input_stream(struct mbox_save_context *ctx, struct
istream *input) { struct istream *filter, *ret, *cache_input, *streams[3];

     /* filter out unwanted headers and keep track of headers' MD5  

sum */ filter = i_stream_create_header_filter(input,
HEADER_FILTER_EXCLUDE | HEADER_FILTER_NO_CR | HEADER_FILTER_ADD_MISSING_EOH, mbox_save_drop_headers, mbox_save_drop_headers_count, save_header_callback,
ctx);

     if ((ctx->mbox->storage->storage.flags &
          MAIL_STORAGE_FLAG_KEEP_HEADER_MD5) != 0) {
             /* we're using MD5 sums to generate POP3 UIDLs.
                clients don't like it much if there are duplicates,
                so make sure that there can't be any by appending
                our own X-Delivery-ID header. */
             const char *hdr;

             T_BEGIN {
                     mbox_save_x_delivery_id(ctx);
             } T_END;
             hdr = ctx->x_delivery_id_header;

             streams[0] = i_stream_create_from_data(hdr,  

strlen(hdr)); streams[1] = filter; streams[2] = NULL; ret = i_stream_create_concat(streams); i_stream_unref(&filter); filter = ret; }

It's my callback for get_stream:

static int rarules_get_stream(struct mail *mail, struct message_size
*hdr_size, struct message_size *body_size, struct istream **stream_r) { struct rarules_mail *m = RA_MAIL_CONTEXT(mail); struct istream *stream = NULL;

     unsigned int deleted = 0;
     unsigned int added = 0;

     int ret = 0;

     DPRINT("func is called");

     /* standard get_stream for mail storage format */
     ret = m->module_ctx.super.get_stream(mail, hdr_size,
                                                body_size, &stream);

     added = array_count(&m->add_hdr_arr);
     deleted = array_count(&m->del_hdr_arr);

     if (m->enabled && (deleted || added)) {
             struct istream * tmp = NULL;
             struct istream **chunks = NULL;
             const unsigned int max_chunks = 4;
             unsigned int i = 0;
             unsigned int cnt = 0;

             DPRINT("modifing message headers");
             /* create message from chunks with new hdrs
                and skip excluded hdrs */
             chunks = t_new(struct istream *, max_chunks);
             chunks[cnt++] =
                     make_header_filter(stream, &m->del_hdr_arr,  

deleted); if (added) { chunks[cnt++] = create_header_stream(&m->add_hdr_arr,
added); } chunks[cnt++] = create_stream_for_msgbody(stream); chunks[cnt++] = NULL;

             tmp = i_stream_create_concat(chunks);

             for (i = 0; chunks[i] != NULL; ++i) {
                     i_stream_unref(&chunks[i]);
             }
             i_stream_unref(&stream);
             stream = tmp;
     }

     *stream_r = stream;

     DPRINT("func is executed");

     return ret;

}