Fix no delayed symbols processing.

diff --git a/src/worker.c b/src/worker.c
index ec8fb464cc556fed498bc3d9715457833e2d2f5d..e59054414f0f2f6699f13eed0008819e5f58fee7 100644 (file)
--- a/src/worker.c
+++ b/src/worker.c
@@ -149,7 +149,7 @@ rspamd_worker_finish_handler (struct rspamd_http_connection *conn,
 {
        struct rspamd_task *task = (struct rspamd_task *) conn->ud;
 
-       if (task->state == CLOSING_CONNECTION || task->state == WRITING_REPLY) {
+       if (task->state == CLOSING_CONNECTION) {
                /* We are done here */
                msg_debug ("normally closing connection from: %s",
                        rspamd_inet_address_to_string (task->client_addr));
@@ -167,6 +167,11 @@ rspamd_worker_finish_handler (struct rspamd_http_connection *conn,
                /* Forcefully set the state */
                task->state = CLOSING_CONNECTION;
        }
+       else if (task->state == WRITING_REPLY) {
+               msg_debug ("still writing reply to: %s",
+                       rspamd_inet_address_to_string (task->client_addr));
+               task->state = CLOSING_CONNECTION;
+       }
        else {
                /*
                 * If all filters have finished their tasks, this function will trigger