|
|
@@ -109,6 +109,11 @@ rspamd_worker_body_handler (struct rspamd_http_connection *conn, |
|
|
|
|
|
|
|
ctx = task->worker->ctx; |
|
|
|
|
|
|
|
if (!rspamd_protocol_handle_request (task, msg)) { |
|
|
|
task->state = WRITE_REPLY; |
|
|
|
return 0; |
|
|
|
} |
|
|
|
|
|
|
|
if (task->cmd == CMD_PING) { |
|
|
|
task->state = WRITE_REPLY; |
|
|
|
return 0; |
|
|
@@ -122,11 +127,6 @@ rspamd_worker_body_handler (struct rspamd_http_connection *conn, |
|
|
|
return 0; |
|
|
|
} |
|
|
|
|
|
|
|
if (!rspamd_protocol_handle_request (task, msg)) { |
|
|
|
task->state = WRITE_REPLY; |
|
|
|
return 0; |
|
|
|
} |
|
|
|
|
|
|
|
if (!rspamd_task_process (task, msg, ctx->classify_pool, TRUE)) { |
|
|
|
task->state = WRITE_REPLY; |
|
|
|
} |