diff options
| author | Donald Sharp <sharpd@nvidia.com> | 2022-12-25 10:26:52 -0500 | 
|---|---|---|
| committer | Donald Sharp <sharpd@nvidia.com> | 2023-03-24 08:32:17 -0400 | 
| commit | e16d030c65ca97b1ba68b93ada93b1d4edde59d3 (patch) | |
| tree | e3a57a2e2887a899cad71c0640047b2b2409b5fa /isisd | |
| parent | 70d4d90c82f3fb4eb552438422afb79e29a4dca0 (diff) | |
*: Convert THREAD_XXX macros to EVENT_XXX macros
Signed-off-by: Donald Sharp <sharpd@nvidia.com>
Diffstat (limited to 'isisd')
| -rw-r--r-- | isisd/fabricd.c | 20 | ||||
| -rw-r--r-- | isisd/isis_adjacency.c | 4 | ||||
| -rw-r--r-- | isisd/isis_circuit.c | 24 | ||||
| -rw-r--r-- | isisd/isis_dr.c | 8 | ||||
| -rw-r--r-- | isisd/isis_dynhn.c | 4 | ||||
| -rw-r--r-- | isisd/isis_events.c | 12 | ||||
| -rw-r--r-- | isisd/isis_ldp_sync.c | 8 | ||||
| -rw-r--r-- | isisd/isis_lfa.c | 6 | ||||
| -rw-r--r-- | isisd/isis_lsp.c | 18 | ||||
| -rw-r--r-- | isisd/isis_main.c | 4 | ||||
| -rw-r--r-- | isisd/isis_pdu.c | 18 | ||||
| -rw-r--r-- | isisd/isis_spf.c | 4 | ||||
| -rw-r--r-- | isisd/isis_sr.c | 4 | ||||
| -rw-r--r-- | isisd/isis_tx_queue.c | 8 | ||||
| -rw-r--r-- | isisd/isisd.c | 24 | 
15 files changed, 83 insertions, 83 deletions
diff --git a/isisd/fabricd.c b/isisd/fabricd.c index 52fd8df006..4fd39498a0 100644 --- a/isisd/fabricd.c +++ b/isisd/fabricd.c @@ -225,11 +225,11 @@ struct fabricd *fabricd_new(struct isis_area *area)  void fabricd_finish(struct fabricd *f)  { -	THREAD_OFF(f->initial_sync_timeout); +	EVENT_OFF(f->initial_sync_timeout); -	THREAD_OFF(f->tier_calculation_timer); +	EVENT_OFF(f->tier_calculation_timer); -	THREAD_OFF(f->tier_set_timer); +	EVENT_OFF(f->tier_set_timer);  	isis_spftree_del(f->spftree);  	neighbor_lists_clear(f); @@ -239,7 +239,7 @@ void fabricd_finish(struct fabricd *f)  static void fabricd_initial_sync_timeout(struct event *thread)  { -	struct fabricd *f = THREAD_ARG(thread); +	struct fabricd *f = EVENT_ARG(thread);  	if (IS_DEBUG_ADJ_PACKETS)  		zlog_debug( @@ -325,7 +325,7 @@ void fabricd_initial_sync_finish(struct isis_area *area)  		  f->initial_sync_circuit->interface->name);  	f->initial_sync_state = FABRICD_SYNC_COMPLETE;  	f->initial_sync_circuit = NULL; -	THREAD_OFF(f->initial_sync_timeout); +	EVENT_OFF(f->initial_sync_timeout);  }  static void fabricd_bump_tier_calculation_timer(struct fabricd *f); @@ -391,14 +391,14 @@ static uint8_t fabricd_calculate_fabric_tier(struct isis_area *area)  static void fabricd_tier_set_timer(struct event *thread)  { -	struct fabricd *f = THREAD_ARG(thread); +	struct fabricd *f = EVENT_ARG(thread);  	fabricd_set_tier(f, f->tier_pending);  }  static void fabricd_tier_calculation_cb(struct event *thread)  { -	struct fabricd *f = THREAD_ARG(thread); +	struct fabricd *f = EVENT_ARG(thread);  	uint8_t tier = ISIS_TIER_UNDEFINED;  	tier = fabricd_calculate_fabric_tier(f->area); @@ -417,14 +417,14 @@ static void fabricd_bump_tier_calculation_timer(struct fabricd *f)  {  	/* Cancel timer if we already know our tier */  	if (f->tier != ISIS_TIER_UNDEFINED || f->tier_set_timer) { -		THREAD_OFF(f->tier_calculation_timer); +		EVENT_OFF(f->tier_calculation_timer);  		return;  	}  	/* If we need to calculate the tier, wait some  	 * time for the topology to settle before running  	 * the calculation */ -	THREAD_OFF(f->tier_calculation_timer); +	EVENT_OFF(f->tier_calculation_timer);  	event_add_timer(master, fabricd_tier_calculation_cb, f,  			2 * f->area->lsp_gen_interval[ISIS_LEVEL2 - 1], @@ -709,7 +709,7 @@ void fabricd_trigger_csnp(struct isis_area *area, bool circuit_scoped)  		if (!circuit->t_send_csnp[1])  			continue; -		THREAD_OFF(circuit->t_send_csnp[ISIS_LEVEL2 - 1]); +		EVENT_OFF(circuit->t_send_csnp[ISIS_LEVEL2 - 1]);  		event_add_timer_msec(master, send_l2_csnp, circuit,  				     isis_jitter(f->csnp_delay, CSNP_JITTER),  				     &circuit->t_send_csnp[ISIS_LEVEL2 - 1]); diff --git a/isisd/isis_adjacency.c b/isisd/isis_adjacency.c index 4443f346db..c7c9582929 100644 --- a/isisd/isis_adjacency.c +++ b/isisd/isis_adjacency.c @@ -148,7 +148,7 @@ void isis_delete_adj(void *arg)  	/* Remove self from snmp list without walking the list*/  	list_delete_node(adj->circuit->snmp_adj_list, adj->snmp_list_node); -	THREAD_OFF(adj->t_expire); +	EVENT_OFF(adj->t_expire);  	if (adj->adj_state != ISIS_ADJ_DOWN)  		adj->adj_state = ISIS_ADJ_DOWN; @@ -485,7 +485,7 @@ void isis_adj_expire(struct event *thread)  	/*  	 * Get the adjacency  	 */ -	adj = THREAD_ARG(thread); +	adj = EVENT_ARG(thread);  	assert(adj);  	adj->t_expire = NULL; diff --git a/isisd/isis_circuit.c b/isisd/isis_circuit.c index 2a33d10216..8d62390743 100644 --- a/isisd/isis_circuit.c +++ b/isisd/isis_circuit.c @@ -863,12 +863,12 @@ void isis_circuit_down(struct isis_circuit *circuit)  		memset(circuit->u.bc.l2_desig_is, 0, ISIS_SYS_ID_LEN + 1);  		memset(circuit->u.bc.snpa, 0, ETH_ALEN); -		THREAD_OFF(circuit->u.bc.t_send_lan_hello[0]); -		THREAD_OFF(circuit->u.bc.t_send_lan_hello[1]); -		THREAD_OFF(circuit->u.bc.t_run_dr[0]); -		THREAD_OFF(circuit->u.bc.t_run_dr[1]); -		THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[0]); -		THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[1]); +		EVENT_OFF(circuit->u.bc.t_send_lan_hello[0]); +		EVENT_OFF(circuit->u.bc.t_send_lan_hello[1]); +		EVENT_OFF(circuit->u.bc.t_run_dr[0]); +		EVENT_OFF(circuit->u.bc.t_run_dr[1]); +		EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[0]); +		EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[1]);  		circuit->lsp_regenerate_pending[0] = 0;  		circuit->lsp_regenerate_pending[1] = 0; @@ -878,7 +878,7 @@ void isis_circuit_down(struct isis_circuit *circuit)  	} else if (circuit->circ_type == CIRCUIT_T_P2P) {  		isis_delete_adj(circuit->u.p2p.neighbor);  		circuit->u.p2p.neighbor = NULL; -		THREAD_OFF(circuit->u.p2p.t_send_p2p_hello); +		EVENT_OFF(circuit->u.p2p.t_send_p2p_hello);  	}  	/* @@ -891,11 +891,11 @@ void isis_circuit_down(struct isis_circuit *circuit)  	circuit->snmp_adj_idx_gen = 0;  	/* Cancel all active threads */ -	THREAD_OFF(circuit->t_send_csnp[0]); -	THREAD_OFF(circuit->t_send_csnp[1]); -	THREAD_OFF(circuit->t_send_psnp[0]); -	THREAD_OFF(circuit->t_send_psnp[1]); -	THREAD_OFF(circuit->t_read); +	EVENT_OFF(circuit->t_send_csnp[0]); +	EVENT_OFF(circuit->t_send_csnp[1]); +	EVENT_OFF(circuit->t_send_psnp[0]); +	EVENT_OFF(circuit->t_send_psnp[1]); +	EVENT_OFF(circuit->t_read);  	if (circuit->tx_queue) {  		isis_tx_queue_free(circuit->tx_queue); diff --git a/isisd/isis_dr.c b/isisd/isis_dr.c index 9a10a61b29..3bc1882736 100644 --- a/isisd/isis_dr.c +++ b/isisd/isis_dr.c @@ -50,7 +50,7 @@ const char *isis_disflag2string(int disflag)  void isis_run_dr(struct event *thread)  { -	struct isis_circuit_arg *arg = THREAD_ARG(thread); +	struct isis_circuit_arg *arg = EVENT_ARG(thread);  	assert(arg); @@ -211,8 +211,8 @@ int isis_dr_resign(struct isis_circuit *circuit, int level)  	circuit->u.bc.is_dr[level - 1] = 0;  	circuit->u.bc.run_dr_elect[level - 1] = 0; -	THREAD_OFF(circuit->u.bc.t_run_dr[level - 1]); -	THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[level - 1]); +	EVENT_OFF(circuit->u.bc.t_run_dr[level - 1]); +	EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[level - 1]);  	circuit->lsp_regenerate_pending[level - 1] = 0;  	memcpy(id, circuit->isis->sysid, ISIS_SYS_ID_LEN); @@ -236,7 +236,7 @@ int isis_dr_resign(struct isis_circuit *circuit, int level)  				&circuit->t_send_psnp[1]);  	} -	THREAD_OFF(circuit->t_send_csnp[level - 1]); +	EVENT_OFF(circuit->t_send_csnp[level - 1]);  	event_add_timer(master, isis_run_dr, &circuit->level_arg[level - 1],  			2 * circuit->hello_interval[level - 1], diff --git a/isisd/isis_dynhn.c b/isisd/isis_dynhn.c index e171419310..469f332be6 100644 --- a/isisd/isis_dynhn.c +++ b/isisd/isis_dynhn.c @@ -44,7 +44,7 @@ void dyn_cache_finish(struct isis *isis)  	struct listnode *node, *nnode;  	struct isis_dynhn *dyn; -	THREAD_OFF(isis->t_dync_clean); +	EVENT_OFF(isis->t_dync_clean);  	for (ALL_LIST_ELEMENTS(isis->dyn_cache, node, nnode, dyn)) {  		list_delete_node(isis->dyn_cache, node); @@ -61,7 +61,7 @@ static void dyn_cache_cleanup(struct event *thread)  	time_t now = time(NULL);  	struct isis *isis = NULL; -	isis = THREAD_ARG(thread); +	isis = EVENT_ARG(thread);  	isis->t_dync_clean = NULL; diff --git a/isisd/isis_events.c b/isisd/isis_events.c index 4610bb2c93..708a2747fb 100644 --- a/isisd/isis_events.c +++ b/isisd/isis_events.c @@ -96,13 +96,13 @@ static void circuit_resign_level(struct isis_circuit *circuit, int level)  			circuit->area->area_tag, circuit->circuit_id,  			circuit->interface->name, level); -	THREAD_OFF(circuit->t_send_csnp[idx]); -	THREAD_OFF(circuit->t_send_psnp[idx]); +	EVENT_OFF(circuit->t_send_csnp[idx]); +	EVENT_OFF(circuit->t_send_psnp[idx]);  	if (circuit->circ_type == CIRCUIT_T_BROADCAST) { -		THREAD_OFF(circuit->u.bc.t_send_lan_hello[idx]); -		THREAD_OFF(circuit->u.bc.t_run_dr[idx]); -		THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[idx]); +		EVENT_OFF(circuit->u.bc.t_send_lan_hello[idx]); +		EVENT_OFF(circuit->u.bc.t_run_dr[idx]); +		EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[idx]);  		circuit->lsp_regenerate_pending[idx] = 0;  		circuit->u.bc.run_dr_elect[idx] = 0;  		circuit->u.bc.is_dr[idx] = 0; @@ -200,7 +200,7 @@ void isis_event_dis_status_change(struct event *thread)  {  	struct isis_circuit *circuit; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	/* invalid arguments */  	if (!circuit || !circuit->area) diff --git a/isisd/isis_ldp_sync.c b/isisd/isis_ldp_sync.c index 6c9292ffc0..59596e1af5 100644 --- a/isisd/isis_ldp_sync.c +++ b/isisd/isis_ldp_sync.c @@ -171,7 +171,7 @@ void isis_ldp_sync_if_complete(struct isis_circuit *circuit)  		if (ldp_sync_info->state == LDP_IGP_SYNC_STATE_REQUIRED_NOT_UP)  			ldp_sync_info->state = LDP_IGP_SYNC_STATE_REQUIRED_UP; -		THREAD_OFF(ldp_sync_info->t_holddown); +		EVENT_OFF(ldp_sync_info->t_holddown);  		isis_ldp_sync_set_if_metric(circuit, true);  	} @@ -191,7 +191,7 @@ void isis_ldp_sync_ldp_fail(struct isis_circuit *circuit)  	if (ldp_sync_info &&  	    ldp_sync_info->enabled == LDP_IGP_SYNC_ENABLED &&  	    ldp_sync_info->state != LDP_IGP_SYNC_STATE_NOT_REQUIRED) { -		THREAD_OFF(ldp_sync_info->t_holddown); +		EVENT_OFF(ldp_sync_info->t_holddown);  		ldp_sync_info->state = LDP_IGP_SYNC_STATE_REQUIRED_NOT_UP;  		isis_ldp_sync_set_if_metric(circuit, true);  	} @@ -340,7 +340,7 @@ static void isis_ldp_sync_holddown_timer(struct event *thread)  	 *  didn't receive msg from LDP indicating sync-complete  	 *  restore interface cost to original value  	 */ -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	if (circuit->ldp_sync_info == NULL)  		return; @@ -516,7 +516,7 @@ void isis_if_ldp_sync_disable(struct isis_circuit *circuit)  	if (!CHECK_FLAG(area->ldp_sync_cmd.flags, LDP_SYNC_FLAG_ENABLE))  		return; -	THREAD_OFF(ldp_sync_info->t_holddown); +	EVENT_OFF(ldp_sync_info->t_holddown);  	ldp_sync_info->state = LDP_IGP_SYNC_STATE_NOT_REQUIRED;  	isis_ldp_sync_set_if_metric(circuit, true);  } diff --git a/isisd/isis_lfa.c b/isisd/isis_lfa.c index 323a25c260..7a25a92535 100644 --- a/isisd/isis_lfa.c +++ b/isisd/isis_lfa.c @@ -1390,7 +1390,7 @@ static struct rlfa *rlfa_lookup(struct isis_spftree *spftree,  static void isis_area_verify_routes_cb(struct event *thread)  { -	struct isis_area *area = THREAD_ARG(thread); +	struct isis_area *area = EVENT_ARG(thread);  	if (IS_DEBUG_LFA)  		zlog_debug("ISIS-LFA: updating RLFAs in the RIB"); @@ -1506,7 +1506,7 @@ int isis_rlfa_activate(struct isis_spftree *spftree, struct rlfa *rlfa,  			  spftree->route_table_backup);  	spftree->lfa.protection_counters.rlfa[vertex->N.ip.priority] += 1; -	THREAD_OFF(area->t_rlfa_rib_update); +	EVENT_OFF(area->t_rlfa_rib_update);  	event_add_timer(master, isis_area_verify_routes_cb, area, 2,  			&area->t_rlfa_rib_update); @@ -1525,7 +1525,7 @@ void isis_rlfa_deactivate(struct isis_spftree *spftree, struct rlfa *rlfa)  	isis_route_delete(area, rn, spftree->route_table_backup);  	spftree->lfa.protection_counters.rlfa[vertex->N.ip.priority] -= 1; -	THREAD_OFF(area->t_rlfa_rib_update); +	EVENT_OFF(area->t_rlfa_rib_update);  	event_add_timer(master, isis_area_verify_routes_cb, area, 2,  			&area->t_rlfa_rib_update);  } diff --git a/isisd/isis_lsp.c b/isisd/isis_lsp.c index 1635d66c39..32540b0faa 100644 --- a/isisd/isis_lsp.c +++ b/isisd/isis_lsp.c @@ -431,7 +431,7 @@ bool isis_level2_adj_up(struct isis_area *area)   */  void set_overload_on_start_timer(struct event *thread)  { -	struct isis_area *area = THREAD_ARG(thread); +	struct isis_area *area = EVENT_ARG(thread);  	assert(area);  	area->t_overload_on_startup_timer = NULL; @@ -1418,7 +1418,7 @@ int lsp_generate(struct isis_area *area, int level)  	refresh_time = lsp_refresh_time(newlsp, rem_lifetime); -	THREAD_OFF(area->t_lsp_refresh[level - 1]); +	EVENT_OFF(area->t_lsp_refresh[level - 1]);  	area->lsp_regenerate_pending[level - 1] = 0;  	event_add_timer(master, lsp_refresh, &area->lsp_refresh_arg[level - 1],  			refresh_time, &area->t_lsp_refresh[level - 1]); @@ -1523,7 +1523,7 @@ static int lsp_regenerate(struct isis_area *area, int level)   */  static void lsp_refresh(struct event *thread)  { -	struct lsp_refresh_arg *arg = THREAD_ARG(thread); +	struct lsp_refresh_arg *arg = EVENT_ARG(thread);  	assert(arg); @@ -1627,7 +1627,7 @@ int _lsp_regenerate_schedule(struct isis_area *area, int level,  			"ISIS (%s): Will schedule regen timer. Last run was: %lld, Now is: %lld",  			area->area_tag, (long long)lsp->last_generated,  			(long long)now); -		THREAD_OFF(area->t_lsp_refresh[lvl - 1]); +		EVENT_OFF(area->t_lsp_refresh[lvl - 1]);  		diff = now - lsp->last_generated;  		if (diff < area->lsp_gen_interval[lvl - 1]  		    && !(area->bfd_signalled_down)) { @@ -1819,7 +1819,7 @@ int lsp_generate_pseudo(struct isis_circuit *circuit, int level)  	lsp_flood(lsp, NULL);  	refresh_time = lsp_refresh_time(lsp, rem_lifetime); -	THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[level - 1]); +	EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[level - 1]);  	circuit->lsp_regenerate_pending[level - 1] = 0;  	if (level == IS_LEVEL_1)  		event_add_timer(master, lsp_l1_refresh_pseudo, circuit, @@ -1905,7 +1905,7 @@ static void lsp_l1_refresh_pseudo(struct event *thread)  	struct isis_circuit *circuit;  	uint8_t id[ISIS_SYS_ID_LEN + 2]; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	circuit->u.bc.t_refresh_pseudo_lsp[0] = NULL;  	circuit->lsp_regenerate_pending[0] = 0; @@ -1927,7 +1927,7 @@ static void lsp_l2_refresh_pseudo(struct event *thread)  	struct isis_circuit *circuit;  	uint8_t id[ISIS_SYS_ID_LEN + 2]; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	circuit->u.bc.t_refresh_pseudo_lsp[1] = NULL;  	circuit->lsp_regenerate_pending[1] = 0; @@ -2010,7 +2010,7 @@ int lsp_regenerate_schedule_pseudo(struct isis_circuit *circuit, int level)  			"ISIS (%s): Will schedule PSN regen timer. Last run was: %lld, Now is: %lld",  			area->area_tag, (long long)lsp->last_generated,  			(long long)now); -		THREAD_OFF(circuit->u.bc.t_refresh_pseudo_lsp[lvl - 1]); +		EVENT_OFF(circuit->u.bc.t_refresh_pseudo_lsp[lvl - 1]);  		diff = now - lsp->last_generated;  		if (diff < circuit->area->lsp_gen_interval[lvl - 1]) {  			timeout = @@ -2054,7 +2054,7 @@ void lsp_tick(struct event *thread)  	uint16_t rem_lifetime;  	bool fabricd_sync_incomplete = false; -	area = THREAD_ARG(thread); +	area = EVENT_ARG(thread);  	assert(area);  	area->t_tick = NULL;  	event_add_timer(master, lsp_tick, area, 1, &area->t_tick); diff --git a/isisd/isis_main.c b/isisd/isis_main.c index 7b5d472352..0e8780c47a 100644 --- a/isisd/isis_main.c +++ b/isisd/isis_main.c @@ -185,7 +185,7 @@ static void isis_config_start(void)  {  	/* Max wait time for config to load before generating lsp */  #define ISIS_PRE_CONFIG_MAX_WAIT_SECONDS 600 -	THREAD_OFF(t_isis_cfg); +	EVENT_OFF(t_isis_cfg);  	event_add_timer(im->master, isis_config_finish, NULL,  			ISIS_PRE_CONFIG_MAX_WAIT_SECONDS, &t_isis_cfg);  } @@ -198,7 +198,7 @@ static void isis_config_end(void)  	if (!event_is_scheduled(t_isis_cfg))  		return; -	THREAD_OFF(t_isis_cfg); +	EVENT_OFF(t_isis_cfg);  	isis_config_finish(t_isis_cfg);  } diff --git a/isisd/isis_pdu.c b/isisd/isis_pdu.c index 00ee7f8ebb..a5d5679c02 100644 --- a/isisd/isis_pdu.c +++ b/isisd/isis_pdu.c @@ -192,7 +192,7 @@ static int process_p2p_hello(struct iih_info *iih)  				      adj);  	/* lets take care of the expiry */ -	THREAD_OFF(adj->t_expire); +	EVENT_OFF(adj->t_expire);  	event_add_timer(master, isis_adj_expire, adj, (long)adj->hold_time,  			&adj->t_expire); @@ -484,7 +484,7 @@ static int process_lan_hello(struct iih_info *iih)  				      adj);  	/* lets take care of the expiry */ -	THREAD_OFF(adj->t_expire); +	EVENT_OFF(adj->t_expire);  	event_add_timer(master, isis_adj_expire, adj, (long)adj->hold_time,  			&adj->t_expire); @@ -1788,7 +1788,7 @@ void isis_receive(struct event *thread)  	/*  	 * Get the circuit  	 */ -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	assert(circuit);  	circuit->t_read = NULL; @@ -2011,7 +2011,7 @@ int send_hello(struct isis_circuit *circuit, int level)  static void send_hello_cb(struct event *thread)  { -	struct isis_circuit_arg *arg = THREAD_ARG(thread); +	struct isis_circuit_arg *arg = EVENT_ARG(thread);  	assert(arg);  	struct isis_circuit *circuit = arg->circuit; @@ -2056,7 +2056,7 @@ static void _send_hello_sched(struct isis_circuit *circuit,  		if (event_timer_remain_msec(*threadp) < (unsigned long)delay)  			return; -		THREAD_OFF(*threadp); +		EVENT_OFF(*threadp);  	}  	event_add_timer_msec(master, send_hello_cb, @@ -2242,7 +2242,7 @@ void send_l1_csnp(struct event *thread)  {  	struct isis_circuit *circuit; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	assert(circuit);  	circuit->t_send_csnp[0] = NULL; @@ -2262,7 +2262,7 @@ void send_l2_csnp(struct event *thread)  {  	struct isis_circuit *circuit; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	assert(circuit);  	circuit->t_send_csnp[1] = NULL; @@ -2397,7 +2397,7 @@ void send_l1_psnp(struct event *thread)  	struct isis_circuit *circuit; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	assert(circuit);  	circuit->t_send_psnp[0] = NULL; @@ -2417,7 +2417,7 @@ void send_l2_psnp(struct event *thread)  {  	struct isis_circuit *circuit; -	circuit = THREAD_ARG(thread); +	circuit = EVENT_ARG(thread);  	assert(circuit);  	circuit->t_send_psnp[1] = NULL; diff --git a/isisd/isis_spf.c b/isisd/isis_spf.c index aabf79024d..f63b000064 100644 --- a/isisd/isis_spf.c +++ b/isisd/isis_spf.c @@ -1855,7 +1855,7 @@ void isis_spf_switchover_routes(struct isis_area *area,  static void isis_run_spf_cb(struct event *thread)  { -	struct isis_spf_run *run = THREAD_ARG(thread); +	struct isis_spf_run *run = EVENT_ARG(thread);  	struct isis_area *area = run->area;  	int level = run->level;  	int have_run = 0; @@ -1950,7 +1950,7 @@ int _isis_spf_schedule(struct isis_area *area, int level,  			area->area_tag, level, diff, func, file, line);  	} -	THREAD_OFF(area->t_rlfa_rib_update); +	EVENT_OFF(area->t_rlfa_rib_update);  	if (area->spf_delay_ietf[level - 1]) {  		/* Need to call schedule function also if spf delay is running  		 * to diff --git a/isisd/isis_sr.c b/isisd/isis_sr.c index 791d221cf9..cb330603e4 100644 --- a/isisd/isis_sr.c +++ b/isisd/isis_sr.c @@ -1085,7 +1085,7 @@ static void sr_start_label_manager(struct event *start)  {  	struct isis_area *area; -	area = THREAD_ARG(start); +	area = EVENT_ARG(start);  	/* re-attempt to start SR & Label Manager connection */  	isis_sr_start(area); @@ -1168,7 +1168,7 @@ void isis_sr_stop(struct isis_area *area)  		 area->area_tag);  	/* Disable any re-attempt to connect to Label Manager */ -	THREAD_OFF(srdb->t_start_lm); +	EVENT_OFF(srdb->t_start_lm);  	/* Uninstall all local Adjacency-SIDs. */  	for (ALL_LIST_ELEMENTS(area->srdb.adj_sids, node, nnode, sra)) diff --git a/isisd/isis_tx_queue.c b/isisd/isis_tx_queue.c index e0c5e164f6..ec2d50d60a 100644 --- a/isisd/isis_tx_queue.c +++ b/isisd/isis_tx_queue.c @@ -79,7 +79,7 @@ static void tx_queue_element_free(void *element)  {  	struct isis_tx_queue_entry *e = element; -	THREAD_OFF(e->retry); +	EVENT_OFF(e->retry);  	XFREE(MTYPE_TX_QUEUE_ENTRY, e);  } @@ -102,7 +102,7 @@ static struct isis_tx_queue_entry *tx_queue_find(struct isis_tx_queue *queue,  static void tx_queue_send_event(struct event *thread)  { -	struct isis_tx_queue_entry *e = THREAD_ARG(thread); +	struct isis_tx_queue_entry *e = EVENT_ARG(thread);  	struct isis_tx_queue *queue = e->queue;  	event_add_timer(master, tx_queue_send_event, e, 5, &e->retry); @@ -147,7 +147,7 @@ void _isis_tx_queue_add(struct isis_tx_queue *queue,  	e->type = type; -	THREAD_OFF(e->retry); +	EVENT_OFF(e->retry);  	event_add_event(master, tx_queue_send_event, e, 0, &e->retry);  	e->is_retry = false; @@ -170,7 +170,7 @@ void _isis_tx_queue_del(struct isis_tx_queue *queue, struct isis_lsp *lsp,  			   func, file, line);  	} -	THREAD_OFF(e->retry); +	EVENT_OFF(e->retry);  	hash_release(queue->hash, e);  	XFREE(MTYPE_TX_QUEUE_ENTRY, e); diff --git a/isisd/isisd.c b/isisd/isisd.c index 267c316702..40f64089c8 100644 --- a/isisd/isisd.c +++ b/isisd/isisd.c @@ -519,11 +519,11 @@ void isis_area_destroy(struct isis_area *area)  	spftree_area_del(area);  	if (area->spf_timer[0]) -		isis_spf_timer_free(THREAD_ARG(area->spf_timer[0])); -	THREAD_OFF(area->spf_timer[0]); +		isis_spf_timer_free(EVENT_ARG(area->spf_timer[0])); +	EVENT_OFF(area->spf_timer[0]);  	if (area->spf_timer[1]) -		isis_spf_timer_free(THREAD_ARG(area->spf_timer[1])); -	THREAD_OFF(area->spf_timer[1]); +		isis_spf_timer_free(EVENT_ARG(area->spf_timer[1])); +	EVENT_OFF(area->spf_timer[1]);  	spf_backoff_free(area->spf_delay_ietf[0]);  	spf_backoff_free(area->spf_delay_ietf[1]); @@ -543,10 +543,10 @@ void isis_area_destroy(struct isis_area *area)  	isis_lfa_tiebreakers_clear(area, ISIS_LEVEL1);  	isis_lfa_tiebreakers_clear(area, ISIS_LEVEL2); -	THREAD_OFF(area->t_tick); -	THREAD_OFF(area->t_lsp_refresh[0]); -	THREAD_OFF(area->t_lsp_refresh[1]); -	THREAD_OFF(area->t_rlfa_rib_update); +	EVENT_OFF(area->t_tick); +	EVENT_OFF(area->t_lsp_refresh[0]); +	EVENT_OFF(area->t_lsp_refresh[1]); +	EVENT_OFF(area->t_rlfa_rib_update);  	event_cancel_event(master, area); @@ -3119,14 +3119,14 @@ static void area_resign_level(struct isis_area *area, int level)  	}  	if (area->spf_timer[level - 1]) -		isis_spf_timer_free(THREAD_ARG(area->spf_timer[level - 1])); +		isis_spf_timer_free(EVENT_ARG(area->spf_timer[level - 1])); -	THREAD_OFF(area->spf_timer[level - 1]); +	EVENT_OFF(area->spf_timer[level - 1]);  	sched_debug(  		"ISIS (%s): Resigned from L%d - canceling LSP regeneration timer.",  		area->area_tag, level); -	THREAD_OFF(area->t_lsp_refresh[level - 1]); +	EVENT_OFF(area->t_lsp_refresh[level - 1]);  	area->lsp_regenerate_pending[level - 1] = 0;  } @@ -3215,7 +3215,7 @@ void isis_area_overload_bit_set(struct isis_area *area, bool overload_bit)  		} else {  			/* Cancel overload on startup timer if it's running */  			if (area->t_overload_on_startup_timer) { -				THREAD_OFF(area->t_overload_on_startup_timer); +				EVENT_OFF(area->t_overload_on_startup_timer);  				area->t_overload_on_startup_timer = NULL;  			}  		}  | 
