summaryrefslogtreecommitdiffstats
path: root/src/worker.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2015-12-26 17:50:35 +0000
committerVsevolod Stakhov <vsevolod@highsecure.ru>2015-12-26 17:50:35 +0000
commitff74d742158c985d4e59655f6989e68a024122d7 (patch)
treef150883001b5766ff76eb6d60edfabaaa3abc313 /src/worker.c
parent62c2acacbb8edf6cb58b16daaf98004d93711bd1 (diff)
downloadrspamd-ff74d742158c985d4e59655f6989e68a024122d7.tar.gz
rspamd-ff74d742158c985d4e59655f6989e68a024122d7.zip
Implement forced timeout for delayed filters
Issue: #452
Diffstat (limited to 'src/worker.c')
-rw-r--r--src/worker.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/worker.c b/src/worker.c
index 2598be415..63cb778f4 100644
--- a/src/worker.c
+++ b/src/worker.c
@@ -129,7 +129,9 @@ rspamd_task_timeout (gint fd, short what, gpointer ud)
if (!(task->processed_stages & RSPAMD_TASK_STAGE_FILTERS)) {
msg_info_task ("processing of task timed out, forced processing");
task->processed_stages |= RSPAMD_TASK_STAGE_FILTERS;
+ rspamd_session_cleanup (task->s);
rspamd_task_process (task, RSPAMD_TASK_PROCESS_ALL);
+ rspamd_session_pending (task->s);
}
}