rspamd_monitored_periodic (EV_P_ ev_timer *w, int revents)
{
struct rspamd_monitored *m = (struct rspamd_monitored *)w->data;
- struct timeval tv;
gdouble jittered;
gboolean ret = FALSE;
jittered = rspamd_time_jitter (m->ctx->monitoring_interval * m->monitoring_mult,
0.0);
- double_to_tv (jittered, &tv);
if (m->proc.monitored_update) {
ret = m->proc.monitored_update (m, m->ctx, m->proc.ud);
rspamd_worker_usr2_handler (struct rspamd_worker_signal_handler *sigh, void *arg)
{
/* Do not accept new connections, preparing to end worker's process */
- struct timeval tv;
-
if (!sigh->worker->wanna_die) {
static ev_timer shutdown_ev;
rspamd_worker_ignore_signal (sigh);
-
- tv.tv_sec = SOFT_SHUTDOWN_TIME;
- tv.tv_usec = 0;
sigh->worker->wanna_die = TRUE;
rspamd_worker_terminate_handlers (sigh->worker);
rspamd_default_log_function (G_LOG_LEVEL_INFO,
struct rspamd_main *rspamd_main)
{
struct waiting_worker *nw;
- struct timeval tv;
nw = g_malloc0 (sizeof (*nw));
nw->cf = cf;
nw->oldindex = index;
nw->rspamd_main = rspamd_main;
- tv.tv_sec = SOFT_FORK_TIME;
- tv.tv_usec = 0;
REF_RETAIN (cf);
nw->wait_ev.data = nw;
ev_timer_init (&nw->wait_ev, rspamd_fork_delayed_cb, SOFT_FORK_TIME, 0.0);