diff options
author | raf <none@none> | 2008-01-23 12:00:31 -0800 |
---|---|---|
committer | raf <none@none> | 2008-01-23 12:00:31 -0800 |
commit | a574db851cdc636fc3939b68e80d79fe7fbd57f2 (patch) | |
tree | 7a28122042d1d24d9c4df92ba257e2d34d111e2e /usr/src/uts/common/os/semaphore.c | |
parent | 4a7ceb24cfcc0a97f96d86cfe5852ae445b50e57 (diff) | |
download | illumos-gate-a574db851cdc636fc3939b68e80d79fe7fbd57f2.tar.gz |
6598890 cancellation code abuses synonyms
--HG--
rename : usr/src/lib/libc/amd64/crt/cerror64.s => deleted_files/usr/src/lib/libc/amd64/crt/cerror64.s
rename : usr/src/lib/libc/port/gen/wait3.c => deleted_files/usr/src/lib/libc/port/gen/wait3.c
rename : usr/src/lib/libc/port/gen/wait4.c => deleted_files/usr/src/lib/libc/port/gen/wait4.c
rename : usr/src/lib/libc/port/sys/fsync.c => deleted_files/usr/src/lib/libc/port/sys/fsync.c
rename : usr/src/lib/libc/sparc/sys/syssun.s => deleted_files/usr/src/lib/libc/sparc/sys/syssun.s
rename : usr/src/lib/libc/common/sys/__fcntl.s => usr/src/lib/libc/common/sys/fcntl.s
rename : usr/src/lib/libc/common/sys/_rename.s => usr/src/lib/libc/common/sys/rename.s
rename : usr/src/lib/libc/port/gen/rename.c => usr/src/lib/libc/port/gen/remove.c
rename : usr/src/lib/libc/port/sys/fcntl.c => usr/src/lib/libc/port/sys/libc_fcntl.c
Diffstat (limited to 'usr/src/uts/common/os/semaphore.c')
-rw-r--r-- | usr/src/uts/common/os/semaphore.c | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/usr/src/uts/common/os/semaphore.c b/usr/src/uts/common/os/semaphore.c index 7f7e6235e3..ad25db33b3 100644 --- a/usr/src/uts/common/os/semaphore.c +++ b/usr/src/uts/common/os/semaphore.c @@ -18,8 +18,9 @@ * * CDDL HEADER END */ + /* - * Copyright 2007 Sun Microsystems, Inc. All rights reserved. + * Copyright 2008 Sun Microsystems, Inc. All rights reserved. * Use is subject to license terms. */ @@ -32,6 +33,7 @@ #include <sys/param.h> #include <sys/types.h> #include <sys/systm.h> +#include <sys/schedctl.h> #include <sys/semaphore.h> #include <sys/sema_impl.h> #include <sys/t_lock.h> @@ -253,6 +255,8 @@ sema_p_sig(ksema_t *sp) { kthread_t *t = curthread; klwp_t *lwp = ttolwp(t); + int cancel_pending; + int cancelled = 0; sema_impl_t *s; disp_lock_t *sqlp; @@ -261,6 +265,7 @@ sema_p_sig(ksema_t *sp) return (0); } + cancel_pending = schedctl_cancel_pending(); s = (sema_impl_t *)sp; sqlp = &SQHASH(s)->sq_lock; disp_lock_enter(sqlp); @@ -273,12 +278,12 @@ sema_p_sig(ksema_t *sp) lwp->lwp_asleep = 1; lwp->lwp_sysabort = 0; thread_unlock_nopreempt(t); - if (ISSIG(t, JUSTLOOKING) || MUSTRETURN(p, t)) + if (ISSIG(t, JUSTLOOKING) || MUSTRETURN(p, t) || cancel_pending) setrun(t); swtch(); t->t_flag &= ~T_WAKEABLE; - if (ISSIG(t, FORREAL) || - lwp->lwp_sysabort || MUSTRETURN(p, t)) { + if (ISSIG(t, FORREAL) || lwp->lwp_sysabort || + MUSTRETURN(p, t) || (cancelled = cancel_pending) != 0) { kthread_t *sq, *tp; lwp->lwp_asleep = 0; lwp->lwp_sysabort = 0; @@ -305,6 +310,8 @@ sema_p_sig(ksema_t *sp) } else { disp_lock_exit(sqlp); } + if (cancelled) + schedctl_cancel_eintr(); return (1); } lwp->lwp_asleep = 0; |