diff options
author | peter <peter@FreeBSD.org> | 2002-08-28 23:45:15 +0000 |
---|---|---|
committer | peter <peter@FreeBSD.org> | 2002-08-28 23:45:15 +0000 |
commit | a2257589334d769f5e515ff0936ee5c13f1769d8 (patch) | |
tree | 3d7240b9022dd46250cd1b622c9e2722e683bca8 /sys | |
parent | 7b726290f1e66d65654b382a03a1ce5fcc35cb8c (diff) | |
download | FreeBSD-src-a2257589334d769f5e515ff0936ee5c13f1769d8.zip FreeBSD-src-a2257589334d769f5e515ff0936ee5c13f1769d8.tar.gz |
updatepri() works on a ksegrp (where the scheduling parameters are), so
directly give it the ksegrp instead of the thread. The only thing it used
to use in the thread was the ksegrp.
Reviewed by: julian
Diffstat (limited to 'sys')
-rw-r--r-- | sys/kern/kern_condvar.c | 8 | ||||
-rw-r--r-- | sys/kern/kern_synch.c | 35 | ||||
-rw-r--r-- | sys/sys/proc.h | 2 |
3 files changed, 24 insertions, 21 deletions
diff --git a/sys/kern/kern_condvar.c b/sys/kern/kern_condvar.c index 53c8571..42f989d 100644 --- a/sys/kern/kern_condvar.c +++ b/sys/kern/kern_condvar.c @@ -507,6 +507,7 @@ static __inline void cv_wakeup(struct cv *cvp) { struct thread *td; + struct ksegrp *kg; mtx_assert(&sched_lock, MA_OWNED); td = TAILQ_FIRST(&cvp->cv_waitq); @@ -519,9 +520,10 @@ cv_wakeup(struct cv *cvp) /* OPTIMIZED EXPANSION OF setrunnable(td); */ CTR3(KTR_PROC, "cv_signal: thread %p (pid %d, %s)", td, td->td_proc->p_pid, td->td_proc->p_comm); - if (td->td_ksegrp->kg_slptime > 1) /* XXXKSE */ - updatepri(td); - td->td_ksegrp->kg_slptime = 0; + kg = td->td_ksegrp; + if (kg->kg_slptime > 1) /* XXXKSE */ + updatepri(kg); + kg->kg_slptime = 0; if (td->td_proc->p_sflag & PS_INMEM) { setrunqueue(td); maybe_resched(td); diff --git a/sys/kern/kern_synch.c b/sys/kern/kern_synch.c index 1b03692..4fd3393 100644 --- a/sys/kern/kern_synch.c +++ b/sys/kern/kern_synch.c @@ -376,16 +376,11 @@ schedcpu(arg) * least six times the loadfactor will decay p_estcpu to zero. */ void -updatepri(td) - register struct thread *td; +updatepri(struct ksegrp *kg) { - register struct ksegrp *kg; register unsigned int newcpu; register fixpt_t loadfac = loadfactor(averunnable.ldavg[0]); - if (td == NULL) - return; - kg = td->td_ksegrp; newcpu = kg->kg_estcpu; if (kg->kg_slptime > 5 * loadfac) kg->kg_estcpu = 0; @@ -395,7 +390,7 @@ updatepri(td) newcpu = decay_cpu(loadfac, newcpu); kg->kg_estcpu = newcpu; } - resetpriority(td->td_ksegrp); + resetpriority(kg); } /* @@ -705,6 +700,7 @@ wakeup(ident) register struct slpquehead *qp; register struct thread *td; struct thread *ntd; + struct ksegrp *kg; struct proc *p; mtx_lock_spin(&sched_lock); @@ -720,9 +716,10 @@ restart: /* OPTIMIZED EXPANSION OF setrunnable(p); */ CTR3(KTR_PROC, "wakeup: thread %p (pid %d, %s)", td, p->p_pid, p->p_comm); - if (td->td_ksegrp->kg_slptime > 1) - updatepri(td); - td->td_ksegrp->kg_slptime = 0; + kg = td->td_ksegrp; + if (kg->kg_slptime > 1) + updatepri(kg); + kg->kg_slptime = 0; if (p->p_sflag & PS_INMEM) { setrunqueue(td); maybe_resched(td); @@ -754,6 +751,7 @@ wakeup_one(ident) register struct thread *td; register struct proc *p; struct thread *ntd; + struct ksegrp *kg; mtx_lock_spin(&sched_lock); qp = &slpque[LOOKUP(ident)]; @@ -768,9 +766,10 @@ restart: /* OPTIMIZED EXPANSION OF setrunnable(p); */ CTR3(KTR_PROC,"wakeup1: thread %p (pid %d, %s)", td, p->p_pid, p->p_comm); - if (td->td_ksegrp->kg_slptime > 1) - updatepri(td); - td->td_ksegrp->kg_slptime = 0; + kg = td->td_ksegrp; + if (kg->kg_slptime > 1) + updatepri(kg); + kg->kg_slptime = 0; if (p->p_sflag & PS_INMEM) { setrunqueue(td); maybe_resched(td); @@ -794,7 +793,7 @@ restart: * The machine independent parts of mi_switch(). */ void -mi_switch() +mi_switch(void) { struct bintime new_switchtime; struct thread *td = curthread; /* XXX */ @@ -931,6 +930,7 @@ void setrunnable(struct thread *td) { struct proc *p = td->td_proc; + struct ksegrp *kg; mtx_assert(&sched_lock, MA_OWNED); switch (p->p_state) { @@ -960,9 +960,10 @@ setrunnable(struct thread *td) case TDS_RUNQ: /* not yet had time to suspend */ break; } - if (td->td_ksegrp->kg_slptime > 1) - updatepri(td); - td->td_ksegrp->kg_slptime = 0; + kg = td->td_ksegrp; + if (kg->kg_slptime > 1) + updatepri(kg); + kg->kg_slptime = 0; if ((p->p_sflag & PS_INMEM) == 0) { td->td_state = TDS_SWAPPED; if ((p->p_sflag & PS_SWAPPINGIN) == 0) { diff --git a/sys/sys/proc.h b/sys/sys/proc.h index 1b5d0c4..2fec2de 100644 --- a/sys/sys/proc.h +++ b/sys/sys/proc.h @@ -829,7 +829,7 @@ void cpu_idle(void); void cpu_switch(void); void cpu_throw(void) __dead2; void unsleep(struct thread *); -void updatepri(struct thread *); +void updatepri(struct ksegrp *); void userret(struct thread *, struct trapframe *, u_int); void maybe_resched(struct thread *); |