proxmox-mirrors/mirror_frr
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_frr synced 2025-11-03 04:28:24 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

lib: pass the thread_master to process_timers()

Browse Source 
Pass the thread_master pointer to process_timers() as we
do for other list-processing apis.

Signed-off-by: Mark Stapp <mjs@voltanet.io>
This commit is contained in:
Mark Stapp 2021-02-18 09:38:19 -05:00
parent 96fe578a64
commit e7d9e44b02
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/thread.c
View File

@ -1452,20 +1452,21 @@ static void thread_process_io(struct thread_master *m, unsigned int num)
}
/* Add all timers that have popped to the ready list. */
static unsigned int thread_process_timers(struct thread_timer_list_head *timers,
static unsigned int thread_process_timers(struct thread_master *m,
struct timeval *timenow)
{
struct thread *thread;
unsigned int ready = 0;
while ((thread = thread_timer_list_first(timers))) {
while ((thread = thread_timer_list_first(&m->timer))) {
if (timercmp(timenow, &thread->u.sands, <))
return ready;
thread_timer_list_pop(timers);
break;
thread_timer_list_pop(&m->timer);
thread->type = THREAD_READY;
thread_list_add_tail(&thread->master->ready, thread);
thread_list_add_tail(&m->ready, thread);
ready++;
}
return ready;
}
@ -1587,7 +1588,7 @@ struct thread *thread_fetch(struct thread_master *m, struct thread *fetch)
/* Post timers to ready queue. */
monotime(&now);
thread_process_timers(&m->timer, &now);
thread_process_timers(m, &now);
/* Post I/O to ready queue. */
if (num > 0)