d/freebsd-dev
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

let thread_schedule_upcall() handle idle kse.

Browse Source
This commit is contained in:
David Xu 2002-10-25 12:50:31 +00:00
parent a40c540ffa
commit 0cf609706f
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=105930
2 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sys/kern/kern_kse.c
View File

@ -369,8 +369,6 @@ kse_wakeup(struct thread *td, struct kse_wakeup_args *uap)
return ESRCH;
}
found:
TAILQ_REMOVE(&kg->kg_iq, ke, ke_kgrlist);
kg->kg_idle_kses--;
thread_schedule_upcall(td, ke);
mtx_unlock_spin(&sched_lock);
td->td_retval[0] = 0;
@ -1039,6 +1037,7 @@ struct thread *
thread_schedule_upcall(struct thread *td, struct kse *ke)
{
struct thread *td2;
struct ksegrp *kg;
int newkse;
mtx_assert(&sched_lock, MA_OWNED);
@ -1059,6 +1058,12 @@ thread_schedule_upcall(struct thread *td, struct kse *ke)
}
KASSERT((ke->ke_bound == NULL), ("kse already bound"));
if (ke->ke_state == KES_IDLE) {
kg = ke->ke_ksegrp;
TAILQ_REMOVE(&kg->kg_iq, ke, ke_kgrlist);
kg->kg_idle_kses--;
ke->ke_state = KES_UNQUEUED;
}
if ((td2 = td->td_standin) != NULL) {
td->td_standin = NULL;
} else {
@ -1115,6 +1120,7 @@ thread_schedule_upcall(struct thread *td, struct kse *ke)
} else {
ke->ke_bound = NULL;
ke->ke_thread = td2;
ke->ke_state = KES_THREAD;
setrunqueue(td2);
}
return (td2); /* bogus.. should be a void function */

10
sys/kern/kern_thread.c
View File

@ -369,8 +369,6 @@ kse_wakeup(struct thread *td, struct kse_wakeup_args *uap)
return ESRCH;
}
found:
TAILQ_REMOVE(&kg->kg_iq, ke, ke_kgrlist);
kg->kg_idle_kses--;
thread_schedule_upcall(td, ke);
mtx_unlock_spin(&sched_lock);
td->td_retval[0] = 0;
@ -1039,6 +1037,7 @@ struct thread *
thread_schedule_upcall(struct thread *td, struct kse *ke)
{
struct thread *td2;
struct ksegrp *kg;
int newkse;
mtx_assert(&sched_lock, MA_OWNED);
@ -1059,6 +1058,12 @@ thread_schedule_upcall(struct thread *td, struct kse *ke)
}
KASSERT((ke->ke_bound == NULL), ("kse already bound"));
if (ke->ke_state == KES_IDLE) {
kg = ke->ke_ksegrp;
TAILQ_REMOVE(&kg->kg_iq, ke, ke_kgrlist);
kg->kg_idle_kses--;
ke->ke_state = KES_UNQUEUED;
}
if ((td2 = td->td_standin) != NULL) {
td->td_standin = NULL;
} else {
@ -1115,6 +1120,7 @@ thread_schedule_upcall(struct thread *td, struct kse *ke)
} else {
ke->ke_bound = NULL;
ke->ke_thread = td2;
ke->ke_state = KES_THREAD;
setrunqueue(td2);
}
return (td2); /* bogus.. should be a void function */