diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-07-06 19:08:15 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2017-07-06 19:08:15 +0100 |
| commit | 52b4b8db0b126f7004d6aff79cbea3b06f94c927 (patch) | |
| tree | aeed0cb84fc81a93133f0f817675a86b6cd62b53 /src/worker.c | |
| parent | fd20fa9f63e72df66b2b702cde982f729f704480 (diff) | |
| download | rspamd-52b4b8db0b126f7004d6aff79cbea3b06f94c927.tar.gz rspamd-52b4b8db0b126f7004d6aff79cbea3b06f94c927.zip | |
[Rework] Send health checks from a single worker
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/worker.c b/src/worker.c index 12a4ae299..5c81f419a 100644 --- a/src/worker.c +++ b/src/worker.c @@ -498,6 +498,7 @@ rspamd_worker_monitored_handler (struct rspamd_main *rspamd_main, struct rspamd_control_reply rep; struct rspamd_monitored *m; struct rspamd_monitored_ctx *mctx = worker->srv->cfg->monitored_ctx; + struct rspamd_config *cfg = worker->srv->cfg; memset (&rep, 0, sizeof (rep)); rep.type = RSPAMD_CONTROL_MONITORED_CHANGE; @@ -506,6 +507,9 @@ rspamd_worker_monitored_handler (struct rspamd_main *rspamd_main, if (!m) { rspamd_monitored_set_alive (m, cmd->cmd.monitored_change.alive); rep.reply.monitored_change.status = 1; + msg_info_config ("updated monitored status for %s: %s", + cmd->cmd.monitored_change.tag, + cmd->cmd.monitored_change.alive ? "alive" : "dead"); } else { msg_err ("cannot find monitored by tag: %*s", 32, @@ -637,8 +641,6 @@ rspamd_worker_init_scanner (struct rspamd_worker *worker, struct event_base *ev_base, struct rspamd_dns_resolver *resolver) { - rspamd_monitored_ctx_config (worker->srv->cfg->monitored_ctx, - worker->srv->cfg, ev_base, resolver->r, NULL, NULL); rspamd_stat_init (worker->srv->cfg, ev_base); g_ptr_array_add (worker->finish_actions, (gpointer) rspamd_worker_on_terminate); |