diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-12-31 17:19:29 +0000 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-12-31 17:19:29 +0000 |
| commit | 60383ec549918fe5f0a1bbdda09fd74abac56e09 (patch) | |
| tree | e21d2da77f9c8f836e641fd3e3fca8077ae2334e /src/worker.c | |
| parent | a7d2ffaef760aa8d61b34a2426e7215e781ff7d4 (diff) | |
| download | rspamd-60383ec549918fe5f0a1bbdda09fd74abac56e09.tar.gz rspamd-60383ec549918fe5f0a1bbdda09fd74abac56e09.zip | |
[Project] Enable language detector init in scanner workers
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/worker.c b/src/worker.c index e001ec288..9dc5fec0f 100644 --- a/src/worker.c +++ b/src/worker.c @@ -17,8 +17,6 @@ * Rspamd worker implementation */ -#include <libserver/rspamd_control.h> -#include <src/libserver/rspamd_control.h> #include "config.h" #include "libutil/util.h" #include "libutil/map.h" @@ -36,7 +34,7 @@ #include "worker_private.h" #include "utlist.h" #include "libutil/http_private.h" -#include "monitored.h" +#include "libmime/lang_detection.h" #include "unix-std.h" #include "lua/lua_common.h" @@ -641,7 +639,8 @@ rspamd_worker_on_terminate (struct rspamd_worker *worker) void rspamd_worker_init_scanner (struct rspamd_worker *worker, struct event_base *ev_base, - struct rspamd_dns_resolver *resolver) + struct rspamd_dns_resolver *resolver, + struct rspamd_lang_detector **plang_det) { rspamd_stat_init (worker->srv->cfg, ev_base); g_ptr_array_add (worker->finish_actions, @@ -660,6 +659,8 @@ rspamd_worker_init_scanner (struct rspamd_worker *worker, RSPAMD_CONTROL_MONITORED_CHANGE, rspamd_worker_monitored_handler, worker->srv->cfg); + + *plang_det = rspamd_language_detector_init (worker->srv->cfg); } /* @@ -685,7 +686,8 @@ start_worker (struct rspamd_worker *worker) /* XXX: stupid default */ ctx->keys_cache = rspamd_keypair_cache_new (256); - rspamd_worker_init_scanner (worker, ctx->ev_base, ctx->resolver); + rspamd_worker_init_scanner (worker, ctx->ev_base, ctx->resolver, + &ctx->lang_det); rspamd_lua_run_postloads (ctx->cfg->lua_state, ctx->cfg, ctx->ev_base, worker); |