@@ -3018,6 +3018,7 @@ rspamd_controller_accept_socket (gint fd, short what, void *arg) | |||
"csession"); | |||
session->ctx = ctx; | |||
session->cfg = ctx->cfg; | |||
session->lang_det = ctx->lang_det; | |||
REF_RETAIN (session->cfg); | |||
session->from_addr = addr; |
@@ -77,6 +77,7 @@ struct rspamd_custom_controller_command { | |||
}; | |||
struct rspamd_controller_worker_ctx; | |||
struct rspamd_lang_detector; | |||
struct rspamd_controller_session { | |||
struct rspamd_controller_worker_ctx *ctx; | |||
@@ -86,6 +87,7 @@ struct rspamd_controller_session { | |||
gchar *classifier; | |||
rspamd_inet_addr_t *from_addr; | |||
struct rspamd_config *cfg; | |||
struct rspamd_lang_detector *lang_det; | |||
gboolean is_spam; | |||
gboolean is_enable; | |||
}; |
@@ -2959,7 +2959,7 @@ fuzzy_process_handler (struct rspamd_http_connection_entry *conn_ent, | |||
gint r, *saved, rules = 0, err_idx; | |||
/* Prepare task */ | |||
task = rspamd_task_new (session->wrk, session->cfg, NULL, NULL); | |||
task = rspamd_task_new (session->wrk, session->cfg, NULL, session->lang_det); | |||
task->cfg = ctx->cfg; | |||
task->ev_base = conn_ent->rt->ev_base; | |||
saved = rspamd_mempool_alloc0 (session->pool, sizeof (gint)); |