[Minor] Try to fix finishing handlers

diff --git a/src/libserver/worker_util.c b/src/libserver/worker_util.c
index 0b86001609bfa205ee7250fc185dc071662ed86d..0007fbe35086c07b2faad63d9ab6450ffd8725ad 100644 (file)
--- a/src/libserver/worker_util.c
+++ b/src/libserver/worker_util.c
@@ -107,6 +107,9 @@ rspamd_worker_check_finished (EV_P_ ev_timer *w, int revents)
                if (refcount == 1) {
                        ev_break (EV_A_ EVBREAK_ONE);
                }
+               else {
+                       ev_timer_again (EV_A_ w);
+               }
        }
 }
 

diff --git a/src/worker.c b/src/worker.c
index 0ed298181f939004df769111bf105a056b1ef6f5..349a0ea92fb16b7b4e57c214cb42912a2fbd2683 100644 (file)
--- a/src/worker.c
+++ b/src/worker.c
@@ -76,7 +76,7 @@ rspamd_worker_finalize (gpointer user_data)
 
        if (!(task->flags & RSPAMD_TASK_FLAG_PROCESSING)) {
                msg_info_task ("finishing actions has been processed, terminating");
-               ev_break (task->event_loop, EVBREAK_ALL);
+               /* ev_break (task->event_loop, EVBREAK_ALL); */
                rspamd_session_destroy (task->s);
 
                return TRUE;