aboutsummaryrefslogtreecommitdiffstats
path: root/src/controller.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2014-01-19 00:27:54 +0000
committerVsevolod Stakhov <vsevolod@highsecure.ru>2014-01-19 00:27:54 +0000
commit7e4a21dc554d42d31afc611fd92aaddd7da1bb6c (patch)
tree1a423d9ca90425eed230aca69d1193a3a511bf0a /src/controller.c
parente2f2eed337ecdb17c897fe7e04626dfffe32f2a2 (diff)
downloadrspamd-7e4a21dc554d42d31afc611fd92aaddd7da1bb6c.tar.gz
rspamd-7e4a21dc554d42d31afc611fd92aaddd7da1bb6c.zip
Simplify states of task. Disable broken code.
Diffstat (limited to 'src/controller.c')
-rw-r--r--src/controller.c17
1 files changed, 1 insertions, 16 deletions
diff --git a/src/controller.c b/src/controller.c
index 097ed0e7c..269ca6db2 100644
--- a/src/controller.c
+++ b/src/controller.c
@@ -1282,19 +1282,7 @@ fin_learn_task (void *arg)
{
struct worker_task *task = (struct worker_task *) arg;
- if (task->state != WRITING_REPLY) {
- task->state = WRITE_REPLY;
- }
-
- /* Check if we have all events finished */
- if (task->state != WRITING_REPLY) {
- if (task->fin_callback) {
- task->fin_callback (task->fin_arg);
- }
- else {
- rspamd_dispatcher_restore (task->dispatcher);
- }
- }
+ /* XXX: needs to be reworked */
return TRUE;
}
@@ -1308,9 +1296,6 @@ restore_learn_task (void *arg)
struct worker_task *task = (struct worker_task *) arg;
/* Special state */
- task->state = WRITING_REPLY;
-
- rspamd_dispatcher_pause (task->dispatcher);
}
static gboolean