if (!irdp)
return;
- thread_cancel(&irdp->t_advertise);
+ THREAD_OFF(irdp->t_advertise);
if (ifp->connected)
for (ALL_LIST_ELEMENTS(ifp->connected, node, nnode, ifc)) {
return;
irdp->flags |= IF_SOLICIT;
- thread_cancel(&irdp->t_advertise);
+ THREAD_OFF(irdp->t_advertise);
timer = (frr_weak_random() % MAX_RESPONSE_DELAY) + 1;
void kernel_terminate(struct zebra_ns *zns, bool complete)
{
- thread_cancel(&zns->t_netlink);
+ THREAD_OFF(zns->t_netlink);
kernel_nlsock_fini(&zns->netlink);
zns_info_list_del(&zdplane_info.dg_zns_list, zi);
if (zdplane_info.dg_master) {
- thread_cancel(&zi->t_read);
- thread_cancel(&zi->t_request);
+ THREAD_OFF(zi->t_read);
+ THREAD_OFF(zi->t_request);
}
XFREE(MTYPE_DP_NS, zi);
*/
static inline void zfpm_read_off(void)
{
- thread_cancel(&zfpm_g->t_read);
+ THREAD_OFF(zfpm_g->t_read);
}
/*
*/
static inline void zfpm_write_off(void)
{
- thread_cancel(&zfpm_g->t_write);
+ THREAD_OFF(zfpm_g->t_write);
}
static inline void zfpm_connect_off(void)
{
- thread_cancel(&zfpm_g->t_connect);
+ THREAD_OFF(zfpm_g->t_connect);
}
/*
/*
* Start thread to push existing routes to the FPM.
*/
- thread_cancel(&zfpm_g->t_conn_up);
+ THREAD_OFF(zfpm_g->t_conn_up);
zfpm_rnodes_iter_init(&zfpm_g->t_conn_up_state.iter);
zfpm_g->fpm_mac_dump_done = false;
return;
zfpm_debug("Stopping existing stats timer");
- thread_cancel(&zfpm_g->t_stats);
+ THREAD_OFF(zfpm_g->t_stats);
}
/*
fd = zebra_netns_notify_current->u.fd;
if (zebra_netns_notify_current->master != NULL)
- thread_cancel(&zebra_netns_notify_current);
+ THREAD_OFF(zebra_netns_notify_current);
/* auto-removal of notify items */
if (fd > 0)
free(ptm_cb.in_data);
/* Cancel events. */
- thread_cancel(&ptm_cb.t_read);
- thread_cancel(&ptm_cb.t_write);
- thread_cancel(&ptm_cb.t_timer);
+ THREAD_OFF(ptm_cb.t_read);
+ THREAD_OFF(ptm_cb.t_write);
+ THREAD_OFF(ptm_cb.t_timer);
if (ptm_cb.wb)
buffer_free(ptm_cb.wb);
ptm_cb.reconnect_time, &ptm_cb.t_timer);
return -1;
case BUFFER_EMPTY:
- thread_cancel(&ptm_cb.t_write);
+ THREAD_OFF(ptm_cb.t_write);
break;
case BUFFER_PENDING:
thread_add_write(zrouter.master, zebra_ptm_flush_messages, NULL,
hook_call(pw_uninstall, pw);
dplane_pw_uninstall(pw);
} else if (pw->install_retry_timer)
- thread_cancel(&pw->install_retry_timer);
+ THREAD_OFF(pw->install_retry_timer);
/* unlink and release memory */
RB_REMOVE(zebra_pw_head, &zvrf->pseudowires, pw);
pw->vrf_id, pw->ifname, PW_INSTALL_RETRY_INTERVAL);
/* schedule to retry later */
- thread_cancel(&pw->install_retry_timer);
+ THREAD_OFF(pw->install_retry_timer);
thread_add_timer(zrouter.master, zebra_pw_install_retry, pw,
PW_INSTALL_RETRY_INTERVAL, &pw->install_retry_timer);