@@ -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); | |||
} | |||
} | |||
} | |||
@@ -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; |