diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-27 16:20:32 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-27 16:20:32 +0100 |
| commit | 3870577d1605c03bee6f1bc67f79365bf3906c97 (patch) | |
| tree | 17ca42329b0cab5edf19980ea893e1018fcdb4c3 /src | |
| parent | 634d1e599394c5cbe167285e632576552e42dcff (diff) | |
| download | rspamd-3870577d1605c03bee6f1bc67f79365bf3906c97.tar.gz rspamd-3870577d1605c03bee6f1bc67f79365bf3906c97.zip | |
Fix no delayed symbols processing.
Diffstat (limited to 'src')
| -rw-r--r-- | src/worker.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/worker.c b/src/worker.c index ec8fb464c..e59054414 100644 --- 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 |