diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2011-11-07 20:03:35 +0300 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2011-11-07 20:03:35 +0300 |
| commit | 229fd540109f92cb8662dd085fcfe46aad3130cf (patch) | |
| tree | 48504709b22738f671cdd21650e9d1d885e721a1 /src/worker.c | |
| parent | 15b079d79c99ed77b90ed510f9666612d518c5cc (diff) | |
| download | rspamd-229fd540109f92cb8662dd085fcfe46aad3130cf.tar.gz rspamd-229fd540109f92cb8662dd085fcfe46aad3130cf.zip | |
Fix main rspamd worker to work with buffer.c changes.
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/worker.c b/src/worker.c index bd2c5de2e..b3e56c13f 100644 --- a/src/worker.c +++ b/src/worker.c @@ -349,6 +349,7 @@ write_socket (void *arg) switch (task->state) { case WRITE_REPLY: + task->state = WRITING_REPLY; if (!write_reply (task)) { return FALSE; } @@ -359,6 +360,7 @@ write_socket (void *arg) return FALSE; break; case WRITE_ERROR: + task->state = WRITING_REPLY; if (!write_reply (task)) { return FALSE; } @@ -376,6 +378,9 @@ write_socket (void *arg) destroy_session (task->s); return FALSE; break; + case WRITING_REPLY: + /* Do nothing here */ + break; default: msg_info ("abnormally closing connection"); if (ctx->is_custom) { |