Aren
/
NetBSD
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

these days make sure we have an lwp lock (for lwp walker smiths)

This commit is contained in:
pooka 2011-01-28 17:57:03 +00:00
parent 840bf0206b
commit 0199e732f8
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sys/rump/librump/rumpkern/sleepq.c
View File

@ -1,4 +1,4 @@
/* $NetBSD: sleepq.c,v 1.12 2011/01/27 21:55:25 pooka Exp $ */
/* $NetBSD: sleepq.c,v 1.13 2011/01/28 17:57:03 pooka Exp $ */
/*
* Copyright (c) 2008 Antti Kantee. All Rights Reserved.
@ -26,7 +26,7 @@
*/
#include <sys/cdefs.h>
__KERNEL_RCSID(0, "$NetBSD: sleepq.c,v 1.12 2011/01/27 21:55:25 pooka Exp $");
__KERNEL_RCSID(0, "$NetBSD: sleepq.c,v 1.13 2011/01/28 17:57:03 pooka Exp $");
#include <sys/param.h>
#include <sys/condvar.h>
@ -87,14 +87,16 @@ sleepq_block(int timo, bool catch)
int biglocks = l->l_biglocks;
while (l->l_wchan) {
l->l_mutex = mp;
l->l_mutex = mp; /* keep sleepq lock until woken up */
error = cv_timedwait(&sq_cv, mp, timo);
if (error == EWOULDBLOCK || error == EINTR) {
if (l->l_wchan) {
TAILQ_REMOVE(l->l_sleepq, l, l_sleepchain);
l->l_wchan = NULL;
l->l_wmesg = NULL;
}
}
}
mutex_spin_exit(mp);
if (biglocks)
@ -118,7 +120,6 @@ sleepq_wake(sleepq_t *sq, wchan_t wchan, u_int expected, kmutex_t *mp)
found = true;
l->l_wchan = NULL;
l->l_wmesg = NULL;
l->l_mutex = NULL;
TAILQ_REMOVE(sq, l, l_sleepchain);
}
}
@ -135,7 +136,6 @@ sleepq_unsleep(struct lwp *l, bool cleanup)
l->l_wchan = NULL;
l->l_wmesg = NULL;
l->l_mutex = NULL;
TAILQ_REMOVE(l->l_sleepq, l, l_sleepchain);
cv_broadcast(&sq_cv);