diff options
author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-02-19 21:16:30 +0300 |
---|---|---|
committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-02-19 21:16:30 +0300 |
commit | bcece60fa1bfd4bbb09a64c058835fe3245e1d18 (patch) | |
tree | 813faac7ee96029e604a8a73c88ffee4e10a579a /src/message.c | |
parent | 2dca592dce2fdde806af89e5cf036bd11bd4df61 (diff) | |
download | rspamd-bcece60fa1bfd4bbb09a64c058835fe3245e1d18.tar.gz rspamd-bcece60fa1bfd4bbb09a64c058835fe3245e1d18.zip |
* Implement rspamd IO with IO dispatcher (TODO: still some issues with timeouts must be resolved)
Diffstat (limited to 'src/message.c')
-rw-r--r-- | src/message.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/message.c b/src/message.c index 5c0f15cf9..d5ec43653 100644 --- a/src/message.c +++ b/src/message.c @@ -304,7 +304,7 @@ process_message (struct worker_task *task) GMimeParser *parser; GMimeStream *stream; - stream = g_mime_stream_mem_new_with_buffer (task->msg->buf->begin, task->msg->buf->len); + stream = g_mime_stream_mem_new_with_buffer (task->msg->begin, task->msg->len); /* create a new parser object to parse the stream */ parser = g_mime_parser_new_with_stream (stream); @@ -393,7 +393,7 @@ process_learn (struct controller_session *session) GMimeParser *parser; GMimeStream *stream; - stream = g_mime_stream_mem_new_with_buffer (session->learn_buf->buf->begin, session->learn_buf->buf->len); + stream = g_mime_stream_mem_new_with_buffer (session->learn_buf->begin, session->learn_buf->len); /* create a new parser object to parse the stream */ parser = g_mime_parser_new_with_stream (stream); |