diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-04-21 13:39:39 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-04-21 13:39:39 +0100 |
| commit | 5f25b69c03972b0adff6bc649e1922111d0ebb2b (patch) | |
| tree | 62fb361ba8eab64f59a1874e5d045d404727ae4e /src/lmtp_proto.c | |
| parent | bc997b7b94a36103a3d409d0de422a71df0a19d6 (diff) | |
| download | rspamd-5f25b69c03972b0adff6bc649e1922111d0ebb2b.tar.gz rspamd-5f25b69c03972b0adff6bc649e1922111d0ebb2b.zip | |
Refactor worker task structure and API.
Diffstat (limited to 'src/lmtp_proto.c')
| -rw-r--r-- | src/lmtp_proto.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/lmtp_proto.c b/src/lmtp_proto.c index 06edc06ad..81cd13607 100644 --- a/src/lmtp_proto.c +++ b/src/lmtp_proto.c @@ -89,7 +89,7 @@ extract_mail (rspamd_mempool_t * pool, f_str_t * line) } static gboolean -out_lmtp_reply (struct worker_task *task, gint code, gchar *rcode, gchar *msg) +out_lmtp_reply (struct rspamd_task *task, gint code, gchar *rcode, gchar *msg) { gchar outbuf[OUTBUFSIZ]; gint r; @@ -252,7 +252,7 @@ read_lmtp_input_line (struct rspamd_lmtp_proto *lmtp, f_str_t * line) } struct mta_callback_data { - struct worker_task *task; + struct rspamd_task *task; rspamd_io_dispatcher_t *dispatcher; enum { LMTP_WANT_GREETING, @@ -445,7 +445,7 @@ mta_err_socket (GError * err, void *arg) * Deliver mail via smtp or lmtp */ static gint -lmtp_deliver_mta (struct worker_task *task) +lmtp_deliver_mta (struct rspamd_task *task) { gint sock; struct sockaddr_un *un; @@ -471,7 +471,7 @@ lmtp_deliver_mta (struct worker_task *task) } static gchar * -format_lda_args (struct worker_task *task) +format_lda_args (struct rspamd_task *task) { gchar *res, *c, *r; size_t len; @@ -555,7 +555,7 @@ format_lda_args (struct worker_task *task) } static gint -lmtp_deliver_lda (struct worker_task *task) +lmtp_deliver_lda (struct rspamd_task *task) { gchar *args, **argv; GMimeStream *stream; @@ -652,7 +652,7 @@ lmtp_deliver_lda (struct worker_task *task) } gint -lmtp_deliver_message (struct worker_task *task) +lmtp_deliver_message (struct rspamd_task *task) { if (task->cfg->deliver_agent_path != NULL) { /* Do deliver to LDA */ @@ -668,7 +668,7 @@ gint write_lmtp_reply (struct rspamd_lmtp_proto *lmtp) { gint r; - struct worker_task *task = lmtp->task; + struct rspamd_task *task = lmtp->task; debug_task ("writing reply to client"); if (lmtp->task->error_code != 0) { |