@@ -671,8 +671,8 @@ static void fpm_reconnect(struct fpm_nl_ctx *fnc)
671671
672672 stream_reset (fnc -> ibuf );
673673 stream_reset (fnc -> obuf );
674- EVENT_OFF ( fnc -> t_read );
675- EVENT_OFF ( fnc -> t_write );
674+ event_cancel ( & fnc -> t_read );
675+ event_cancel ( & fnc -> t_write );
676676
677677 /* Reset the barrier value */
678678 cleaning_p = true;
@@ -3006,7 +3006,7 @@ static void fpm_process_queue(struct event *t)
30063006 event_add_timer (fnc -> fthread -> master , fpm_process_wedged , fnc ,
30073007 DPLANE_FPM_NL_WEDGIE_TIME , & fnc -> t_wedged );
30083008 } else
3009- EVENT_OFF ( fnc -> t_wedged );
3009+ event_cancel ( & fnc -> t_wedged );
30103010
30113011 /*
30123012 * Let the dataplane thread know if there are items in the
@@ -3119,16 +3119,16 @@ static int fpm_nl_finish_early(struct fpm_nl_ctx *fnc)
31193119 return 0 ;
31203120
31213121 /* Disable all events and close socket. */
3122- EVENT_OFF ( fnc -> t_lspreset );
3123- EVENT_OFF ( fnc -> t_lspwalk );
3124- EVENT_OFF ( fnc -> t_nhgreset );
3125- EVENT_OFF ( fnc -> t_nhgwalk );
3126- EVENT_OFF ( fnc -> t_ribreset );
3127- EVENT_OFF ( fnc -> t_ribwalk );
3128- EVENT_OFF ( fnc -> t_rmacreset );
3129- EVENT_OFF ( fnc -> t_rmacwalk );
3130- EVENT_OFF ( fnc -> t_event );
3131- EVENT_OFF ( fnc -> t_nhg );
3122+ event_cancel ( & fnc -> t_lspreset );
3123+ event_cancel ( & fnc -> t_lspwalk );
3124+ event_cancel ( & fnc -> t_nhgreset );
3125+ event_cancel ( & fnc -> t_nhgwalk );
3126+ event_cancel ( & fnc -> t_ribreset );
3127+ event_cancel ( & fnc -> t_ribwalk );
3128+ event_cancel ( & fnc -> t_rmacreset );
3129+ event_cancel ( & fnc -> t_rmacwalk );
3130+ event_cancel ( & fnc -> t_event );
3131+ event_cancel ( & fnc -> t_nhg );
31323132 event_cancel_async (fnc -> fthread -> master , & fnc -> t_read , NULL);
31333133 event_cancel_async (fnc -> fthread -> master , & fnc -> t_write , NULL);
31343134 event_cancel_async (fnc -> fthread -> master , & fnc -> t_connect , NULL);
0 commit comments