diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2012-04-20 02:55:22 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2012-04-20 02:55:22 +0400 |
| commit | 80efd10c7fda505905f960c73ce567c57e91a86b (patch) | |
| tree | aeb87f6d772f7f6359baa8debcaf850cdc20ee8b /src/worker.c | |
| parent | 637d09abaceb0e3babff9fd25fa133da4c0732ae (diff) | |
| download | rspamd-80efd10c7fda505905f960c73ce567c57e91a86b.tar.gz rspamd-80efd10c7fda505905f960c73ce567c57e91a86b.zip | |
Allow rspamd dispatcher code to process half-closed connections.
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/worker.c b/src/worker.c index dad842ce3..eecaf45dc 100644 --- a/src/worker.c +++ b/src/worker.c @@ -470,6 +470,8 @@ read_socket (f_str_t * in, void *arg) task->msg->len = in->len; debug_task ("got string of length %z", task->msg->len); task->state = WAIT_FILTER; + /* No more need of reading allowing half-closed connections to be proceed */ + task->dispatcher->want_read = FALSE; r = process_message (task); if (r == -1) { msg_warn ("processing of message failed"); |