From 9d4ef4f19ca6838d213df7f6ac04590336afa71c Mon Sep 17 00:00:00 2001 From: jhb Date: Wed, 24 Jan 2001 11:28:36 +0000 Subject: [PATCH] - Catch up to proc flag changes. - Minimal proc locking. - Use queue macros. --- sys/vm/vm_meter.c | 21 +++++++++++++-------- sys/vm/vm_pageout.c | 11 ++++++++--- 2 files changed, 21 insertions(+), 11 deletions(-) diff --git a/sys/vm/vm_meter.c b/sys/vm/vm_meter.c index 2fa07545874e..d0283ba8366a 100644 --- a/sys/vm/vm_meter.c +++ b/sys/vm/vm_meter.c @@ -144,33 +144,35 @@ vmtotal(SYSCTL_HANDLER_ARGS) /* * Mark all objects as inactive. */ - for (object = TAILQ_FIRST(&vm_object_list); - object != NULL; - object = TAILQ_NEXT(object,object_list)) + TAILQ_FOREACH(object, &vm_object_list, object_list) vm_object_clear_flag(object, OBJ_ACTIVE); /* * Calculate process statistics. */ ALLPROC_LOCK(AP_SHARED); - for (p = allproc.lh_first; p != 0; p = p->p_list.le_next) { + LIST_FOREACH(p, &allproc, p_list) { if (p->p_flag & P_SYSTEM) continue; + mtx_enter(&sched_lock, MTX_SPIN); switch (p->p_stat) { case 0: + mtx_exit(&sched_lock, MTX_SPIN); continue; case SMTX: case SSLEEP: case SSTOP: - if (p->p_flag & P_INMEM) { + if (p->p_sflag & PS_INMEM) { if (p->p_priority <= PZERO) totalp->t_dw++; else if (p->p_slptime < maxslp) totalp->t_sl++; } else if (p->p_slptime < maxslp) totalp->t_sw++; - if (p->p_slptime >= maxslp) + if (p->p_slptime >= maxslp) { + mtx_exit(&sched_lock, MTX_SPIN); continue; + } break; case SWAIT: @@ -179,14 +181,17 @@ vmtotal(SYSCTL_HANDLER_ARGS) case SRUN: case SIDL: - if (p->p_flag & P_INMEM) + if (p->p_sflag & PS_INMEM) totalp->t_rq++; else totalp->t_sw++; - if (p->p_stat == SIDL) + if (p->p_stat == SIDL) { + mtx_exit(&sched_lock, MTX_SPIN); continue; + } break; } + mtx_exit(&sched_lock, MTX_SPIN); /* * Note active objects. */ diff --git a/sys/vm/vm_pageout.c b/sys/vm/vm_pageout.c index 943fb1178e52..0dd7ecbdf56d 100644 --- a/sys/vm/vm_pageout.c +++ b/sys/vm/vm_pageout.c @@ -1124,15 +1124,18 @@ vm_pageout_scan(int pass) bigproc = NULL; bigsize = 0; ALLPROC_LOCK(AP_SHARED); - for (p = allproc.lh_first; p != 0; p = p->p_list.le_next) { + LIST_FOREACH(p, &allproc, p_list) { /* * if this is a system process, skip it */ + PROC_LOCK(p); if ((p->p_flag & P_SYSTEM) || (p->p_lock > 0) || (p->p_pid == 1) || ((p->p_pid < 48) && (vm_swap_size != 0))) { + PROC_UNLOCK(p); continue; } + PROC_UNLOCK(p); /* * if the process is in a non-running type state, * don't touch it. @@ -1159,9 +1162,11 @@ vm_pageout_scan(int pass) ALLPROC_LOCK(AP_RELEASE); if (bigproc != NULL) { killproc(bigproc, "out of swap space"); + mtx_enter(&sched_lock, MTX_SPIN); bigproc->p_estcpu = 0; bigproc->p_nice = PRIO_MIN; resetpriority(bigproc); + mtx_exit(&sched_lock, MTX_SPIN); wakeup(&cnt.v_free_count); } } @@ -1477,7 +1482,6 @@ vm_daemon() mtx_exit(&sched_lock, MTX_SPIN); continue; } - mtx_exit(&sched_lock, MTX_SPIN); /* * get a limit */ @@ -1490,8 +1494,9 @@ vm_daemon() * swapped out set the limit to nothing (will force a * swap-out.) */ - if ((p->p_flag & P_INMEM) == 0) + if ((p->p_sflag & PS_INMEM) == 0) limit = 0; /* XXX */ + mtx_exit(&sched_lock, MTX_SPIN); size = vmspace_resident_count(p->p_vmspace); if (limit >= 0 && size >= limit) {