diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2011-08-01 15:32:45 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2011-08-01 15:32:45 +0400 |
| commit | 643576fcff380140d714e6f9711c402246f16a28 (patch) | |
| tree | afff9f26fa71cc67c5163009c6fbbf3abf822493 /src/worker.c | |
| parent | 0c6e9d1f0bc8e010d30c27af1635513adfa9a6dd (diff) | |
| download | rspamd-643576fcff380140d714e6f9711c402246f16a28.tar.gz rspamd-643576fcff380140d714e6f9711c402246f16a28.zip | |
Fix controller stages and debug info.
Handle timeouts in librspamdclient correctly.
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/worker.c b/src/worker.c index b919ad407..16e33ed9e 100644 --- a/src/worker.c +++ b/src/worker.c @@ -272,6 +272,7 @@ read_socket (f_str_t * in, void *arg) task->msg->begin = in->begin; task->msg->len = in->len; debug_task ("got string of length %z", task->msg->len); + task->state = WAIT_FILTER; r = process_message (task); if (r == -1) { msg_warn ("processing of message failed"); @@ -323,6 +324,9 @@ read_socket (f_str_t * in, void *arg) case WRITE_ERROR: return write_socket (task); break; + case WAIT_FILTER: + msg_info ("ignoring trailing garbadge of size %z", in->len); + break; default: debug_task ("invalid state on reading stage"); break; |