diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-04-21 13:39:39 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-04-21 13:39:39 +0100 |
| commit | 5f25b69c03972b0adff6bc649e1922111d0ebb2b (patch) | |
| tree | 62fb361ba8eab64f59a1874e5d045d404727ae4e /src/worker.c | |
| parent | bc997b7b94a36103a3d409d0de422a71df0a19d6 (diff) | |
| download | rspamd-5f25b69c03972b0adff6bc649e1922111d0ebb2b.tar.gz rspamd-5f25b69c03972b0adff6bc649e1922111d0ebb2b.zip | |
Refactor worker task structure and API.
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/worker.c b/src/worker.c index 8f6766350..b67b02775 100644 --- a/src/worker.c +++ b/src/worker.c @@ -168,7 +168,7 @@ rspamd_worker_body_handler (struct rspamd_http_connection *conn, struct rspamd_http_message *msg, const gchar *chunk, gsize len) { - struct worker_task *task = (struct worker_task *) conn->ud; + struct rspamd_task *task = (struct rspamd_task *) conn->ud; struct rspamd_worker_ctx *ctx; ssize_t r; GError *err = NULL; @@ -251,7 +251,7 @@ rspamd_worker_body_handler (struct rspamd_http_connection *conn, static void rspamd_worker_error_handler (struct rspamd_http_connection *conn, GError *err) { - struct worker_task *task = (struct worker_task *) conn->ud; + struct rspamd_task *task = (struct rspamd_task *) conn->ud; msg_info ("abnormally closing connection from: %s, error: %s", inet_ntoa (task->client_addr), err->message); @@ -272,7 +272,7 @@ static gint rspamd_worker_finish_handler (struct rspamd_http_connection *conn, struct rspamd_http_message *msg) { - struct worker_task *task = (struct worker_task *) conn->ud; + struct rspamd_task *task = (struct rspamd_task *) conn->ud; if (task->state == CLOSING_CONNECTION) { msg_debug ("normally closing connection from: %s", inet_ntoa (task->client_addr)); @@ -299,7 +299,7 @@ accept_socket (gint fd, short what, void *arg) struct rspamd_worker *worker = (struct rspamd_worker *) arg; struct rspamd_worker_ctx *ctx; union sa_union su; - struct worker_task *new_task; + struct rspamd_task *new_task; char ip_str[INET6_ADDRSTRLEN + 1]; socklen_t addrlen = sizeof (su); |