ev_timer_again (task->event_loop, &rt->timeout_event);
}
else {
+ rt->timeout_event.data = rt;
ev_timer_init (&rt->timeout_event, rspamd_redis_timeout,
rt->ctx->timeout, 0.);
ev_timer_start (task->event_loop, &rt->timeout_event);
ev_timer_again (task->event_loop, &rt->timeout_event);
}
else {
+ rt->timeout_event.data = rt;
ev_timer_init (&rt->timeout_event, rspamd_redis_timeout,
rt->ctx->timeout, 0.);
ev_timer_start (task->event_loop, &rt->timeout_event);
* First we set timeval to zero as we want cb to be executed as
* fast as possible
*/
+ elt->timer_ev.data = elt;
ev_timer_init (&elt->timer_ev, rspamd_async_elt_on_timer, 0.0, 0.0);
ev_timer_start (st_ctx->event_loop, &elt->timer_ev);
}
map->scheduled_check = TRUE;
REF_INIT_RETAIN (cbd, rspamd_map_periodic_dtor);
+ cbd->ev.data = cbd;
ev_timer_init (&cbd->ev, rspamd_map_periodic_callback, jittered_sec, 0.0);
ev_timer_start (map->event_loop, &cbd->ev);
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);
ev_timer_start (rspamd_main->event_loop, &nw->wait_ev);
}