diff options
Diffstat (limited to 'src/webui.c')
-rw-r--r-- | src/webui.c | 76 |
1 files changed, 2 insertions, 74 deletions
diff --git a/src/webui.c b/src/webui.c index 3027947bc..812cee249 100644 --- a/src/webui.c +++ b/src/webui.c @@ -128,72 +128,10 @@ struct rspamd_webui_session { gboolean is_spam; }; -static sig_atomic_t wanna_die = 0; +sig_atomic_t wanna_die = 0; /* Signal handlers */ -#ifndef HAVE_SA_SIGINFO -static void -sig_handler (gint signo) -#else -static void -sig_handler (gint signo, siginfo_t * info, void *unused) -#endif -{ - struct timeval tv; - - switch (signo) { - case SIGINT: - case SIGTERM: - if (!wanna_die) { - wanna_die = 1; - tv.tv_sec = 0; - tv.tv_usec = 0; - event_loopexit (&tv); - -#ifdef WITH_GPERF_TOOLS - ProfilerStop (); -#endif - } - break; - } -} - -/* - * Config reload is designed by sending sigusr2 to active workers and pending shutdown of them - */ -static void -sigusr2_handler (gint fd, short what, void *arg) -{ - struct rspamd_worker *worker = (struct rspamd_worker *) arg; - /* Do not accept new connections, preparing to end worker's process */ - struct timeval tv; - - if (!wanna_die) { - tv.tv_sec = SOFT_SHUTDOWN_TIME; - tv.tv_usec = 0; - event_del (&worker->sig_ev_usr1); - event_del (&worker->sig_ev_usr2); - worker_stop_accept (worker); - msg_info ("worker's shutdown is pending in %d sec", SOFT_SHUTDOWN_TIME); - event_loopexit (&tv); - } - return; -} - -/* - * Reopen log is designed by sending sigusr1 to active workers and pending shutdown of them - */ -static void -sigusr1_handler (gint fd, short what, void *arg) -{ - struct rspamd_worker *worker = (struct rspamd_worker *) arg; - - reopen_log (worker->srv->logger); - - return; -} - static void rspamd_webui_send_error (struct rspamd_http_connection_entry *entry, gint code, const gchar *error_msg) @@ -1456,19 +1394,9 @@ start_webui_worker (struct rspamd_worker *worker) { struct rspamd_webui_worker_ctx *ctx = worker->ctx; - ctx->ev_base = prepare_worker (worker, "controller", sig_handler, rspamd_webui_accept_socket); + ctx->ev_base = prepare_worker (worker, "controller", rspamd_webui_accept_socket); msec_to_tv (ctx->timeout, &ctx->io_tv); - /* SIGUSR2 handler */ - signal_set (&worker->sig_ev_usr2, SIGUSR2, sigusr2_handler, (void *) worker); - event_base_set (ctx->ev_base, &worker->sig_ev_usr2); - signal_add (&worker->sig_ev_usr2, NULL); - - /* SIGUSR1 handler */ - signal_set (&worker->sig_ev_usr1, SIGUSR1, sigusr1_handler, (void *) worker); - event_base_set (ctx->ev_base, &worker->sig_ev_usr1); - signal_add (&worker->sig_ev_usr1, NULL); - ctx->start_time = time (NULL); ctx->worker = worker; ctx->cfg = worker->srv->cfg; |