diff options
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; |