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

Add thread_find() function to search a thread by lwpid.

Browse Source
This commit is contained in:
David Xu 2005-11-03 01:34:08 +00:00
parent 9af9b983e1
commit 44355392b4
3 changed files with 24 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
sys/kern/kern_thr.c
View File

@ -310,10 +310,7 @@ thr_kill(struct thread *td, struct thr_kill_args *uap)
p = td->td_proc;
error = 0;
PROC_LOCK(p);
FOREACH_THREAD_IN_PROC(p, ttd) {
if (ttd->td_tid == uap->id)
break;
}
ttd = thread_find(p, uap->id);
if (ttd == NULL) {
error = ESRCH;
goto out;
@ -324,7 +321,7 @@ thr_kill(struct thread *td, struct thr_kill_args *uap)
error = EINVAL;
goto out;
}
tdsignal(ttd, uap->sig, NULL, SIGTARGET_TD);
tdsignal(p, ttd, uap->sig, NULL);
out:
PROC_UNLOCK(p);
return (error);
@ -378,21 +375,20 @@ int
thr_wake(struct thread *td, struct thr_wake_args *uap)
/* long id */
{
struct proc *p;
struct thread *ttd;
PROC_LOCK(td->td_proc);
FOREACH_THREAD_IN_PROC(td->td_proc, ttd) {
if (ttd->td_tid == uap->id)
break;
}
p = td->td_proc;
PROC_LOCK(p);
ttd = thread_find(p, uap->id);
if (ttd == NULL) {
PROC_UNLOCK(td->td_proc);
PROC_UNLOCK(p);
return (ESRCH);
}
mtx_lock_spin(&sched_lock);
ttd->td_flags |= TDF_THRWAKEUP;
mtx_unlock_spin(&sched_lock);
wakeup((void *)ttd);
PROC_UNLOCK(td->td_proc);
PROC_UNLOCK(p);
return (0);
}

15
sys/kern/kern_thread.c
View File

@ -1022,3 +1022,18 @@ thread_sleep_check(struct thread *td)
}
return (0);
}
struct thread *
thread_find(struct proc *p, lwpid_t tid)
{
struct thread *td;
PROC_LOCK_ASSERT(p, MA_OWNED);
mtx_lock_spin(&sched_lock);
FOREACH_THREAD_IN_PROC(p, td) {
if (td->td_tid == tid)
break;
}
mtx_unlock_spin(&sched_lock);
return (td);
}

1
sys/sys/proc.h
View File

@ -941,6 +941,7 @@ void thread_unthread(struct thread *td);
int thread_userret(struct thread *td, struct trapframe *frame);
void thread_user_enter(struct thread *td);
void thread_wait(struct proc *p);
struct thread *thread_find(struct proc *p, lwpid_t tid);
void thr_exit1(void);
struct kse_upcall *upcall_alloc(void);
void upcall_free(struct kse_upcall *ku);