1 1.410 riastrad /* $NetBSD: kern_sig.c,v 1.410 2025/03/13 12:48:21 riastradh Exp $ */ 2 1.243 ad 3 1.243 ad /*- 4 1.406 ad * Copyright (c) 2006, 2007, 2008, 2019, 2023 The NetBSD Foundation, Inc. 5 1.243 ad * All rights reserved. 6 1.243 ad * 7 1.243 ad * This code is derived from software contributed to The NetBSD Foundation 8 1.243 ad * by Andrew Doran. 9 1.243 ad * 10 1.243 ad * Redistribution and use in source and binary forms, with or without 11 1.243 ad * modification, are permitted provided that the following conditions 12 1.243 ad * are met: 13 1.243 ad * 1. Redistributions of source code must retain the above copyright 14 1.243 ad * notice, this list of conditions and the following disclaimer. 15 1.243 ad * 2. Redistributions in binary form must reproduce the above copyright 16 1.243 ad * notice, this list of conditions and the following disclaimer in the 17 1.243 ad * documentation and/or other materials provided with the distribution. 18 1.243 ad * 19 1.243 ad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 20 1.243 ad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 21 1.243 ad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 22 1.243 ad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 23 1.243 ad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 24 1.243 ad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 25 1.243 ad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 26 1.243 ad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 27 1.243 ad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 28 1.243 ad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 29 1.243 ad * POSSIBILITY OF SUCH DAMAGE. 30 1.243 ad */ 31 1.29 cgd 32 1.29 cgd /* 33 1.29 cgd * Copyright (c) 1982, 1986, 1989, 1991, 1993 34 1.29 cgd * The Regents of the University of California. All rights reserved. 35 1.29 cgd * (c) UNIX System Laboratories, Inc. 36 1.29 cgd * All or some portions of this file are derived from material licensed 37 1.29 cgd * to the University of California by American Telephone and Telegraph 38 1.29 cgd * Co. or Unix System Laboratories, Inc. and are reproduced herein with 39 1.29 cgd * the permission of UNIX System Laboratories, Inc. 40 1.29 cgd * 41 1.29 cgd * Redistribution and use in source and binary forms, with or without 42 1.29 cgd * modification, are permitted provided that the following conditions 43 1.29 cgd * are met: 44 1.29 cgd * 1. Redistributions of source code must retain the above copyright 45 1.29 cgd * notice, this list of conditions and the following disclaimer. 46 1.29 cgd * 2. Redistributions in binary form must reproduce the above copyright 47 1.29 cgd * notice, this list of conditions and the following disclaimer in the 48 1.29 cgd * documentation and/or other materials provided with the distribution. 49 1.146 agc * 3. Neither the name of the University nor the names of its contributors 50 1.29 cgd * may be used to endorse or promote products derived from this software 51 1.29 cgd * without specific prior written permission. 52 1.29 cgd * 53 1.29 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 54 1.29 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 55 1.29 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 56 1.29 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 57 1.29 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 58 1.29 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 59 1.29 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 60 1.29 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 61 1.29 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 62 1.29 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 63 1.29 cgd * SUCH DAMAGE. 64 1.29 cgd * 65 1.71 fvdl * @(#)kern_sig.c 8.14 (Berkeley) 5/14/95 66 1.29 cgd */ 67 1.116 lukem 68 1.308 rmind /* 69 1.308 rmind * Signal subsystem. 70 1.308 rmind */ 71 1.308 rmind 72 1.116 lukem #include <sys/cdefs.h> 73 1.410 riastrad __KERNEL_RCSID(0, "$NetBSD: kern_sig.c,v 1.410 2025/03/13 12:48:21 riastradh Exp $"); 74 1.70 mrg 75 1.393 christos #include "opt_execfmt.h" 76 1.227 matt #include "opt_ptrace.h" 77 1.320 christos #include "opt_dtrace.h" 78 1.74 thorpej #include "opt_compat_sunos.h" 79 1.158 christos #include "opt_compat_netbsd.h" 80 1.202 perry #include "opt_compat_netbsd32.h" 81 1.240 elad #include "opt_pax.h" 82 1.29 cgd 83 1.29 cgd #define SIGPROP /* include signal properties table */ 84 1.29 cgd #include <sys/param.h> 85 1.29 cgd #include <sys/signalvar.h> 86 1.29 cgd #include <sys/proc.h> 87 1.334 christos #include <sys/ptrace.h> 88 1.29 cgd #include <sys/systm.h> 89 1.29 cgd #include <sys/wait.h> 90 1.29 cgd #include <sys/ktrace.h> 91 1.29 cgd #include <sys/syslog.h> 92 1.59 cgd #include <sys/filedesc.h> 93 1.243 ad #include <sys/file.h> 94 1.89 thorpej #include <sys/pool.h> 95 1.130 thorpej #include <sys/ucontext.h> 96 1.118 thorpej #include <sys/exec.h> 97 1.220 elad #include <sys/kauth.h> 98 1.243 ad #include <sys/acct.h> 99 1.243 ad #include <sys/callout.h> 100 1.260 ad #include <sys/atomic.h> 101 1.258 ad #include <sys/cpu.h> 102 1.290 ad #include <sys/module.h> 103 1.303 darran #include <sys/sdt.h> 104 1.391 christos #include <sys/exec_elf.h> 105 1.377 pgoyette #include <sys/compat_stub.h> 106 1.29 cgd 107 1.240 elad #ifdef PAX_SEGVGUARD 108 1.240 elad #include <sys/pax.h> 109 1.240 elad #endif /* PAX_SEGVGUARD */ 110 1.240 elad 111 1.307 uebayasi #include <uvm/uvm_extern.h> 112 1.69 mrg 113 1.397 simonb /* Many hard-coded assumptions that there are <= 4 x 32bit signal mask bits */ 114 1.397 simonb __CTASSERT(NSIG <= 128); 115 1.397 simonb 116 1.328 christos #define SIGQUEUE_MAX 32 117 1.308 rmind static pool_cache_t sigacts_cache __read_mostly; 118 1.308 rmind static pool_cache_t ksiginfo_cache __read_mostly; 119 1.308 rmind static callout_t proc_stop_ch __cacheline_aligned; 120 1.308 rmind 121 1.308 rmind sigset_t contsigmask __cacheline_aligned; 122 1.347 kamil sigset_t stopsigmask __cacheline_aligned; 123 1.345 kamil static sigset_t vforksigmask __cacheline_aligned; 124 1.308 rmind sigset_t sigcantmask __cacheline_aligned; 125 1.308 rmind 126 1.334 christos static void proc_stop(struct proc *, int); 127 1.342 kamil static void proc_stop_done(struct proc *, int); 128 1.243 ad static void proc_stop_callout(void *); 129 1.297 rmind static int sigchecktrace(void); 130 1.317 rmind static int sigpost(struct lwp *, sig_t, int, int); 131 1.328 christos static int sigput(sigpend_t *, struct proc *, ksiginfo_t *); 132 1.297 rmind static int sigunwait(struct proc *, const ksiginfo_t *); 133 1.369 kamil static void sigswitch(int, int, bool); 134 1.370 kamil static void sigswitch_unlock_and_switch_away(struct lwp *); 135 1.152 christos 136 1.243 ad static void sigacts_poolpage_free(struct pool *, void *); 137 1.243 ad static void *sigacts_poolpage_alloc(struct pool *, int); 138 1.196 skrll 139 1.303 darran /* 140 1.303 darran * DTrace SDT provider definitions 141 1.303 darran */ 142 1.320 christos SDT_PROVIDER_DECLARE(proc); 143 1.320 christos SDT_PROBE_DEFINE3(proc, kernel, , signal__send, 144 1.320 christos "struct lwp *", /* target thread */ 145 1.320 christos "struct proc *", /* target process */ 146 1.320 christos "int"); /* signal */ 147 1.320 christos SDT_PROBE_DEFINE3(proc, kernel, , signal__discard, 148 1.320 christos "struct lwp *", /* target thread */ 149 1.320 christos "struct proc *", /* target process */ 150 1.320 christos "int"); /* signal */ 151 1.320 christos SDT_PROBE_DEFINE3(proc, kernel, , signal__handle, 152 1.320 christos "int", /* signal */ 153 1.320 christos "ksiginfo_t *", /* signal info */ 154 1.320 christos "void (*)(void)"); /* handler address */ 155 1.303 darran 156 1.303 darran 157 1.196 skrll static struct pool_allocator sigactspool_allocator = { 158 1.301 rmind .pa_alloc = sigacts_poolpage_alloc, 159 1.301 rmind .pa_free = sigacts_poolpage_free 160 1.196 skrll }; 161 1.196 skrll 162 1.243 ad #ifdef DEBUG 163 1.243 ad int kern_logsigexit = 1; 164 1.243 ad #else 165 1.243 ad int kern_logsigexit = 0; 166 1.243 ad #endif 167 1.89 thorpej 168 1.301 rmind static const char logcoredump[] = 169 1.243 ad "pid %d (%s), uid %d: exited on signal %d (core dumped)\n"; 170 1.301 rmind static const char lognocoredump[] = 171 1.243 ad "pid %d (%s), uid %d: exited on signal %d (core not dumped, err = %d)\n"; 172 1.237 yamt 173 1.299 elad static kauth_listener_t signal_listener; 174 1.299 elad 175 1.299 elad static int 176 1.299 elad signal_listener_cb(kauth_cred_t cred, kauth_action_t action, void *cookie, 177 1.299 elad void *arg0, void *arg1, void *arg2, void *arg3) 178 1.299 elad { 179 1.299 elad struct proc *p; 180 1.299 elad int result, signum; 181 1.299 elad 182 1.299 elad result = KAUTH_RESULT_DEFER; 183 1.299 elad p = arg0; 184 1.299 elad signum = (int)(unsigned long)arg1; 185 1.299 elad 186 1.299 elad if (action != KAUTH_PROCESS_SIGNAL) 187 1.299 elad return result; 188 1.299 elad 189 1.299 elad if (kauth_cred_uidmatch(cred, p->p_cred) || 190 1.299 elad (signum == SIGCONT && (curproc->p_session == p->p_session))) 191 1.299 elad result = KAUTH_RESULT_ALLOW; 192 1.299 elad 193 1.299 elad return result; 194 1.299 elad } 195 1.299 elad 196 1.350 maxv static int 197 1.350 maxv sigacts_ctor(void *arg __unused, void *obj, int flags __unused) 198 1.350 maxv { 199 1.350 maxv memset(obj, 0, sizeof(struct sigacts)); 200 1.350 maxv return 0; 201 1.350 maxv } 202 1.350 maxv 203 1.29 cgd /* 204 1.243 ad * signal_init: 205 1.243 ad * 206 1.301 rmind * Initialize global signal-related data structures. 207 1.152 christos */ 208 1.243 ad void 209 1.243 ad signal_init(void) 210 1.152 christos { 211 1.152 christos 212 1.243 ad sigactspool_allocator.pa_pagesz = (PAGE_SIZE)*2; 213 1.152 christos 214 1.279 ad sigacts_cache = pool_cache_init(sizeof(struct sigacts), 0, 0, 0, 215 1.279 ad "sigacts", sizeof(struct sigacts) > PAGE_SIZE ? 216 1.350 maxv &sigactspool_allocator : NULL, IPL_NONE, sigacts_ctor, NULL, NULL); 217 1.286 ad ksiginfo_cache = pool_cache_init(sizeof(ksiginfo_t), 0, 0, 0, 218 1.286 ad "ksiginfo", NULL, IPL_VM, NULL, NULL, NULL); 219 1.286 ad 220 1.265 ad callout_init(&proc_stop_ch, CALLOUT_MPSAFE); 221 1.243 ad callout_setfunc(&proc_stop_ch, proc_stop_callout, NULL); 222 1.299 elad 223 1.299 elad signal_listener = kauth_listen_scope(KAUTH_SCOPE_PROCESS, 224 1.299 elad signal_listener_cb, NULL); 225 1.152 christos } 226 1.152 christos 227 1.152 christos /* 228 1.243 ad * sigacts_poolpage_alloc: 229 1.243 ad * 230 1.301 rmind * Allocate a page for the sigacts memory pool. 231 1.152 christos */ 232 1.243 ad static void * 233 1.243 ad sigacts_poolpage_alloc(struct pool *pp, int flags) 234 1.152 christos { 235 1.152 christos 236 1.243 ad return (void *)uvm_km_alloc(kernel_map, 237 1.301 rmind PAGE_SIZE * 2, PAGE_SIZE * 2, 238 1.243 ad ((flags & PR_WAITOK) ? 0 : UVM_KMF_NOWAIT | UVM_KMF_TRYLOCK) 239 1.243 ad | UVM_KMF_WIRED); 240 1.152 christos } 241 1.152 christos 242 1.152 christos /* 243 1.243 ad * sigacts_poolpage_free: 244 1.243 ad * 245 1.301 rmind * Free a page on behalf of the sigacts memory pool. 246 1.89 thorpej */ 247 1.243 ad static void 248 1.243 ad sigacts_poolpage_free(struct pool *pp, void *v) 249 1.89 thorpej { 250 1.279 ad 251 1.301 rmind uvm_km_free(kernel_map, (vaddr_t)v, PAGE_SIZE * 2, UVM_KMF_WIRED); 252 1.89 thorpej } 253 1.89 thorpej 254 1.89 thorpej /* 255 1.243 ad * sigactsinit: 256 1.301 rmind * 257 1.301 rmind * Create an initial sigacts structure, using the same signal state 258 1.301 rmind * as of specified process. If 'share' is set, share the sigacts by 259 1.301 rmind * holding a reference, otherwise just copy it from parent. 260 1.89 thorpej */ 261 1.243 ad struct sigacts * 262 1.243 ad sigactsinit(struct proc *pp, int share) 263 1.89 thorpej { 264 1.302 rmind struct sigacts *ps = pp->p_sigacts, *ps2; 265 1.89 thorpej 266 1.302 rmind if (__predict_false(share)) { 267 1.279 ad atomic_inc_uint(&ps->sa_refcnt); 268 1.302 rmind return ps; 269 1.109 jdolecek } 270 1.302 rmind ps2 = pool_cache_get(sigacts_cache, PR_WAITOK); 271 1.302 rmind mutex_init(&ps2->sa_mutex, MUTEX_DEFAULT, IPL_SCHED); 272 1.302 rmind ps2->sa_refcnt = 1; 273 1.243 ad 274 1.302 rmind mutex_enter(&ps->sa_mutex); 275 1.302 rmind memcpy(ps2->sa_sigdesc, ps->sa_sigdesc, sizeof(ps2->sa_sigdesc)); 276 1.302 rmind mutex_exit(&ps->sa_mutex); 277 1.259 ad return ps2; 278 1.89 thorpej } 279 1.89 thorpej 280 1.89 thorpej /* 281 1.243 ad * sigactsunshare: 282 1.301 rmind * 283 1.301 rmind * Make this process not share its sigacts, maintaining all signal state. 284 1.89 thorpej */ 285 1.89 thorpej void 286 1.112 lukem sigactsunshare(struct proc *p) 287 1.89 thorpej { 288 1.302 rmind struct sigacts *ps, *oldps = p->p_sigacts; 289 1.243 ad 290 1.302 rmind if (__predict_true(oldps->sa_refcnt == 1)) 291 1.89 thorpej return; 292 1.302 rmind 293 1.279 ad ps = pool_cache_get(sigacts_cache, PR_WAITOK); 294 1.262 ad mutex_init(&ps->sa_mutex, MUTEX_DEFAULT, IPL_SCHED); 295 1.316 reinoud memcpy(ps->sa_sigdesc, oldps->sa_sigdesc, sizeof(ps->sa_sigdesc)); 296 1.302 rmind ps->sa_refcnt = 1; 297 1.302 rmind 298 1.243 ad p->p_sigacts = ps; 299 1.243 ad sigactsfree(oldps); 300 1.89 thorpej } 301 1.89 thorpej 302 1.89 thorpej /* 303 1.243 ad * sigactsfree; 304 1.243 ad * 305 1.301 rmind * Release a sigacts structure. 306 1.89 thorpej */ 307 1.89 thorpej void 308 1.195 pk sigactsfree(struct sigacts *ps) 309 1.89 thorpej { 310 1.89 thorpej 311 1.404 riastrad membar_release(); 312 1.279 ad if (atomic_dec_uint_nv(&ps->sa_refcnt) == 0) { 313 1.404 riastrad membar_acquire(); 314 1.243 ad mutex_destroy(&ps->sa_mutex); 315 1.279 ad pool_cache_put(sigacts_cache, ps); 316 1.29 cgd } 317 1.29 cgd } 318 1.29 cgd 319 1.29 cgd /* 320 1.243 ad * siginit: 321 1.243 ad * 322 1.243 ad * Initialize signal state for process 0; set to ignore signals that 323 1.243 ad * are ignored by default and disable the signal stack. Locking not 324 1.243 ad * required as the system is still cold. 325 1.29 cgd */ 326 1.29 cgd void 327 1.112 lukem siginit(struct proc *p) 328 1.29 cgd { 329 1.243 ad struct lwp *l; 330 1.243 ad struct sigacts *ps; 331 1.243 ad int signo, prop; 332 1.79 mycroft 333 1.112 lukem ps = p->p_sigacts; 334 1.79 mycroft sigemptyset(&contsigmask); 335 1.79 mycroft sigemptyset(&stopsigmask); 336 1.345 kamil sigemptyset(&vforksigmask); 337 1.79 mycroft sigemptyset(&sigcantmask); 338 1.243 ad for (signo = 1; signo < NSIG; signo++) { 339 1.243 ad prop = sigprop[signo]; 340 1.79 mycroft if (prop & SA_CONT) 341 1.243 ad sigaddset(&contsigmask, signo); 342 1.79 mycroft if (prop & SA_STOP) 343 1.243 ad sigaddset(&stopsigmask, signo); 344 1.345 kamil if (prop & SA_STOP && signo != SIGSTOP) 345 1.345 kamil sigaddset(&vforksigmask, signo); 346 1.79 mycroft if (prop & SA_CANTMASK) 347 1.243 ad sigaddset(&sigcantmask, signo); 348 1.243 ad if (prop & SA_IGNORE && signo != SIGCONT) 349 1.243 ad sigaddset(&p->p_sigctx.ps_sigignore, signo); 350 1.243 ad sigemptyset(&SIGACTION_PS(ps, signo).sa_mask); 351 1.243 ad SIGACTION_PS(ps, signo).sa_flags = SA_RESTART; 352 1.79 mycroft } 353 1.109 jdolecek sigemptyset(&p->p_sigctx.ps_sigcatch); 354 1.243 ad p->p_sflag &= ~PS_NOCLDSTOP; 355 1.243 ad 356 1.243 ad ksiginfo_queue_init(&p->p_sigpend.sp_info); 357 1.243 ad sigemptyset(&p->p_sigpend.sp_set); 358 1.29 cgd 359 1.79 mycroft /* 360 1.243 ad * Reset per LWP state. 361 1.79 mycroft */ 362 1.243 ad l = LIST_FIRST(&p->p_lwps); 363 1.243 ad l->l_sigwaited = NULL; 364 1.336 christos l->l_sigstk = SS_INIT; 365 1.243 ad ksiginfo_queue_init(&l->l_sigpend.sp_info); 366 1.243 ad sigemptyset(&l->l_sigpend.sp_set); 367 1.89 thorpej 368 1.89 thorpej /* One reference. */ 369 1.109 jdolecek ps->sa_refcnt = 1; 370 1.29 cgd } 371 1.29 cgd 372 1.29 cgd /* 373 1.243 ad * execsigs: 374 1.243 ad * 375 1.243 ad * Reset signals for an exec of the specified process. 376 1.29 cgd */ 377 1.29 cgd void 378 1.112 lukem execsigs(struct proc *p) 379 1.29 cgd { 380 1.243 ad struct sigacts *ps; 381 1.243 ad struct lwp *l; 382 1.243 ad int signo, prop; 383 1.243 ad sigset_t tset; 384 1.243 ad ksiginfoq_t kq; 385 1.243 ad 386 1.243 ad KASSERT(p->p_nlwps == 1); 387 1.243 ad 388 1.115 thorpej sigactsunshare(p); 389 1.112 lukem ps = p->p_sigacts; 390 1.115 thorpej 391 1.29 cgd /* 392 1.243 ad * Reset caught signals. Held signals remain held through 393 1.243 ad * l->l_sigmask (unless they were caught, and are now ignored 394 1.243 ad * by default). 395 1.259 ad * 396 1.259 ad * No need to lock yet, the process has only one LWP and 397 1.259 ad * at this point the sigacts are private to the process. 398 1.243 ad */ 399 1.243 ad sigemptyset(&tset); 400 1.243 ad for (signo = 1; signo < NSIG; signo++) { 401 1.243 ad if (sigismember(&p->p_sigctx.ps_sigcatch, signo)) { 402 1.243 ad prop = sigprop[signo]; 403 1.79 mycroft if (prop & SA_IGNORE) { 404 1.79 mycroft if ((prop & SA_CONT) == 0) 405 1.112 lukem sigaddset(&p->p_sigctx.ps_sigignore, 406 1.243 ad signo); 407 1.243 ad sigaddset(&tset, signo); 408 1.79 mycroft } 409 1.243 ad SIGACTION_PS(ps, signo).sa_handler = SIG_DFL; 410 1.29 cgd } 411 1.243 ad sigemptyset(&SIGACTION_PS(ps, signo).sa_mask); 412 1.243 ad SIGACTION_PS(ps, signo).sa_flags = SA_RESTART; 413 1.29 cgd } 414 1.243 ad ksiginfo_queue_init(&kq); 415 1.259 ad 416 1.277 ad mutex_enter(p->p_lock); 417 1.243 ad sigclearall(p, &tset, &kq); 418 1.109 jdolecek sigemptyset(&p->p_sigctx.ps_sigcatch); 419 1.205 christos 420 1.205 christos /* 421 1.205 christos * Reset no zombies if child dies flag as Solaris does. 422 1.205 christos */ 423 1.246 pavel p->p_flag &= ~(PK_NOCLDWAIT | PK_CLDSIGIGN); 424 1.205 christos if (SIGACTION_PS(ps, SIGCHLD).sa_handler == SIG_IGN) 425 1.205 christos SIGACTION_PS(ps, SIGCHLD).sa_handler = SIG_DFL; 426 1.79 mycroft 427 1.29 cgd /* 428 1.243 ad * Reset per-LWP state. 429 1.29 cgd */ 430 1.243 ad l = LIST_FIRST(&p->p_lwps); 431 1.243 ad l->l_sigwaited = NULL; 432 1.336 christos l->l_sigstk = SS_INIT; 433 1.243 ad ksiginfo_queue_init(&l->l_sigpend.sp_info); 434 1.243 ad sigemptyset(&l->l_sigpend.sp_set); 435 1.277 ad mutex_exit(p->p_lock); 436 1.243 ad 437 1.243 ad ksiginfo_queue_drain(&kq); 438 1.29 cgd } 439 1.29 cgd 440 1.243 ad /* 441 1.243 ad * ksiginfo_alloc: 442 1.243 ad * 443 1.243 ad * Allocate a new ksiginfo structure from the pool, and optionally copy 444 1.243 ad * an existing one. If the existing ksiginfo_t is from the pool, and 445 1.243 ad * has not been queued somewhere, then just return it. Additionally, 446 1.243 ad * if the existing ksiginfo_t does not contain any information beyond 447 1.243 ad * the signal number, then just return it. 448 1.29 cgd */ 449 1.243 ad ksiginfo_t * 450 1.243 ad ksiginfo_alloc(struct proc *p, ksiginfo_t *ok, int flags) 451 1.48 thorpej { 452 1.243 ad ksiginfo_t *kp; 453 1.29 cgd 454 1.243 ad if (ok != NULL) { 455 1.243 ad if ((ok->ksi_flags & (KSI_QUEUED | KSI_FROMPOOL)) == 456 1.243 ad KSI_FROMPOOL) 457 1.301 rmind return ok; 458 1.243 ad if (KSI_EMPTY_P(ok)) 459 1.243 ad return ok; 460 1.79 mycroft } 461 1.243 ad 462 1.286 ad kp = pool_cache_get(ksiginfo_cache, flags); 463 1.243 ad if (kp == NULL) { 464 1.243 ad #ifdef DIAGNOSTIC 465 1.243 ad printf("Out of memory allocating ksiginfo for pid %d\n", 466 1.243 ad p->p_pid); 467 1.243 ad #endif 468 1.243 ad return NULL; 469 1.79 mycroft } 470 1.243 ad 471 1.243 ad if (ok != NULL) { 472 1.243 ad memcpy(kp, ok, sizeof(*kp)); 473 1.243 ad kp->ksi_flags &= ~KSI_QUEUED; 474 1.243 ad } else 475 1.243 ad KSI_INIT_EMPTY(kp); 476 1.243 ad 477 1.243 ad kp->ksi_flags |= KSI_FROMPOOL; 478 1.243 ad 479 1.243 ad return kp; 480 1.79 mycroft } 481 1.79 mycroft 482 1.243 ad /* 483 1.243 ad * ksiginfo_free: 484 1.243 ad * 485 1.243 ad * If the given ksiginfo_t is from the pool and has not been queued, 486 1.243 ad * then free it. 487 1.243 ad */ 488 1.79 mycroft void 489 1.243 ad ksiginfo_free(ksiginfo_t *kp) 490 1.79 mycroft { 491 1.29 cgd 492 1.243 ad if ((kp->ksi_flags & (KSI_QUEUED | KSI_FROMPOOL)) != KSI_FROMPOOL) 493 1.243 ad return; 494 1.286 ad pool_cache_put(ksiginfo_cache, kp); 495 1.29 cgd } 496 1.29 cgd 497 1.243 ad /* 498 1.243 ad * ksiginfo_queue_drain: 499 1.243 ad * 500 1.243 ad * Drain a non-empty ksiginfo_t queue. 501 1.243 ad */ 502 1.243 ad void 503 1.243 ad ksiginfo_queue_drain0(ksiginfoq_t *kq) 504 1.29 cgd { 505 1.243 ad ksiginfo_t *ksi; 506 1.79 mycroft 507 1.319 christos KASSERT(!TAILQ_EMPTY(kq)); 508 1.243 ad 509 1.319 christos while (!TAILQ_EMPTY(kq)) { 510 1.319 christos ksi = TAILQ_FIRST(kq); 511 1.319 christos TAILQ_REMOVE(kq, ksi, ksi_list); 512 1.286 ad pool_cache_put(ksiginfo_cache, ksi); 513 1.243 ad } 514 1.79 mycroft } 515 1.79 mycroft 516 1.328 christos static int 517 1.314 christos siggetinfo(sigpend_t *sp, ksiginfo_t *out, int signo) 518 1.314 christos { 519 1.329 hannken ksiginfo_t *ksi, *nksi; 520 1.314 christos 521 1.314 christos if (sp == NULL) 522 1.314 christos goto out; 523 1.314 christos 524 1.314 christos /* Find siginfo and copy it out. */ 525 1.328 christos int count = 0; 526 1.329 hannken TAILQ_FOREACH_SAFE(ksi, &sp->sp_info, ksi_list, nksi) { 527 1.314 christos if (ksi->ksi_signo != signo) 528 1.314 christos continue; 529 1.328 christos if (count++ > 0) /* Only remove the first, count all of them */ 530 1.396 skrll continue; 531 1.319 christos TAILQ_REMOVE(&sp->sp_info, ksi, ksi_list); 532 1.314 christos KASSERT((ksi->ksi_flags & KSI_FROMPOOL) != 0); 533 1.314 christos KASSERT((ksi->ksi_flags & KSI_QUEUED) != 0); 534 1.314 christos ksi->ksi_flags &= ~KSI_QUEUED; 535 1.314 christos if (out != NULL) { 536 1.314 christos memcpy(out, ksi, sizeof(*out)); 537 1.314 christos out->ksi_flags &= ~(KSI_FROMPOOL | KSI_QUEUED); 538 1.314 christos } 539 1.328 christos ksiginfo_free(ksi); 540 1.314 christos } 541 1.328 christos if (count) 542 1.328 christos return count; 543 1.314 christos 544 1.314 christos out: 545 1.314 christos /* If there is no siginfo, then manufacture it. */ 546 1.314 christos if (out != NULL) { 547 1.314 christos KSI_INIT(out); 548 1.314 christos out->ksi_info._signo = signo; 549 1.314 christos out->ksi_info._code = SI_NOINFO; 550 1.314 christos } 551 1.328 christos return 0; 552 1.314 christos } 553 1.314 christos 554 1.243 ad /* 555 1.243 ad * sigget: 556 1.243 ad * 557 1.243 ad * Fetch the first pending signal from a set. Optionally, also fetch 558 1.243 ad * or manufacture a ksiginfo element. Returns the number of the first 559 1.243 ad * pending signal, or zero. 560 1.396 skrll */ 561 1.243 ad int 562 1.270 yamt sigget(sigpend_t *sp, ksiginfo_t *out, int signo, const sigset_t *mask) 563 1.243 ad { 564 1.243 ad sigset_t tset; 565 1.328 christos int count; 566 1.243 ad 567 1.243 ad /* If there's no pending set, the signal is from the debugger. */ 568 1.287 christos if (sp == NULL) 569 1.287 christos goto out; 570 1.243 ad 571 1.243 ad /* Construct mask from signo, and 'mask'. */ 572 1.243 ad if (signo == 0) { 573 1.243 ad if (mask != NULL) { 574 1.243 ad tset = *mask; 575 1.243 ad __sigandset(&sp->sp_set, &tset); 576 1.243 ad } else 577 1.243 ad tset = sp->sp_set; 578 1.301 rmind 579 1.301 rmind /* If there are no signals pending - return. */ 580 1.243 ad if ((signo = firstsig(&tset)) == 0) 581 1.287 christos goto out; 582 1.243 ad } else { 583 1.243 ad KASSERT(sigismember(&sp->sp_set, signo)); 584 1.243 ad } 585 1.243 ad 586 1.243 ad sigdelset(&sp->sp_set, signo); 587 1.287 christos out: 588 1.328 christos count = siggetinfo(sp, out, signo); 589 1.328 christos if (count > 1) 590 1.328 christos sigaddset(&sp->sp_set, signo); 591 1.243 ad return signo; 592 1.29 cgd } 593 1.29 cgd 594 1.29 cgd /* 595 1.243 ad * sigput: 596 1.301 rmind * 597 1.296 drochner * Append a new ksiginfo element to the list of pending ksiginfo's. 598 1.29 cgd */ 599 1.328 christos static int 600 1.243 ad sigput(sigpend_t *sp, struct proc *p, ksiginfo_t *ksi) 601 1.48 thorpej { 602 1.243 ad ksiginfo_t *kp; 603 1.243 ad 604 1.277 ad KASSERT(mutex_owned(p->p_lock)); 605 1.243 ad KASSERT((ksi->ksi_flags & KSI_QUEUED) == 0); 606 1.243 ad 607 1.243 ad sigaddset(&sp->sp_set, ksi->ksi_signo); 608 1.243 ad 609 1.243 ad /* 610 1.296 drochner * If there is no siginfo, we are done. 611 1.243 ad */ 612 1.296 drochner if (KSI_EMPTY_P(ksi)) 613 1.328 christos return 0; 614 1.243 ad 615 1.243 ad KASSERT((ksi->ksi_flags & KSI_FROMPOOL) != 0); 616 1.79 mycroft 617 1.328 christos size_t count = 0; 618 1.328 christos TAILQ_FOREACH(kp, &sp->sp_info, ksi_list) { 619 1.328 christos count++; 620 1.328 christos if (ksi->ksi_signo >= SIGRTMIN && ksi->ksi_signo <= SIGRTMAX) 621 1.328 christos continue; 622 1.328 christos if (kp->ksi_signo == ksi->ksi_signo) { 623 1.328 christos KSI_COPY(ksi, kp); 624 1.328 christos kp->ksi_flags |= KSI_QUEUED; 625 1.328 christos return 0; 626 1.328 christos } 627 1.328 christos } 628 1.396 skrll 629 1.328 christos if (count >= SIGQUEUE_MAX) { 630 1.328 christos #ifdef DIAGNOSTIC 631 1.328 christos printf("%s(%d): Signal queue is full signal=%d\n", 632 1.328 christos p->p_comm, p->p_pid, ksi->ksi_signo); 633 1.243 ad #endif 634 1.328 christos return EAGAIN; 635 1.79 mycroft } 636 1.243 ad ksi->ksi_flags |= KSI_QUEUED; 637 1.319 christos TAILQ_INSERT_TAIL(&sp->sp_info, ksi, ksi_list); 638 1.396 skrll 639 1.328 christos return 0; 640 1.79 mycroft } 641 1.79 mycroft 642 1.243 ad /* 643 1.243 ad * sigclear: 644 1.243 ad * 645 1.243 ad * Clear all pending signals in the specified set. 646 1.243 ad */ 647 1.243 ad void 648 1.270 yamt sigclear(sigpend_t *sp, const sigset_t *mask, ksiginfoq_t *kq) 649 1.79 mycroft { 650 1.243 ad ksiginfo_t *ksi, *next; 651 1.112 lukem 652 1.243 ad if (mask == NULL) 653 1.243 ad sigemptyset(&sp->sp_set); 654 1.243 ad else 655 1.243 ad sigminusset(mask, &sp->sp_set); 656 1.79 mycroft 657 1.319 christos TAILQ_FOREACH_SAFE(ksi, &sp->sp_info, ksi_list, next) { 658 1.243 ad if (mask == NULL || sigismember(mask, ksi->ksi_signo)) { 659 1.319 christos TAILQ_REMOVE(&sp->sp_info, ksi, ksi_list); 660 1.243 ad KASSERT((ksi->ksi_flags & KSI_FROMPOOL) != 0); 661 1.243 ad KASSERT((ksi->ksi_flags & KSI_QUEUED) != 0); 662 1.319 christos TAILQ_INSERT_TAIL(kq, ksi, ksi_list); 663 1.79 mycroft } 664 1.79 mycroft } 665 1.243 ad } 666 1.243 ad 667 1.243 ad /* 668 1.243 ad * sigclearall: 669 1.243 ad * 670 1.243 ad * Clear all pending signals in the specified set from a process and 671 1.243 ad * its LWPs. 672 1.243 ad */ 673 1.243 ad void 674 1.270 yamt sigclearall(struct proc *p, const sigset_t *mask, ksiginfoq_t *kq) 675 1.243 ad { 676 1.243 ad struct lwp *l; 677 1.243 ad 678 1.277 ad KASSERT(mutex_owned(p->p_lock)); 679 1.79 mycroft 680 1.243 ad sigclear(&p->p_sigpend, mask, kq); 681 1.243 ad 682 1.243 ad LIST_FOREACH(l, &p->p_lwps, l_sibling) { 683 1.243 ad sigclear(&l->l_sigpend, mask, kq); 684 1.243 ad } 685 1.29 cgd } 686 1.29 cgd 687 1.243 ad /* 688 1.243 ad * sigispending: 689 1.243 ad * 690 1.311 christos * Return the first signal number if there are pending signals for the 691 1.311 christos * current LWP. May be called unlocked provided that LW_PENDSIG is set, 692 1.311 christos * and that the signal has been posted to the appopriate queue before 693 1.311 christos * LW_PENDSIG is set. 694 1.380 ad * 695 1.380 ad * This should only ever be called with (l == curlwp), unless the 696 1.380 ad * result does not matter (procfs, sysctl). 697 1.396 skrll */ 698 1.52 christos int 699 1.243 ad sigispending(struct lwp *l, int signo) 700 1.48 thorpej { 701 1.243 ad struct proc *p = l->l_proc; 702 1.243 ad sigset_t tset; 703 1.243 ad 704 1.260 ad membar_consumer(); 705 1.243 ad 706 1.243 ad tset = l->l_sigpend.sp_set; 707 1.243 ad sigplusset(&p->p_sigpend.sp_set, &tset); 708 1.243 ad sigminusset(&p->p_sigctx.ps_sigignore, &tset); 709 1.243 ad sigminusset(&l->l_sigmask, &tset); 710 1.243 ad 711 1.243 ad if (signo == 0) { 712 1.312 rmind return firstsig(&tset); 713 1.312 rmind } 714 1.312 rmind return sigismember(&tset, signo) ? signo : 0; 715 1.243 ad } 716 1.243 ad 717 1.243 ad void 718 1.243 ad getucontext(struct lwp *l, ucontext_t *ucp) 719 1.243 ad { 720 1.243 ad struct proc *p = l->l_proc; 721 1.243 ad 722 1.277 ad KASSERT(mutex_owned(p->p_lock)); 723 1.243 ad 724 1.243 ad ucp->uc_flags = 0; 725 1.243 ad ucp->uc_link = l->l_ctxlink; 726 1.317 rmind ucp->uc_sigmask = l->l_sigmask; 727 1.243 ad ucp->uc_flags |= _UC_SIGMASK; 728 1.243 ad 729 1.243 ad /* 730 1.243 ad * The (unsupplied) definition of the `current execution stack' 731 1.243 ad * in the System V Interface Definition appears to allow returning 732 1.243 ad * the main context stack. 733 1.243 ad */ 734 1.243 ad if ((l->l_sigstk.ss_flags & SS_ONSTACK) == 0) { 735 1.263 christos ucp->uc_stack.ss_sp = (void *)l->l_proc->p_stackbase; 736 1.243 ad ucp->uc_stack.ss_size = ctob(l->l_proc->p_vmspace->vm_ssize); 737 1.243 ad ucp->uc_stack.ss_flags = 0; /* XXX, def. is Very Fishy */ 738 1.243 ad } else { 739 1.243 ad /* Simply copy alternate signal execution stack. */ 740 1.243 ad ucp->uc_stack = l->l_sigstk; 741 1.79 mycroft } 742 1.243 ad ucp->uc_flags |= _UC_STACK; 743 1.277 ad mutex_exit(p->p_lock); 744 1.243 ad cpu_getmcontext(l, &ucp->uc_mcontext, &ucp->uc_flags); 745 1.277 ad mutex_enter(p->p_lock); 746 1.29 cgd } 747 1.29 cgd 748 1.29 cgd int 749 1.243 ad setucontext(struct lwp *l, const ucontext_t *ucp) 750 1.48 thorpej { 751 1.243 ad struct proc *p = l->l_proc; 752 1.223 yamt int error; 753 1.29 cgd 754 1.277 ad KASSERT(mutex_owned(p->p_lock)); 755 1.243 ad 756 1.243 ad if ((ucp->uc_flags & _UC_SIGMASK) != 0) { 757 1.243 ad error = sigprocmask1(l, SIG_SETMASK, &ucp->uc_sigmask, NULL); 758 1.243 ad if (error != 0) 759 1.223 yamt return error; 760 1.29 cgd } 761 1.243 ad 762 1.277 ad mutex_exit(p->p_lock); 763 1.243 ad error = cpu_setmcontext(l, &ucp->uc_mcontext, ucp->uc_flags); 764 1.277 ad mutex_enter(p->p_lock); 765 1.243 ad if (error != 0) 766 1.243 ad return (error); 767 1.243 ad 768 1.243 ad l->l_ctxlink = ucp->uc_link; 769 1.243 ad 770 1.243 ad /* 771 1.243 ad * If there was stack information, update whether or not we are 772 1.243 ad * still running on an alternate signal stack. 773 1.243 ad */ 774 1.243 ad if ((ucp->uc_flags & _UC_STACK) != 0) { 775 1.243 ad if (ucp->uc_stack.ss_flags & SS_ONSTACK) 776 1.243 ad l->l_sigstk.ss_flags |= SS_ONSTACK; 777 1.243 ad else 778 1.243 ad l->l_sigstk.ss_flags &= ~SS_ONSTACK; 779 1.243 ad } 780 1.243 ad 781 1.243 ad return 0; 782 1.29 cgd } 783 1.29 cgd 784 1.29 cgd /* 785 1.301 rmind * killpg1: common code for kill process group/broadcast kill. 786 1.29 cgd */ 787 1.52 christos int 788 1.224 ad killpg1(struct lwp *l, ksiginfo_t *ksi, int pgid, int all) 789 1.29 cgd { 790 1.224 ad struct proc *p, *cp; 791 1.220 elad kauth_cred_t pc; 792 1.112 lukem struct pgrp *pgrp; 793 1.112 lukem int nfound; 794 1.243 ad int signo = ksi->ksi_signo; 795 1.202 perry 796 1.224 ad cp = l->l_proc; 797 1.224 ad pc = l->l_cred; 798 1.112 lukem nfound = 0; 799 1.243 ad 800 1.390 ad mutex_enter(&proc_lock); 801 1.91 thorpej if (all) { 802 1.202 perry /* 803 1.301 rmind * Broadcast. 804 1.29 cgd */ 805 1.199 yamt PROCLIST_FOREACH(p, &allproc) { 806 1.283 ad if (p->p_pid <= 1 || p == cp || 807 1.304 yamt (p->p_flag & PK_SYSTEM) != 0) 808 1.29 cgd continue; 809 1.277 ad mutex_enter(p->p_lock); 810 1.243 ad if (kauth_authorize_process(pc, 811 1.264 elad KAUTH_PROCESS_SIGNAL, p, KAUTH_ARG(signo), NULL, 812 1.264 elad NULL) == 0) { 813 1.243 ad nfound++; 814 1.277 ad if (signo) 815 1.243 ad kpsignal2(p, ksi); 816 1.243 ad } 817 1.277 ad mutex_exit(p->p_lock); 818 1.29 cgd } 819 1.91 thorpej } else { 820 1.202 perry if (pgid == 0) 821 1.301 rmind /* Zero pgid means send to my process group. */ 822 1.29 cgd pgrp = cp->p_pgrp; 823 1.29 cgd else { 824 1.306 rmind pgrp = pgrp_find(pgid); 825 1.29 cgd if (pgrp == NULL) 826 1.243 ad goto out; 827 1.29 cgd } 828 1.124 matt LIST_FOREACH(p, &pgrp->pg_members, p_pglist) { 829 1.246 pavel if (p->p_pid <= 1 || p->p_flag & PK_SYSTEM) 830 1.29 cgd continue; 831 1.277 ad mutex_enter(p->p_lock); 832 1.264 elad if (kauth_authorize_process(pc, KAUTH_PROCESS_SIGNAL, 833 1.264 elad p, KAUTH_ARG(signo), NULL, NULL) == 0) { 834 1.243 ad nfound++; 835 1.277 ad if (signo && P_ZOMBIE(p) == 0) 836 1.277 ad kpsignal2(p, ksi); 837 1.243 ad } 838 1.277 ad mutex_exit(p->p_lock); 839 1.29 cgd } 840 1.29 cgd } 841 1.301 rmind out: 842 1.390 ad mutex_exit(&proc_lock); 843 1.301 rmind return nfound ? 0 : ESRCH; 844 1.29 cgd } 845 1.29 cgd 846 1.29 cgd /* 847 1.301 rmind * Send a signal to a process group. If checktty is set, limit to members 848 1.243 ad * which have a controlling terminal. 849 1.29 cgd */ 850 1.29 cgd void 851 1.243 ad pgsignal(struct pgrp *pgrp, int sig, int checkctty) 852 1.29 cgd { 853 1.148 christos ksiginfo_t ksi; 854 1.148 christos 855 1.276 ad KASSERT(!cpu_intr_p()); 856 1.390 ad KASSERT(mutex_owned(&proc_lock)); 857 1.29 cgd 858 1.192 matt KSI_INIT_EMPTY(&ksi); 859 1.148 christos ksi.ksi_signo = sig; 860 1.148 christos kpgsignal(pgrp, &ksi, NULL, checkctty); 861 1.148 christos } 862 1.148 christos 863 1.148 christos void 864 1.148 christos kpgsignal(struct pgrp *pgrp, ksiginfo_t *ksi, void *data, int checkctty) 865 1.29 cgd { 866 1.98 augustss struct proc *p; 867 1.29 cgd 868 1.276 ad KASSERT(!cpu_intr_p()); 869 1.390 ad KASSERT(mutex_owned(&proc_lock)); 870 1.301 rmind KASSERT(pgrp != NULL); 871 1.243 ad 872 1.297 rmind LIST_FOREACH(p, &pgrp->pg_members, p_pglist) 873 1.297 rmind if (checkctty == 0 || p->p_lflag & PL_CONTROLT) 874 1.297 rmind kpsignal(p, ksi, data); 875 1.29 cgd } 876 1.29 cgd 877 1.29 cgd /* 878 1.243 ad * Send a signal caused by a trap to the current LWP. If it will be caught 879 1.243 ad * immediately, deliver it with correct code. Otherwise, post it normally. 880 1.29 cgd */ 881 1.148 christos void 882 1.243 ad trapsignal(struct lwp *l, ksiginfo_t *ksi) 883 1.148 christos { 884 1.130 thorpej struct proc *p; 885 1.130 thorpej struct sigacts *ps; 886 1.243 ad int signo = ksi->ksi_signo; 887 1.288 wrstuden sigset_t *mask; 888 1.357 kamil sig_t action; 889 1.29 cgd 890 1.166 thorpej KASSERT(KSI_TRAP_P(ksi)); 891 1.166 thorpej 892 1.243 ad ksi->ksi_lid = l->l_lid; 893 1.130 thorpej p = l->l_proc; 894 1.243 ad 895 1.276 ad KASSERT(!cpu_intr_p()); 896 1.390 ad mutex_enter(&proc_lock); 897 1.277 ad mutex_enter(p->p_lock); 898 1.351 kamil 899 1.367 kamil repeat: 900 1.359 kamil /* 901 1.359 kamil * If we are exiting, demise now. 902 1.359 kamil * 903 1.359 kamil * This avoids notifying tracer and deadlocking. 904 1.359 kamil */ 905 1.359 kamil if (__predict_false(ISSET(p->p_sflag, PS_WEXIT))) { 906 1.359 kamil mutex_exit(p->p_lock); 907 1.390 ad mutex_exit(&proc_lock); 908 1.359 kamil lwp_exit(l); 909 1.359 kamil panic("trapsignal"); 910 1.359 kamil /* NOTREACHED */ 911 1.359 kamil } 912 1.359 kamil 913 1.367 kamil /* 914 1.367 kamil * The process is already stopping. 915 1.367 kamil */ 916 1.367 kamil if ((p->p_sflag & PS_STOPPING) != 0) { 917 1.390 ad mutex_exit(&proc_lock); 918 1.370 kamil sigswitch_unlock_and_switch_away(l); 919 1.390 ad mutex_enter(&proc_lock); 920 1.367 kamil mutex_enter(p->p_lock); 921 1.370 kamil goto repeat; 922 1.367 kamil } 923 1.367 kamil 924 1.357 kamil mask = &l->l_sigmask; 925 1.357 kamil ps = p->p_sigacts; 926 1.357 kamil action = SIGACTION_PS(ps, signo).sa_handler; 927 1.357 kamil 928 1.351 kamil if (ISSET(p->p_slflag, PSL_TRACED) && 929 1.356 kamil !(p->p_pptr == p->p_opptr && ISSET(p->p_lflag, PL_PPWAIT)) && 930 1.356 kamil p->p_xsig != SIGKILL && 931 1.356 kamil !sigismember(&p->p_sigpend.sp_set, SIGKILL)) { 932 1.356 kamil p->p_xsig = signo; 933 1.356 kamil p->p_sigctx.ps_faked = true; 934 1.356 kamil p->p_sigctx.ps_lwp = ksi->ksi_lid; 935 1.356 kamil p->p_sigctx.ps_info = ksi->ksi_info; 936 1.369 kamil sigswitch(0, signo, true); 937 1.357 kamil 938 1.357 kamil if (ktrpoint(KTR_PSIG)) { 939 1.357 kamil if (p->p_emul->e_ktrpsig) 940 1.357 kamil p->p_emul->e_ktrpsig(signo, action, mask, ksi); 941 1.357 kamil else 942 1.357 kamil ktrpsig(signo, action, mask, ksi); 943 1.357 kamil } 944 1.351 kamil return; 945 1.351 kamil } 946 1.351 kamil 947 1.339 christos const bool caught = sigismember(&p->p_sigctx.ps_sigcatch, signo); 948 1.339 christos const bool masked = sigismember(mask, signo); 949 1.351 kamil if (caught && !masked) { 950 1.390 ad mutex_exit(&proc_lock); 951 1.275 ad l->l_ru.ru_nsignals++; 952 1.288 wrstuden kpsendsig(l, ksi, mask); 953 1.277 ad mutex_exit(p->p_lock); 954 1.357 kamil 955 1.325 christos if (ktrpoint(KTR_PSIG)) { 956 1.330 martin if (p->p_emul->e_ktrpsig) 957 1.357 kamil p->p_emul->e_ktrpsig(signo, action, mask, ksi); 958 1.330 martin else 959 1.357 kamil ktrpsig(signo, action, mask, ksi); 960 1.325 christos } 961 1.339 christos return; 962 1.339 christos } 963 1.339 christos 964 1.339 christos /* 965 1.339 christos * If the signal is masked or ignored, then unmask it and 966 1.339 christos * reset it to the default action so that the process or 967 1.339 christos * its tracer will be notified. 968 1.339 christos */ 969 1.357 kamil const bool ignored = action == SIG_IGN; 970 1.339 christos if (masked || ignored) { 971 1.339 christos mutex_enter(&ps->sa_mutex); 972 1.396 skrll sigdelset(mask, signo); 973 1.339 christos sigdelset(&p->p_sigctx.ps_sigcatch, signo); 974 1.339 christos sigdelset(&p->p_sigctx.ps_sigignore, signo); 975 1.339 christos sigdelset(&SIGACTION_PS(ps, signo).sa_mask, signo); 976 1.339 christos SIGACTION_PS(ps, signo).sa_handler = SIG_DFL; 977 1.339 christos mutex_exit(&ps->sa_mutex); 978 1.29 cgd } 979 1.339 christos 980 1.339 christos kpsignal2(p, ksi); 981 1.339 christos mutex_exit(p->p_lock); 982 1.390 ad mutex_exit(&proc_lock); 983 1.29 cgd } 984 1.29 cgd 985 1.29 cgd /* 986 1.151 christos * Fill in signal information and signal the parent for a child status change. 987 1.151 christos */ 988 1.216 christos void 989 1.243 ad child_psignal(struct proc *p, int mask) 990 1.151 christos { 991 1.151 christos ksiginfo_t ksi; 992 1.243 ad struct proc *q; 993 1.322 christos int xsig; 994 1.243 ad 995 1.390 ad KASSERT(mutex_owned(&proc_lock)); 996 1.277 ad KASSERT(mutex_owned(p->p_lock)); 997 1.243 ad 998 1.322 christos xsig = p->p_xsig; 999 1.151 christos 1000 1.191 matt KSI_INIT(&ksi); 1001 1.151 christos ksi.ksi_signo = SIGCHLD; 1002 1.322 christos ksi.ksi_code = (xsig == SIGCONT ? CLD_CONTINUED : CLD_STOPPED); 1003 1.151 christos ksi.ksi_pid = p->p_pid; 1004 1.220 elad ksi.ksi_uid = kauth_cred_geteuid(p->p_cred); 1005 1.322 christos ksi.ksi_status = xsig; 1006 1.151 christos ksi.ksi_utime = p->p_stats->p_ru.ru_utime.tv_sec; 1007 1.151 christos ksi.ksi_stime = p->p_stats->p_ru.ru_stime.tv_sec; 1008 1.243 ad 1009 1.243 ad q = p->p_pptr; 1010 1.243 ad 1011 1.277 ad mutex_exit(p->p_lock); 1012 1.277 ad mutex_enter(q->p_lock); 1013 1.243 ad 1014 1.243 ad if ((q->p_sflag & mask) == 0) 1015 1.243 ad kpsignal2(q, &ksi); 1016 1.243 ad 1017 1.277 ad mutex_exit(q->p_lock); 1018 1.277 ad mutex_enter(p->p_lock); 1019 1.151 christos } 1020 1.151 christos 1021 1.29 cgd void 1022 1.243 ad psignal(struct proc *p, int signo) 1023 1.148 christos { 1024 1.165 thorpej ksiginfo_t ksi; 1025 1.165 thorpej 1026 1.276 ad KASSERT(!cpu_intr_p()); 1027 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1028 1.243 ad 1029 1.192 matt KSI_INIT_EMPTY(&ksi); 1030 1.243 ad ksi.ksi_signo = signo; 1031 1.277 ad mutex_enter(p->p_lock); 1032 1.234 yamt kpsignal2(p, &ksi); 1033 1.277 ad mutex_exit(p->p_lock); 1034 1.148 christos } 1035 1.148 christos 1036 1.148 christos void 1037 1.234 yamt kpsignal(struct proc *p, ksiginfo_t *ksi, void *data) 1038 1.160 christos { 1039 1.274 ad fdfile_t *ff; 1040 1.274 ad file_t *fp; 1041 1.298 ad fdtab_t *dt; 1042 1.165 thorpej 1043 1.276 ad KASSERT(!cpu_intr_p()); 1044 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1045 1.243 ad 1046 1.243 ad if ((p->p_sflag & PS_WEXIT) == 0 && data) { 1047 1.160 christos size_t fd; 1048 1.274 ad filedesc_t *fdp = p->p_fd; 1049 1.165 thorpej 1050 1.274 ad /* XXXSMP locking */ 1051 1.160 christos ksi->ksi_fd = -1; 1052 1.383 riastrad dt = atomic_load_consume(&fdp->fd_dt); 1053 1.298 ad for (fd = 0; fd < dt->dt_nfiles; fd++) { 1054 1.298 ad if ((ff = dt->dt_ff[fd]) == NULL) 1055 1.274 ad continue; 1056 1.384 riastrad if ((fp = atomic_load_consume(&ff->ff_file)) == NULL) 1057 1.274 ad continue; 1058 1.274 ad if (fp->f_data == data) { 1059 1.160 christos ksi->ksi_fd = fd; 1060 1.160 christos break; 1061 1.160 christos } 1062 1.160 christos } 1063 1.160 christos } 1064 1.277 ad mutex_enter(p->p_lock); 1065 1.234 yamt kpsignal2(p, ksi); 1066 1.277 ad mutex_exit(p->p_lock); 1067 1.160 christos } 1068 1.160 christos 1069 1.243 ad /* 1070 1.243 ad * sigismasked: 1071 1.243 ad * 1072 1.301 rmind * Returns true if signal is ignored or masked for the specified LWP. 1073 1.243 ad */ 1074 1.243 ad int 1075 1.243 ad sigismasked(struct lwp *l, int sig) 1076 1.29 cgd { 1077 1.243 ad struct proc *p = l->l_proc; 1078 1.243 ad 1079 1.317 rmind return sigismember(&p->p_sigctx.ps_sigignore, sig) || 1080 1.317 rmind sigismember(&l->l_sigmask, sig); 1081 1.243 ad } 1082 1.29 cgd 1083 1.243 ad /* 1084 1.243 ad * sigpost: 1085 1.243 ad * 1086 1.301 rmind * Post a pending signal to an LWP. Returns non-zero if the LWP may 1087 1.301 rmind * be able to take the signal. 1088 1.243 ad */ 1089 1.297 rmind static int 1090 1.317 rmind sigpost(struct lwp *l, sig_t action, int prop, int sig) 1091 1.243 ad { 1092 1.243 ad int rv, masked; 1093 1.288 wrstuden struct proc *p = l->l_proc; 1094 1.148 christos 1095 1.288 wrstuden KASSERT(mutex_owned(p->p_lock)); 1096 1.148 christos 1097 1.183 fvdl /* 1098 1.243 ad * If the LWP is on the way out, sigclear() will be busy draining all 1099 1.243 ad * pending signals. Don't give it more. 1100 1.126 jdolecek */ 1101 1.385 ad if (l->l_stat == LSZOMB) 1102 1.243 ad return 0; 1103 1.243 ad 1104 1.320 christos SDT_PROBE(proc, kernel, , signal__send, l, p, sig, 0, 0); 1105 1.303 darran 1106 1.366 kamil lwp_lock(l); 1107 1.366 kamil if (__predict_false((l->l_flag & LW_DBGSUSPEND) != 0)) { 1108 1.366 kamil if ((prop & SA_KILL) != 0) 1109 1.366 kamil l->l_flag &= ~LW_DBGSUSPEND; 1110 1.366 kamil else { 1111 1.366 kamil lwp_unlock(l); 1112 1.366 kamil return 0; 1113 1.366 kamil } 1114 1.366 kamil } 1115 1.366 kamil 1116 1.289 wrstuden /* 1117 1.243 ad * Have the LWP check for signals. This ensures that even if no LWP 1118 1.243 ad * is found to take the signal immediately, it should be taken soon. 1119 1.243 ad */ 1120 1.380 ad signotify(l); 1121 1.29 cgd 1122 1.29 cgd /* 1123 1.297 rmind * SIGCONT can be masked, but if LWP is stopped, it needs restart. 1124 1.297 rmind * Note: SIGKILL and SIGSTOP cannot be masked. 1125 1.29 cgd */ 1126 1.317 rmind masked = sigismember(&l->l_sigmask, sig); 1127 1.243 ad if (masked && ((prop & SA_CONT) == 0 || l->l_stat != LSSTOP)) { 1128 1.243 ad lwp_unlock(l); 1129 1.243 ad return 0; 1130 1.243 ad } 1131 1.198 jdolecek 1132 1.243 ad /* 1133 1.247 ad * If killing the process, make it run fast. 1134 1.247 ad */ 1135 1.247 ad if (__predict_false((prop & SA_KILL) != 0) && 1136 1.266 rmind action == SIG_DFL && l->l_priority < MAXPRI_USER) { 1137 1.266 rmind KASSERT(l->l_class == SCHED_OTHER); 1138 1.266 rmind lwp_changepri(l, MAXPRI_USER); 1139 1.266 rmind } 1140 1.247 ad 1141 1.247 ad /* 1142 1.243 ad * If the LWP is running or on a run queue, then we win. If it's 1143 1.243 ad * sleeping interruptably, wake it and make it take the signal. If 1144 1.243 ad * the sleep isn't interruptable, then the chances are it will get 1145 1.243 ad * to see the signal soon anyhow. If suspended, it can't take the 1146 1.243 ad * signal right now. If it's LWP private or for all LWPs, save it 1147 1.243 ad * for later; otherwise punt. 1148 1.243 ad */ 1149 1.243 ad rv = 0; 1150 1.243 ad 1151 1.243 ad switch (l->l_stat) { 1152 1.243 ad case LSRUN: 1153 1.243 ad case LSONPROC: 1154 1.243 ad rv = 1; 1155 1.243 ad break; 1156 1.243 ad 1157 1.243 ad case LSSLEEP: 1158 1.246 pavel if ((l->l_flag & LW_SINTR) != 0) { 1159 1.243 ad /* setrunnable() will release the lock. */ 1160 1.243 ad setrunnable(l); 1161 1.243 ad return 1; 1162 1.232 mrg } 1163 1.243 ad break; 1164 1.243 ad 1165 1.243 ad case LSSUSPENDED: 1166 1.309 yamt if ((prop & SA_KILL) != 0 && (l->l_flag & LW_WCORE) != 0) { 1167 1.243 ad /* lwp_continue() will release the lock. */ 1168 1.243 ad lwp_continue(l); 1169 1.243 ad return 1; 1170 1.190 matt } 1171 1.243 ad break; 1172 1.243 ad 1173 1.243 ad case LSSTOP: 1174 1.243 ad if ((prop & SA_STOP) != 0) 1175 1.243 ad break; 1176 1.198 jdolecek 1177 1.198 jdolecek /* 1178 1.243 ad * If the LWP is stopped and we are sending a continue 1179 1.243 ad * signal, then start it again. 1180 1.198 jdolecek */ 1181 1.243 ad if ((prop & SA_CONT) != 0) { 1182 1.243 ad if (l->l_wchan != NULL) { 1183 1.243 ad l->l_stat = LSSLEEP; 1184 1.288 wrstuden p->p_nrlwps++; 1185 1.243 ad rv = 1; 1186 1.243 ad break; 1187 1.243 ad } 1188 1.243 ad /* setrunnable() will release the lock. */ 1189 1.243 ad setrunnable(l); 1190 1.243 ad return 1; 1191 1.246 pavel } else if (l->l_wchan == NULL || (l->l_flag & LW_SINTR) != 0) { 1192 1.243 ad /* setrunnable() will release the lock. */ 1193 1.243 ad setrunnable(l); 1194 1.243 ad return 1; 1195 1.243 ad } 1196 1.243 ad break; 1197 1.198 jdolecek 1198 1.243 ad default: 1199 1.243 ad break; 1200 1.243 ad } 1201 1.44 mycroft 1202 1.243 ad lwp_unlock(l); 1203 1.243 ad return rv; 1204 1.243 ad } 1205 1.29 cgd 1206 1.243 ad /* 1207 1.243 ad * Notify an LWP that it has a pending signal. 1208 1.243 ad */ 1209 1.243 ad void 1210 1.243 ad signotify(struct lwp *l) 1211 1.243 ad { 1212 1.250 ad KASSERT(lwp_locked(l, NULL)); 1213 1.29 cgd 1214 1.246 pavel l->l_flag |= LW_PENDSIG; 1215 1.243 ad lwp_need_userret(l); 1216 1.243 ad } 1217 1.44 mycroft 1218 1.243 ad /* 1219 1.243 ad * Find an LWP within process p that is waiting on signal ksi, and hand 1220 1.243 ad * it on. 1221 1.243 ad */ 1222 1.297 rmind static int 1223 1.243 ad sigunwait(struct proc *p, const ksiginfo_t *ksi) 1224 1.243 ad { 1225 1.243 ad struct lwp *l; 1226 1.243 ad int signo; 1227 1.135 jdolecek 1228 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1229 1.171 jdolecek 1230 1.243 ad signo = ksi->ksi_signo; 1231 1.243 ad 1232 1.243 ad if (ksi->ksi_lid != 0) { 1233 1.243 ad /* 1234 1.243 ad * Signal came via _lwp_kill(). Find the LWP and see if 1235 1.243 ad * it's interested. 1236 1.243 ad */ 1237 1.243 ad if ((l = lwp_find(p, ksi->ksi_lid)) == NULL) 1238 1.243 ad return 0; 1239 1.243 ad if (l->l_sigwaited == NULL || 1240 1.243 ad !sigismember(&l->l_sigwaitset, signo)) 1241 1.243 ad return 0; 1242 1.243 ad } else { 1243 1.243 ad /* 1244 1.243 ad * Look for any LWP that may be interested. 1245 1.243 ad */ 1246 1.243 ad LIST_FOREACH(l, &p->p_sigwaiters, l_sigwaiter) { 1247 1.243 ad KASSERT(l->l_sigwaited != NULL); 1248 1.243 ad if (sigismember(&l->l_sigwaitset, signo)) 1249 1.243 ad break; 1250 1.243 ad } 1251 1.243 ad } 1252 1.243 ad 1253 1.243 ad if (l != NULL) { 1254 1.243 ad l->l_sigwaited->ksi_info = ksi->ksi_info; 1255 1.243 ad l->l_sigwaited = NULL; 1256 1.243 ad LIST_REMOVE(l, l_sigwaiter); 1257 1.243 ad cv_signal(&l->l_sigcv); 1258 1.243 ad return 1; 1259 1.243 ad } 1260 1.243 ad 1261 1.243 ad return 0; 1262 1.243 ad } 1263 1.243 ad 1264 1.243 ad /* 1265 1.243 ad * Send the signal to the process. If the signal has an action, the action 1266 1.243 ad * is usually performed by the target process rather than the caller; we add 1267 1.243 ad * the signal to the set of pending signals for the process. 1268 1.243 ad * 1269 1.243 ad * Exceptions: 1270 1.243 ad * o When a stop signal is sent to a sleeping process that takes the 1271 1.243 ad * default action, the process is stopped without awakening it. 1272 1.243 ad * o SIGCONT restarts stopped processes (or puts them back to sleep) 1273 1.243 ad * regardless of the signal action (eg, blocked or ignored). 1274 1.243 ad * 1275 1.243 ad * Other ignored signals are discarded immediately. 1276 1.243 ad */ 1277 1.328 christos int 1278 1.243 ad kpsignal2(struct proc *p, ksiginfo_t *ksi) 1279 1.243 ad { 1280 1.301 rmind int prop, signo = ksi->ksi_signo; 1281 1.320 christos struct lwp *l = NULL; 1282 1.243 ad ksiginfo_t *kp; 1283 1.301 rmind lwpid_t lid; 1284 1.243 ad sig_t action; 1285 1.352 kamil bool toall; 1286 1.389 kamil bool traced; 1287 1.328 christos int error = 0; 1288 1.243 ad 1289 1.276 ad KASSERT(!cpu_intr_p()); 1290 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1291 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1292 1.243 ad KASSERT((ksi->ksi_flags & KSI_QUEUED) == 0); 1293 1.405 riastrad KASSERT(signo > 0); 1294 1.405 riastrad KASSERT(signo < NSIG); 1295 1.171 jdolecek 1296 1.135 jdolecek /* 1297 1.243 ad * If the process is being created by fork, is a zombie or is 1298 1.243 ad * exiting, then just drop the signal here and bail out. 1299 1.29 cgd */ 1300 1.352 kamil if (p->p_stat != SACTIVE && p->p_stat != SSTOP) 1301 1.328 christos return 0; 1302 1.231 mrg 1303 1.231 mrg /* 1304 1.243 ad * Notify any interested parties of the signal. 1305 1.301 rmind */ 1306 1.243 ad KNOTE(&p->p_klist, NOTE_SIGNAL | signo); 1307 1.243 ad 1308 1.243 ad /* 1309 1.243 ad * Some signals including SIGKILL must act on the entire process. 1310 1.231 mrg */ 1311 1.243 ad kp = NULL; 1312 1.243 ad prop = sigprop[signo]; 1313 1.243 ad toall = ((prop & SA_TOALL) != 0); 1314 1.301 rmind lid = toall ? 0 : ksi->ksi_lid; 1315 1.389 kamil traced = ISSET(p->p_slflag, PSL_TRACED) && 1316 1.389 kamil !sigismember(&p->p_sigctx.ps_sigpass, signo); 1317 1.231 mrg 1318 1.243 ad /* 1319 1.243 ad * If proc is traced, always give parent a chance. 1320 1.243 ad */ 1321 1.389 kamil if (traced) { 1322 1.243 ad action = SIG_DFL; 1323 1.104 thorpej 1324 1.243 ad if (lid == 0) { 1325 1.243 ad /* 1326 1.243 ad * If the process is being traced and the signal 1327 1.243 ad * is being caught, make sure to save any ksiginfo. 1328 1.243 ad */ 1329 1.243 ad if ((kp = ksiginfo_alloc(p, ksi, PR_NOWAIT)) == NULL) 1330 1.320 christos goto discard; 1331 1.328 christos if ((error = sigput(&p->p_sigpend, p, kp)) != 0) 1332 1.328 christos goto out; 1333 1.243 ad } 1334 1.243 ad } else { 1335 1.243 ad 1336 1.29 cgd /* 1337 1.243 ad * If the signal is being ignored, then drop it. Note: we 1338 1.243 ad * don't set SIGCONT in ps_sigignore, and if it is set to 1339 1.243 ad * SIG_IGN, action will be SIG_DFL here. 1340 1.29 cgd */ 1341 1.243 ad if (sigismember(&p->p_sigctx.ps_sigignore, signo)) 1342 1.320 christos goto discard; 1343 1.243 ad 1344 1.243 ad else if (sigismember(&p->p_sigctx.ps_sigcatch, signo)) 1345 1.243 ad action = SIG_CATCH; 1346 1.243 ad else { 1347 1.243 ad action = SIG_DFL; 1348 1.243 ad 1349 1.243 ad /* 1350 1.243 ad * If sending a tty stop signal to a member of an 1351 1.243 ad * orphaned process group, discard the signal here if 1352 1.243 ad * the action is default; don't stop the process below 1353 1.243 ad * if sleeping, and don't clear any pending SIGCONT. 1354 1.243 ad */ 1355 1.276 ad if (prop & SA_TTYSTOP && p->p_pgrp->pg_jobc == 0) 1356 1.320 christos goto discard; 1357 1.243 ad 1358 1.243 ad if (prop & SA_KILL && p->p_nice > NZERO) 1359 1.243 ad p->p_nice = NZERO; 1360 1.29 cgd } 1361 1.175 cl } 1362 1.175 cl 1363 1.243 ad /* 1364 1.243 ad * If stopping or continuing a process, discard any pending 1365 1.243 ad * signals that would do the inverse. 1366 1.243 ad */ 1367 1.243 ad if ((prop & (SA_CONT | SA_STOP)) != 0) { 1368 1.301 rmind ksiginfoq_t kq; 1369 1.301 rmind 1370 1.243 ad ksiginfo_queue_init(&kq); 1371 1.243 ad if ((prop & SA_CONT) != 0) 1372 1.243 ad sigclear(&p->p_sigpend, &stopsigmask, &kq); 1373 1.243 ad if ((prop & SA_STOP) != 0) 1374 1.243 ad sigclear(&p->p_sigpend, &contsigmask, &kq); 1375 1.243 ad ksiginfo_queue_drain(&kq); /* XXXSMP */ 1376 1.243 ad } 1377 1.243 ad 1378 1.317 rmind /* 1379 1.243 ad * If the signal doesn't have SA_CANTMASK (no override for SIGKILL, 1380 1.243 ad * please!), check if any LWPs are waiting on it. If yes, pass on 1381 1.243 ad * the signal info. The signal won't be processed further here. 1382 1.243 ad */ 1383 1.243 ad if ((prop & SA_CANTMASK) == 0 && !LIST_EMPTY(&p->p_sigwaiters) && 1384 1.243 ad p->p_stat == SACTIVE && (p->p_sflag & PS_STOPPING) == 0 && 1385 1.243 ad sigunwait(p, ksi)) 1386 1.320 christos goto discard; 1387 1.243 ad 1388 1.243 ad /* 1389 1.243 ad * XXXSMP Should be allocated by the caller, we're holding locks 1390 1.243 ad * here. 1391 1.243 ad */ 1392 1.243 ad if (kp == NULL && (kp = ksiginfo_alloc(p, ksi, PR_NOWAIT)) == NULL) 1393 1.320 christos goto discard; 1394 1.243 ad 1395 1.243 ad /* 1396 1.243 ad * LWP private signals are easy - just find the LWP and post 1397 1.243 ad * the signal to it. 1398 1.243 ad */ 1399 1.243 ad if (lid != 0) { 1400 1.352 kamil l = lwp_find(p, lid); 1401 1.243 ad if (l != NULL) { 1402 1.328 christos if ((error = sigput(&l->l_sigpend, p, kp)) != 0) 1403 1.328 christos goto out; 1404 1.260 ad membar_producer(); 1405 1.339 christos if (sigpost(l, action, prop, kp->ksi_signo) != 0) 1406 1.339 christos signo = -1; 1407 1.243 ad } 1408 1.243 ad goto out; 1409 1.243 ad } 1410 1.130 thorpej 1411 1.243 ad /* 1412 1.288 wrstuden * Some signals go to all LWPs, even if posted with _lwp_kill() 1413 1.288 wrstuden * or for an SA process. 1414 1.243 ad */ 1415 1.243 ad if (p->p_stat == SACTIVE && (p->p_sflag & PS_STOPPING) == 0) { 1416 1.389 kamil if (traced) 1417 1.243 ad goto deliver; 1418 1.202 perry 1419 1.176 cl /* 1420 1.176 cl * If SIGCONT is default (or ignored) and process is 1421 1.176 cl * asleep, we are finished; the process should not 1422 1.176 cl * be awakened. 1423 1.176 cl */ 1424 1.243 ad if ((prop & SA_CONT) != 0 && action == SIG_DFL) 1425 1.243 ad goto out; 1426 1.243 ad } else { 1427 1.176 cl /* 1428 1.300 rmind * Process is stopped or stopping. 1429 1.300 rmind * - If traced, then no action is needed, unless killing. 1430 1.300 rmind * - Run the process only if sending SIGCONT or SIGKILL. 1431 1.176 cl */ 1432 1.389 kamil if (traced && signo != SIGKILL) { 1433 1.243 ad goto out; 1434 1.300 rmind } 1435 1.297 rmind if ((prop & SA_CONT) != 0 || signo == SIGKILL) { 1436 1.243 ad /* 1437 1.321 pgoyette * Re-adjust p_nstopchild if the process was 1438 1.321 pgoyette * stopped but not yet collected by its parent. 1439 1.243 ad */ 1440 1.321 pgoyette if (p->p_stat == SSTOP && !p->p_waited) 1441 1.321 pgoyette p->p_pptr->p_nstopchild--; 1442 1.243 ad p->p_stat = SACTIVE; 1443 1.243 ad p->p_sflag &= ~PS_STOPPING; 1444 1.389 kamil if (traced) { 1445 1.300 rmind KASSERT(signo == SIGKILL); 1446 1.300 rmind goto deliver; 1447 1.300 rmind } 1448 1.29 cgd /* 1449 1.297 rmind * Do not make signal pending if SIGCONT is default. 1450 1.297 rmind * 1451 1.297 rmind * If the process catches SIGCONT, let it handle the 1452 1.297 rmind * signal itself (if waiting on event - process runs, 1453 1.297 rmind * otherwise continues sleeping). 1454 1.29 cgd */ 1455 1.324 christos if ((prop & SA_CONT) != 0) { 1456 1.324 christos p->p_xsig = SIGCONT; 1457 1.326 christos p->p_sflag |= PS_CONTINUED; 1458 1.324 christos child_psignal(p, 0); 1459 1.324 christos if (action == SIG_DFL) { 1460 1.324 christos KASSERT(signo != SIGKILL); 1461 1.324 christos goto deliver; 1462 1.324 christos } 1463 1.297 rmind } 1464 1.243 ad } else if ((prop & SA_STOP) != 0) { 1465 1.29 cgd /* 1466 1.176 cl * Already stopped, don't need to stop again. 1467 1.176 cl * (If we did the shell could get confused.) 1468 1.29 cgd */ 1469 1.243 ad goto out; 1470 1.297 rmind } 1471 1.243 ad } 1472 1.297 rmind /* 1473 1.297 rmind * Make signal pending. 1474 1.297 rmind */ 1475 1.389 kamil KASSERT(!traced); 1476 1.328 christos if ((error = sigput(&p->p_sigpend, p, kp)) != 0) 1477 1.328 christos goto out; 1478 1.301 rmind deliver: 1479 1.243 ad /* 1480 1.271 yamt * Before we set LW_PENDSIG on any LWP, ensure that the signal is 1481 1.243 ad * visible on the per process list (for sigispending()). This 1482 1.243 ad * is unlikely to be needed in practice, but... 1483 1.243 ad */ 1484 1.260 ad membar_producer(); 1485 1.29 cgd 1486 1.29 cgd /* 1487 1.243 ad * Try to find an LWP that can take the signal. 1488 1.29 cgd */ 1489 1.301 rmind LIST_FOREACH(l, &p->p_lwps, l_sibling) { 1490 1.317 rmind if (sigpost(l, action, prop, kp->ksi_signo) && !toall) 1491 1.301 rmind break; 1492 1.288 wrstuden } 1493 1.320 christos signo = -1; 1494 1.301 rmind out: 1495 1.301 rmind /* 1496 1.301 rmind * If the ksiginfo wasn't used, then bin it. XXXSMP freeing memory 1497 1.301 rmind * with locks held. The caller should take care of this. 1498 1.301 rmind */ 1499 1.301 rmind ksiginfo_free(kp); 1500 1.320 christos if (signo == -1) 1501 1.328 christos return error; 1502 1.320 christos discard: 1503 1.320 christos SDT_PROBE(proc, kernel, , signal__discard, l, p, signo, 0, 0); 1504 1.328 christos return error; 1505 1.29 cgd } 1506 1.29 cgd 1507 1.243 ad void 1508 1.243 ad kpsendsig(struct lwp *l, const ksiginfo_t *ksi, const sigset_t *mask) 1509 1.209 chs { 1510 1.243 ad struct proc *p = l->l_proc; 1511 1.243 ad 1512 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1513 1.243 ad (*p->p_emul->e_sendsig)(ksi, mask); 1514 1.209 chs } 1515 1.209 chs 1516 1.243 ad /* 1517 1.272 yamt * Stop any LWPs sleeping interruptably. 1518 1.272 yamt */ 1519 1.272 yamt static void 1520 1.272 yamt proc_stop_lwps(struct proc *p) 1521 1.272 yamt { 1522 1.272 yamt struct lwp *l; 1523 1.272 yamt 1524 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1525 1.272 yamt KASSERT((p->p_sflag & PS_STOPPING) != 0); 1526 1.272 yamt 1527 1.272 yamt LIST_FOREACH(l, &p->p_lwps, l_sibling) { 1528 1.272 yamt lwp_lock(l); 1529 1.272 yamt if (l->l_stat == LSSLEEP && (l->l_flag & LW_SINTR) != 0) { 1530 1.272 yamt l->l_stat = LSSTOP; 1531 1.272 yamt p->p_nrlwps--; 1532 1.272 yamt } 1533 1.272 yamt lwp_unlock(l); 1534 1.272 yamt } 1535 1.272 yamt } 1536 1.272 yamt 1537 1.272 yamt /* 1538 1.272 yamt * Finish stopping of a process. Mark it stopped and notify the parent. 1539 1.272 yamt * 1540 1.362 kamil * Drop p_lock briefly if ppsig is true. 1541 1.272 yamt */ 1542 1.272 yamt static void 1543 1.340 kamil proc_stop_done(struct proc *p, int ppmask) 1544 1.272 yamt { 1545 1.272 yamt 1546 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1547 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1548 1.272 yamt KASSERT((p->p_sflag & PS_STOPPING) != 0); 1549 1.405 riastrad KASSERT(p->p_nrlwps == 0 || p->p_nrlwps == 1); 1550 1.405 riastrad KASSERT(p->p_nrlwps == 0 || p == curproc); 1551 1.272 yamt 1552 1.272 yamt p->p_sflag &= ~PS_STOPPING; 1553 1.272 yamt p->p_stat = SSTOP; 1554 1.272 yamt p->p_waited = 0; 1555 1.272 yamt p->p_pptr->p_nstopchild++; 1556 1.362 kamil 1557 1.362 kamil /* child_psignal drops p_lock briefly. */ 1558 1.362 kamil child_psignal(p, ppmask); 1559 1.362 kamil cv_broadcast(&p->p_pptr->p_waitcv); 1560 1.272 yamt } 1561 1.272 yamt 1562 1.357 kamil /* 1563 1.357 kamil * Stop the current process and switch away to the debugger notifying 1564 1.357 kamil * an event specific to a traced process only. 1565 1.357 kamil */ 1566 1.353 kamil void 1567 1.365 kamil eventswitch(int code, int pe_report_event, int entity) 1568 1.353 kamil { 1569 1.353 kamil struct lwp *l = curlwp; 1570 1.353 kamil struct proc *p = l->l_proc; 1571 1.357 kamil struct sigacts *ps; 1572 1.357 kamil sigset_t *mask; 1573 1.357 kamil sig_t action; 1574 1.357 kamil ksiginfo_t ksi; 1575 1.357 kamil const int signo = SIGTRAP; 1576 1.353 kamil 1577 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1578 1.353 kamil KASSERT(mutex_owned(p->p_lock)); 1579 1.357 kamil KASSERT(p->p_pptr != initproc); 1580 1.353 kamil KASSERT(l->l_stat == LSONPROC); 1581 1.357 kamil KASSERT(ISSET(p->p_slflag, PSL_TRACED)); 1582 1.357 kamil KASSERT(!ISSET(l->l_flag, LW_SYSTEM)); 1583 1.353 kamil KASSERT(p->p_nrlwps > 0); 1584 1.357 kamil KASSERT((code == TRAP_CHLD) || (code == TRAP_LWP) || 1585 1.357 kamil (code == TRAP_EXEC)); 1586 1.368 kamil KASSERT((code != TRAP_CHLD) || (entity > 1)); /* prevent pid1 */ 1587 1.368 kamil KASSERT((code != TRAP_LWP) || (entity > 0)); 1588 1.353 kamil 1589 1.367 kamil repeat: 1590 1.354 kamil /* 1591 1.359 kamil * If we are exiting, demise now. 1592 1.359 kamil * 1593 1.359 kamil * This avoids notifying tracer and deadlocking. 1594 1.367 kamil */ 1595 1.359 kamil if (__predict_false(ISSET(p->p_sflag, PS_WEXIT))) { 1596 1.359 kamil mutex_exit(p->p_lock); 1597 1.390 ad mutex_exit(&proc_lock); 1598 1.372 kamil 1599 1.372 kamil if (pe_report_event == PTRACE_LWP_EXIT) { 1600 1.372 kamil /* Avoid double lwp_exit() and panic. */ 1601 1.372 kamil return; 1602 1.372 kamil } 1603 1.372 kamil 1604 1.359 kamil lwp_exit(l); 1605 1.359 kamil panic("eventswitch"); 1606 1.359 kamil /* NOTREACHED */ 1607 1.359 kamil } 1608 1.359 kamil 1609 1.359 kamil /* 1610 1.367 kamil * If we are no longer traced, abandon this event signal. 1611 1.367 kamil * 1612 1.367 kamil * This avoids killing a process after detaching the debugger. 1613 1.367 kamil */ 1614 1.367 kamil if (__predict_false(!ISSET(p->p_slflag, PSL_TRACED))) { 1615 1.367 kamil mutex_exit(p->p_lock); 1616 1.390 ad mutex_exit(&proc_lock); 1617 1.367 kamil return; 1618 1.367 kamil } 1619 1.367 kamil 1620 1.367 kamil /* 1621 1.354 kamil * If there's a pending SIGKILL process it immediately. 1622 1.354 kamil */ 1623 1.354 kamil if (p->p_xsig == SIGKILL || 1624 1.354 kamil sigismember(&p->p_sigpend.sp_set, SIGKILL)) { 1625 1.357 kamil mutex_exit(p->p_lock); 1626 1.390 ad mutex_exit(&proc_lock); 1627 1.354 kamil return; 1628 1.354 kamil } 1629 1.354 kamil 1630 1.367 kamil /* 1631 1.367 kamil * The process is already stopping. 1632 1.367 kamil */ 1633 1.367 kamil if ((p->p_sflag & PS_STOPPING) != 0) { 1634 1.390 ad mutex_exit(&proc_lock); 1635 1.370 kamil sigswitch_unlock_and_switch_away(l); 1636 1.390 ad mutex_enter(&proc_lock); 1637 1.367 kamil mutex_enter(p->p_lock); 1638 1.370 kamil goto repeat; 1639 1.367 kamil } 1640 1.367 kamil 1641 1.357 kamil KSI_INIT_TRAP(&ksi); 1642 1.357 kamil ksi.ksi_lid = l->l_lid; 1643 1.365 kamil ksi.ksi_signo = signo; 1644 1.365 kamil ksi.ksi_code = code; 1645 1.365 kamil ksi.ksi_pe_report_event = pe_report_event; 1646 1.365 kamil 1647 1.365 kamil CTASSERT(sizeof(ksi.ksi_pe_other_pid) == sizeof(ksi.ksi_pe_lwp)); 1648 1.365 kamil ksi.ksi_pe_other_pid = entity; 1649 1.357 kamil 1650 1.357 kamil /* Needed for ktrace */ 1651 1.357 kamil ps = p->p_sigacts; 1652 1.357 kamil action = SIGACTION_PS(ps, signo).sa_handler; 1653 1.357 kamil mask = &l->l_sigmask; 1654 1.357 kamil 1655 1.353 kamil p->p_xsig = signo; 1656 1.353 kamil p->p_sigctx.ps_faked = true; 1657 1.357 kamil p->p_sigctx.ps_lwp = ksi.ksi_lid; 1658 1.357 kamil p->p_sigctx.ps_info = ksi.ksi_info; 1659 1.353 kamil 1660 1.369 kamil sigswitch(0, signo, true); 1661 1.357 kamil 1662 1.361 kamil if (code == TRAP_CHLD) { 1663 1.390 ad mutex_enter(&proc_lock); 1664 1.361 kamil while (l->l_vforkwaiting) 1665 1.390 ad cv_wait(&l->l_waitcv, &proc_lock); 1666 1.390 ad mutex_exit(&proc_lock); 1667 1.361 kamil } 1668 1.357 kamil 1669 1.357 kamil if (ktrpoint(KTR_PSIG)) { 1670 1.357 kamil if (p->p_emul->e_ktrpsig) 1671 1.357 kamil p->p_emul->e_ktrpsig(signo, action, mask, &ksi); 1672 1.357 kamil else 1673 1.357 kamil ktrpsig(signo, action, mask, &ksi); 1674 1.357 kamil } 1675 1.353 kamil } 1676 1.353 kamil 1677 1.386 christos void 1678 1.386 christos eventswitchchild(struct proc *p, int code, int pe_report_event) 1679 1.386 christos { 1680 1.390 ad mutex_enter(&proc_lock); 1681 1.386 christos mutex_enter(p->p_lock); 1682 1.388 kamil if ((p->p_slflag & (PSL_TRACED|PSL_TRACEDCHILD)) != 1683 1.388 kamil (PSL_TRACED|PSL_TRACEDCHILD)) { 1684 1.386 christos mutex_exit(p->p_lock); 1685 1.390 ad mutex_exit(&proc_lock); 1686 1.386 christos return; 1687 1.386 christos } 1688 1.387 kamil eventswitch(code, pe_report_event, p->p_oppid); 1689 1.386 christos } 1690 1.386 christos 1691 1.272 yamt /* 1692 1.243 ad * Stop the current process and switch away when being stopped or traced. 1693 1.243 ad */ 1694 1.369 kamil static void 1695 1.369 kamil sigswitch(int ppmask, int signo, bool proc_lock_held) 1696 1.209 chs { 1697 1.272 yamt struct lwp *l = curlwp; 1698 1.243 ad struct proc *p = l->l_proc; 1699 1.243 ad 1700 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1701 1.250 ad KASSERT(l->l_stat == LSONPROC); 1702 1.250 ad KASSERT(p->p_nrlwps > 0); 1703 1.243 ad 1704 1.369 kamil if (proc_lock_held) { 1705 1.390 ad KASSERT(mutex_owned(&proc_lock)); 1706 1.369 kamil } else { 1707 1.390 ad KASSERT(!mutex_owned(&proc_lock)); 1708 1.369 kamil } 1709 1.369 kamil 1710 1.243 ad /* 1711 1.243 ad * On entry we know that the process needs to stop. If it's 1712 1.243 ad * the result of a 'sideways' stop signal that has been sourced 1713 1.243 ad * through issignal(), then stop other LWPs in the process too. 1714 1.243 ad */ 1715 1.243 ad if (p->p_stat == SACTIVE && (p->p_sflag & PS_STOPPING) == 0) { 1716 1.243 ad KASSERT(signo != 0); 1717 1.334 christos proc_stop(p, signo); 1718 1.250 ad KASSERT(p->p_nrlwps > 0); 1719 1.243 ad } 1720 1.243 ad 1721 1.243 ad /* 1722 1.243 ad * If we are the last live LWP, and the stop was a result of 1723 1.243 ad * a new signal, then signal the parent. 1724 1.243 ad */ 1725 1.243 ad if ((p->p_sflag & PS_STOPPING) != 0) { 1726 1.390 ad if (!proc_lock_held && !mutex_tryenter(&proc_lock)) { 1727 1.277 ad mutex_exit(p->p_lock); 1728 1.390 ad mutex_enter(&proc_lock); 1729 1.277 ad mutex_enter(p->p_lock); 1730 1.243 ad } 1731 1.243 ad 1732 1.243 ad if (p->p_nrlwps == 1 && (p->p_sflag & PS_STOPPING) != 0) { 1733 1.272 yamt /* 1734 1.272 yamt * Note that proc_stop_done() can drop 1735 1.277 ad * p->p_lock briefly. 1736 1.272 yamt */ 1737 1.340 kamil proc_stop_done(p, ppmask); 1738 1.243 ad } 1739 1.243 ad 1740 1.390 ad mutex_exit(&proc_lock); 1741 1.243 ad } 1742 1.243 ad 1743 1.370 kamil sigswitch_unlock_and_switch_away(l); 1744 1.370 kamil } 1745 1.370 kamil 1746 1.370 kamil /* 1747 1.370 kamil * Unlock and switch away. 1748 1.370 kamil */ 1749 1.370 kamil static void 1750 1.370 kamil sigswitch_unlock_and_switch_away(struct lwp *l) 1751 1.370 kamil { 1752 1.370 kamil struct proc *p; 1753 1.370 kamil 1754 1.370 kamil p = l->l_proc; 1755 1.370 kamil 1756 1.370 kamil KASSERT(mutex_owned(p->p_lock)); 1757 1.390 ad KASSERT(!mutex_owned(&proc_lock)); 1758 1.370 kamil 1759 1.370 kamil KASSERT(l->l_stat == LSONPROC); 1760 1.370 kamil KASSERT(p->p_nrlwps > 0); 1761 1.408 ad KASSERT(l->l_blcnt == 0); 1762 1.370 kamil 1763 1.243 ad if (p->p_stat == SSTOP || (p->p_sflag & PS_STOPPING) != 0) { 1764 1.243 ad p->p_nrlwps--; 1765 1.243 ad lwp_lock(l); 1766 1.243 ad KASSERT(l->l_stat == LSONPROC || l->l_stat == LSSLEEP); 1767 1.243 ad l->l_stat = LSSTOP; 1768 1.243 ad lwp_unlock(l); 1769 1.243 ad } 1770 1.243 ad 1771 1.277 ad mutex_exit(p->p_lock); 1772 1.243 ad lwp_lock(l); 1773 1.381 ad spc_lock(l->l_cpu); 1774 1.253 yamt mi_switch(l); 1775 1.209 chs } 1776 1.209 chs 1777 1.243 ad /* 1778 1.243 ad * Check for a signal from the debugger. 1779 1.243 ad */ 1780 1.297 rmind static int 1781 1.293 ad sigchecktrace(void) 1782 1.130 thorpej { 1783 1.243 ad struct lwp *l = curlwp; 1784 1.130 thorpej struct proc *p = l->l_proc; 1785 1.243 ad int signo; 1786 1.243 ad 1787 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1788 1.130 thorpej 1789 1.292 ad /* If there's a pending SIGKILL, process it immediately. */ 1790 1.292 ad if (sigismember(&p->p_sigpend.sp_set, SIGKILL)) 1791 1.292 ad return 0; 1792 1.292 ad 1793 1.243 ad /* 1794 1.243 ad * If we are no longer being traced, or the parent didn't 1795 1.305 christos * give us a signal, or we're stopping, look for more signals. 1796 1.243 ad */ 1797 1.322 christos if ((p->p_slflag & PSL_TRACED) == 0 || p->p_xsig == 0 || 1798 1.305 christos (p->p_sflag & PS_STOPPING) != 0) 1799 1.243 ad return 0; 1800 1.130 thorpej 1801 1.243 ad /* 1802 1.243 ad * If the new signal is being masked, look for other signals. 1803 1.243 ad * `p->p_sigctx.ps_siglist |= mask' is done in setrunnable(). 1804 1.243 ad */ 1805 1.322 christos signo = p->p_xsig; 1806 1.322 christos p->p_xsig = 0; 1807 1.317 rmind if (sigismember(&l->l_sigmask, signo)) { 1808 1.243 ad signo = 0; 1809 1.317 rmind } 1810 1.243 ad return signo; 1811 1.79 mycroft } 1812 1.79 mycroft 1813 1.29 cgd /* 1814 1.29 cgd * If the current process has received a signal (should be caught or cause 1815 1.29 cgd * termination, should interrupt current syscall), return the signal number. 1816 1.243 ad * 1817 1.29 cgd * Stop signals with default action are processed immediately, then cleared; 1818 1.29 cgd * they aren't returned. This is checked after each entry to the system for 1819 1.243 ad * a syscall or trap. 1820 1.243 ad * 1821 1.243 ad * We will also return -1 if the process is exiting and the current LWP must 1822 1.243 ad * follow suit. 1823 1.29 cgd */ 1824 1.29 cgd int 1825 1.130 thorpej issignal(struct lwp *l) 1826 1.29 cgd { 1827 1.293 ad struct proc *p; 1828 1.376 mgorny int siglwp, signo, prop; 1829 1.293 ad sigpend_t *sp; 1830 1.243 ad sigset_t ss; 1831 1.389 kamil bool traced; 1832 1.243 ad 1833 1.293 ad p = l->l_proc; 1834 1.293 ad sp = NULL; 1835 1.293 ad signo = 0; 1836 1.293 ad 1837 1.293 ad KASSERT(p == curproc); 1838 1.277 ad KASSERT(mutex_owned(p->p_lock)); 1839 1.29 cgd 1840 1.243 ad for (;;) { 1841 1.243 ad /* Discard any signals that we have decided not to take. */ 1842 1.314 christos if (signo != 0) { 1843 1.243 ad (void)sigget(sp, NULL, signo, NULL); 1844 1.314 christos } 1845 1.144 fvdl 1846 1.243 ad /* 1847 1.243 ad * If the process is stopped/stopping, then stop ourselves 1848 1.243 ad * now that we're on the kernel/userspace boundary. When 1849 1.243 ad * we awaken, check for a signal from the debugger. 1850 1.243 ad */ 1851 1.243 ad if (p->p_stat == SSTOP || (p->p_sflag & PS_STOPPING) != 0) { 1852 1.370 kamil sigswitch_unlock_and_switch_away(l); 1853 1.357 kamil mutex_enter(p->p_lock); 1854 1.371 kamil continue; 1855 1.351 kamil } else if (p->p_stat == SACTIVE) 1856 1.351 kamil signo = sigchecktrace(); 1857 1.351 kamil else 1858 1.243 ad signo = 0; 1859 1.238 ad 1860 1.293 ad /* Signals from the debugger are "out of band". */ 1861 1.293 ad sp = NULL; 1862 1.293 ad 1863 1.130 thorpej /* 1864 1.243 ad * If the debugger didn't provide a signal, find a pending 1865 1.243 ad * signal from our set. Check per-LWP signals first, and 1866 1.243 ad * then per-process. 1867 1.243 ad */ 1868 1.243 ad if (signo == 0) { 1869 1.243 ad sp = &l->l_sigpend; 1870 1.243 ad ss = sp->sp_set; 1871 1.376 mgorny siglwp = l->l_lid; 1872 1.285 ad if ((p->p_lflag & PL_PPWAIT) != 0) 1873 1.345 kamil sigminusset(&vforksigmask, &ss); 1874 1.243 ad sigminusset(&l->l_sigmask, &ss); 1875 1.243 ad 1876 1.243 ad if ((signo = firstsig(&ss)) == 0) { 1877 1.243 ad sp = &p->p_sigpend; 1878 1.243 ad ss = sp->sp_set; 1879 1.376 mgorny siglwp = 0; 1880 1.285 ad if ((p->p_lflag & PL_PPWAIT) != 0) 1881 1.345 kamil sigminusset(&vforksigmask, &ss); 1882 1.243 ad sigminusset(&l->l_sigmask, &ss); 1883 1.243 ad 1884 1.243 ad if ((signo = firstsig(&ss)) == 0) { 1885 1.243 ad /* 1886 1.243 ad * No signal pending - clear the 1887 1.243 ad * indicator and bail out. 1888 1.243 ad */ 1889 1.243 ad lwp_lock(l); 1890 1.246 pavel l->l_flag &= ~LW_PENDSIG; 1891 1.243 ad lwp_unlock(l); 1892 1.243 ad sp = NULL; 1893 1.243 ad break; 1894 1.243 ad } 1895 1.243 ad } 1896 1.79 mycroft } 1897 1.42 mycroft 1898 1.389 kamil traced = ISSET(p->p_slflag, PSL_TRACED) && 1899 1.389 kamil !sigismember(&p->p_sigctx.ps_sigpass, signo); 1900 1.389 kamil 1901 1.376 mgorny if (sp) { 1902 1.376 mgorny /* Overwrite process' signal context to correspond 1903 1.376 mgorny * to the currently reported LWP. This is necessary 1904 1.376 mgorny * for PT_GET_SIGINFO to report the correct signal when 1905 1.376 mgorny * multiple LWPs have pending signals. We do this only 1906 1.376 mgorny * when the signal comes from the queue, for signals 1907 1.376 mgorny * created by the debugger we assume it set correct 1908 1.376 mgorny * siginfo. 1909 1.376 mgorny */ 1910 1.376 mgorny ksiginfo_t *ksi = TAILQ_FIRST(&sp->sp_info); 1911 1.376 mgorny if (ksi) { 1912 1.376 mgorny p->p_sigctx.ps_lwp = ksi->ksi_lid; 1913 1.376 mgorny p->p_sigctx.ps_info = ksi->ksi_info; 1914 1.376 mgorny } else { 1915 1.376 mgorny p->p_sigctx.ps_lwp = siglwp; 1916 1.376 mgorny memset(&p->p_sigctx.ps_info, 0, 1917 1.376 mgorny sizeof(p->p_sigctx.ps_info)); 1918 1.376 mgorny p->p_sigctx.ps_info._signo = signo; 1919 1.376 mgorny p->p_sigctx.ps_info._code = SI_NOINFO; 1920 1.376 mgorny } 1921 1.376 mgorny } 1922 1.376 mgorny 1923 1.29 cgd /* 1924 1.243 ad * We should see pending but ignored signals only if 1925 1.243 ad * we are being traced. 1926 1.29 cgd */ 1927 1.243 ad if (sigismember(&p->p_sigctx.ps_sigignore, signo) && 1928 1.389 kamil !traced) { 1929 1.243 ad /* Discard the signal. */ 1930 1.29 cgd continue; 1931 1.243 ad } 1932 1.42 mycroft 1933 1.243 ad /* 1934 1.243 ad * If traced, always stop, and stay stopped until released 1935 1.342 kamil * by the debugger. If the our parent is our debugger waiting 1936 1.342 kamil * for us and we vforked, don't hang as we could deadlock. 1937 1.243 ad */ 1938 1.389 kamil if (traced && signo != SIGKILL && 1939 1.344 kamil !(ISSET(p->p_lflag, PL_PPWAIT) && 1940 1.344 kamil (p->p_pptr == p->p_opptr))) { 1941 1.313 christos /* 1942 1.313 christos * Take the signal, but don't remove it from the 1943 1.313 christos * siginfo queue, because the debugger can send 1944 1.313 christos * it later. 1945 1.313 christos */ 1946 1.315 christos if (sp) 1947 1.315 christos sigdelset(&sp->sp_set, signo); 1948 1.322 christos p->p_xsig = signo; 1949 1.184 manu 1950 1.343 kamil /* Handling of signal trace */ 1951 1.369 kamil sigswitch(0, signo, false); 1952 1.357 kamil mutex_enter(p->p_lock); 1953 1.29 cgd 1954 1.243 ad /* Check for a signal from the debugger. */ 1955 1.293 ad if ((signo = sigchecktrace()) == 0) 1956 1.29 cgd continue; 1957 1.293 ad 1958 1.293 ad /* Signals from the debugger are "out of band". */ 1959 1.293 ad sp = NULL; 1960 1.29 cgd } 1961 1.29 cgd 1962 1.243 ad prop = sigprop[signo]; 1963 1.42 mycroft 1964 1.29 cgd /* 1965 1.29 cgd * Decide whether the signal should be returned. 1966 1.29 cgd */ 1967 1.243 ad switch ((long)SIGACTION(p, signo).sa_handler) { 1968 1.33 cgd case (long)SIG_DFL: 1969 1.29 cgd /* 1970 1.29 cgd * Don't take default actions on system processes. 1971 1.29 cgd */ 1972 1.29 cgd if (p->p_pid <= 1) { 1973 1.29 cgd #ifdef DIAGNOSTIC 1974 1.29 cgd /* 1975 1.29 cgd * Are you sure you want to ignore SIGSEGV 1976 1.29 cgd * in init? XXX 1977 1.29 cgd */ 1978 1.243 ad printf_nolog("Process (pid %d) got sig %d\n", 1979 1.243 ad p->p_pid, signo); 1980 1.29 cgd #endif 1981 1.243 ad continue; 1982 1.29 cgd } 1983 1.243 ad 1984 1.29 cgd /* 1985 1.243 ad * If there is a pending stop signal to process with 1986 1.396 skrll * default action, stop here, then clear the signal. 1987 1.243 ad * However, if process is member of an orphaned 1988 1.29 cgd * process group, ignore tty stop signals. 1989 1.29 cgd */ 1990 1.29 cgd if (prop & SA_STOP) { 1991 1.276 ad /* 1992 1.276 ad * XXX Don't hold proc_lock for p_lflag, 1993 1.276 ad * but it's not a big deal. 1994 1.276 ad */ 1995 1.389 kamil if ((traced && 1996 1.346 kamil !(ISSET(p->p_lflag, PL_PPWAIT) && 1997 1.346 kamil (p->p_pptr == p->p_opptr))) || 1998 1.301 rmind ((p->p_lflag & PL_ORPHANPG) != 0 && 1999 1.243 ad prop & SA_TTYSTOP)) { 2000 1.301 rmind /* Ignore the signal. */ 2001 1.243 ad continue; 2002 1.243 ad } 2003 1.243 ad /* Take the signal. */ 2004 1.243 ad (void)sigget(sp, NULL, signo, NULL); 2005 1.322 christos p->p_xsig = signo; 2006 1.327 christos p->p_sflag &= ~PS_CONTINUED; 2007 1.243 ad signo = 0; 2008 1.369 kamil sigswitch(PS_NOCLDSTOP, p->p_xsig, false); 2009 1.357 kamil mutex_enter(p->p_lock); 2010 1.29 cgd } else if (prop & SA_IGNORE) { 2011 1.29 cgd /* 2012 1.29 cgd * Except for SIGCONT, shouldn't get here. 2013 1.29 cgd * Default action is to ignore; drop it. 2014 1.29 cgd */ 2015 1.243 ad continue; 2016 1.243 ad } 2017 1.243 ad break; 2018 1.29 cgd 2019 1.33 cgd case (long)SIG_IGN: 2020 1.243 ad #ifdef DEBUG_ISSIGNAL 2021 1.29 cgd /* 2022 1.29 cgd * Masking above should prevent us ever trying 2023 1.29 cgd * to take action on an ignored signal other 2024 1.29 cgd * than SIGCONT, unless process is traced. 2025 1.29 cgd */ 2026 1.389 kamil if ((prop & SA_CONT) == 0 && !traced) 2027 1.243 ad printf_nolog("issignal\n"); 2028 1.128 jdolecek #endif 2029 1.243 ad continue; 2030 1.29 cgd 2031 1.29 cgd default: 2032 1.29 cgd /* 2033 1.243 ad * This signal has an action, let postsig() process 2034 1.243 ad * it. 2035 1.29 cgd */ 2036 1.243 ad break; 2037 1.29 cgd } 2038 1.243 ad 2039 1.243 ad break; 2040 1.29 cgd } 2041 1.42 mycroft 2042 1.243 ad l->l_sigpendset = sp; 2043 1.243 ad return signo; 2044 1.29 cgd } 2045 1.29 cgd 2046 1.29 cgd /* 2047 1.243 ad * Take the action for the specified signal 2048 1.243 ad * from the current set of pending signals. 2049 1.29 cgd */ 2050 1.179 christos void 2051 1.243 ad postsig(int signo) 2052 1.29 cgd { 2053 1.243 ad struct lwp *l; 2054 1.243 ad struct proc *p; 2055 1.243 ad struct sigacts *ps; 2056 1.243 ad sig_t action; 2057 1.243 ad sigset_t *returnmask; 2058 1.243 ad ksiginfo_t ksi; 2059 1.243 ad 2060 1.243 ad l = curlwp; 2061 1.243 ad p = l->l_proc; 2062 1.243 ad ps = p->p_sigacts; 2063 1.243 ad 2064 1.277 ad KASSERT(mutex_owned(p->p_lock)); 2065 1.243 ad KASSERT(signo > 0); 2066 1.243 ad 2067 1.243 ad /* 2068 1.243 ad * Set the new mask value and also defer further occurrences of this 2069 1.243 ad * signal. 2070 1.243 ad * 2071 1.268 yamt * Special case: user has done a sigsuspend. Here the current mask is 2072 1.293 ad * not of interest, but rather the mask from before the sigsuspend is 2073 1.243 ad * what we want restored after the signal processing is completed. 2074 1.243 ad */ 2075 1.243 ad if (l->l_sigrestore) { 2076 1.243 ad returnmask = &l->l_sigoldmask; 2077 1.243 ad l->l_sigrestore = 0; 2078 1.243 ad } else 2079 1.243 ad returnmask = &l->l_sigmask; 2080 1.29 cgd 2081 1.243 ad /* 2082 1.243 ad * Commit to taking the signal before releasing the mutex. 2083 1.243 ad */ 2084 1.243 ad action = SIGACTION_PS(ps, signo).sa_handler; 2085 1.275 ad l->l_ru.ru_nsignals++; 2086 1.314 christos if (l->l_sigpendset == NULL) { 2087 1.313 christos /* From the debugger */ 2088 1.332 kamil if (p->p_sigctx.ps_faked && 2089 1.332 kamil signo == p->p_sigctx.ps_info._signo) { 2090 1.332 kamil KSI_INIT(&ksi); 2091 1.332 kamil ksi.ksi_info = p->p_sigctx.ps_info; 2092 1.332 kamil ksi.ksi_lid = p->p_sigctx.ps_lwp; 2093 1.332 kamil p->p_sigctx.ps_faked = false; 2094 1.332 kamil } else { 2095 1.332 kamil if (!siggetinfo(&l->l_sigpend, &ksi, signo)) 2096 1.332 kamil (void)siggetinfo(&p->p_sigpend, &ksi, signo); 2097 1.332 kamil } 2098 1.314 christos } else 2099 1.314 christos sigget(l->l_sigpendset, &ksi, signo, NULL); 2100 1.104 thorpej 2101 1.255 ad if (ktrpoint(KTR_PSIG)) { 2102 1.277 ad mutex_exit(p->p_lock); 2103 1.330 martin if (p->p_emul->e_ktrpsig) 2104 1.330 martin p->p_emul->e_ktrpsig(signo, action, 2105 1.330 martin returnmask, &ksi); 2106 1.330 martin else 2107 1.330 martin ktrpsig(signo, action, returnmask, &ksi); 2108 1.277 ad mutex_enter(p->p_lock); 2109 1.243 ad } 2110 1.130 thorpej 2111 1.320 christos SDT_PROBE(proc, kernel, , signal__handle, signo, &ksi, action, 0, 0); 2112 1.320 christos 2113 1.243 ad if (action == SIG_DFL) { 2114 1.175 cl /* 2115 1.243 ad * Default action, where the default is to kill 2116 1.243 ad * the process. (Other cases were ignored above.) 2117 1.175 cl */ 2118 1.243 ad sigexit(l, signo); 2119 1.243 ad return; 2120 1.175 cl } 2121 1.175 cl 2122 1.202 perry /* 2123 1.243 ad * If we get here, the signal must be caught. 2124 1.130 thorpej */ 2125 1.130 thorpej #ifdef DIAGNOSTIC 2126 1.243 ad if (action == SIG_IGN || sigismember(&l->l_sigmask, signo)) 2127 1.243 ad panic("postsig action"); 2128 1.130 thorpej #endif 2129 1.144 fvdl 2130 1.243 ad kpsendsig(l, &ksi, returnmask); 2131 1.29 cgd } 2132 1.29 cgd 2133 1.133 nathanw /* 2134 1.290 ad * sendsig: 2135 1.290 ad * 2136 1.290 ad * Default signal delivery method for NetBSD. 2137 1.290 ad */ 2138 1.290 ad void 2139 1.290 ad sendsig(const struct ksiginfo *ksi, const sigset_t *mask) 2140 1.290 ad { 2141 1.290 ad struct sigacts *sa; 2142 1.290 ad int sig; 2143 1.290 ad 2144 1.290 ad sig = ksi->ksi_signo; 2145 1.290 ad sa = curproc->p_sigacts; 2146 1.290 ad 2147 1.290 ad switch (sa->sa_sigdesc[sig].sd_vers) { 2148 1.400 thorpej case __SIGTRAMP_SIGCODE_VERSION: 2149 1.400 thorpej #ifdef __HAVE_STRUCT_SIGCONTEXT 2150 1.400 thorpej case __SIGTRAMP_SIGCONTEXT_VERSION_MIN ... 2151 1.400 thorpej __SIGTRAMP_SIGCONTEXT_VERSION_MAX: 2152 1.290 ad /* Compat for 1.6 and earlier. */ 2153 1.377 pgoyette MODULE_HOOK_CALL_VOID(sendsig_sigcontext_16_hook, (ksi, mask), 2154 1.377 pgoyette break); 2155 1.290 ad return; 2156 1.400 thorpej #endif /* __HAVE_STRUCT_SIGCONTEXT */ 2157 1.400 thorpej case __SIGTRAMP_SIGINFO_VERSION_MIN ... 2158 1.400 thorpej __SIGTRAMP_SIGINFO_VERSION_MAX: 2159 1.290 ad sendsig_siginfo(ksi, mask); 2160 1.290 ad return; 2161 1.290 ad default: 2162 1.290 ad break; 2163 1.290 ad } 2164 1.290 ad 2165 1.290 ad printf("sendsig: bad version %d\n", sa->sa_sigdesc[sig].sd_vers); 2166 1.290 ad sigexit(curlwp, SIGILL); 2167 1.290 ad } 2168 1.290 ad 2169 1.290 ad /* 2170 1.243 ad * sendsig_reset: 2171 1.133 nathanw * 2172 1.243 ad * Reset the signal action. Called from emulation specific sendsig() 2173 1.243 ad * before unlocking to deliver the signal. 2174 1.29 cgd */ 2175 1.29 cgd void 2176 1.243 ad sendsig_reset(struct lwp *l, int signo) 2177 1.29 cgd { 2178 1.243 ad struct proc *p = l->l_proc; 2179 1.243 ad struct sigacts *ps = p->p_sigacts; 2180 1.29 cgd 2181 1.277 ad KASSERT(mutex_owned(p->p_lock)); 2182 1.106 thorpej 2183 1.243 ad p->p_sigctx.ps_lwp = 0; 2184 1.332 kamil memset(&p->p_sigctx.ps_info, 0, sizeof(p->p_sigctx.ps_info)); 2185 1.243 ad 2186 1.259 ad mutex_enter(&ps->sa_mutex); 2187 1.317 rmind sigplusset(&SIGACTION_PS(ps, signo).sa_mask, &l->l_sigmask); 2188 1.243 ad if (SIGACTION_PS(ps, signo).sa_flags & SA_RESETHAND) { 2189 1.243 ad sigdelset(&p->p_sigctx.ps_sigcatch, signo); 2190 1.243 ad if (signo != SIGCONT && sigprop[signo] & SA_IGNORE) 2191 1.243 ad sigaddset(&p->p_sigctx.ps_sigignore, signo); 2192 1.243 ad SIGACTION_PS(ps, signo).sa_handler = SIG_DFL; 2193 1.29 cgd } 2194 1.259 ad mutex_exit(&ps->sa_mutex); 2195 1.29 cgd } 2196 1.29 cgd 2197 1.29 cgd /* 2198 1.29 cgd * Kill the current process for stated reason. 2199 1.29 cgd */ 2200 1.52 christos void 2201 1.122 manu killproc(struct proc *p, const char *why) 2202 1.29 cgd { 2203 1.276 ad 2204 1.390 ad KASSERT(mutex_owned(&proc_lock)); 2205 1.276 ad 2206 1.29 cgd log(LOG_ERR, "pid %d was killed: %s\n", p->p_pid, why); 2207 1.243 ad uprintf_locked("sorry, pid %d was killed: %s\n", p->p_pid, why); 2208 1.29 cgd psignal(p, SIGKILL); 2209 1.29 cgd } 2210 1.29 cgd 2211 1.29 cgd /* 2212 1.29 cgd * Force the current process to exit with the specified signal, dumping core 2213 1.243 ad * if appropriate. We bypass the normal tests for masked and caught 2214 1.243 ad * signals, allowing unrecoverable failures to terminate the process without 2215 1.243 ad * changing signal state. Mark the accounting record with the signal 2216 1.396 skrll * termination. If dumping core, save the signal number for the debugger. 2217 1.243 ad * Calls exit and does not return. 2218 1.29 cgd */ 2219 1.243 ad void 2220 1.243 ad sigexit(struct lwp *l, int signo) 2221 1.243 ad { 2222 1.323 christos int exitsig, error, docore; 2223 1.243 ad struct proc *p; 2224 1.243 ad struct lwp *t; 2225 1.96 fair 2226 1.243 ad p = l->l_proc; 2227 1.96 fair 2228 1.277 ad KASSERT(mutex_owned(p->p_lock)); 2229 1.408 ad KASSERT(l->l_blcnt == 0); 2230 1.96 fair 2231 1.243 ad /* 2232 1.243 ad * Don't permit coredump() multiple times in the same process. 2233 1.243 ad * Call back into sigexit, where we will be suspended until 2234 1.243 ad * the deed is done. Note that this is a recursive call, but 2235 1.246 pavel * LW_WCORE will prevent us from coming back this way. 2236 1.243 ad */ 2237 1.243 ad if ((p->p_sflag & PS_WCORE) != 0) { 2238 1.243 ad lwp_lock(l); 2239 1.246 pavel l->l_flag |= (LW_WCORE | LW_WEXIT | LW_WSUSPEND); 2240 1.407 ad lwp_need_userret(l); 2241 1.243 ad lwp_unlock(l); 2242 1.277 ad mutex_exit(p->p_lock); 2243 1.243 ad lwp_userret(l); 2244 1.281 ad panic("sigexit 1"); 2245 1.281 ad /* NOTREACHED */ 2246 1.281 ad } 2247 1.281 ad 2248 1.281 ad /* If process is already on the way out, then bail now. */ 2249 1.281 ad if ((p->p_sflag & PS_WEXIT) != 0) { 2250 1.281 ad mutex_exit(p->p_lock); 2251 1.281 ad lwp_exit(l); 2252 1.281 ad panic("sigexit 2"); 2253 1.243 ad /* NOTREACHED */ 2254 1.243 ad } 2255 1.130 thorpej 2256 1.130 thorpej /* 2257 1.243 ad * Prepare all other LWPs for exit. If dumping core, suspend them 2258 1.243 ad * so that their registers are available long enough to be dumped. 2259 1.243 ad */ 2260 1.243 ad if ((docore = (sigprop[signo] & SA_CORE)) != 0) { 2261 1.243 ad p->p_sflag |= PS_WCORE; 2262 1.243 ad for (;;) { 2263 1.243 ad LIST_FOREACH(t, &p->p_lwps, l_sibling) { 2264 1.243 ad lwp_lock(t); 2265 1.243 ad if (t == l) { 2266 1.366 kamil t->l_flag &= 2267 1.366 kamil ~(LW_WSUSPEND | LW_DBGSUSPEND); 2268 1.243 ad lwp_unlock(t); 2269 1.243 ad continue; 2270 1.243 ad } 2271 1.246 pavel t->l_flag |= (LW_WCORE | LW_WEXIT); 2272 1.407 ad lwp_need_userret(t); 2273 1.243 ad lwp_suspend(l, t); 2274 1.243 ad } 2275 1.130 thorpej 2276 1.243 ad if (p->p_nrlwps == 1) 2277 1.243 ad break; 2278 1.130 thorpej 2279 1.243 ad /* 2280 1.243 ad * Kick any LWPs sitting in lwp_wait1(), and wait 2281 1.243 ad * for everyone else to stop before proceeding. 2282 1.243 ad */ 2283 1.243 ad p->p_nlwpwait++; 2284 1.243 ad cv_broadcast(&p->p_lwpcv); 2285 1.277 ad cv_wait(&p->p_lwpcv, p->p_lock); 2286 1.243 ad p->p_nlwpwait--; 2287 1.243 ad } 2288 1.243 ad } 2289 1.130 thorpej 2290 1.243 ad exitsig = signo; 2291 1.243 ad p->p_acflag |= AXSIG; 2292 1.332 kamil memset(&p->p_sigctx.ps_info, 0, sizeof(p->p_sigctx.ps_info)); 2293 1.332 kamil p->p_sigctx.ps_info._signo = signo; 2294 1.332 kamil p->p_sigctx.ps_info._code = SI_NOINFO; 2295 1.130 thorpej 2296 1.243 ad if (docore) { 2297 1.281 ad mutex_exit(p->p_lock); 2298 1.378 pgoyette MODULE_HOOK_CALL(coredump_hook, (l, NULL), enosys(), error); 2299 1.102 sommerfe 2300 1.102 sommerfe if (kern_logsigexit) { 2301 1.224 ad int uid = l->l_cred ? 2302 1.224 ad (int)kauth_cred_geteuid(l->l_cred) : -1; 2303 1.102 sommerfe 2304 1.202 perry if (error) 2305 1.102 sommerfe log(LOG_INFO, lognocoredump, p->p_pid, 2306 1.243 ad p->p_comm, uid, signo, error); 2307 1.102 sommerfe else 2308 1.102 sommerfe log(LOG_INFO, logcoredump, p->p_pid, 2309 1.243 ad p->p_comm, uid, signo); 2310 1.96 fair } 2311 1.96 fair 2312 1.240 elad #ifdef PAX_SEGVGUARD 2313 1.382 ad rw_enter(&exec_lock, RW_WRITER); 2314 1.249 thorpej pax_segvguard(l, p->p_textvp, p->p_comm, true); 2315 1.382 ad rw_exit(&exec_lock); 2316 1.240 elad #endif /* PAX_SEGVGUARD */ 2317 1.382 ad 2318 1.281 ad /* Acquire the sched state mutex. exit1() will release it. */ 2319 1.281 ad mutex_enter(p->p_lock); 2320 1.323 christos if (error == 0) 2321 1.323 christos p->p_sflag |= PS_COREDUMP; 2322 1.29 cgd } 2323 1.96 fair 2324 1.243 ad /* No longer dumping core. */ 2325 1.243 ad p->p_sflag &= ~PS_WCORE; 2326 1.243 ad 2327 1.323 christos exit1(l, 0, exitsig); 2328 1.29 cgd /* NOTREACHED */ 2329 1.29 cgd } 2330 1.29 cgd 2331 1.29 cgd /* 2332 1.391 christos * Since the "real" code may (or may not) be present in loadable module, 2333 1.391 christos * we provide routines here which calls the module hooks. 2334 1.379 pgoyette */ 2335 1.395 pgoyette 2336 1.379 pgoyette int 2337 1.379 pgoyette coredump_netbsd(struct lwp *l, struct coredump_iostate *iocookie) 2338 1.379 pgoyette { 2339 1.395 pgoyette 2340 1.379 pgoyette int retval; 2341 1.379 pgoyette 2342 1.379 pgoyette MODULE_HOOK_CALL(coredump_netbsd_hook, (l, iocookie), ENOSYS, retval); 2343 1.379 pgoyette return retval; 2344 1.379 pgoyette } 2345 1.379 pgoyette 2346 1.395 pgoyette int 2347 1.395 pgoyette coredump_netbsd32(struct lwp *l, struct coredump_iostate *iocookie) 2348 1.395 pgoyette { 2349 1.395 pgoyette 2350 1.395 pgoyette int retval; 2351 1.395 pgoyette 2352 1.395 pgoyette MODULE_HOOK_CALL(coredump_netbsd32_hook, (l, iocookie), ENOSYS, retval); 2353 1.395 pgoyette return retval; 2354 1.395 pgoyette } 2355 1.395 pgoyette 2356 1.391 christos int 2357 1.391 christos coredump_elf32(struct lwp *l, struct coredump_iostate *iocookie) 2358 1.391 christos { 2359 1.391 christos int retval; 2360 1.391 christos 2361 1.391 christos MODULE_HOOK_CALL(coredump_elf32_hook, (l, iocookie), ENOSYS, retval); 2362 1.391 christos return retval; 2363 1.391 christos } 2364 1.391 christos 2365 1.391 christos int 2366 1.391 christos coredump_elf64(struct lwp *l, struct coredump_iostate *iocookie) 2367 1.391 christos { 2368 1.391 christos int retval; 2369 1.391 christos 2370 1.391 christos MODULE_HOOK_CALL(coredump_elf64_hook, (l, iocookie), ENOSYS, retval); 2371 1.391 christos return retval; 2372 1.391 christos } 2373 1.391 christos 2374 1.379 pgoyette /* 2375 1.243 ad * Put process 'p' into the stopped state and optionally, notify the parent. 2376 1.29 cgd */ 2377 1.243 ad void 2378 1.334 christos proc_stop(struct proc *p, int signo) 2379 1.29 cgd { 2380 1.243 ad struct lwp *l; 2381 1.112 lukem 2382 1.277 ad KASSERT(mutex_owned(p->p_lock)); 2383 1.29 cgd 2384 1.59 cgd /* 2385 1.243 ad * First off, set the stopping indicator and bring all sleeping 2386 1.409 andvar * LWPs to a halt so they are included in p->p_nrlwps. We mustn't 2387 1.243 ad * unlock between here and the p->p_nrlwps check below. 2388 1.59 cgd */ 2389 1.362 kamil p->p_sflag |= PS_STOPPING; 2390 1.260 ad membar_producer(); 2391 1.59 cgd 2392 1.272 yamt proc_stop_lwps(p); 2393 1.59 cgd 2394 1.59 cgd /* 2395 1.243 ad * If there are no LWPs available to take the signal, then we 2396 1.243 ad * signal the parent process immediately. Otherwise, the last 2397 1.243 ad * LWP to stop will take care of it. 2398 1.59 cgd */ 2399 1.59 cgd 2400 1.334 christos if (p->p_nrlwps == 0) { 2401 1.340 kamil proc_stop_done(p, PS_NOCLDSTOP); 2402 1.243 ad } else { 2403 1.243 ad /* 2404 1.243 ad * Have the remaining LWPs come to a halt, and trigger 2405 1.243 ad * proc_stop_callout() to ensure that they do. 2406 1.243 ad */ 2407 1.317 rmind LIST_FOREACH(l, &p->p_lwps, l_sibling) { 2408 1.317 rmind sigpost(l, SIG_DFL, SA_STOP, signo); 2409 1.317 rmind } 2410 1.243 ad callout_schedule(&proc_stop_ch, 1); 2411 1.169 hannken } 2412 1.29 cgd } 2413 1.29 cgd 2414 1.29 cgd /* 2415 1.402 andvar * When stopping a process, we do not immediately set sleeping LWPs stopped, 2416 1.243 ad * but wait for them to come to a halt at the kernel-user boundary. This is 2417 1.243 ad * to allow LWPs to release any locks that they may hold before stopping. 2418 1.243 ad * 2419 1.243 ad * Non-interruptable sleeps can be long, and there is the potential for an 2420 1.243 ad * LWP to begin sleeping interruptably soon after the process has been set 2421 1.243 ad * stopping (PS_STOPPING). These LWPs will not notice that the process is 2422 1.243 ad * stopping, and so complete halt of the process and the return of status 2423 1.243 ad * information to the parent could be delayed indefinitely. 2424 1.243 ad * 2425 1.243 ad * To handle this race, proc_stop_callout() runs once per tick while there 2426 1.256 ad * are stopping processes in the system. It sets LWPs that are sleeping 2427 1.243 ad * interruptably into the LSSTOP state. 2428 1.243 ad * 2429 1.243 ad * Note that we are not concerned about keeping all LWPs stopped while the 2430 1.396 skrll * process is stopped: stopped LWPs can awaken briefly to handle signals. 2431 1.243 ad * What we do need to ensure is that all LWPs in a stopping process have 2432 1.243 ad * stopped at least once, so that notification can be sent to the parent 2433 1.243 ad * process. 2434 1.29 cgd */ 2435 1.243 ad static void 2436 1.243 ad proc_stop_callout(void *cookie) 2437 1.29 cgd { 2438 1.248 thorpej bool more, restart; 2439 1.243 ad struct proc *p; 2440 1.29 cgd 2441 1.243 ad (void)cookie; 2442 1.94 bouyer 2443 1.243 ad do { 2444 1.249 thorpej restart = false; 2445 1.249 thorpej more = false; 2446 1.130 thorpej 2447 1.390 ad mutex_enter(&proc_lock); 2448 1.243 ad PROCLIST_FOREACH(p, &allproc) { 2449 1.277 ad mutex_enter(p->p_lock); 2450 1.130 thorpej 2451 1.243 ad if ((p->p_sflag & PS_STOPPING) == 0) { 2452 1.277 ad mutex_exit(p->p_lock); 2453 1.243 ad continue; 2454 1.243 ad } 2455 1.130 thorpej 2456 1.243 ad /* Stop any LWPs sleeping interruptably. */ 2457 1.272 yamt proc_stop_lwps(p); 2458 1.243 ad if (p->p_nrlwps == 0) { 2459 1.243 ad /* 2460 1.243 ad * We brought the process to a halt. 2461 1.243 ad * Mark it as stopped and notify the 2462 1.243 ad * parent. 2463 1.362 kamil * 2464 1.362 kamil * Note that proc_stop_done() will 2465 1.362 kamil * drop p->p_lock briefly. 2466 1.362 kamil * Arrange to restart and check 2467 1.362 kamil * all processes again. 2468 1.243 ad */ 2469 1.362 kamil restart = true; 2470 1.340 kamil proc_stop_done(p, PS_NOCLDSTOP); 2471 1.243 ad } else 2472 1.249 thorpej more = true; 2473 1.130 thorpej 2474 1.277 ad mutex_exit(p->p_lock); 2475 1.243 ad if (restart) 2476 1.243 ad break; 2477 1.243 ad } 2478 1.390 ad mutex_exit(&proc_lock); 2479 1.243 ad } while (restart); 2480 1.185 matt 2481 1.130 thorpej /* 2482 1.243 ad * If we noted processes that are stopping but still have 2483 1.243 ad * running LWPs, then arrange to check again in 1 tick. 2484 1.130 thorpej */ 2485 1.243 ad if (more) 2486 1.243 ad callout_schedule(&proc_stop_ch, 1); 2487 1.108 jdolecek } 2488 1.130 thorpej 2489 1.135 jdolecek /* 2490 1.243 ad * Given a process in state SSTOP, set the state back to SACTIVE and 2491 1.243 ad * move LSSTOP'd LWPs to LSSLEEP or make them runnable. 2492 1.135 jdolecek */ 2493 1.243 ad void 2494 1.243 ad proc_unstop(struct proc *p) 2495 1.135 jdolecek { 2496 1.243 ad struct lwp *l; 2497 1.243 ad int sig; 2498 1.208 cube 2499 1.390 ad KASSERT(mutex_owned(&proc_lock)); 2500 1.277 ad KASSERT(mutex_owned(p->p_lock)); 2501 1.135 jdolecek 2502 1.243 ad p->p_stat = SACTIVE; 2503 1.243 ad p->p_sflag &= ~PS_STOPPING; 2504 1.322 christos sig = p->p_xsig; 2505 1.219 mrg 2506 1.243 ad if (!p->p_waited) 2507 1.243 ad p->p_pptr->p_nstopchild--; 2508 1.173 jdolecek 2509 1.243 ad LIST_FOREACH(l, &p->p_lwps, l_sibling) { 2510 1.243 ad lwp_lock(l); 2511 1.366 kamil if (l->l_stat != LSSTOP || (l->l_flag & LW_DBGSUSPEND) != 0) { 2512 1.243 ad lwp_unlock(l); 2513 1.243 ad continue; 2514 1.171 jdolecek } 2515 1.243 ad if (l->l_wchan == NULL) { 2516 1.243 ad setrunnable(l); 2517 1.243 ad continue; 2518 1.241 enami } 2519 1.246 pavel if (sig && (l->l_flag & LW_SINTR) != 0) { 2520 1.301 rmind setrunnable(l); 2521 1.301 rmind sig = 0; 2522 1.250 ad } else { 2523 1.250 ad l->l_stat = LSSLEEP; 2524 1.250 ad p->p_nrlwps++; 2525 1.243 ad lwp_unlock(l); 2526 1.250 ad } 2527 1.135 jdolecek } 2528 1.29 cgd } 2529 1.126 jdolecek 2530 1.334 christos void 2531 1.358 kamil proc_stoptrace(int trapno, int sysnum, const register_t args[], 2532 1.358 kamil const register_t *ret, int error) 2533 1.334 christos { 2534 1.334 christos struct lwp *l = curlwp; 2535 1.341 kamil struct proc *p = l->l_proc; 2536 1.341 kamil struct sigacts *ps; 2537 1.341 kamil sigset_t *mask; 2538 1.341 kamil sig_t action; 2539 1.341 kamil ksiginfo_t ksi; 2540 1.358 kamil size_t i, sy_narg; 2541 1.341 kamil const int signo = SIGTRAP; 2542 1.341 kamil 2543 1.341 kamil KASSERT((trapno == TRAP_SCE) || (trapno == TRAP_SCX)); 2544 1.358 kamil KASSERT(p->p_pptr != initproc); 2545 1.358 kamil KASSERT(ISSET(p->p_slflag, PSL_TRACED)); 2546 1.358 kamil KASSERT(ISSET(p->p_slflag, PSL_SYSCALL)); 2547 1.358 kamil 2548 1.358 kamil sy_narg = p->p_emul->e_sysent[sysnum].sy_narg; 2549 1.341 kamil 2550 1.341 kamil KSI_INIT_TRAP(&ksi); 2551 1.341 kamil ksi.ksi_lid = l->l_lid; 2552 1.358 kamil ksi.ksi_signo = signo; 2553 1.358 kamil ksi.ksi_code = trapno; 2554 1.358 kamil 2555 1.358 kamil ksi.ksi_sysnum = sysnum; 2556 1.358 kamil if (trapno == TRAP_SCE) { 2557 1.358 kamil ksi.ksi_retval[0] = 0; 2558 1.358 kamil ksi.ksi_retval[1] = 0; 2559 1.358 kamil ksi.ksi_error = 0; 2560 1.358 kamil } else { 2561 1.358 kamil ksi.ksi_retval[0] = ret[0]; 2562 1.358 kamil ksi.ksi_retval[1] = ret[1]; 2563 1.358 kamil ksi.ksi_error = error; 2564 1.358 kamil } 2565 1.358 kamil 2566 1.358 kamil memset(ksi.ksi_args, 0, sizeof(ksi.ksi_args)); 2567 1.358 kamil 2568 1.358 kamil for (i = 0; i < sy_narg; i++) 2569 1.358 kamil ksi.ksi_args[i] = args[i]; 2570 1.334 christos 2571 1.334 christos mutex_enter(p->p_lock); 2572 1.334 christos 2573 1.367 kamil repeat: 2574 1.357 kamil /* 2575 1.359 kamil * If we are exiting, demise now. 2576 1.359 kamil * 2577 1.359 kamil * This avoids notifying tracer and deadlocking. 2578 1.359 kamil */ 2579 1.359 kamil if (__predict_false(ISSET(p->p_sflag, PS_WEXIT))) { 2580 1.359 kamil mutex_exit(p->p_lock); 2581 1.359 kamil lwp_exit(l); 2582 1.359 kamil panic("proc_stoptrace"); 2583 1.359 kamil /* NOTREACHED */ 2584 1.359 kamil } 2585 1.359 kamil 2586 1.359 kamil /* 2587 1.357 kamil * If there's a pending SIGKILL process it immediately. 2588 1.357 kamil */ 2589 1.357 kamil if (p->p_xsig == SIGKILL || 2590 1.357 kamil sigismember(&p->p_sigpend.sp_set, SIGKILL)) { 2591 1.357 kamil mutex_exit(p->p_lock); 2592 1.357 kamil return; 2593 1.357 kamil } 2594 1.357 kamil 2595 1.367 kamil /* 2596 1.367 kamil * If we are no longer traced, abandon this event signal. 2597 1.367 kamil * 2598 1.367 kamil * This avoids killing a process after detaching the debugger. 2599 1.367 kamil */ 2600 1.367 kamil if (__predict_false(!ISSET(p->p_slflag, PSL_TRACED))) { 2601 1.367 kamil mutex_exit(p->p_lock); 2602 1.367 kamil return; 2603 1.367 kamil } 2604 1.367 kamil 2605 1.367 kamil /* 2606 1.367 kamil * The process is already stopping. 2607 1.367 kamil */ 2608 1.367 kamil if ((p->p_sflag & PS_STOPPING) != 0) { 2609 1.370 kamil sigswitch_unlock_and_switch_away(l); 2610 1.367 kamil mutex_enter(p->p_lock); 2611 1.370 kamil goto repeat; 2612 1.367 kamil } 2613 1.367 kamil 2614 1.341 kamil /* Needed for ktrace */ 2615 1.341 kamil ps = p->p_sigacts; 2616 1.341 kamil action = SIGACTION_PS(ps, signo).sa_handler; 2617 1.341 kamil mask = &l->l_sigmask; 2618 1.341 kamil 2619 1.341 kamil p->p_xsig = signo; 2620 1.341 kamil p->p_sigctx.ps_lwp = ksi.ksi_lid; 2621 1.341 kamil p->p_sigctx.ps_info = ksi.ksi_info; 2622 1.369 kamil sigswitch(0, signo, false); 2623 1.341 kamil 2624 1.341 kamil if (ktrpoint(KTR_PSIG)) { 2625 1.341 kamil if (p->p_emul->e_ktrpsig) 2626 1.341 kamil p->p_emul->e_ktrpsig(signo, action, mask, &ksi); 2627 1.341 kamil else 2628 1.341 kamil ktrpsig(signo, action, mask, &ksi); 2629 1.341 kamil } 2630 1.334 christos } 2631 1.334 christos 2632 1.126 jdolecek static int 2633 1.126 jdolecek filt_sigattach(struct knote *kn) 2634 1.126 jdolecek { 2635 1.126 jdolecek struct proc *p = curproc; 2636 1.126 jdolecek 2637 1.274 ad kn->kn_obj = p; 2638 1.301 rmind kn->kn_flags |= EV_CLEAR; /* automatically set */ 2639 1.126 jdolecek 2640 1.277 ad mutex_enter(p->p_lock); 2641 1.401 thorpej klist_insert(&p->p_klist, kn); 2642 1.277 ad mutex_exit(p->p_lock); 2643 1.126 jdolecek 2644 1.301 rmind return 0; 2645 1.126 jdolecek } 2646 1.126 jdolecek 2647 1.126 jdolecek static void 2648 1.126 jdolecek filt_sigdetach(struct knote *kn) 2649 1.126 jdolecek { 2650 1.274 ad struct proc *p = kn->kn_obj; 2651 1.126 jdolecek 2652 1.277 ad mutex_enter(p->p_lock); 2653 1.401 thorpej klist_remove(&p->p_klist, kn); 2654 1.277 ad mutex_exit(p->p_lock); 2655 1.126 jdolecek } 2656 1.126 jdolecek 2657 1.126 jdolecek /* 2658 1.301 rmind * Signal knotes are shared with proc knotes, so we apply a mask to 2659 1.126 jdolecek * the hint in order to differentiate them from process hints. This 2660 1.126 jdolecek * could be avoided by using a signal-specific knote list, but probably 2661 1.126 jdolecek * isn't worth the trouble. 2662 1.126 jdolecek */ 2663 1.126 jdolecek static int 2664 1.126 jdolecek filt_signal(struct knote *kn, long hint) 2665 1.126 jdolecek { 2666 1.126 jdolecek 2667 1.126 jdolecek if (hint & NOTE_SIGNAL) { 2668 1.126 jdolecek hint &= ~NOTE_SIGNAL; 2669 1.126 jdolecek 2670 1.126 jdolecek if (kn->kn_id == hint) 2671 1.126 jdolecek kn->kn_data++; 2672 1.126 jdolecek } 2673 1.126 jdolecek return (kn->kn_data != 0); 2674 1.126 jdolecek } 2675 1.126 jdolecek 2676 1.126 jdolecek const struct filterops sig_filtops = { 2677 1.399 thorpej .f_flags = FILTEROP_MPSAFE, 2678 1.394 christos .f_attach = filt_sigattach, 2679 1.394 christos .f_detach = filt_sigdetach, 2680 1.394 christos .f_event = filt_signal, 2681 1.126 jdolecek }; 2682