Proxmox-Port/libqb
1
0
Fork 0
mirror of https://salsa.debian.org/ha-team/libqb synced 2026-08-11 09:56:06 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

LOOP: prevent jobs from consuming too much cpu.

Browse Source 
Signed-off-by: Angus Salkeld <asalkeld@redhat.com>
This commit is contained in:
Angus Salkeld 2012-02-06 22:35:30 +11:00
parent 42d20b5090
commit f869f93deb
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lib/loop.c
View File

@ -119,6 +119,8 @@ qb_loop_run(struct qb_loop *l)
int32_t p;
int32_t p_stop = QB_LOOP_LOW;
int32_t todo = 0;
int32_t job_todo;
int32_t timer_todo;
int32_t ms_timeout;
l->stop_requested = QB_FALSE;
@ -131,13 +133,28 @@ qb_loop_run(struct qb_loop *l)
}
if (l->job_source && l->job_source->poll) {
todo += l->job_source->poll(l->job_source, 0);
job_todo = l->job_source->poll(l->job_source, 0);
} else {
job_todo = 0;
}
if (l->timer_source && l->timer_source->poll) {
todo += l->timer_source->poll(l->timer_source, 0);
timer_todo = l->timer_source->poll(l->timer_source, 0);
} else {
timer_todo = 0;
}
if (todo > 0) {
if (todo > 0 || timer_todo > 0) {
/*
* if there are old todos or timer todos then don't wait.
*/
ms_timeout = 0;
} else if (job_todo > 0) {
todo = 0;
/*
* if we only have jobs to do (not timers or old todos)
* then set a non-zero timeout. Jobs can spin out of
* control if someone keeps adding them.
*/
ms_timeout = 50;
} else {
todo = 0;
if (l->timer_source) {