diff options
| author | Donald Sharp <sharpd@nvidia.com> | 2022-05-20 14:19:08 -0400 | 
|---|---|---|
| committer | Donald Sharp <sharpd@nvidia.com> | 2023-03-24 08:32:17 -0400 | 
| commit | 907a2395f423e3b97335d554557c2cef7195db84 (patch) | |
| tree | 18ea691bc5589fa570c739a9f221429633778ea9 /zebra/zebra_fpm.c | |
| parent | e6685141aae8fc869d49cde1d459f73b87bbec89 (diff) | |
*: Convert thread_add_XXX functions to event_add_XXX
Signed-off-by: Donald Sharp <sharpd@nvidia.com>
Diffstat (limited to 'zebra/zebra_fpm.c')
| -rw-r--r-- | zebra/zebra_fpm.c | 32 | 
1 files changed, 16 insertions, 16 deletions
diff --git a/zebra/zebra_fpm.c b/zebra/zebra_fpm.c index 0795d12263..a97873c384 100644 --- a/zebra/zebra_fpm.c +++ b/zebra/zebra_fpm.c @@ -460,8 +460,8 @@ static inline void zfpm_read_on(void)  	assert(!zfpm_g->t_read);  	assert(zfpm_g->sock >= 0); -	thread_add_read(zfpm_g->master, zfpm_read_cb, 0, zfpm_g->sock, -			&zfpm_g->t_read); +	event_add_read(zfpm_g->master, zfpm_read_cb, 0, zfpm_g->sock, +		       &zfpm_g->t_read);  }  /* @@ -472,8 +472,8 @@ static inline void zfpm_write_on(void)  	assert(!zfpm_g->t_write);  	assert(zfpm_g->sock >= 0); -	thread_add_write(zfpm_g->master, zfpm_write_cb, 0, zfpm_g->sock, -			 &zfpm_g->t_write); +	event_add_write(zfpm_g->master, zfpm_write_cb, 0, zfpm_g->sock, +			&zfpm_g->t_write);  }  /* @@ -542,8 +542,8 @@ static void zfpm_conn_up_thread_cb(struct event *thread)  		zfpm_g->stats.t_conn_up_yields++;  		zfpm_rnodes_iter_pause(iter); -		thread_add_timer_msec(zfpm_g->master, zfpm_conn_up_thread_cb, -				      NULL, 0, &zfpm_g->t_conn_up); +		event_add_timer_msec(zfpm_g->master, zfpm_conn_up_thread_cb, +				     NULL, 0, &zfpm_g->t_conn_up);  		return;  	} @@ -575,8 +575,8 @@ static void zfpm_connection_up(const char *detail)  	zfpm_debug("Starting conn_up thread"); -	thread_add_timer_msec(zfpm_g->master, zfpm_conn_up_thread_cb, NULL, 0, -			      &zfpm_g->t_conn_up); +	event_add_timer_msec(zfpm_g->master, zfpm_conn_up_thread_cb, NULL, 0, +			     &zfpm_g->t_conn_up);  	zfpm_g->stats.t_conn_up_starts++;  } @@ -668,8 +668,8 @@ static void zfpm_conn_down_thread_cb(struct event *thread)  		zfpm_g->stats.t_conn_down_yields++;  		zfpm_rnodes_iter_pause(iter);  		zfpm_g->t_conn_down = NULL; -		thread_add_timer_msec(zfpm_g->master, zfpm_conn_down_thread_cb, -				      NULL, 0, &zfpm_g->t_conn_down); +		event_add_timer_msec(zfpm_g->master, zfpm_conn_down_thread_cb, +				     NULL, 0, &zfpm_g->t_conn_down);  		return;  	} @@ -713,8 +713,8 @@ static void zfpm_connection_down(const char *detail)  	assert(!zfpm_g->t_conn_down);  	zfpm_rnodes_iter_init(&zfpm_g->t_conn_down_state.iter);  	zfpm_g->t_conn_down = NULL; -	thread_add_timer_msec(zfpm_g->master, zfpm_conn_down_thread_cb, NULL, 0, -			      &zfpm_g->t_conn_down); +	event_add_timer_msec(zfpm_g->master, zfpm_conn_down_thread_cb, NULL, 0, +			     &zfpm_g->t_conn_down);  	zfpm_g->stats.t_conn_down_starts++;  	zfpm_set_state(ZFPM_STATE_IDLE, detail); @@ -1388,8 +1388,8 @@ static void zfpm_start_connect_timer(const char *reason)  	delay_secs = zfpm_calc_connect_delay();  	zfpm_debug("scheduling connect in %ld seconds", delay_secs); -	thread_add_timer(zfpm_g->master, zfpm_connect_cb, 0, delay_secs, -			 &zfpm_g->t_connect); +	event_add_timer(zfpm_g->master, zfpm_connect_cb, 0, delay_secs, +			&zfpm_g->t_connect);  	zfpm_set_state(ZFPM_STATE_ACTIVE, reason);  } @@ -1707,8 +1707,8 @@ void zfpm_start_stats_timer(void)  {  	assert(!zfpm_g->t_stats); -	thread_add_timer(zfpm_g->master, zfpm_stats_timer_cb, 0, -			 ZFPM_STATS_IVL_SECS, &zfpm_g->t_stats); +	event_add_timer(zfpm_g->master, zfpm_stats_timer_cb, 0, +			ZFPM_STATS_IVL_SECS, &zfpm_g->t_stats);  }  /*  | 
