diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-26 11:37:48 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-26 11:37:48 +0100 |
| commit | b1575711e78b96cd8560d4bebcebcfa92e2d14a7 (patch) | |
| tree | 9f4961a083214173d883a0825d5fccb6918372bc /src/controller.c | |
| parent | 9f4ebd97d0fbc2bffba13ec945de5e785b15b371 (diff) | |
| download | rspamd-b1575711e78b96cd8560d4bebcebcfa92e2d14a7.tar.gz rspamd-b1575711e78b96cd8560d4bebcebcfa92e2d14a7.zip | |
Remove threading support at all.
Diffstat (limited to 'src/controller.c')
| -rw-r--r-- | src/controller.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/controller.c b/src/controller.c index 52a3dd12a..0d8520058 100644 --- a/src/controller.c +++ b/src/controller.c @@ -1000,14 +1000,13 @@ rspamd_controller_handle_learn_common ( NULL, rspamd_task_free_hard, task); - task->s->wanna_die = TRUE; task->fin_arg = conn_ent; task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; task->sock = conn_ent->conn->fd; /* XXX: Handle encrypted messages */ - if (!rspamd_task_process (task, msg, msg->body->str, msg->body->len, NULL, FALSE)) { + if (!rspamd_task_process (task, msg, msg->body->str, msg->body->len, FALSE)) { msg_warn ("filters cannot be processed for %s", task->message_id); rspamd_controller_send_error (conn_ent, 500, task->last_error); destroy_session (task->s); @@ -1091,13 +1090,12 @@ rspamd_controller_handle_scan (struct rspamd_http_connection_entry *conn_ent, NULL, rspamd_task_free_hard, task); - task->s->wanna_die = TRUE; task->fin_arg = conn_ent; task->http_conn = rspamd_http_connection_ref (conn_ent->conn); task->sock = conn_ent->conn->fd; /* XXX: handle encrypted messages */ - if (!rspamd_task_process (task, msg, msg->body->str, msg->body->len, NULL, FALSE)) { + if (!rspamd_task_process (task, msg, msg->body->str, msg->body->len, FALSE)) { msg_warn ("filters cannot be processed for %s", task->message_id); rspamd_controller_send_error (conn_ent, 500, task->last_error); destroy_session (task->s); |