diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-06-08 19:16:56 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-06-08 19:16:56 +0100 |
| commit | e7a43c0fb358c1947fa3e21f2f2442408372d348 (patch) | |
| tree | e895630f0a9c21d88da6ef95e077f3baaa3cea13 /src/controller.c | |
| parent | e825c3d0d96836c341aeb252c95cf11bb7eab67b (diff) | |
| download | rspamd-e7a43c0fb358c1947fa3e21f2f2442408372d348.tar.gz rspamd-e7a43c0fb358c1947fa3e21f2f2442408372d348.zip | |
[Minor] Allow to set custom pool for a task
Diffstat (limited to 'src/controller.c')
| -rw-r--r-- | src/controller.c | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/controller.c b/src/controller.c index 9806e119e..052525750 100644 --- a/src/controller.c +++ b/src/controller.c @@ -1464,7 +1464,8 @@ rspamd_controller_handle_lua_history (lua_State *L, lua_gettable (L, -2); if (lua_isfunction (L, -1)) { - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, + NULL); task->resolver = ctx->resolver; task->ev_base = ctx->ev_base; @@ -1762,7 +1763,7 @@ rspamd_controller_handle_lua (struct rspamd_http_connection_entry *conn_ent, return 0; } - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, NULL); task->resolver = ctx->resolver; task->ev_base = ctx->ev_base; @@ -1945,7 +1946,7 @@ rspamd_controller_handle_learn_common ( return 0; } - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, NULL); task->resolver = ctx->resolver; task->ev_base = ctx->ev_base; @@ -2045,7 +2046,7 @@ rspamd_controller_handle_scan (struct rspamd_http_connection_entry *conn_ent, return 0; } - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, NULL); task->ev_base = session->ctx->ev_base; task->resolver = ctx->resolver; @@ -2543,7 +2544,7 @@ rspamd_controller_handle_stat_common ( rspamd_mempool_stat (&mem_st); memcpy (&stat_copy, session->ctx->worker->srv->stat, sizeof (stat_copy)); stat = &stat_copy; - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, NULL); ctx = session->ctx; task->resolver = ctx->resolver; @@ -2877,7 +2878,7 @@ rspamd_controller_handle_lua_plugin (struct rspamd_http_connection_entry *conn_e return 0; } - task = rspamd_task_new (session->ctx->worker, session->cfg); + task = rspamd_task_new (session->ctx->worker, session->cfg, NULL); task->resolver = ctx->resolver; task->ev_base = ctx->ev_base; |