kern_sig.c revision 1.232 1 1.232 mrg /* $NetBSD: kern_sig.c,v 1.232 2006/10/28 08:09:31 mrg Exp $ */
2 1.29 cgd
3 1.29 cgd /*
4 1.29 cgd * Copyright (c) 1982, 1986, 1989, 1991, 1993
5 1.29 cgd * The Regents of the University of California. All rights reserved.
6 1.29 cgd * (c) UNIX System Laboratories, Inc.
7 1.29 cgd * All or some portions of this file are derived from material licensed
8 1.29 cgd * to the University of California by American Telephone and Telegraph
9 1.29 cgd * Co. or Unix System Laboratories, Inc. and are reproduced herein with
10 1.29 cgd * the permission of UNIX System Laboratories, Inc.
11 1.29 cgd *
12 1.29 cgd * Redistribution and use in source and binary forms, with or without
13 1.29 cgd * modification, are permitted provided that the following conditions
14 1.29 cgd * are met:
15 1.29 cgd * 1. Redistributions of source code must retain the above copyright
16 1.29 cgd * notice, this list of conditions and the following disclaimer.
17 1.29 cgd * 2. Redistributions in binary form must reproduce the above copyright
18 1.29 cgd * notice, this list of conditions and the following disclaimer in the
19 1.29 cgd * documentation and/or other materials provided with the distribution.
20 1.146 agc * 3. Neither the name of the University nor the names of its contributors
21 1.29 cgd * may be used to endorse or promote products derived from this software
22 1.29 cgd * without specific prior written permission.
23 1.29 cgd *
24 1.29 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
25 1.29 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26 1.29 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27 1.29 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
28 1.29 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
29 1.29 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
30 1.29 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
31 1.29 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
32 1.29 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
33 1.29 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34 1.29 cgd * SUCH DAMAGE.
35 1.29 cgd *
36 1.71 fvdl * @(#)kern_sig.c 8.14 (Berkeley) 5/14/95
37 1.29 cgd */
38 1.116 lukem
39 1.116 lukem #include <sys/cdefs.h>
40 1.232 mrg __KERNEL_RCSID(0, "$NetBSD: kern_sig.c,v 1.232 2006/10/28 08:09:31 mrg Exp $");
41 1.70 mrg
42 1.225 matt #include "opt_coredump.h"
43 1.73 thorpej #include "opt_ktrace.h"
44 1.227 matt #include "opt_ptrace.h"
45 1.222 rjs #include "opt_multiprocessor.h"
46 1.74 thorpej #include "opt_compat_sunos.h"
47 1.158 christos #include "opt_compat_netbsd.h"
48 1.202 perry #include "opt_compat_netbsd32.h"
49 1.29 cgd
50 1.29 cgd #define SIGPROP /* include signal properties table */
51 1.29 cgd #include <sys/param.h>
52 1.29 cgd #include <sys/signalvar.h>
53 1.29 cgd #include <sys/resourcevar.h>
54 1.29 cgd #include <sys/namei.h>
55 1.29 cgd #include <sys/vnode.h>
56 1.29 cgd #include <sys/proc.h>
57 1.29 cgd #include <sys/systm.h>
58 1.29 cgd #include <sys/timeb.h>
59 1.29 cgd #include <sys/times.h>
60 1.29 cgd #include <sys/buf.h>
61 1.29 cgd #include <sys/acct.h>
62 1.29 cgd #include <sys/file.h>
63 1.29 cgd #include <sys/kernel.h>
64 1.29 cgd #include <sys/wait.h>
65 1.29 cgd #include <sys/ktrace.h>
66 1.29 cgd #include <sys/syslog.h>
67 1.29 cgd #include <sys/stat.h>
68 1.29 cgd #include <sys/core.h>
69 1.59 cgd #include <sys/filedesc.h>
70 1.89 thorpej #include <sys/malloc.h>
71 1.89 thorpej #include <sys/pool.h>
72 1.130 thorpej #include <sys/ucontext.h>
73 1.130 thorpej #include <sys/sa.h>
74 1.130 thorpej #include <sys/savar.h>
75 1.118 thorpej #include <sys/exec.h>
76 1.214 elad #include <sys/sysctl.h>
77 1.220 elad #include <sys/kauth.h>
78 1.29 cgd
79 1.32 cgd #include <sys/mount.h>
80 1.32 cgd #include <sys/syscallargs.h>
81 1.32 cgd
82 1.29 cgd #include <machine/cpu.h>
83 1.29 cgd
84 1.29 cgd #include <sys/user.h> /* for coredump */
85 1.52 christos
86 1.196 skrll #include <uvm/uvm.h>
87 1.69 mrg #include <uvm/uvm_extern.h>
88 1.69 mrg
89 1.226 cube #ifdef COREDUMP
90 1.201 christos static int build_corename(struct proc *, char *, const char *, size_t);
91 1.226 cube #endif
92 1.152 christos static void ksiginfo_exithook(struct proc *, void *);
93 1.231 mrg static void ksiginfo_queue(struct proc *, const ksiginfo_t *, ksiginfo_t **);
94 1.231 mrg static ksiginfo_t *ksiginfo_dequeue(struct proc *, int);
95 1.160 christos static void kpsignal2(struct proc *, const ksiginfo_t *, int);
96 1.152 christos
97 1.198 jdolecek sigset_t contsigmask, stopsigmask, sigcantmask;
98 1.29 cgd
99 1.196 skrll struct pool sigacts_pool; /* memory pool for sigacts structures */
100 1.196 skrll
101 1.196 skrll /*
102 1.196 skrll * struct sigacts memory pool allocator.
103 1.196 skrll */
104 1.196 skrll
105 1.196 skrll static void *
106 1.230 christos sigacts_poolpage_alloc(struct pool *pp __unused, int flags)
107 1.196 skrll {
108 1.196 skrll
109 1.204 yamt return (void *)uvm_km_alloc(kernel_map,
110 1.204 yamt (PAGE_SIZE)*2, (PAGE_SIZE)*2,
111 1.204 yamt ((flags & PR_WAITOK) ? 0 : UVM_KMF_NOWAIT | UVM_KMF_TRYLOCK)
112 1.204 yamt | UVM_KMF_WIRED);
113 1.196 skrll }
114 1.196 skrll
115 1.196 skrll static void
116 1.230 christos sigacts_poolpage_free(struct pool *pp __unused, void *v)
117 1.196 skrll {
118 1.204 yamt uvm_km_free(kernel_map, (vaddr_t)v, (PAGE_SIZE)*2, UVM_KMF_WIRED);
119 1.196 skrll }
120 1.196 skrll
121 1.196 skrll static struct pool_allocator sigactspool_allocator = {
122 1.228 christos .pa_alloc = sigacts_poolpage_alloc,
123 1.228 christos .pa_free = sigacts_poolpage_free,
124 1.196 skrll };
125 1.196 skrll
126 1.194 simonb POOL_INIT(siginfo_pool, sizeof(siginfo_t), 0, 0, 0, "siginfo",
127 1.194 simonb &pool_allocator_nointr);
128 1.194 simonb POOL_INIT(ksiginfo_pool, sizeof(ksiginfo_t), 0, 0, 0, "ksiginfo", NULL);
129 1.89 thorpej
130 1.29 cgd /*
131 1.155 christos * Remove and return the first ksiginfo element that matches our requested
132 1.155 christos * signal, or return NULL if one not found.
133 1.152 christos */
134 1.152 christos static ksiginfo_t *
135 1.231 mrg ksiginfo_dequeue(struct proc *p, int signo)
136 1.152 christos {
137 1.155 christos ksiginfo_t *ksi;
138 1.168 pk int s;
139 1.152 christos
140 1.168 pk s = splsoftclock();
141 1.155 christos simple_lock(&p->p_sigctx.ps_silock);
142 1.155 christos CIRCLEQ_FOREACH(ksi, &p->p_sigctx.ps_siginfo, ksi_list) {
143 1.155 christos if (ksi->ksi_signo == signo) {
144 1.155 christos CIRCLEQ_REMOVE(&p->p_sigctx.ps_siginfo, ksi, ksi_list);
145 1.168 pk goto out;
146 1.155 christos }
147 1.152 christos }
148 1.168 pk ksi = NULL;
149 1.168 pk out:
150 1.155 christos simple_unlock(&p->p_sigctx.ps_silock);
151 1.168 pk splx(s);
152 1.168 pk return ksi;
153 1.152 christos }
154 1.152 christos
155 1.155 christos /*
156 1.155 christos * Append a new ksiginfo element to the list of pending ksiginfo's, if
157 1.155 christos * we need to (SA_SIGINFO was requested). We replace non RT signals if
158 1.155 christos * they already existed in the queue and we add new entries for RT signals,
159 1.155 christos * or for non RT signals with non-existing entries.
160 1.155 christos */
161 1.152 christos static void
162 1.231 mrg ksiginfo_queue(struct proc *p, const ksiginfo_t *ksi, ksiginfo_t **newkp)
163 1.152 christos {
164 1.155 christos ksiginfo_t *kp;
165 1.155 christos struct sigaction *sa = &SIGACTION_PS(p->p_sigacts, ksi->ksi_signo);
166 1.167 pk int s;
167 1.152 christos
168 1.155 christos if ((sa->sa_flags & SA_SIGINFO) == 0)
169 1.155 christos return;
170 1.231 mrg
171 1.192 matt /*
172 1.192 matt * If there's no info, don't save it.
173 1.192 matt */
174 1.192 matt if (KSI_EMPTY_P(ksi))
175 1.192 matt return;
176 1.152 christos
177 1.167 pk s = splsoftclock();
178 1.155 christos simple_lock(&p->p_sigctx.ps_silock);
179 1.152 christos #ifdef notyet /* XXX: QUEUING */
180 1.155 christos if (ksi->ksi_signo < SIGRTMIN)
181 1.152 christos #endif
182 1.155 christos {
183 1.155 christos CIRCLEQ_FOREACH(kp, &p->p_sigctx.ps_siginfo, ksi_list) {
184 1.155 christos if (kp->ksi_signo == ksi->ksi_signo) {
185 1.174 jdolecek KSI_COPY(ksi, kp);
186 1.167 pk goto out;
187 1.155 christos }
188 1.155 christos }
189 1.153 christos }
190 1.231 mrg if (newkp && *newkp) {
191 1.231 mrg kp = *newkp;
192 1.231 mrg *newkp = NULL;
193 1.231 mrg } else {
194 1.232 mrg SCHED_ASSERT_UNLOCKED();
195 1.231 mrg kp = pool_get(&ksiginfo_pool, PR_NOWAIT);
196 1.231 mrg if (kp == NULL) {
197 1.157 christos #ifdef DIAGNOSTIC
198 1.231 mrg printf("Out of memory allocating siginfo for pid %d\n",
199 1.231 mrg p->p_pid);
200 1.157 christos #endif
201 1.231 mrg goto out;
202 1.231 mrg }
203 1.157 christos }
204 1.155 christos *kp = *ksi;
205 1.155 christos CIRCLEQ_INSERT_TAIL(&p->p_sigctx.ps_siginfo, kp, ksi_list);
206 1.167 pk out:
207 1.155 christos simple_unlock(&p->p_sigctx.ps_silock);
208 1.167 pk splx(s);
209 1.152 christos }
210 1.152 christos
211 1.152 christos /*
212 1.152 christos * free all pending ksiginfo on exit
213 1.152 christos */
214 1.152 christos static void
215 1.230 christos ksiginfo_exithook(struct proc *p, void *v __unused)
216 1.152 christos {
217 1.168 pk int s;
218 1.152 christos
219 1.168 pk s = splsoftclock();
220 1.155 christos simple_lock(&p->p_sigctx.ps_silock);
221 1.155 christos while (!CIRCLEQ_EMPTY(&p->p_sigctx.ps_siginfo)) {
222 1.155 christos ksiginfo_t *ksi = CIRCLEQ_FIRST(&p->p_sigctx.ps_siginfo);
223 1.155 christos CIRCLEQ_REMOVE(&p->p_sigctx.ps_siginfo, ksi, ksi_list);
224 1.152 christos pool_put(&ksiginfo_pool, ksi);
225 1.152 christos }
226 1.155 christos simple_unlock(&p->p_sigctx.ps_silock);
227 1.168 pk splx(s);
228 1.152 christos }
229 1.152 christos
230 1.152 christos /*
231 1.89 thorpej * Initialize signal-related data structures.
232 1.89 thorpej */
233 1.89 thorpej void
234 1.112 lukem signal_init(void)
235 1.89 thorpej {
236 1.194 simonb
237 1.197 he sigactspool_allocator.pa_pagesz = (PAGE_SIZE)*2;
238 1.197 he
239 1.196 skrll pool_init(&sigacts_pool, sizeof(struct sigacts), 0, 0, 0, "sigapl",
240 1.196 skrll sizeof(struct sigacts) > PAGE_SIZE ?
241 1.196 skrll &sigactspool_allocator : &pool_allocator_nointr);
242 1.196 skrll
243 1.152 christos exithook_establish(ksiginfo_exithook, NULL);
244 1.152 christos exechook_establish(ksiginfo_exithook, NULL);
245 1.89 thorpej }
246 1.89 thorpej
247 1.89 thorpej /*
248 1.109 jdolecek * Create an initial sigctx structure, using the same signal state
249 1.109 jdolecek * as p. If 'share' is set, share the sigctx_proc part, otherwise just
250 1.109 jdolecek * copy it from parent.
251 1.89 thorpej */
252 1.109 jdolecek void
253 1.112 lukem sigactsinit(struct proc *np, struct proc *pp, int share)
254 1.89 thorpej {
255 1.89 thorpej struct sigacts *ps;
256 1.89 thorpej
257 1.109 jdolecek if (share) {
258 1.109 jdolecek np->p_sigacts = pp->p_sigacts;
259 1.109 jdolecek pp->p_sigacts->sa_refcnt++;
260 1.109 jdolecek } else {
261 1.109 jdolecek ps = pool_get(&sigacts_pool, PR_WAITOK);
262 1.109 jdolecek if (pp)
263 1.109 jdolecek memcpy(ps, pp->p_sigacts, sizeof(struct sigacts));
264 1.109 jdolecek else
265 1.109 jdolecek memset(ps, '\0', sizeof(struct sigacts));
266 1.109 jdolecek ps->sa_refcnt = 1;
267 1.109 jdolecek np->p_sigacts = ps;
268 1.109 jdolecek }
269 1.89 thorpej }
270 1.89 thorpej
271 1.89 thorpej /*
272 1.109 jdolecek * Make this process not share its sigctx, maintaining all
273 1.89 thorpej * signal state.
274 1.89 thorpej */
275 1.89 thorpej void
276 1.112 lukem sigactsunshare(struct proc *p)
277 1.89 thorpej {
278 1.109 jdolecek struct sigacts *oldps;
279 1.89 thorpej
280 1.109 jdolecek if (p->p_sigacts->sa_refcnt == 1)
281 1.89 thorpej return;
282 1.89 thorpej
283 1.109 jdolecek oldps = p->p_sigacts;
284 1.109 jdolecek sigactsinit(p, NULL, 0);
285 1.109 jdolecek
286 1.109 jdolecek if (--oldps->sa_refcnt == 0)
287 1.109 jdolecek pool_put(&sigacts_pool, oldps);
288 1.89 thorpej }
289 1.89 thorpej
290 1.89 thorpej /*
291 1.109 jdolecek * Release a sigctx structure.
292 1.89 thorpej */
293 1.89 thorpej void
294 1.195 pk sigactsfree(struct sigacts *ps)
295 1.89 thorpej {
296 1.89 thorpej
297 1.109 jdolecek if (--ps->sa_refcnt > 0)
298 1.89 thorpej return;
299 1.89 thorpej
300 1.89 thorpej pool_put(&sigacts_pool, ps);
301 1.89 thorpej }
302 1.89 thorpej
303 1.79 mycroft int
304 1.112 lukem sigaction1(struct proc *p, int signum, const struct sigaction *nsa,
305 1.162 matt struct sigaction *osa, const void *tramp, int vers)
306 1.79 mycroft {
307 1.112 lukem struct sigacts *ps;
308 1.112 lukem int prop;
309 1.79 mycroft
310 1.112 lukem ps = p->p_sigacts;
311 1.79 mycroft if (signum <= 0 || signum >= NSIG)
312 1.79 mycroft return (EINVAL);
313 1.79 mycroft
314 1.121 thorpej /*
315 1.121 thorpej * Trampoline ABI version 0 is reserved for the legacy
316 1.162 matt * kernel-provided on-stack trampoline. Conversely, if we are
317 1.162 matt * using a non-0 ABI version, we must have a trampoline. Only
318 1.163 christos * validate the vers if a new sigaction was supplied. Emulations
319 1.163 christos * use legacy kernel trampolines with version 0, alternatively
320 1.163 christos * check for that too.
321 1.121 thorpej */
322 1.121 thorpej if ((vers != 0 && tramp == NULL) ||
323 1.161 matt #ifdef SIGTRAMP_VALID
324 1.202 perry (nsa != NULL &&
325 1.202 perry ((vers == 0) ?
326 1.163 christos (p->p_emul->e_sigcode == NULL) :
327 1.163 christos !SIGTRAMP_VALID(vers))) ||
328 1.161 matt #endif
329 1.121 thorpej (vers == 0 && tramp != NULL))
330 1.121 thorpej return (EINVAL);
331 1.121 thorpej
332 1.79 mycroft if (osa)
333 1.109 jdolecek *osa = SIGACTION_PS(ps, signum);
334 1.79 mycroft
335 1.79 mycroft if (nsa) {
336 1.79 mycroft if (nsa->sa_flags & ~SA_ALLBITS)
337 1.79 mycroft return (EINVAL);
338 1.149 kleink
339 1.79 mycroft prop = sigprop[signum];
340 1.79 mycroft if (prop & SA_CANTMASK)
341 1.79 mycroft return (EINVAL);
342 1.79 mycroft
343 1.105 thorpej (void) splsched(); /* XXXSMP */
344 1.109 jdolecek SIGACTION_PS(ps, signum) = *nsa;
345 1.121 thorpej ps->sa_sigdesc[signum].sd_tramp = tramp;
346 1.121 thorpej ps->sa_sigdesc[signum].sd_vers = vers;
347 1.109 jdolecek sigminusset(&sigcantmask, &SIGACTION_PS(ps, signum).sa_mask);
348 1.79 mycroft if ((prop & SA_NORESET) != 0)
349 1.109 jdolecek SIGACTION_PS(ps, signum).sa_flags &= ~SA_RESETHAND;
350 1.79 mycroft if (signum == SIGCHLD) {
351 1.79 mycroft if (nsa->sa_flags & SA_NOCLDSTOP)
352 1.79 mycroft p->p_flag |= P_NOCLDSTOP;
353 1.79 mycroft else
354 1.79 mycroft p->p_flag &= ~P_NOCLDSTOP;
355 1.82 enami if (nsa->sa_flags & SA_NOCLDWAIT) {
356 1.81 christos /*
357 1.81 christos * Paranoia: since SA_NOCLDWAIT is implemented
358 1.81 christos * by reparenting the dying child to PID 1 (and
359 1.112 lukem * trust it to reap the zombie), PID 1 itself
360 1.112 lukem * is forbidden to set SA_NOCLDWAIT.
361 1.81 christos */
362 1.81 christos if (p->p_pid == 1)
363 1.81 christos p->p_flag &= ~P_NOCLDWAIT;
364 1.81 christos else
365 1.81 christos p->p_flag |= P_NOCLDWAIT;
366 1.81 christos } else
367 1.81 christos p->p_flag &= ~P_NOCLDWAIT;
368 1.203 christos
369 1.203 christos if (nsa->sa_handler == SIG_IGN) {
370 1.203 christos /*
371 1.203 christos * Paranoia: same as above.
372 1.203 christos */
373 1.203 christos if (p->p_pid == 1)
374 1.203 christos p->p_flag &= ~P_CLDSIGIGN;
375 1.203 christos else
376 1.203 christos p->p_flag |= P_CLDSIGIGN;
377 1.203 christos } else
378 1.203 christos p->p_flag &= ~P_CLDSIGIGN;
379 1.203 christos
380 1.79 mycroft }
381 1.79 mycroft if ((nsa->sa_flags & SA_NODEFER) == 0)
382 1.109 jdolecek sigaddset(&SIGACTION_PS(ps, signum).sa_mask, signum);
383 1.79 mycroft else
384 1.109 jdolecek sigdelset(&SIGACTION_PS(ps, signum).sa_mask, signum);
385 1.79 mycroft /*
386 1.112 lukem * Set bit in p_sigctx.ps_sigignore for signals that are set to
387 1.112 lukem * SIG_IGN, and for signals set to SIG_DFL where the default is
388 1.112 lukem * to ignore. However, don't put SIGCONT in
389 1.112 lukem * p_sigctx.ps_sigignore, as we have to restart the process.
390 1.112 lukem */
391 1.79 mycroft if (nsa->sa_handler == SIG_IGN ||
392 1.79 mycroft (nsa->sa_handler == SIG_DFL && (prop & SA_IGNORE) != 0)) {
393 1.112 lukem /* never to be seen again */
394 1.112 lukem sigdelset(&p->p_sigctx.ps_siglist, signum);
395 1.112 lukem if (signum != SIGCONT) {
396 1.112 lukem /* easier in psignal */
397 1.112 lukem sigaddset(&p->p_sigctx.ps_sigignore, signum);
398 1.112 lukem }
399 1.109 jdolecek sigdelset(&p->p_sigctx.ps_sigcatch, signum);
400 1.79 mycroft } else {
401 1.109 jdolecek sigdelset(&p->p_sigctx.ps_sigignore, signum);
402 1.79 mycroft if (nsa->sa_handler == SIG_DFL)
403 1.109 jdolecek sigdelset(&p->p_sigctx.ps_sigcatch, signum);
404 1.79 mycroft else
405 1.109 jdolecek sigaddset(&p->p_sigctx.ps_sigcatch, signum);
406 1.79 mycroft }
407 1.79 mycroft (void) spl0();
408 1.79 mycroft }
409 1.79 mycroft
410 1.79 mycroft return (0);
411 1.79 mycroft }
412 1.79 mycroft
413 1.158 christos #ifdef COMPAT_16
414 1.29 cgd /* ARGSUSED */
415 1.52 christos int
416 1.230 christos compat_16_sys___sigaction14(struct lwp *l, void *v, register_t *retval __unused)
417 1.48 thorpej {
418 1.159 nathanw struct compat_16_sys___sigaction14_args /* {
419 1.112 lukem syscallarg(int) signum;
420 1.112 lukem syscallarg(const struct sigaction *) nsa;
421 1.112 lukem syscallarg(struct sigaction *) osa;
422 1.48 thorpej } */ *uap = v;
423 1.130 thorpej struct proc *p;
424 1.112 lukem struct sigaction nsa, osa;
425 1.112 lukem int error;
426 1.29 cgd
427 1.79 mycroft if (SCARG(uap, nsa)) {
428 1.79 mycroft error = copyin(SCARG(uap, nsa), &nsa, sizeof(nsa));
429 1.52 christos if (error)
430 1.29 cgd return (error);
431 1.29 cgd }
432 1.130 thorpej p = l->l_proc;
433 1.79 mycroft error = sigaction1(p, SCARG(uap, signum),
434 1.121 thorpej SCARG(uap, nsa) ? &nsa : 0, SCARG(uap, osa) ? &osa : 0,
435 1.121 thorpej NULL, 0);
436 1.121 thorpej if (error)
437 1.121 thorpej return (error);
438 1.121 thorpej if (SCARG(uap, osa)) {
439 1.121 thorpej error = copyout(&osa, SCARG(uap, osa), sizeof(osa));
440 1.121 thorpej if (error)
441 1.121 thorpej return (error);
442 1.121 thorpej }
443 1.121 thorpej return (0);
444 1.121 thorpej }
445 1.158 christos #endif
446 1.121 thorpej
447 1.121 thorpej /* ARGSUSED */
448 1.121 thorpej int
449 1.230 christos sys___sigaction_sigtramp(struct lwp *l, void *v, register_t *retval __unused)
450 1.121 thorpej {
451 1.121 thorpej struct sys___sigaction_sigtramp_args /* {
452 1.121 thorpej syscallarg(int) signum;
453 1.121 thorpej syscallarg(const struct sigaction *) nsa;
454 1.121 thorpej syscallarg(struct sigaction *) osa;
455 1.121 thorpej syscallarg(void *) tramp;
456 1.121 thorpej syscallarg(int) vers;
457 1.121 thorpej } */ *uap = v;
458 1.130 thorpej struct proc *p = l->l_proc;
459 1.121 thorpej struct sigaction nsa, osa;
460 1.121 thorpej int error;
461 1.121 thorpej
462 1.121 thorpej if (SCARG(uap, nsa)) {
463 1.121 thorpej error = copyin(SCARG(uap, nsa), &nsa, sizeof(nsa));
464 1.121 thorpej if (error)
465 1.121 thorpej return (error);
466 1.121 thorpej }
467 1.121 thorpej error = sigaction1(p, SCARG(uap, signum),
468 1.121 thorpej SCARG(uap, nsa) ? &nsa : 0, SCARG(uap, osa) ? &osa : 0,
469 1.121 thorpej SCARG(uap, tramp), SCARG(uap, vers));
470 1.79 mycroft if (error)
471 1.79 mycroft return (error);
472 1.79 mycroft if (SCARG(uap, osa)) {
473 1.79 mycroft error = copyout(&osa, SCARG(uap, osa), sizeof(osa));
474 1.52 christos if (error)
475 1.29 cgd return (error);
476 1.29 cgd }
477 1.29 cgd return (0);
478 1.29 cgd }
479 1.29 cgd
480 1.29 cgd /*
481 1.29 cgd * Initialize signal state for process 0;
482 1.79 mycroft * set to ignore signals that are ignored by default and disable the signal
483 1.79 mycroft * stack.
484 1.29 cgd */
485 1.29 cgd void
486 1.112 lukem siginit(struct proc *p)
487 1.29 cgd {
488 1.112 lukem struct sigacts *ps;
489 1.112 lukem int signum, prop;
490 1.79 mycroft
491 1.112 lukem ps = p->p_sigacts;
492 1.79 mycroft sigemptyset(&contsigmask);
493 1.79 mycroft sigemptyset(&stopsigmask);
494 1.79 mycroft sigemptyset(&sigcantmask);
495 1.85 mycroft for (signum = 1; signum < NSIG; signum++) {
496 1.79 mycroft prop = sigprop[signum];
497 1.79 mycroft if (prop & SA_CONT)
498 1.79 mycroft sigaddset(&contsigmask, signum);
499 1.79 mycroft if (prop & SA_STOP)
500 1.79 mycroft sigaddset(&stopsigmask, signum);
501 1.79 mycroft if (prop & SA_CANTMASK)
502 1.79 mycroft sigaddset(&sigcantmask, signum);
503 1.79 mycroft if (prop & SA_IGNORE && signum != SIGCONT)
504 1.109 jdolecek sigaddset(&p->p_sigctx.ps_sigignore, signum);
505 1.109 jdolecek sigemptyset(&SIGACTION_PS(ps, signum).sa_mask);
506 1.109 jdolecek SIGACTION_PS(ps, signum).sa_flags = SA_RESTART;
507 1.79 mycroft }
508 1.109 jdolecek sigemptyset(&p->p_sigctx.ps_sigcatch);
509 1.171 jdolecek p->p_sigctx.ps_sigwaited = NULL;
510 1.79 mycroft p->p_flag &= ~P_NOCLDSTOP;
511 1.29 cgd
512 1.79 mycroft /*
513 1.79 mycroft * Reset stack state to the user stack.
514 1.79 mycroft */
515 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_flags = SS_DISABLE;
516 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_size = 0;
517 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_sp = 0;
518 1.89 thorpej
519 1.89 thorpej /* One reference. */
520 1.109 jdolecek ps->sa_refcnt = 1;
521 1.29 cgd }
522 1.29 cgd
523 1.29 cgd /*
524 1.29 cgd * Reset signals for an exec of the specified process.
525 1.29 cgd */
526 1.29 cgd void
527 1.112 lukem execsigs(struct proc *p)
528 1.29 cgd {
529 1.112 lukem struct sigacts *ps;
530 1.112 lukem int signum, prop;
531 1.29 cgd
532 1.115 thorpej sigactsunshare(p);
533 1.115 thorpej
534 1.112 lukem ps = p->p_sigacts;
535 1.115 thorpej
536 1.29 cgd /*
537 1.29 cgd * Reset caught signals. Held signals remain held
538 1.109 jdolecek * through p_sigctx.ps_sigmask (unless they were caught,
539 1.29 cgd * and are now ignored by default).
540 1.29 cgd */
541 1.85 mycroft for (signum = 1; signum < NSIG; signum++) {
542 1.109 jdolecek if (sigismember(&p->p_sigctx.ps_sigcatch, signum)) {
543 1.79 mycroft prop = sigprop[signum];
544 1.79 mycroft if (prop & SA_IGNORE) {
545 1.79 mycroft if ((prop & SA_CONT) == 0)
546 1.112 lukem sigaddset(&p->p_sigctx.ps_sigignore,
547 1.112 lukem signum);
548 1.109 jdolecek sigdelset(&p->p_sigctx.ps_siglist, signum);
549 1.79 mycroft }
550 1.109 jdolecek SIGACTION_PS(ps, signum).sa_handler = SIG_DFL;
551 1.29 cgd }
552 1.109 jdolecek sigemptyset(&SIGACTION_PS(ps, signum).sa_mask);
553 1.109 jdolecek SIGACTION_PS(ps, signum).sa_flags = SA_RESTART;
554 1.29 cgd }
555 1.109 jdolecek sigemptyset(&p->p_sigctx.ps_sigcatch);
556 1.171 jdolecek p->p_sigctx.ps_sigwaited = NULL;
557 1.205 christos
558 1.205 christos /*
559 1.205 christos * Reset no zombies if child dies flag as Solaris does.
560 1.205 christos */
561 1.205 christos p->p_flag &= ~(P_NOCLDWAIT | P_CLDSIGIGN);
562 1.205 christos if (SIGACTION_PS(ps, SIGCHLD).sa_handler == SIG_IGN)
563 1.205 christos SIGACTION_PS(ps, SIGCHLD).sa_handler = SIG_DFL;
564 1.79 mycroft
565 1.29 cgd /*
566 1.29 cgd * Reset stack state to the user stack.
567 1.29 cgd */
568 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_flags = SS_DISABLE;
569 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_size = 0;
570 1.109 jdolecek p->p_sigctx.ps_sigstk.ss_sp = 0;
571 1.29 cgd }
572 1.29 cgd
573 1.79 mycroft int
574 1.112 lukem sigprocmask1(struct proc *p, int how, const sigset_t *nss, sigset_t *oss)
575 1.79 mycroft {
576 1.79 mycroft
577 1.79 mycroft if (oss)
578 1.109 jdolecek *oss = p->p_sigctx.ps_sigmask;
579 1.79 mycroft
580 1.79 mycroft if (nss) {
581 1.105 thorpej (void)splsched(); /* XXXSMP */
582 1.79 mycroft switch (how) {
583 1.79 mycroft case SIG_BLOCK:
584 1.109 jdolecek sigplusset(nss, &p->p_sigctx.ps_sigmask);
585 1.79 mycroft break;
586 1.79 mycroft case SIG_UNBLOCK:
587 1.109 jdolecek sigminusset(nss, &p->p_sigctx.ps_sigmask);
588 1.110 thorpej CHECKSIGS(p);
589 1.79 mycroft break;
590 1.79 mycroft case SIG_SETMASK:
591 1.109 jdolecek p->p_sigctx.ps_sigmask = *nss;
592 1.110 thorpej CHECKSIGS(p);
593 1.79 mycroft break;
594 1.79 mycroft default:
595 1.104 thorpej (void)spl0(); /* XXXSMP */
596 1.79 mycroft return (EINVAL);
597 1.79 mycroft }
598 1.109 jdolecek sigminusset(&sigcantmask, &p->p_sigctx.ps_sigmask);
599 1.104 thorpej (void)spl0(); /* XXXSMP */
600 1.79 mycroft }
601 1.79 mycroft
602 1.79 mycroft return (0);
603 1.79 mycroft }
604 1.202 perry
605 1.29 cgd /*
606 1.29 cgd * Manipulate signal mask.
607 1.29 cgd * Note that we receive new mask, not pointer,
608 1.29 cgd * and return old mask as return value;
609 1.29 cgd * the library stub does the rest.
610 1.29 cgd */
611 1.52 christos int
612 1.230 christos sys___sigprocmask14(struct lwp *l, void *v, register_t *retval __unused)
613 1.48 thorpej {
614 1.79 mycroft struct sys___sigprocmask14_args /* {
615 1.112 lukem syscallarg(int) how;
616 1.112 lukem syscallarg(const sigset_t *) set;
617 1.112 lukem syscallarg(sigset_t *) oset;
618 1.48 thorpej } */ *uap = v;
619 1.130 thorpej struct proc *p;
620 1.112 lukem sigset_t nss, oss;
621 1.112 lukem int error;
622 1.29 cgd
623 1.79 mycroft if (SCARG(uap, set)) {
624 1.79 mycroft error = copyin(SCARG(uap, set), &nss, sizeof(nss));
625 1.79 mycroft if (error)
626 1.79 mycroft return (error);
627 1.79 mycroft }
628 1.130 thorpej p = l->l_proc;
629 1.79 mycroft error = sigprocmask1(p, SCARG(uap, how),
630 1.79 mycroft SCARG(uap, set) ? &nss : 0, SCARG(uap, oset) ? &oss : 0);
631 1.79 mycroft if (error)
632 1.79 mycroft return (error);
633 1.79 mycroft if (SCARG(uap, oset)) {
634 1.79 mycroft error = copyout(&oss, SCARG(uap, oset), sizeof(oss));
635 1.79 mycroft if (error)
636 1.79 mycroft return (error);
637 1.79 mycroft }
638 1.79 mycroft return (0);
639 1.79 mycroft }
640 1.79 mycroft
641 1.79 mycroft void
642 1.112 lukem sigpending1(struct proc *p, sigset_t *ss)
643 1.79 mycroft {
644 1.29 cgd
645 1.109 jdolecek *ss = p->p_sigctx.ps_siglist;
646 1.109 jdolecek sigminusset(&p->p_sigctx.ps_sigmask, ss);
647 1.29 cgd }
648 1.29 cgd
649 1.29 cgd /* ARGSUSED */
650 1.52 christos int
651 1.230 christos sys___sigpending14(struct lwp *l, void *v, register_t *retval __unused)
652 1.29 cgd {
653 1.98 augustss struct sys___sigpending14_args /* {
654 1.112 lukem syscallarg(sigset_t *) set;
655 1.79 mycroft } */ *uap = v;
656 1.130 thorpej struct proc *p;
657 1.130 thorpej sigset_t ss;
658 1.79 mycroft
659 1.130 thorpej p = l->l_proc;
660 1.79 mycroft sigpending1(p, &ss);
661 1.79 mycroft return (copyout(&ss, SCARG(uap, set), sizeof(ss)));
662 1.79 mycroft }
663 1.79 mycroft
664 1.79 mycroft int
665 1.112 lukem sigsuspend1(struct proc *p, const sigset_t *ss)
666 1.79 mycroft {
667 1.112 lukem struct sigacts *ps;
668 1.29 cgd
669 1.112 lukem ps = p->p_sigacts;
670 1.79 mycroft if (ss) {
671 1.79 mycroft /*
672 1.79 mycroft * When returning from sigpause, we want
673 1.79 mycroft * the old mask to be restored after the
674 1.79 mycroft * signal handler has finished. Thus, we
675 1.109 jdolecek * save it here and mark the sigctx structure
676 1.79 mycroft * to indicate this.
677 1.79 mycroft */
678 1.109 jdolecek p->p_sigctx.ps_oldmask = p->p_sigctx.ps_sigmask;
679 1.109 jdolecek p->p_sigctx.ps_flags |= SAS_OLDMASK;
680 1.105 thorpej (void) splsched(); /* XXXSMP */
681 1.109 jdolecek p->p_sigctx.ps_sigmask = *ss;
682 1.110 thorpej CHECKSIGS(p);
683 1.109 jdolecek sigminusset(&sigcantmask, &p->p_sigctx.ps_sigmask);
684 1.104 thorpej (void) spl0(); /* XXXSMP */
685 1.79 mycroft }
686 1.79 mycroft
687 1.79 mycroft while (tsleep((caddr_t) ps, PPAUSE|PCATCH, "pause", 0) == 0)
688 1.145 nathanw /* void */;
689 1.202 perry
690 1.79 mycroft /* always return EINTR rather than ERESTART... */
691 1.79 mycroft return (EINTR);
692 1.29 cgd }
693 1.29 cgd
694 1.29 cgd /*
695 1.29 cgd * Suspend process until signal, providing mask to be set
696 1.29 cgd * in the meantime. Note nonstandard calling convention:
697 1.29 cgd * libc stub passes mask, not pointer, to save a copyin.
698 1.29 cgd */
699 1.29 cgd /* ARGSUSED */
700 1.29 cgd int
701 1.230 christos sys___sigsuspend14(struct lwp *l, void *v, register_t *retval __unused)
702 1.48 thorpej {
703 1.79 mycroft struct sys___sigsuspend14_args /* {
704 1.112 lukem syscallarg(const sigset_t *) set;
705 1.48 thorpej } */ *uap = v;
706 1.130 thorpej struct proc *p;
707 1.112 lukem sigset_t ss;
708 1.112 lukem int error;
709 1.79 mycroft
710 1.79 mycroft if (SCARG(uap, set)) {
711 1.79 mycroft error = copyin(SCARG(uap, set), &ss, sizeof(ss));
712 1.79 mycroft if (error)
713 1.79 mycroft return (error);
714 1.79 mycroft }
715 1.79 mycroft
716 1.130 thorpej p = l->l_proc;
717 1.79 mycroft return (sigsuspend1(p, SCARG(uap, set) ? &ss : 0));
718 1.79 mycroft }
719 1.79 mycroft
720 1.79 mycroft int
721 1.112 lukem sigaltstack1(struct proc *p, const struct sigaltstack *nss,
722 1.112 lukem struct sigaltstack *oss)
723 1.79 mycroft {
724 1.112 lukem
725 1.79 mycroft if (oss)
726 1.109 jdolecek *oss = p->p_sigctx.ps_sigstk;
727 1.79 mycroft
728 1.79 mycroft if (nss) {
729 1.79 mycroft if (nss->ss_flags & ~SS_ALLBITS)
730 1.79 mycroft return (EINVAL);
731 1.79 mycroft
732 1.79 mycroft if (nss->ss_flags & SS_DISABLE) {
733 1.109 jdolecek if (p->p_sigctx.ps_sigstk.ss_flags & SS_ONSTACK)
734 1.79 mycroft return (EINVAL);
735 1.79 mycroft } else {
736 1.79 mycroft if (nss->ss_size < MINSIGSTKSZ)
737 1.79 mycroft return (ENOMEM);
738 1.79 mycroft }
739 1.109 jdolecek p->p_sigctx.ps_sigstk = *nss;
740 1.79 mycroft }
741 1.79 mycroft
742 1.79 mycroft return (0);
743 1.29 cgd }
744 1.29 cgd
745 1.29 cgd /* ARGSUSED */
746 1.52 christos int
747 1.230 christos sys___sigaltstack14(struct lwp *l, void *v, register_t *retval __unused)
748 1.48 thorpej {
749 1.98 augustss struct sys___sigaltstack14_args /* {
750 1.112 lukem syscallarg(const struct sigaltstack *) nss;
751 1.112 lukem syscallarg(struct sigaltstack *) oss;
752 1.48 thorpej } */ *uap = v;
753 1.130 thorpej struct proc *p;
754 1.112 lukem struct sigaltstack nss, oss;
755 1.112 lukem int error;
756 1.29 cgd
757 1.79 mycroft if (SCARG(uap, nss)) {
758 1.79 mycroft error = copyin(SCARG(uap, nss), &nss, sizeof(nss));
759 1.79 mycroft if (error)
760 1.79 mycroft return (error);
761 1.79 mycroft }
762 1.130 thorpej p = l->l_proc;
763 1.79 mycroft error = sigaltstack1(p,
764 1.79 mycroft SCARG(uap, nss) ? &nss : 0, SCARG(uap, oss) ? &oss : 0);
765 1.52 christos if (error)
766 1.29 cgd return (error);
767 1.79 mycroft if (SCARG(uap, oss)) {
768 1.79 mycroft error = copyout(&oss, SCARG(uap, oss), sizeof(oss));
769 1.79 mycroft if (error)
770 1.79 mycroft return (error);
771 1.29 cgd }
772 1.29 cgd return (0);
773 1.29 cgd }
774 1.29 cgd
775 1.29 cgd /* ARGSUSED */
776 1.29 cgd int
777 1.230 christos sys_kill(struct lwp *l, void *v, register_t *retval __unused)
778 1.48 thorpej {
779 1.98 augustss struct sys_kill_args /* {
780 1.112 lukem syscallarg(int) pid;
781 1.112 lukem syscallarg(int) signum;
782 1.48 thorpej } */ *uap = v;
783 1.224 ad struct proc *p;
784 1.148 christos ksiginfo_t ksi;
785 1.223 yamt int signum = SCARG(uap, signum);
786 1.223 yamt int error;
787 1.29 cgd
788 1.223 yamt if ((u_int)signum >= NSIG)
789 1.29 cgd return (EINVAL);
790 1.191 matt KSI_INIT(&ksi);
791 1.223 yamt ksi.ksi_signo = signum;
792 1.148 christos ksi.ksi_code = SI_USER;
793 1.224 ad ksi.ksi_pid = l->l_proc->p_pid;
794 1.224 ad ksi.ksi_uid = kauth_cred_geteuid(l->l_cred);
795 1.32 cgd if (SCARG(uap, pid) > 0) {
796 1.29 cgd /* kill single process */
797 1.32 cgd if ((p = pfind(SCARG(uap, pid))) == NULL)
798 1.29 cgd return (ESRCH);
799 1.224 ad error = kauth_authorize_process(l->l_cred,
800 1.224 ad KAUTH_PROCESS_CANSIGNAL, p, (void *)(uintptr_t)signum,
801 1.224 ad NULL, NULL);
802 1.223 yamt if (error)
803 1.223 yamt return error;
804 1.223 yamt if (signum)
805 1.160 christos kpsignal2(p, &ksi, 1);
806 1.29 cgd return (0);
807 1.29 cgd }
808 1.32 cgd switch (SCARG(uap, pid)) {
809 1.29 cgd case -1: /* broadcast signal */
810 1.224 ad return (killpg1(l, &ksi, 0, 1));
811 1.29 cgd case 0: /* signal own process group */
812 1.224 ad return (killpg1(l, &ksi, 0, 0));
813 1.29 cgd default: /* negative explicit process group */
814 1.224 ad return (killpg1(l, &ksi, -SCARG(uap, pid), 0));
815 1.29 cgd }
816 1.29 cgd /* NOTREACHED */
817 1.29 cgd }
818 1.29 cgd
819 1.29 cgd /*
820 1.29 cgd * Common code for kill process group/broadcast kill.
821 1.29 cgd * cp is calling process.
822 1.29 cgd */
823 1.52 christos int
824 1.224 ad killpg1(struct lwp *l, ksiginfo_t *ksi, int pgid, int all)
825 1.29 cgd {
826 1.224 ad struct proc *p, *cp;
827 1.220 elad kauth_cred_t pc;
828 1.112 lukem struct pgrp *pgrp;
829 1.112 lukem int nfound;
830 1.148 christos int signum = ksi->ksi_signo;
831 1.202 perry
832 1.224 ad cp = l->l_proc;
833 1.224 ad pc = l->l_cred;
834 1.112 lukem nfound = 0;
835 1.91 thorpej if (all) {
836 1.202 perry /*
837 1.202 perry * broadcast
838 1.29 cgd */
839 1.92 thorpej proclist_lock_read();
840 1.199 yamt PROCLIST_FOREACH(p, &allproc) {
841 1.223 yamt if (p->p_pid <= 1 || p->p_flag & P_SYSTEM || p == cp ||
842 1.223 yamt kauth_authorize_process(pc, KAUTH_PROCESS_CANSIGNAL,
843 1.223 yamt p, (void *)(uintptr_t)signum, NULL, NULL) != 0)
844 1.29 cgd continue;
845 1.29 cgd nfound++;
846 1.29 cgd if (signum)
847 1.160 christos kpsignal2(p, ksi, 1);
848 1.29 cgd }
849 1.91 thorpej proclist_unlock_read();
850 1.91 thorpej } else {
851 1.202 perry if (pgid == 0)
852 1.202 perry /*
853 1.29 cgd * zero pgid means send to my process group.
854 1.29 cgd */
855 1.29 cgd pgrp = cp->p_pgrp;
856 1.29 cgd else {
857 1.29 cgd pgrp = pgfind(pgid);
858 1.29 cgd if (pgrp == NULL)
859 1.29 cgd return (ESRCH);
860 1.29 cgd }
861 1.124 matt LIST_FOREACH(p, &pgrp->pg_members, p_pglist) {
862 1.29 cgd if (p->p_pid <= 1 || p->p_flag & P_SYSTEM ||
863 1.223 yamt kauth_authorize_process(pc, KAUTH_PROCESS_CANSIGNAL,
864 1.223 yamt p, (void *)(uintptr_t)signum, NULL, NULL) != 0)
865 1.29 cgd continue;
866 1.29 cgd nfound++;
867 1.90 thorpej if (signum && P_ZOMBIE(p) == 0)
868 1.160 christos kpsignal2(p, ksi, 1);
869 1.29 cgd }
870 1.29 cgd }
871 1.29 cgd return (nfound ? 0 : ESRCH);
872 1.29 cgd }
873 1.29 cgd
874 1.29 cgd /*
875 1.29 cgd * Send a signal to a process group.
876 1.29 cgd */
877 1.29 cgd void
878 1.112 lukem gsignal(int pgid, int signum)
879 1.29 cgd {
880 1.148 christos ksiginfo_t ksi;
881 1.192 matt KSI_INIT_EMPTY(&ksi);
882 1.148 christos ksi.ksi_signo = signum;
883 1.148 christos kgsignal(pgid, &ksi, NULL);
884 1.148 christos }
885 1.148 christos
886 1.148 christos void
887 1.148 christos kgsignal(int pgid, ksiginfo_t *ksi, void *data)
888 1.148 christos {
889 1.29 cgd struct pgrp *pgrp;
890 1.29 cgd
891 1.29 cgd if (pgid && (pgrp = pgfind(pgid)))
892 1.148 christos kpgsignal(pgrp, ksi, data, 0);
893 1.29 cgd }
894 1.29 cgd
895 1.29 cgd /*
896 1.71 fvdl * Send a signal to a process group. If checktty is 1,
897 1.29 cgd * limit to members which have a controlling terminal.
898 1.29 cgd */
899 1.29 cgd void
900 1.148 christos pgsignal(struct pgrp *pgrp, int sig, int checkctty)
901 1.148 christos {
902 1.148 christos ksiginfo_t ksi;
903 1.192 matt KSI_INIT_EMPTY(&ksi);
904 1.148 christos ksi.ksi_signo = sig;
905 1.148 christos kpgsignal(pgrp, &ksi, NULL, checkctty);
906 1.148 christos }
907 1.148 christos
908 1.148 christos void
909 1.148 christos kpgsignal(struct pgrp *pgrp, ksiginfo_t *ksi, void *data, int checkctty)
910 1.29 cgd {
911 1.98 augustss struct proc *p;
912 1.29 cgd
913 1.29 cgd if (pgrp)
914 1.124 matt LIST_FOREACH(p, &pgrp->pg_members, p_pglist)
915 1.29 cgd if (checkctty == 0 || p->p_flag & P_CONTROLT)
916 1.148 christos kpsignal(p, ksi, data);
917 1.29 cgd }
918 1.29 cgd
919 1.29 cgd /*
920 1.29 cgd * Send a signal caused by a trap to the current process.
921 1.29 cgd * If it will be caught immediately, deliver it with correct code.
922 1.29 cgd * Otherwise, post it normally.
923 1.29 cgd */
924 1.148 christos void
925 1.160 christos trapsignal(struct lwp *l, const ksiginfo_t *ksi)
926 1.148 christos {
927 1.130 thorpej struct proc *p;
928 1.130 thorpej struct sigacts *ps;
929 1.148 christos int signum = ksi->ksi_signo;
930 1.29 cgd
931 1.166 thorpej KASSERT(KSI_TRAP_P(ksi));
932 1.166 thorpej
933 1.130 thorpej p = l->l_proc;
934 1.112 lukem ps = p->p_sigacts;
935 1.79 mycroft if ((p->p_flag & P_TRACED) == 0 &&
936 1.109 jdolecek sigismember(&p->p_sigctx.ps_sigcatch, signum) &&
937 1.109 jdolecek !sigismember(&p->p_sigctx.ps_sigmask, signum)) {
938 1.29 cgd p->p_stats->p_ru.ru_nsignals++;
939 1.29 cgd #ifdef KTRACE
940 1.29 cgd if (KTRPOINT(p, KTR_PSIG))
941 1.212 christos ktrpsig(l, signum, SIGACTION_PS(ps, signum).sa_handler,
942 1.157 christos &p->p_sigctx.ps_sigmask, ksi);
943 1.29 cgd #endif
944 1.148 christos kpsendsig(l, ksi, &p->p_sigctx.ps_sigmask);
945 1.105 thorpej (void) splsched(); /* XXXSMP */
946 1.112 lukem sigplusset(&SIGACTION_PS(ps, signum).sa_mask,
947 1.112 lukem &p->p_sigctx.ps_sigmask);
948 1.109 jdolecek if (SIGACTION_PS(ps, signum).sa_flags & SA_RESETHAND) {
949 1.109 jdolecek sigdelset(&p->p_sigctx.ps_sigcatch, signum);
950 1.45 mycroft if (signum != SIGCONT && sigprop[signum] & SA_IGNORE)
951 1.109 jdolecek sigaddset(&p->p_sigctx.ps_sigignore, signum);
952 1.109 jdolecek SIGACTION_PS(ps, signum).sa_handler = SIG_DFL;
953 1.45 mycroft }
954 1.104 thorpej (void) spl0(); /* XXXSMP */
955 1.29 cgd } else {
956 1.152 christos p->p_sigctx.ps_lwp = l->l_lid;
957 1.148 christos /* XXX for core dump/debugger */
958 1.152 christos p->p_sigctx.ps_signo = ksi->ksi_signo;
959 1.152 christos p->p_sigctx.ps_code = ksi->ksi_trap;
960 1.160 christos kpsignal2(p, ksi, 1);
961 1.29 cgd }
962 1.29 cgd }
963 1.29 cgd
964 1.29 cgd /*
965 1.151 christos * Fill in signal information and signal the parent for a child status change.
966 1.151 christos */
967 1.216 christos void
968 1.151 christos child_psignal(struct proc *p, int dolock)
969 1.151 christos {
970 1.151 christos ksiginfo_t ksi;
971 1.151 christos
972 1.191 matt KSI_INIT(&ksi);
973 1.151 christos ksi.ksi_signo = SIGCHLD;
974 1.151 christos ksi.ksi_code = p->p_xstat == SIGCONT ? CLD_CONTINUED : CLD_STOPPED;
975 1.151 christos ksi.ksi_pid = p->p_pid;
976 1.220 elad ksi.ksi_uid = kauth_cred_geteuid(p->p_cred);
977 1.151 christos ksi.ksi_status = p->p_xstat;
978 1.151 christos ksi.ksi_utime = p->p_stats->p_ru.ru_utime.tv_sec;
979 1.151 christos ksi.ksi_stime = p->p_stats->p_ru.ru_stime.tv_sec;
980 1.160 christos kpsignal2(p->p_pptr, &ksi, dolock);
981 1.151 christos }
982 1.151 christos
983 1.151 christos /*
984 1.29 cgd * Send the signal to the process. If the signal has an action, the action
985 1.29 cgd * is usually performed by the target process rather than the caller; we add
986 1.29 cgd * the signal to the set of pending signals for the process.
987 1.29 cgd *
988 1.29 cgd * Exceptions:
989 1.29 cgd * o When a stop signal is sent to a sleeping process that takes the
990 1.29 cgd * default action, the process is stopped without awakening it.
991 1.29 cgd * o SIGCONT restarts stopped processes (or puts them back to sleep)
992 1.29 cgd * regardless of the signal action (eg, blocked or ignored).
993 1.29 cgd *
994 1.29 cgd * Other ignored signals are discarded immediately.
995 1.104 thorpej *
996 1.104 thorpej * XXXSMP: Invoked as psignal() or sched_psignal().
997 1.29 cgd */
998 1.29 cgd void
999 1.148 christos psignal1(struct proc *p, int signum, int dolock)
1000 1.148 christos {
1001 1.165 thorpej ksiginfo_t ksi;
1002 1.165 thorpej
1003 1.192 matt KSI_INIT_EMPTY(&ksi);
1004 1.165 thorpej ksi.ksi_signo = signum;
1005 1.165 thorpej kpsignal2(p, &ksi, dolock);
1006 1.148 christos }
1007 1.148 christos
1008 1.148 christos void
1009 1.160 christos kpsignal1(struct proc *p, ksiginfo_t *ksi, void *data, int dolock)
1010 1.160 christos {
1011 1.165 thorpej
1012 1.164 christos if ((p->p_flag & P_WEXIT) == 0 && data) {
1013 1.160 christos size_t fd;
1014 1.160 christos struct filedesc *fdp = p->p_fd;
1015 1.165 thorpej
1016 1.160 christos ksi->ksi_fd = -1;
1017 1.160 christos for (fd = 0; fd < fdp->fd_nfiles; fd++) {
1018 1.160 christos struct file *fp = fdp->fd_ofiles[fd];
1019 1.160 christos /* XXX: lock? */
1020 1.160 christos if (fp && fp->f_data == data) {
1021 1.160 christos ksi->ksi_fd = fd;
1022 1.160 christos break;
1023 1.160 christos }
1024 1.160 christos }
1025 1.160 christos }
1026 1.160 christos kpsignal2(p, ksi, dolock);
1027 1.160 christos }
1028 1.160 christos
1029 1.202 perry static void
1030 1.160 christos kpsignal2(struct proc *p, const ksiginfo_t *ksi, int dolock)
1031 1.29 cgd {
1032 1.170 christos struct lwp *l, *suspended = NULL;
1033 1.187 cl struct sadata_vp *vp;
1034 1.231 mrg ksiginfo_t *newkp;
1035 1.130 thorpej int s = 0, prop, allsusp;
1036 1.112 lukem sig_t action;
1037 1.148 christos int signum = ksi->ksi_signo;
1038 1.29 cgd
1039 1.79 mycroft #ifdef DIAGNOSTIC
1040 1.79 mycroft if (signum <= 0 || signum >= NSIG)
1041 1.148 christos panic("psignal signal number %d", signum);
1042 1.148 christos
1043 1.104 thorpej /* XXXSMP: works, but icky */
1044 1.229 dogcow if (dolock) {
1045 1.104 thorpej SCHED_ASSERT_UNLOCKED();
1046 1.229 dogcow } else {
1047 1.104 thorpej SCHED_ASSERT_LOCKED();
1048 1.229 dogcow }
1049 1.79 mycroft #endif
1050 1.148 christos
1051 1.183 fvdl /*
1052 1.126 jdolecek * Notify any interested parties in the signal.
1053 1.126 jdolecek */
1054 1.126 jdolecek KNOTE(&p->p_klist, NOTE_SIGNAL | signum);
1055 1.126 jdolecek
1056 1.29 cgd prop = sigprop[signum];
1057 1.29 cgd
1058 1.29 cgd /*
1059 1.29 cgd * If proc is traced, always give parent a chance.
1060 1.29 cgd */
1061 1.198 jdolecek if (p->p_flag & P_TRACED) {
1062 1.198 jdolecek action = SIG_DFL;
1063 1.198 jdolecek
1064 1.198 jdolecek /*
1065 1.198 jdolecek * If the process is being traced and the signal is being
1066 1.198 jdolecek * caught, make sure to save any ksiginfo.
1067 1.198 jdolecek */
1068 1.232 mrg if (sigismember(&p->p_sigctx.ps_sigcatch, signum)) {
1069 1.232 mrg SCHED_ASSERT_UNLOCKED();
1070 1.231 mrg ksiginfo_queue(p, ksi, NULL);
1071 1.232 mrg }
1072 1.198 jdolecek } else {
1073 1.198 jdolecek /*
1074 1.198 jdolecek * If the signal was the result of a trap, reset it
1075 1.198 jdolecek * to default action if it's currently masked, so that it would
1076 1.198 jdolecek * coredump immediatelly instead of spinning repeatedly
1077 1.198 jdolecek * taking the signal.
1078 1.198 jdolecek */
1079 1.198 jdolecek if (KSI_TRAP_P(ksi)
1080 1.198 jdolecek && sigismember(&p->p_sigctx.ps_sigmask, signum)
1081 1.198 jdolecek && !sigismember(&p->p_sigctx.ps_sigcatch, signum)) {
1082 1.198 jdolecek sigdelset(&p->p_sigctx.ps_sigignore, signum);
1083 1.198 jdolecek sigdelset(&p->p_sigctx.ps_sigcatch, signum);
1084 1.198 jdolecek sigdelset(&p->p_sigctx.ps_sigmask, signum);
1085 1.198 jdolecek SIGACTION(p, signum).sa_handler = SIG_DFL;
1086 1.190 matt }
1087 1.198 jdolecek
1088 1.198 jdolecek /*
1089 1.198 jdolecek * If the signal is being ignored,
1090 1.198 jdolecek * then we forget about it immediately.
1091 1.198 jdolecek * (Note: we don't set SIGCONT in p_sigctx.ps_sigignore,
1092 1.198 jdolecek * and if it is set to SIG_IGN,
1093 1.198 jdolecek * action will be SIG_DFL here.)
1094 1.198 jdolecek */
1095 1.198 jdolecek if (sigismember(&p->p_sigctx.ps_sigignore, signum))
1096 1.198 jdolecek return;
1097 1.198 jdolecek if (sigismember(&p->p_sigctx.ps_sigmask, signum))
1098 1.198 jdolecek action = SIG_HOLD;
1099 1.198 jdolecek else if (sigismember(&p->p_sigctx.ps_sigcatch, signum))
1100 1.198 jdolecek action = SIG_CATCH;
1101 1.198 jdolecek else {
1102 1.198 jdolecek action = SIG_DFL;
1103 1.198 jdolecek
1104 1.44 mycroft if (prop & SA_KILL && p->p_nice > NZERO)
1105 1.44 mycroft p->p_nice = NZERO;
1106 1.44 mycroft
1107 1.44 mycroft /*
1108 1.44 mycroft * If sending a tty stop signal to a member of an
1109 1.44 mycroft * orphaned process group, discard the signal here if
1110 1.44 mycroft * the action is default; don't stop the process below
1111 1.44 mycroft * if sleeping, and don't clear any pending SIGCONT.
1112 1.44 mycroft */
1113 1.44 mycroft if (prop & SA_TTYSTOP && p->p_pgrp->pg_jobc == 0)
1114 1.44 mycroft return;
1115 1.44 mycroft }
1116 1.29 cgd }
1117 1.29 cgd
1118 1.29 cgd if (prop & SA_CONT)
1119 1.109 jdolecek sigminusset(&stopsigmask, &p->p_sigctx.ps_siglist);
1120 1.29 cgd
1121 1.44 mycroft if (prop & SA_STOP)
1122 1.109 jdolecek sigminusset(&contsigmask, &p->p_sigctx.ps_siglist);
1123 1.44 mycroft
1124 1.29 cgd /*
1125 1.135 jdolecek * If the signal doesn't have SA_CANTMASK (no override for SIGKILL,
1126 1.171 jdolecek * please!), check if anything waits on it. If yes, save the
1127 1.171 jdolecek * info into provided ps_sigwaited, and wake-up the waiter.
1128 1.135 jdolecek * The signal won't be processed further here.
1129 1.135 jdolecek */
1130 1.135 jdolecek if ((prop & SA_CANTMASK) == 0
1131 1.171 jdolecek && p->p_sigctx.ps_sigwaited
1132 1.171 jdolecek && sigismember(p->p_sigctx.ps_sigwait, signum)
1133 1.152 christos && p->p_stat != SSTOP) {
1134 1.171 jdolecek p->p_sigctx.ps_sigwaited->ksi_info = ksi->ksi_info;
1135 1.171 jdolecek p->p_sigctx.ps_sigwaited = NULL;
1136 1.135 jdolecek if (dolock)
1137 1.135 jdolecek wakeup_one(&p->p_sigctx.ps_sigwait);
1138 1.135 jdolecek else
1139 1.135 jdolecek sched_wakeup(&p->p_sigctx.ps_sigwait);
1140 1.135 jdolecek return;
1141 1.135 jdolecek }
1142 1.135 jdolecek
1143 1.171 jdolecek sigaddset(&p->p_sigctx.ps_siglist, signum);
1144 1.171 jdolecek
1145 1.171 jdolecek /* CHECKSIGS() is "inlined" here. */
1146 1.171 jdolecek p->p_sigctx.ps_sigcheck = 1;
1147 1.171 jdolecek
1148 1.135 jdolecek /*
1149 1.29 cgd * Defer further processing for signals which are held,
1150 1.29 cgd * except that stopped processes must be continued by SIGCONT.
1151 1.29 cgd */
1152 1.152 christos if (action == SIG_HOLD &&
1153 1.152 christos ((prop & SA_CONT) == 0 || p->p_stat != SSTOP)) {
1154 1.232 mrg SCHED_ASSERT_UNLOCKED();
1155 1.231 mrg ksiginfo_queue(p, ksi, NULL);
1156 1.231 mrg return;
1157 1.231 mrg }
1158 1.231 mrg
1159 1.231 mrg /*
1160 1.232 mrg * Allocate a ksiginfo_t incase we need to insert it with the
1161 1.232 mrg * scheduler lock held, but only if this ksiginfo_t isn't empty.
1162 1.231 mrg */
1163 1.232 mrg if (dolock && !KSI_EMPTY_P(ksi)) {
1164 1.232 mrg newkp = pool_get(&ksiginfo_pool, PR_NOWAIT);
1165 1.232 mrg if (newkp == NULL) {
1166 1.231 mrg #ifdef DIAGNOSTIC
1167 1.232 mrg printf("kpsignal2: couldn't allocated from ksiginfo_pool\n");
1168 1.231 mrg #endif
1169 1.232 mrg return;
1170 1.232 mrg }
1171 1.232 mrg } else
1172 1.232 mrg newkp = NULL;
1173 1.231 mrg
1174 1.104 thorpej /* XXXSMP: works, but icky */
1175 1.104 thorpej if (dolock)
1176 1.104 thorpej SCHED_LOCK(s);
1177 1.104 thorpej
1178 1.175 cl if (p->p_flag & P_SA) {
1179 1.175 cl allsusp = 0;
1180 1.187 cl l = NULL;
1181 1.175 cl if (p->p_stat == SACTIVE) {
1182 1.187 cl SLIST_FOREACH(vp, &p->p_sa->sa_vps, savp_next) {
1183 1.187 cl l = vp->savp_lwp;
1184 1.187 cl KDASSERT(l != NULL);
1185 1.187 cl if (l->l_flag & L_SA_IDLE) {
1186 1.187 cl /* wakeup idle LWP */
1187 1.187 cl goto found;
1188 1.187 cl /*NOTREACHED*/
1189 1.187 cl } else if (l->l_flag & L_SA_YIELD) {
1190 1.187 cl /* idle LWP is already waking up */
1191 1.187 cl goto out;
1192 1.187 cl /*NOTREACHED*/
1193 1.187 cl }
1194 1.187 cl }
1195 1.187 cl SLIST_FOREACH(vp, &p->p_sa->sa_vps, savp_next) {
1196 1.187 cl l = vp->savp_lwp;
1197 1.175 cl if (l->l_stat == LSRUN ||
1198 1.175 cl l->l_stat == LSONPROC) {
1199 1.175 cl signotify(p);
1200 1.175 cl goto out;
1201 1.175 cl /*NOTREACHED*/
1202 1.175 cl }
1203 1.202 perry if (l->l_stat == LSSLEEP &&
1204 1.175 cl l->l_flag & L_SINTR) {
1205 1.175 cl /* ok to signal vp lwp */
1206 1.211 chs break;
1207 1.175 cl } else
1208 1.175 cl l = NULL;
1209 1.175 cl }
1210 1.175 cl } else if (p->p_stat == SSTOP) {
1211 1.187 cl SLIST_FOREACH(vp, &p->p_sa->sa_vps, savp_next) {
1212 1.187 cl l = vp->savp_lwp;
1213 1.187 cl if (l->l_stat == LSSLEEP && (l->l_flag & L_SINTR) != 0)
1214 1.187 cl break;
1215 1.175 cl l = NULL;
1216 1.187 cl }
1217 1.175 cl }
1218 1.175 cl } else if (p->p_nrlwps > 0 && (p->p_stat != SSTOP)) {
1219 1.29 cgd /*
1220 1.202 perry * At least one LWP is running or on a run queue.
1221 1.202 perry * The signal will be noticed when one of them returns
1222 1.130 thorpej * to userspace.
1223 1.29 cgd */
1224 1.130 thorpej signotify(p);
1225 1.202 perry /*
1226 1.130 thorpej * The signal will be noticed very soon.
1227 1.29 cgd */
1228 1.130 thorpej goto out;
1229 1.175 cl /*NOTREACHED*/
1230 1.130 thorpej } else {
1231 1.175 cl /*
1232 1.175 cl * Find out if any of the sleeps are interruptable,
1233 1.175 cl * and if all the live LWPs remaining are suspended.
1234 1.175 cl */
1235 1.175 cl allsusp = 1;
1236 1.175 cl LIST_FOREACH(l, &p->p_lwps, l_sibling) {
1237 1.202 perry if (l->l_stat == LSSLEEP &&
1238 1.175 cl l->l_flag & L_SINTR)
1239 1.175 cl break;
1240 1.175 cl if (l->l_stat == LSSUSPENDED)
1241 1.175 cl suspended = l;
1242 1.202 perry else if ((l->l_stat != LSZOMB) &&
1243 1.175 cl (l->l_stat != LSDEAD))
1244 1.144 fvdl allsusp = 0;
1245 1.29 cgd }
1246 1.175 cl }
1247 1.175 cl
1248 1.187 cl found:
1249 1.186 christos switch (p->p_stat) {
1250 1.186 christos case SACTIVE:
1251 1.130 thorpej
1252 1.176 cl if (l != NULL && (p->p_flag & P_TRACED))
1253 1.176 cl goto run;
1254 1.202 perry
1255 1.176 cl /*
1256 1.176 cl * If SIGCONT is default (or ignored) and process is
1257 1.176 cl * asleep, we are finished; the process should not
1258 1.176 cl * be awakened.
1259 1.176 cl */
1260 1.176 cl if ((prop & SA_CONT) && action == SIG_DFL) {
1261 1.176 cl sigdelset(&p->p_sigctx.ps_siglist, signum);
1262 1.176 cl goto done;
1263 1.176 cl }
1264 1.176 cl
1265 1.176 cl /*
1266 1.176 cl * When a sleeping process receives a stop
1267 1.176 cl * signal, process immediately if possible.
1268 1.176 cl */
1269 1.176 cl if ((prop & SA_STOP) && action == SIG_DFL) {
1270 1.29 cgd /*
1271 1.176 cl * If a child holding parent blocked,
1272 1.176 cl * stopping could cause deadlock.
1273 1.29 cgd */
1274 1.176 cl if (p->p_flag & P_PPWAIT) {
1275 1.176 cl goto out;
1276 1.130 thorpej }
1277 1.176 cl sigdelset(&p->p_sigctx.ps_siglist, signum);
1278 1.176 cl p->p_xstat = signum;
1279 1.176 cl if ((p->p_pptr->p_flag & P_NOCLDSTOP) == 0) {
1280 1.104 thorpej /*
1281 1.176 cl * XXXSMP: recursive call; don't lock
1282 1.176 cl * the second time around.
1283 1.104 thorpej */
1284 1.176 cl child_psignal(p, 0);
1285 1.104 thorpej }
1286 1.180 manu proc_stop(p, 1); /* XXXSMP: recurse? */
1287 1.176 cl goto done;
1288 1.176 cl }
1289 1.29 cgd
1290 1.176 cl if (l == NULL) {
1291 1.130 thorpej /*
1292 1.176 cl * Special case: SIGKILL of a process
1293 1.176 cl * which is entirely composed of
1294 1.176 cl * suspended LWPs should succeed. We
1295 1.176 cl * make this happen by unsuspending one of
1296 1.176 cl * them.
1297 1.130 thorpej */
1298 1.187 cl if (allsusp && (signum == SIGKILL)) {
1299 1.176 cl lwp_continue(suspended);
1300 1.187 cl }
1301 1.176 cl goto done;
1302 1.176 cl }
1303 1.176 cl /*
1304 1.176 cl * All other (caught or default) signals
1305 1.176 cl * cause the process to run.
1306 1.176 cl */
1307 1.176 cl goto runfast;
1308 1.176 cl /*NOTREACHED*/
1309 1.186 christos case SSTOP:
1310 1.176 cl /* Process is stopped */
1311 1.176 cl /*
1312 1.176 cl * If traced process is already stopped,
1313 1.176 cl * then no further action is necessary.
1314 1.176 cl */
1315 1.176 cl if (p->p_flag & P_TRACED)
1316 1.176 cl goto done;
1317 1.29 cgd
1318 1.176 cl /*
1319 1.176 cl * Kill signal always sets processes running,
1320 1.176 cl * if possible.
1321 1.176 cl */
1322 1.176 cl if (signum == SIGKILL) {
1323 1.176 cl l = proc_unstop(p);
1324 1.176 cl if (l)
1325 1.176 cl goto runfast;
1326 1.176 cl goto done;
1327 1.176 cl }
1328 1.202 perry
1329 1.176 cl if (prop & SA_CONT) {
1330 1.29 cgd /*
1331 1.176 cl * If SIGCONT is default (or ignored),
1332 1.176 cl * we continue the process but don't
1333 1.176 cl * leave the signal in ps_siglist, as
1334 1.176 cl * it has no further action. If
1335 1.176 cl * SIGCONT is held, we continue the
1336 1.176 cl * process and leave the signal in
1337 1.176 cl * ps_siglist. If the process catches
1338 1.176 cl * SIGCONT, let it handle the signal
1339 1.176 cl * itself. If it isn't waiting on an
1340 1.176 cl * event, then it goes back to run
1341 1.176 cl * state. Otherwise, process goes
1342 1.202 perry * back to sleep state.
1343 1.29 cgd */
1344 1.176 cl if (action == SIG_DFL)
1345 1.202 perry sigdelset(&p->p_sigctx.ps_siglist,
1346 1.176 cl signum);
1347 1.176 cl l = proc_unstop(p);
1348 1.176 cl if (l && (action == SIG_CATCH))
1349 1.176 cl goto runfast;
1350 1.176 cl goto out;
1351 1.176 cl }
1352 1.29 cgd
1353 1.176 cl if (prop & SA_STOP) {
1354 1.29 cgd /*
1355 1.176 cl * Already stopped, don't need to stop again.
1356 1.176 cl * (If we did the shell could get confused.)
1357 1.29 cgd */
1358 1.176 cl sigdelset(&p->p_sigctx.ps_siglist, signum);
1359 1.176 cl goto done;
1360 1.29 cgd }
1361 1.176 cl
1362 1.176 cl /*
1363 1.176 cl * If a lwp is sleeping interruptibly, then
1364 1.176 cl * wake it up; it will run until the kernel
1365 1.176 cl * boundary, where it will stop in issignal(),
1366 1.176 cl * since p->p_stat is still SSTOP. When the
1367 1.176 cl * process is continued, it will be made
1368 1.176 cl * runnable and can look at the signal.
1369 1.176 cl */
1370 1.176 cl if (l)
1371 1.176 cl goto run;
1372 1.176 cl goto out;
1373 1.186 christos case SIDL:
1374 1.186 christos /* Process is being created by fork */
1375 1.186 christos /* XXX: We are not ready to receive signals yet */
1376 1.186 christos goto done;
1377 1.186 christos default:
1378 1.176 cl /* Else what? */
1379 1.176 cl panic("psignal: Invalid process state %d.", p->p_stat);
1380 1.176 cl }
1381 1.29 cgd /*NOTREACHED*/
1382 1.29 cgd
1383 1.112 lukem runfast:
1384 1.152 christos if (action == SIG_CATCH) {
1385 1.231 mrg ksiginfo_queue(p, ksi, &newkp);
1386 1.152 christos action = SIG_HOLD;
1387 1.152 christos }
1388 1.29 cgd /*
1389 1.29 cgd * Raise priority to at least PUSER.
1390 1.29 cgd */
1391 1.130 thorpej if (l->l_priority > PUSER)
1392 1.130 thorpej l->l_priority = PUSER;
1393 1.112 lukem run:
1394 1.152 christos if (action == SIG_CATCH) {
1395 1.231 mrg ksiginfo_queue(p, ksi, &newkp);
1396 1.152 christos action = SIG_HOLD;
1397 1.152 christos }
1398 1.202 perry
1399 1.130 thorpej setrunnable(l); /* XXXSMP: recurse? */
1400 1.112 lukem out:
1401 1.152 christos if (action == SIG_CATCH)
1402 1.231 mrg ksiginfo_queue(p, ksi, &newkp);
1403 1.152 christos done:
1404 1.104 thorpej /* XXXSMP: works, but icky */
1405 1.104 thorpej if (dolock)
1406 1.104 thorpej SCHED_UNLOCK(s);
1407 1.231 mrg
1408 1.231 mrg if (newkp)
1409 1.231 mrg pool_put(&ksiginfo_pool, newkp);
1410 1.29 cgd }
1411 1.29 cgd
1412 1.209 chs siginfo_t *
1413 1.209 chs siginfo_alloc(int flags)
1414 1.209 chs {
1415 1.209 chs
1416 1.209 chs return pool_get(&siginfo_pool, flags);
1417 1.209 chs }
1418 1.209 chs
1419 1.209 chs void
1420 1.209 chs siginfo_free(void *arg)
1421 1.209 chs {
1422 1.209 chs
1423 1.209 chs pool_put(&siginfo_pool, arg);
1424 1.209 chs }
1425 1.209 chs
1426 1.130 thorpej void
1427 1.160 christos kpsendsig(struct lwp *l, const ksiginfo_t *ksi, const sigset_t *mask)
1428 1.130 thorpej {
1429 1.130 thorpej struct proc *p = l->l_proc;
1430 1.130 thorpej struct lwp *le, *li;
1431 1.150 cl siginfo_t *si;
1432 1.150 cl int f;
1433 1.130 thorpej
1434 1.130 thorpej if (p->p_flag & P_SA) {
1435 1.144 fvdl
1436 1.144 fvdl /* XXXUPSXXX What if not on sa_vp ? */
1437 1.144 fvdl
1438 1.150 cl f = l->l_flag & L_SA;
1439 1.202 perry l->l_flag &= ~L_SA;
1440 1.209 chs si = siginfo_alloc(PR_WAITOK);
1441 1.166 thorpej si->_info = ksi->ksi_info;
1442 1.130 thorpej le = li = NULL;
1443 1.166 thorpej if (KSI_TRAP_P(ksi))
1444 1.130 thorpej le = l;
1445 1.130 thorpej else
1446 1.130 thorpej li = l;
1447 1.202 perry if (sa_upcall(l, SA_UPCALL_SIGNAL | SA_UPCALL_DEFER, le, li,
1448 1.209 chs sizeof(*si), si, siginfo_free) != 0) {
1449 1.209 chs siginfo_free(si);
1450 1.228 christos #if 0
1451 1.200 mycroft if (KSI_TRAP_P(ksi))
1452 1.200 mycroft /* XXX What do we do here?? */;
1453 1.228 christos #endif
1454 1.200 mycroft }
1455 1.150 cl l->l_flag |= f;
1456 1.130 thorpej return;
1457 1.130 thorpej }
1458 1.130 thorpej
1459 1.148 christos (*p->p_emul->e_sendsig)(ksi, mask);
1460 1.130 thorpej }
1461 1.130 thorpej
1462 1.213 perry static inline int firstsig(const sigset_t *);
1463 1.79 mycroft
1464 1.213 perry static inline int
1465 1.112 lukem firstsig(const sigset_t *ss)
1466 1.79 mycroft {
1467 1.79 mycroft int sig;
1468 1.79 mycroft
1469 1.79 mycroft sig = ffs(ss->__bits[0]);
1470 1.79 mycroft if (sig != 0)
1471 1.79 mycroft return (sig);
1472 1.79 mycroft #if NSIG > 33
1473 1.79 mycroft sig = ffs(ss->__bits[1]);
1474 1.79 mycroft if (sig != 0)
1475 1.79 mycroft return (sig + 32);
1476 1.79 mycroft #endif
1477 1.79 mycroft #if NSIG > 65
1478 1.79 mycroft sig = ffs(ss->__bits[2]);
1479 1.79 mycroft if (sig != 0)
1480 1.79 mycroft return (sig + 64);
1481 1.79 mycroft #endif
1482 1.79 mycroft #if NSIG > 97
1483 1.79 mycroft sig = ffs(ss->__bits[3]);
1484 1.79 mycroft if (sig != 0)
1485 1.79 mycroft return (sig + 96);
1486 1.79 mycroft #endif
1487 1.79 mycroft return (0);
1488 1.79 mycroft }
1489 1.79 mycroft
1490 1.29 cgd /*
1491 1.29 cgd * If the current process has received a signal (should be caught or cause
1492 1.29 cgd * termination, should interrupt current syscall), return the signal number.
1493 1.29 cgd * Stop signals with default action are processed immediately, then cleared;
1494 1.29 cgd * they aren't returned. This is checked after each entry to the system for
1495 1.29 cgd * a syscall or trap (though this can usually be done without calling issignal
1496 1.29 cgd * by checking the pending signal masks in the CURSIG macro.) The normal call
1497 1.29 cgd * sequence is
1498 1.29 cgd *
1499 1.130 thorpej * while (signum = CURSIG(curlwp))
1500 1.29 cgd * postsig(signum);
1501 1.29 cgd */
1502 1.29 cgd int
1503 1.130 thorpej issignal(struct lwp *l)
1504 1.29 cgd {
1505 1.130 thorpej struct proc *p = l->l_proc;
1506 1.127 scw int s = 0, signum, prop;
1507 1.130 thorpej int dolock = (l->l_flag & L_SINTR) == 0, locked = !dolock;
1508 1.112 lukem sigset_t ss;
1509 1.29 cgd
1510 1.187 cl /* Bail out if we do not own the virtual processor */
1511 1.187 cl if (l->l_flag & L_SA && l->l_savp->savp_lwp != l)
1512 1.187 cl return 0;
1513 1.144 fvdl
1514 1.130 thorpej if (p->p_stat == SSTOP) {
1515 1.130 thorpej /*
1516 1.130 thorpej * The process is stopped/stopping. Stop ourselves now that
1517 1.130 thorpej * we're on the kernel/userspace boundary.
1518 1.130 thorpej */
1519 1.130 thorpej if (dolock)
1520 1.130 thorpej SCHED_LOCK(s);
1521 1.130 thorpej l->l_stat = LSSTOP;
1522 1.130 thorpej p->p_nrlwps--;
1523 1.130 thorpej if (p->p_flag & P_TRACED)
1524 1.130 thorpej goto sigtraceswitch;
1525 1.130 thorpej else
1526 1.130 thorpej goto sigswitch;
1527 1.130 thorpej }
1528 1.29 cgd for (;;) {
1529 1.79 mycroft sigpending1(p, &ss);
1530 1.29 cgd if (p->p_flag & P_PPWAIT)
1531 1.79 mycroft sigminusset(&stopsigmask, &ss);
1532 1.79 mycroft signum = firstsig(&ss);
1533 1.79 mycroft if (signum == 0) { /* no signal to send */
1534 1.109 jdolecek p->p_sigctx.ps_sigcheck = 0;
1535 1.119 christos if (locked && dolock)
1536 1.119 christos SCHED_LOCK(s);
1537 1.29 cgd return (0);
1538 1.79 mycroft }
1539 1.112 lukem /* take the signal! */
1540 1.112 lukem sigdelset(&p->p_sigctx.ps_siglist, signum);
1541 1.42 mycroft
1542 1.29 cgd /*
1543 1.29 cgd * We should see pending but ignored signals
1544 1.29 cgd * only if P_TRACED was on when they were posted.
1545 1.29 cgd */
1546 1.109 jdolecek if (sigismember(&p->p_sigctx.ps_sigignore, signum) &&
1547 1.79 mycroft (p->p_flag & P_TRACED) == 0)
1548 1.29 cgd continue;
1549 1.42 mycroft
1550 1.29 cgd if (p->p_flag & P_TRACED && (p->p_flag & P_PPWAIT) == 0) {
1551 1.29 cgd /*
1552 1.29 cgd * If traced, always stop, and stay
1553 1.29 cgd * stopped until released by the debugger.
1554 1.29 cgd */
1555 1.29 cgd p->p_xstat = signum;
1556 1.184 manu
1557 1.184 manu /* Emulation-specific handling of signal trace */
1558 1.184 manu if ((p->p_emul->e_tracesig != NULL) &&
1559 1.184 manu ((*p->p_emul->e_tracesig)(p, signum) != 0))
1560 1.184 manu goto childresumed;
1561 1.184 manu
1562 1.66 mycroft if ((p->p_flag & P_FSTRACE) == 0)
1563 1.151 christos child_psignal(p, dolock);
1564 1.119 christos if (dolock)
1565 1.119 christos SCHED_LOCK(s);
1566 1.180 manu proc_stop(p, 1);
1567 1.130 thorpej sigtraceswitch:
1568 1.130 thorpej mi_switch(l, NULL);
1569 1.114 nathanw SCHED_ASSERT_UNLOCKED();
1570 1.119 christos if (dolock)
1571 1.119 christos splx(s);
1572 1.119 christos else
1573 1.119 christos dolock = 1;
1574 1.29 cgd
1575 1.184 manu childresumed:
1576 1.29 cgd /*
1577 1.42 mycroft * If we are no longer being traced, or the parent
1578 1.42 mycroft * didn't give us a signal, look for more signals.
1579 1.29 cgd */
1580 1.42 mycroft if ((p->p_flag & P_TRACED) == 0 || p->p_xstat == 0)
1581 1.29 cgd continue;
1582 1.29 cgd
1583 1.29 cgd /*
1584 1.42 mycroft * If the new signal is being masked, look for other
1585 1.42 mycroft * signals.
1586 1.29 cgd */
1587 1.42 mycroft signum = p->p_xstat;
1588 1.130 thorpej p->p_xstat = 0;
1589 1.112 lukem /*
1590 1.112 lukem * `p->p_sigctx.ps_siglist |= mask' is done
1591 1.112 lukem * in setrunnable().
1592 1.112 lukem */
1593 1.109 jdolecek if (sigismember(&p->p_sigctx.ps_sigmask, signum))
1594 1.29 cgd continue;
1595 1.112 lukem /* take the signal! */
1596 1.112 lukem sigdelset(&p->p_sigctx.ps_siglist, signum);
1597 1.29 cgd }
1598 1.29 cgd
1599 1.42 mycroft prop = sigprop[signum];
1600 1.42 mycroft
1601 1.29 cgd /*
1602 1.29 cgd * Decide whether the signal should be returned.
1603 1.29 cgd * Return the signal's number, or fall through
1604 1.29 cgd * to clear it from the pending mask.
1605 1.29 cgd */
1606 1.109 jdolecek switch ((long)SIGACTION(p, signum).sa_handler) {
1607 1.29 cgd
1608 1.33 cgd case (long)SIG_DFL:
1609 1.29 cgd /*
1610 1.29 cgd * Don't take default actions on system processes.
1611 1.29 cgd */
1612 1.29 cgd if (p->p_pid <= 1) {
1613 1.29 cgd #ifdef DIAGNOSTIC
1614 1.29 cgd /*
1615 1.29 cgd * Are you sure you want to ignore SIGSEGV
1616 1.29 cgd * in init? XXX
1617 1.29 cgd */
1618 1.57 christos printf("Process (pid %d) got signal %d\n",
1619 1.29 cgd p->p_pid, signum);
1620 1.29 cgd #endif
1621 1.29 cgd break; /* == ignore */
1622 1.29 cgd }
1623 1.29 cgd /*
1624 1.29 cgd * If there is a pending stop signal to process
1625 1.29 cgd * with default action, stop here,
1626 1.29 cgd * then clear the signal. However,
1627 1.29 cgd * if process is member of an orphaned
1628 1.29 cgd * process group, ignore tty stop signals.
1629 1.29 cgd */
1630 1.29 cgd if (prop & SA_STOP) {
1631 1.29 cgd if (p->p_flag & P_TRACED ||
1632 1.29 cgd (p->p_pgrp->pg_jobc == 0 &&
1633 1.29 cgd prop & SA_TTYSTOP))
1634 1.29 cgd break; /* == ignore */
1635 1.29 cgd p->p_xstat = signum;
1636 1.29 cgd if ((p->p_pptr->p_flag & P_NOCLDSTOP) == 0)
1637 1.151 christos child_psignal(p, dolock);
1638 1.119 christos if (dolock)
1639 1.119 christos SCHED_LOCK(s);
1640 1.180 manu proc_stop(p, 1);
1641 1.130 thorpej sigswitch:
1642 1.130 thorpej mi_switch(l, NULL);
1643 1.104 thorpej SCHED_ASSERT_UNLOCKED();
1644 1.119 christos if (dolock)
1645 1.119 christos splx(s);
1646 1.119 christos else
1647 1.119 christos dolock = 1;
1648 1.29 cgd break;
1649 1.29 cgd } else if (prop & SA_IGNORE) {
1650 1.29 cgd /*
1651 1.29 cgd * Except for SIGCONT, shouldn't get here.
1652 1.29 cgd * Default action is to ignore; drop it.
1653 1.29 cgd */
1654 1.29 cgd break; /* == ignore */
1655 1.29 cgd } else
1656 1.42 mycroft goto keep;
1657 1.29 cgd /*NOTREACHED*/
1658 1.29 cgd
1659 1.33 cgd case (long)SIG_IGN:
1660 1.29 cgd /*
1661 1.29 cgd * Masking above should prevent us ever trying
1662 1.29 cgd * to take action on an ignored signal other
1663 1.29 cgd * than SIGCONT, unless process is traced.
1664 1.29 cgd */
1665 1.128 jdolecek #ifdef DEBUG_ISSIGNAL
1666 1.29 cgd if ((prop & SA_CONT) == 0 &&
1667 1.29 cgd (p->p_flag & P_TRACED) == 0)
1668 1.57 christos printf("issignal\n");
1669 1.128 jdolecek #endif
1670 1.29 cgd break; /* == ignore */
1671 1.29 cgd
1672 1.29 cgd default:
1673 1.29 cgd /*
1674 1.29 cgd * This signal has an action, let
1675 1.29 cgd * postsig() process it.
1676 1.29 cgd */
1677 1.42 mycroft goto keep;
1678 1.29 cgd }
1679 1.29 cgd }
1680 1.29 cgd /* NOTREACHED */
1681 1.42 mycroft
1682 1.112 lukem keep:
1683 1.112 lukem /* leave the signal for later */
1684 1.112 lukem sigaddset(&p->p_sigctx.ps_siglist, signum);
1685 1.110 thorpej CHECKSIGS(p);
1686 1.119 christos if (locked && dolock)
1687 1.119 christos SCHED_LOCK(s);
1688 1.42 mycroft return (signum);
1689 1.29 cgd }
1690 1.29 cgd
1691 1.29 cgd /*
1692 1.29 cgd * Put the argument process into the stopped state and notify the parent
1693 1.29 cgd * via wakeup. Signals are handled elsewhere. The process must not be
1694 1.29 cgd * on the run queue.
1695 1.29 cgd */
1696 1.179 christos void
1697 1.206 christos proc_stop(struct proc *p, int dowakeup)
1698 1.29 cgd {
1699 1.130 thorpej struct lwp *l;
1700 1.178 dsl struct proc *parent;
1701 1.187 cl struct sadata_vp *vp;
1702 1.29 cgd
1703 1.104 thorpej SCHED_ASSERT_LOCKED();
1704 1.104 thorpej
1705 1.130 thorpej /* XXX lock process LWP state */
1706 1.178 dsl p->p_flag &= ~P_WAITED;
1707 1.29 cgd p->p_stat = SSTOP;
1708 1.178 dsl parent = p->p_pptr;
1709 1.178 dsl parent->p_nstopchild++;
1710 1.130 thorpej
1711 1.175 cl if (p->p_flag & P_SA) {
1712 1.175 cl /*
1713 1.175 cl * Only (try to) put the LWP on the VP in stopped
1714 1.202 perry * state.
1715 1.177 cl * All other LWPs will suspend in sa_setwoken()
1716 1.177 cl * because the VP-LWP in stopped state cannot be
1717 1.177 cl * repossessed.
1718 1.175 cl */
1719 1.187 cl SLIST_FOREACH(vp, &p->p_sa->sa_vps, savp_next) {
1720 1.187 cl l = vp->savp_lwp;
1721 1.187 cl if (l->l_stat == LSONPROC && l->l_cpu == curcpu()) {
1722 1.187 cl l->l_stat = LSSTOP;
1723 1.187 cl p->p_nrlwps--;
1724 1.187 cl } else if (l->l_stat == LSRUN) {
1725 1.187 cl /* Remove LWP from the run queue */
1726 1.187 cl remrunqueue(l);
1727 1.187 cl l->l_stat = LSSTOP;
1728 1.187 cl p->p_nrlwps--;
1729 1.187 cl } else if (l->l_stat == LSSLEEP &&
1730 1.187 cl l->l_flag & L_SA_IDLE) {
1731 1.187 cl l->l_flag &= ~L_SA_IDLE;
1732 1.187 cl l->l_stat = LSSTOP;
1733 1.187 cl }
1734 1.175 cl }
1735 1.175 cl goto out;
1736 1.175 cl }
1737 1.175 cl
1738 1.202 perry /*
1739 1.202 perry * Put as many LWP's as possible in stopped state.
1740 1.130 thorpej * Sleeping ones will notice the stopped state as they try to
1741 1.130 thorpej * return to userspace.
1742 1.130 thorpej */
1743 1.175 cl
1744 1.132 jdolecek LIST_FOREACH(l, &p->p_lwps, l_sibling) {
1745 1.175 cl if (l->l_stat == LSONPROC) {
1746 1.130 thorpej /* XXX SMP this assumes that a LWP that is LSONPROC
1747 1.202 perry * is curlwp and hence is about to be mi_switched
1748 1.130 thorpej * away; the only callers of proc_stop() are:
1749 1.130 thorpej * - psignal
1750 1.130 thorpej * - issignal()
1751 1.130 thorpej * For the former, proc_stop() is only called when
1752 1.130 thorpej * no processes are running, so we don't worry.
1753 1.130 thorpej * For the latter, proc_stop() is called right
1754 1.130 thorpej * before mi_switch().
1755 1.130 thorpej */
1756 1.130 thorpej l->l_stat = LSSTOP;
1757 1.130 thorpej p->p_nrlwps--;
1758 1.175 cl } else if (l->l_stat == LSRUN) {
1759 1.130 thorpej /* Remove LWP from the run queue */
1760 1.130 thorpej remrunqueue(l);
1761 1.130 thorpej l->l_stat = LSSTOP;
1762 1.130 thorpej p->p_nrlwps--;
1763 1.130 thorpej } else if ((l->l_stat == LSSLEEP) ||
1764 1.202 perry (l->l_stat == LSSUSPENDED) ||
1765 1.130 thorpej (l->l_stat == LSZOMB) ||
1766 1.130 thorpej (l->l_stat == LSDEAD)) {
1767 1.130 thorpej /*
1768 1.130 thorpej * Don't do anything; let sleeping LWPs
1769 1.130 thorpej * discover the stopped state of the process
1770 1.130 thorpej * on their way out of the kernel; otherwise,
1771 1.130 thorpej * things like NFS threads that sleep with
1772 1.130 thorpej * locks will block the rest of the system
1773 1.130 thorpej * from getting any work done.
1774 1.130 thorpej *
1775 1.130 thorpej * Suspended/dead/zombie LWPs aren't going
1776 1.130 thorpej * anywhere, so we don't need to touch them.
1777 1.130 thorpej */
1778 1.130 thorpej }
1779 1.130 thorpej #ifdef DIAGNOSTIC
1780 1.130 thorpej else {
1781 1.130 thorpej panic("proc_stop: process %d lwp %d "
1782 1.202 perry "in unstoppable state %d.\n",
1783 1.130 thorpej p->p_pid, l->l_lid, l->l_stat);
1784 1.130 thorpej }
1785 1.130 thorpej #endif
1786 1.130 thorpej }
1787 1.175 cl
1788 1.175 cl out:
1789 1.130 thorpej /* XXX unlock process LWP state */
1790 1.144 fvdl
1791 1.206 christos if (dowakeup)
1792 1.180 manu sched_wakeup((caddr_t)p->p_pptr);
1793 1.29 cgd }
1794 1.29 cgd
1795 1.133 nathanw /*
1796 1.202 perry * Given a process in state SSTOP, set the state back to SACTIVE and
1797 1.133 nathanw * move LSSTOP'd LWPs to LSSLEEP or make them runnable.
1798 1.133 nathanw *
1799 1.133 nathanw * If no LWPs ended up runnable (and therefore able to take a signal),
1800 1.133 nathanw * return a LWP that is sleeping interruptably. The caller can wake
1801 1.133 nathanw * that LWP up to take a signal.
1802 1.133 nathanw */
1803 1.130 thorpej struct lwp *
1804 1.139 skrll proc_unstop(struct proc *p)
1805 1.130 thorpej {
1806 1.130 thorpej struct lwp *l, *lr = NULL;
1807 1.187 cl struct sadata_vp *vp;
1808 1.133 nathanw int cantake = 0;
1809 1.130 thorpej
1810 1.130 thorpej SCHED_ASSERT_LOCKED();
1811 1.130 thorpej
1812 1.130 thorpej /*
1813 1.140 nathanw * Our caller wants to be informed if there are only sleeping
1814 1.140 nathanw * and interruptable LWPs left after we have run so that it
1815 1.140 nathanw * can invoke setrunnable() if required - return one of the
1816 1.140 nathanw * interruptable LWPs if this is the case.
1817 1.130 thorpej */
1818 1.130 thorpej
1819 1.178 dsl if (!(p->p_flag & P_WAITED))
1820 1.178 dsl p->p_pptr->p_nstopchild--;
1821 1.130 thorpej p->p_stat = SACTIVE;
1822 1.132 jdolecek LIST_FOREACH(l, &p->p_lwps, l_sibling) {
1823 1.140 nathanw if (l->l_stat == LSRUN) {
1824 1.140 nathanw lr = NULL;
1825 1.133 nathanw cantake = 1;
1826 1.140 nathanw }
1827 1.132 jdolecek if (l->l_stat != LSSTOP)
1828 1.132 jdolecek continue;
1829 1.132 jdolecek
1830 1.133 nathanw if (l->l_wchan != NULL) {
1831 1.133 nathanw l->l_stat = LSSLEEP;
1832 1.133 nathanw if ((cantake == 0) && (l->l_flag & L_SINTR)) {
1833 1.132 jdolecek lr = l;
1834 1.133 nathanw cantake = 1;
1835 1.133 nathanw }
1836 1.133 nathanw } else {
1837 1.140 nathanw setrunnable(l);
1838 1.140 nathanw lr = NULL;
1839 1.133 nathanw cantake = 1;
1840 1.133 nathanw }
1841 1.132 jdolecek }
1842 1.175 cl if (p->p_flag & P_SA) {
1843 1.175 cl /* Only consider returning the LWP on the VP. */
1844 1.187 cl SLIST_FOREACH(vp, &p->p_sa->sa_vps, savp_next) {
1845 1.187 cl lr = vp->savp_lwp;
1846 1.187 cl if (lr->l_stat == LSSLEEP) {
1847 1.187 cl if (lr->l_flag & L_SA_YIELD) {
1848 1.187 cl setrunnable(lr);
1849 1.187 cl break;
1850 1.187 cl } else if (lr->l_flag & L_SINTR)
1851 1.187 cl return lr;
1852 1.187 cl }
1853 1.175 cl }
1854 1.175 cl return NULL;
1855 1.175 cl }
1856 1.130 thorpej return lr;
1857 1.130 thorpej }
1858 1.130 thorpej
1859 1.29 cgd /*
1860 1.29 cgd * Take the action for the specified signal
1861 1.29 cgd * from the current set of pending signals.
1862 1.29 cgd */
1863 1.29 cgd void
1864 1.112 lukem postsig(int signum)
1865 1.29 cgd {
1866 1.130 thorpej struct lwp *l;
1867 1.112 lukem struct proc *p;
1868 1.112 lukem struct sigacts *ps;
1869 1.112 lukem sig_t action;
1870 1.112 lukem sigset_t *returnmask;
1871 1.29 cgd
1872 1.130 thorpej l = curlwp;
1873 1.130 thorpej p = l->l_proc;
1874 1.112 lukem ps = p->p_sigacts;
1875 1.29 cgd #ifdef DIAGNOSTIC
1876 1.29 cgd if (signum == 0)
1877 1.29 cgd panic("postsig");
1878 1.29 cgd #endif
1879 1.106 thorpej
1880 1.130 thorpej KERNEL_PROC_LOCK(l);
1881 1.106 thorpej
1882 1.188 cl #ifdef MULTIPROCESSOR
1883 1.188 cl /*
1884 1.188 cl * On MP, issignal() can return the same signal to multiple
1885 1.188 cl * LWPs. The LWPs will block above waiting for the kernel
1886 1.188 cl * lock and the first LWP which gets through will then remove
1887 1.188 cl * the signal from ps_siglist. All other LWPs exit here.
1888 1.188 cl */
1889 1.188 cl if (!sigismember(&p->p_sigctx.ps_siglist, signum)) {
1890 1.188 cl KERNEL_PROC_UNLOCK(l);
1891 1.188 cl return;
1892 1.188 cl }
1893 1.188 cl #endif
1894 1.109 jdolecek sigdelset(&p->p_sigctx.ps_siglist, signum);
1895 1.109 jdolecek action = SIGACTION_PS(ps, signum).sa_handler;
1896 1.157 christos if (action == SIG_DFL) {
1897 1.29 cgd #ifdef KTRACE
1898 1.157 christos if (KTRPOINT(p, KTR_PSIG))
1899 1.212 christos ktrpsig(l, signum, action,
1900 1.157 christos p->p_sigctx.ps_flags & SAS_OLDMASK ?
1901 1.157 christos &p->p_sigctx.ps_oldmask : &p->p_sigctx.ps_sigmask,
1902 1.157 christos NULL);
1903 1.29 cgd #endif
1904 1.29 cgd /*
1905 1.29 cgd * Default action, where the default is to kill
1906 1.29 cgd * the process. (Other cases were ignored above.)
1907 1.29 cgd */
1908 1.130 thorpej sigexit(l, signum);
1909 1.29 cgd /* NOTREACHED */
1910 1.29 cgd } else {
1911 1.152 christos ksiginfo_t *ksi;
1912 1.29 cgd /*
1913 1.29 cgd * If we get here, the signal must be caught.
1914 1.29 cgd */
1915 1.29 cgd #ifdef DIAGNOSTIC
1916 1.112 lukem if (action == SIG_IGN ||
1917 1.112 lukem sigismember(&p->p_sigctx.ps_sigmask, signum))
1918 1.29 cgd panic("postsig action");
1919 1.29 cgd #endif
1920 1.29 cgd /*
1921 1.29 cgd * Set the new mask value and also defer further
1922 1.138 wiz * occurrences of this signal.
1923 1.29 cgd *
1924 1.29 cgd * Special case: user has done a sigpause. Here the
1925 1.29 cgd * current mask is not of interest, but rather the
1926 1.29 cgd * mask from before the sigpause is what we want
1927 1.29 cgd * restored after the signal processing is completed.
1928 1.29 cgd */
1929 1.109 jdolecek if (p->p_sigctx.ps_flags & SAS_OLDMASK) {
1930 1.109 jdolecek returnmask = &p->p_sigctx.ps_oldmask;
1931 1.109 jdolecek p->p_sigctx.ps_flags &= ~SAS_OLDMASK;
1932 1.29 cgd } else
1933 1.109 jdolecek returnmask = &p->p_sigctx.ps_sigmask;
1934 1.29 cgd p->p_stats->p_ru.ru_nsignals++;
1935 1.231 mrg ksi = ksiginfo_dequeue(p, signum);
1936 1.157 christos #ifdef KTRACE
1937 1.157 christos if (KTRPOINT(p, KTR_PSIG))
1938 1.212 christos ktrpsig(l, signum, action,
1939 1.157 christos p->p_sigctx.ps_flags & SAS_OLDMASK ?
1940 1.157 christos &p->p_sigctx.ps_oldmask : &p->p_sigctx.ps_sigmask,
1941 1.157 christos ksi);
1942 1.157 christos #endif
1943 1.152 christos if (ksi == NULL) {
1944 1.152 christos ksiginfo_t ksi1;
1945 1.152 christos /*
1946 1.152 christos * we did not save any siginfo for this, either
1947 1.152 christos * because the signal was not caught, or because the
1948 1.152 christos * user did not request SA_SIGINFO
1949 1.152 christos */
1950 1.192 matt KSI_INIT_EMPTY(&ksi1);
1951 1.152 christos ksi1.ksi_signo = signum;
1952 1.152 christos kpsendsig(l, &ksi1, returnmask);
1953 1.29 cgd } else {
1954 1.152 christos kpsendsig(l, ksi, returnmask);
1955 1.152 christos pool_put(&ksiginfo_pool, ksi);
1956 1.152 christos }
1957 1.152 christos p->p_sigctx.ps_lwp = 0;
1958 1.152 christos p->p_sigctx.ps_code = 0;
1959 1.152 christos p->p_sigctx.ps_signo = 0;
1960 1.105 thorpej (void) splsched(); /* XXXSMP */
1961 1.112 lukem sigplusset(&SIGACTION_PS(ps, signum).sa_mask,
1962 1.112 lukem &p->p_sigctx.ps_sigmask);
1963 1.109 jdolecek if (SIGACTION_PS(ps, signum).sa_flags & SA_RESETHAND) {
1964 1.109 jdolecek sigdelset(&p->p_sigctx.ps_sigcatch, signum);
1965 1.79 mycroft if (signum != SIGCONT && sigprop[signum] & SA_IGNORE)
1966 1.109 jdolecek sigaddset(&p->p_sigctx.ps_sigignore, signum);
1967 1.109 jdolecek SIGACTION_PS(ps, signum).sa_handler = SIG_DFL;
1968 1.79 mycroft }
1969 1.104 thorpej (void) spl0(); /* XXXSMP */
1970 1.29 cgd }
1971 1.106 thorpej
1972 1.130 thorpej KERNEL_PROC_UNLOCK(l);
1973 1.29 cgd }
1974 1.29 cgd
1975 1.29 cgd /*
1976 1.29 cgd * Kill the current process for stated reason.
1977 1.29 cgd */
1978 1.52 christos void
1979 1.122 manu killproc(struct proc *p, const char *why)
1980 1.29 cgd {
1981 1.29 cgd log(LOG_ERR, "pid %d was killed: %s\n", p->p_pid, why);
1982 1.29 cgd uprintf("sorry, pid %d was killed: %s\n", p->p_pid, why);
1983 1.29 cgd psignal(p, SIGKILL);
1984 1.29 cgd }
1985 1.29 cgd
1986 1.29 cgd /*
1987 1.29 cgd * Force the current process to exit with the specified signal, dumping core
1988 1.29 cgd * if appropriate. We bypass the normal tests for masked and caught signals,
1989 1.29 cgd * allowing unrecoverable failures to terminate the process without changing
1990 1.29 cgd * signal state. Mark the accounting record with the signal termination.
1991 1.29 cgd * If dumping core, save the signal number for the debugger. Calls exit and
1992 1.29 cgd * does not return.
1993 1.29 cgd */
1994 1.96 fair
1995 1.97 fair #if defined(DEBUG)
1996 1.96 fair int kern_logsigexit = 1; /* not static to make public for sysctl */
1997 1.96 fair #else
1998 1.96 fair int kern_logsigexit = 0; /* not static to make public for sysctl */
1999 1.96 fair #endif
2000 1.96 fair
2001 1.102 sommerfe static const char logcoredump[] =
2002 1.96 fair "pid %d (%s), uid %d: exited on signal %d (core dumped)\n";
2003 1.102 sommerfe static const char lognocoredump[] =
2004 1.96 fair "pid %d (%s), uid %d: exited on signal %d (core not dumped, err = %d)\n";
2005 1.96 fair
2006 1.130 thorpej /* Wrapper function for use in p_userret */
2007 1.130 thorpej static void
2008 1.230 christos lwp_coredump_hook(struct lwp *l, void *arg __unused)
2009 1.130 thorpej {
2010 1.130 thorpej int s;
2011 1.130 thorpej
2012 1.130 thorpej /*
2013 1.130 thorpej * Suspend ourselves, so that the kernel stack and therefore
2014 1.130 thorpej * the userland registers saved in the trapframe are around
2015 1.130 thorpej * for coredump() to write them out.
2016 1.130 thorpej */
2017 1.130 thorpej KERNEL_PROC_LOCK(l);
2018 1.130 thorpej l->l_flag &= ~L_DETACHED;
2019 1.130 thorpej SCHED_LOCK(s);
2020 1.130 thorpej l->l_stat = LSSUSPENDED;
2021 1.130 thorpej l->l_proc->p_nrlwps--;
2022 1.130 thorpej /* XXX NJWLWP check if this makes sense here: */
2023 1.202 perry l->l_proc->p_stats->p_ru.ru_nvcsw++;
2024 1.130 thorpej mi_switch(l, NULL);
2025 1.130 thorpej SCHED_ASSERT_UNLOCKED();
2026 1.130 thorpej splx(s);
2027 1.130 thorpej
2028 1.130 thorpej lwp_exit(l);
2029 1.130 thorpej }
2030 1.130 thorpej
2031 1.52 christos void
2032 1.130 thorpej sigexit(struct lwp *l, int signum)
2033 1.29 cgd {
2034 1.130 thorpej struct proc *p;
2035 1.144 fvdl #if 0
2036 1.136 nathanw struct lwp *l2;
2037 1.144 fvdl #endif
2038 1.226 cube int exitsig;
2039 1.226 cube #ifdef COREDUMP
2040 1.226 cube int error;
2041 1.226 cube #endif
2042 1.130 thorpej
2043 1.130 thorpej p = l->l_proc;
2044 1.130 thorpej
2045 1.130 thorpej /*
2046 1.202 perry * Don't permit coredump() or exit1() multiple times
2047 1.130 thorpej * in the same process.
2048 1.130 thorpej */
2049 1.136 nathanw if (p->p_flag & P_WEXIT) {
2050 1.136 nathanw KERNEL_PROC_UNLOCK(l);
2051 1.130 thorpej (*p->p_userret)(l, p->p_userret_arg);
2052 1.136 nathanw }
2053 1.130 thorpej p->p_flag |= P_WEXIT;
2054 1.130 thorpej /* We don't want to switch away from exiting. */
2055 1.130 thorpej /* XXX multiprocessor: stop LWPs on other processors. */
2056 1.144 fvdl #if 0
2057 1.136 nathanw if (p->p_flag & P_SA) {
2058 1.136 nathanw LIST_FOREACH(l2, &p->p_lwps, l_sibling)
2059 1.136 nathanw l2->l_flag &= ~L_SA;
2060 1.130 thorpej p->p_flag &= ~P_SA;
2061 1.130 thorpej }
2062 1.144 fvdl #endif
2063 1.130 thorpej
2064 1.130 thorpej /* Make other LWPs stick around long enough to be dumped */
2065 1.130 thorpej p->p_userret = lwp_coredump_hook;
2066 1.130 thorpej p->p_userret_arg = NULL;
2067 1.96 fair
2068 1.112 lukem exitsig = signum;
2069 1.29 cgd p->p_acflag |= AXSIG;
2070 1.29 cgd if (sigprop[signum] & SA_CORE) {
2071 1.152 christos p->p_sigctx.ps_signo = signum;
2072 1.225 matt #ifdef COREDUMP
2073 1.201 christos if ((error = coredump(l, NULL)) == 0)
2074 1.102 sommerfe exitsig |= WCOREFLAG;
2075 1.225 matt #endif
2076 1.102 sommerfe
2077 1.102 sommerfe if (kern_logsigexit) {
2078 1.123 thorpej /* XXX What if we ever have really large UIDs? */
2079 1.224 ad int uid = l->l_cred ?
2080 1.224 ad (int)kauth_cred_geteuid(l->l_cred) : -1;
2081 1.102 sommerfe
2082 1.226 cube #ifdef COREDUMP
2083 1.202 perry if (error)
2084 1.102 sommerfe log(LOG_INFO, lognocoredump, p->p_pid,
2085 1.102 sommerfe p->p_comm, uid, signum, error);
2086 1.102 sommerfe else
2087 1.226 cube #endif
2088 1.102 sommerfe log(LOG_INFO, logcoredump, p->p_pid,
2089 1.102 sommerfe p->p_comm, uid, signum);
2090 1.96 fair }
2091 1.96 fair
2092 1.29 cgd }
2093 1.96 fair
2094 1.130 thorpej exit1(l, W_EXITCODE(0, exitsig));
2095 1.29 cgd /* NOTREACHED */
2096 1.29 cgd }
2097 1.29 cgd
2098 1.225 matt #ifdef COREDUMP
2099 1.207 matt struct coredump_iostate {
2100 1.212 christos struct lwp *io_lwp;
2101 1.207 matt struct vnode *io_vp;
2102 1.220 elad kauth_cred_t io_cred;
2103 1.207 matt off_t io_offset;
2104 1.207 matt };
2105 1.207 matt
2106 1.207 matt int
2107 1.207 matt coredump_write(void *cookie, enum uio_seg segflg, const void *data, size_t len)
2108 1.207 matt {
2109 1.207 matt struct coredump_iostate *io = cookie;
2110 1.207 matt int error;
2111 1.207 matt
2112 1.207 matt error = vn_rdwr(UIO_WRITE, io->io_vp, __UNCONST(data), len,
2113 1.207 matt io->io_offset, segflg,
2114 1.207 matt IO_NODELOCKED|IO_UNIT, io->io_cred, NULL,
2115 1.212 christos segflg == UIO_USERSPACE ? io->io_lwp : NULL);
2116 1.217 matt if (error) {
2117 1.217 matt printf("pid %d (%s): %s write of %zu@%p at %lld failed: %d\n",
2118 1.217 matt io->io_lwp->l_proc->p_pid, io->io_lwp->l_proc->p_comm,
2119 1.217 matt segflg == UIO_USERSPACE ? "user" : "system",
2120 1.217 matt len, data, (long long) io->io_offset, error);
2121 1.207 matt return (error);
2122 1.217 matt }
2123 1.207 matt
2124 1.207 matt io->io_offset += len;
2125 1.207 matt return (0);
2126 1.207 matt }
2127 1.207 matt
2128 1.29 cgd /*
2129 1.202 perry * Dump core, into a file named "progname.core" or "core" (depending on the
2130 1.75 nathanw * value of shortcorename), unless the process was setuid/setgid.
2131 1.29 cgd */
2132 1.29 cgd int
2133 1.201 christos coredump(struct lwp *l, const char *pattern)
2134 1.29 cgd {
2135 1.112 lukem struct vnode *vp;
2136 1.130 thorpej struct proc *p;
2137 1.112 lukem struct vmspace *vm;
2138 1.220 elad kauth_cred_t cred;
2139 1.112 lukem struct nameidata nd;
2140 1.112 lukem struct vattr vattr;
2141 1.169 hannken struct mount *mp;
2142 1.207 matt struct coredump_iostate io;
2143 1.112 lukem int error, error1;
2144 1.215 yamt char *name = NULL;
2145 1.112 lukem
2146 1.130 thorpej p = l->l_proc;
2147 1.112 lukem vm = p->p_vmspace;
2148 1.224 ad cred = l->l_cred;
2149 1.29 cgd
2150 1.59 cgd /*
2151 1.214 elad * Make sure the process has not set-id, to prevent data leaks,
2152 1.214 elad * unless it was specifically requested to allow set-id coredumps.
2153 1.59 cgd */
2154 1.214 elad if ((p->p_flag & P_SUGID) && !security_setidcore_dump)
2155 1.218 christos return EPERM;
2156 1.59 cgd
2157 1.59 cgd /*
2158 1.59 cgd * Refuse to core if the data + stack + user size is larger than
2159 1.59 cgd * the core dump limit. XXX THIS IS WRONG, because of mapped
2160 1.59 cgd * data.
2161 1.59 cgd */
2162 1.30 deraadt if (USPACE + ctob(vm->vm_dsize + vm->vm_ssize) >=
2163 1.29 cgd p->p_rlimit[RLIMIT_CORE].rlim_cur)
2164 1.218 christos return EFBIG; /* better error code? */
2165 1.59 cgd
2166 1.169 hannken restart:
2167 1.59 cgd /*
2168 1.59 cgd * The core dump will go in the current working directory. Make
2169 1.80 pk * sure that the directory is still there and that the mount flags
2170 1.80 pk * allow us to write core dumps there.
2171 1.59 cgd */
2172 1.88 thorpej vp = p->p_cwdi->cwdi_cdir;
2173 1.80 pk if (vp->v_mount == NULL ||
2174 1.215 yamt (vp->v_mount->mnt_flag & MNT_NOCOREDUMP) != 0) {
2175 1.215 yamt error = EPERM;
2176 1.215 yamt goto done;
2177 1.215 yamt }
2178 1.59 cgd
2179 1.218 christos if ((p->p_flag & P_SUGID) && security_setidcore_dump)
2180 1.214 elad pattern = security_setidcore_path;
2181 1.214 elad
2182 1.201 christos if (pattern == NULL)
2183 1.201 christos pattern = p->p_limit->pl_corename;
2184 1.215 yamt if (name == NULL) {
2185 1.215 yamt name = PNBUF_GET();
2186 1.215 yamt }
2187 1.218 christos if ((error = build_corename(p, name, pattern, MAXPATHLEN)) != 0)
2188 1.215 yamt goto done;
2189 1.212 christos NDINIT(&nd, LOOKUP, NOFOLLOW, UIO_SYSSPACE, name, l);
2190 1.218 christos if ((error = vn_open(&nd, O_CREAT | O_NOFOLLOW | FWRITE,
2191 1.218 christos S_IRUSR | S_IWUSR)) != 0)
2192 1.215 yamt goto done;
2193 1.29 cgd vp = nd.ni_vp;
2194 1.29 cgd
2195 1.169 hannken if (vn_start_write(vp, &mp, V_NOWAIT) != 0) {
2196 1.169 hannken VOP_UNLOCK(vp, 0);
2197 1.218 christos if ((error = vn_close(vp, FWRITE, cred, l)) != 0)
2198 1.215 yamt goto done;
2199 1.169 hannken if ((error = vn_start_write(NULL, &mp,
2200 1.218 christos V_WAIT | V_SLEEPONLY | V_PCATCH)) != 0)
2201 1.215 yamt goto done;
2202 1.169 hannken goto restart;
2203 1.169 hannken }
2204 1.169 hannken
2205 1.29 cgd /* Don't dump to non-regular files or files with links. */
2206 1.29 cgd if (vp->v_type != VREG ||
2207 1.212 christos VOP_GETATTR(vp, &vattr, cred, l) || vattr.va_nlink != 1) {
2208 1.59 cgd error = EINVAL;
2209 1.29 cgd goto out;
2210 1.29 cgd }
2211 1.29 cgd VATTR_NULL(&vattr);
2212 1.29 cgd vattr.va_size = 0;
2213 1.214 elad
2214 1.218 christos if ((p->p_flag & P_SUGID) && security_setidcore_dump) {
2215 1.214 elad vattr.va_uid = security_setidcore_owner;
2216 1.214 elad vattr.va_gid = security_setidcore_group;
2217 1.214 elad vattr.va_mode = security_setidcore_mode;
2218 1.214 elad }
2219 1.214 elad
2220 1.212 christos VOP_LEASE(vp, l, cred, LEASE_WRITE);
2221 1.212 christos VOP_SETATTR(vp, &vattr, cred, l);
2222 1.29 cgd p->p_acflag |= ACORE;
2223 1.95 eeh
2224 1.212 christos io.io_lwp = l;
2225 1.207 matt io.io_vp = vp;
2226 1.207 matt io.io_cred = cred;
2227 1.207 matt io.io_offset = 0;
2228 1.207 matt
2229 1.118 thorpej /* Now dump the actual core file. */
2230 1.207 matt error = (*p->p_execsw->es_coredump)(l, &io);
2231 1.112 lukem out:
2232 1.71 fvdl VOP_UNLOCK(vp, 0);
2233 1.169 hannken vn_finished_write(mp, 0);
2234 1.212 christos error1 = vn_close(vp, FWRITE, cred, l);
2235 1.29 cgd if (error == 0)
2236 1.29 cgd error = error1;
2237 1.215 yamt done:
2238 1.218 christos if (name != NULL)
2239 1.215 yamt PNBUF_PUT(name);
2240 1.218 christos return error;
2241 1.29 cgd }
2242 1.225 matt #endif /* COREDUMP */
2243 1.29 cgd
2244 1.29 cgd /*
2245 1.29 cgd * Nonexistent system call-- signal process (may want to handle it).
2246 1.29 cgd * Flag error in case process won't see signal immediately (blocked or ignored).
2247 1.29 cgd */
2248 1.227 matt #ifndef PTRACE
2249 1.227 matt __weak_alias(sys_ptrace, sys_nosys);
2250 1.227 matt #endif
2251 1.227 matt
2252 1.29 cgd /* ARGSUSED */
2253 1.29 cgd int
2254 1.230 christos sys_nosys(struct lwp *l, void *v __unused, register_t *retval __unused)
2255 1.29 cgd {
2256 1.130 thorpej struct proc *p;
2257 1.29 cgd
2258 1.130 thorpej p = l->l_proc;
2259 1.29 cgd psignal(p, SIGSYS);
2260 1.36 cgd return (ENOSYS);
2261 1.94 bouyer }
2262 1.94 bouyer
2263 1.225 matt #ifdef COREDUMP
2264 1.94 bouyer static int
2265 1.201 christos build_corename(struct proc *p, char *dst, const char *src, size_t len)
2266 1.94 bouyer {
2267 1.112 lukem const char *s;
2268 1.112 lukem char *d, *end;
2269 1.112 lukem int i;
2270 1.202 perry
2271 1.201 christos for (s = src, d = dst, end = d + len; *s != '\0'; s++) {
2272 1.94 bouyer if (*s == '%') {
2273 1.107 enami switch (*(s + 1)) {
2274 1.94 bouyer case 'n':
2275 1.107 enami i = snprintf(d, end - d, "%s", p->p_comm);
2276 1.94 bouyer break;
2277 1.94 bouyer case 'p':
2278 1.107 enami i = snprintf(d, end - d, "%d", p->p_pid);
2279 1.94 bouyer break;
2280 1.94 bouyer case 'u':
2281 1.134 dsl i = snprintf(d, end - d, "%.*s",
2282 1.134 dsl (int)sizeof p->p_pgrp->pg_session->s_login,
2283 1.100 sommerfe p->p_pgrp->pg_session->s_login);
2284 1.94 bouyer break;
2285 1.94 bouyer case 't':
2286 1.107 enami i = snprintf(d, end - d, "%ld",
2287 1.100 sommerfe p->p_stats->p_start.tv_sec);
2288 1.94 bouyer break;
2289 1.94 bouyer default:
2290 1.94 bouyer goto copy;
2291 1.94 bouyer }
2292 1.94 bouyer d += i;
2293 1.94 bouyer s++;
2294 1.94 bouyer } else {
2295 1.112 lukem copy: *d = *s;
2296 1.94 bouyer d++;
2297 1.94 bouyer }
2298 1.107 enami if (d >= end)
2299 1.107 enami return (ENAMETOOLONG);
2300 1.94 bouyer }
2301 1.94 bouyer *d = '\0';
2302 1.130 thorpej return 0;
2303 1.130 thorpej }
2304 1.225 matt #endif /* COREDUMP */
2305 1.130 thorpej
2306 1.130 thorpej void
2307 1.130 thorpej getucontext(struct lwp *l, ucontext_t *ucp)
2308 1.130 thorpej {
2309 1.130 thorpej struct proc *p;
2310 1.130 thorpej
2311 1.130 thorpej p = l->l_proc;
2312 1.130 thorpej
2313 1.130 thorpej ucp->uc_flags = 0;
2314 1.130 thorpej ucp->uc_link = l->l_ctxlink;
2315 1.130 thorpej
2316 1.130 thorpej (void)sigprocmask1(p, 0, NULL, &ucp->uc_sigmask);
2317 1.130 thorpej ucp->uc_flags |= _UC_SIGMASK;
2318 1.130 thorpej
2319 1.130 thorpej /*
2320 1.130 thorpej * The (unsupplied) definition of the `current execution stack'
2321 1.130 thorpej * in the System V Interface Definition appears to allow returning
2322 1.130 thorpej * the main context stack.
2323 1.130 thorpej */
2324 1.130 thorpej if ((p->p_sigctx.ps_sigstk.ss_flags & SS_ONSTACK) == 0) {
2325 1.130 thorpej ucp->uc_stack.ss_sp = (void *)USRSTACK;
2326 1.130 thorpej ucp->uc_stack.ss_size = ctob(p->p_vmspace->vm_ssize);
2327 1.130 thorpej ucp->uc_stack.ss_flags = 0; /* XXX, def. is Very Fishy */
2328 1.130 thorpej } else {
2329 1.130 thorpej /* Simply copy alternate signal execution stack. */
2330 1.130 thorpej ucp->uc_stack = p->p_sigctx.ps_sigstk;
2331 1.130 thorpej }
2332 1.130 thorpej ucp->uc_flags |= _UC_STACK;
2333 1.130 thorpej
2334 1.130 thorpej cpu_getmcontext(l, &ucp->uc_mcontext, &ucp->uc_flags);
2335 1.130 thorpej }
2336 1.130 thorpej
2337 1.130 thorpej /* ARGSUSED */
2338 1.130 thorpej int
2339 1.230 christos sys_getcontext(struct lwp *l, void *v, register_t *retval __unused)
2340 1.130 thorpej {
2341 1.130 thorpej struct sys_getcontext_args /* {
2342 1.130 thorpej syscallarg(struct __ucontext *) ucp;
2343 1.130 thorpej } */ *uap = v;
2344 1.130 thorpej ucontext_t uc;
2345 1.130 thorpej
2346 1.130 thorpej getucontext(l, &uc);
2347 1.130 thorpej
2348 1.130 thorpej return (copyout(&uc, SCARG(uap, ucp), sizeof (*SCARG(uap, ucp))));
2349 1.130 thorpej }
2350 1.130 thorpej
2351 1.130 thorpej int
2352 1.130 thorpej setucontext(struct lwp *l, const ucontext_t *ucp)
2353 1.130 thorpej {
2354 1.130 thorpej struct proc *p;
2355 1.130 thorpej int error;
2356 1.130 thorpej
2357 1.130 thorpej p = l->l_proc;
2358 1.130 thorpej if ((error = cpu_setmcontext(l, &ucp->uc_mcontext, ucp->uc_flags)) != 0)
2359 1.130 thorpej return (error);
2360 1.130 thorpej l->l_ctxlink = ucp->uc_link;
2361 1.185 matt
2362 1.185 matt if ((ucp->uc_flags & _UC_SIGMASK) != 0)
2363 1.185 matt sigprocmask1(p, SIG_SETMASK, &ucp->uc_sigmask, NULL);
2364 1.185 matt
2365 1.130 thorpej /*
2366 1.185 matt * If there was stack information, update whether or not we are
2367 1.185 matt * still running on an alternate signal stack.
2368 1.130 thorpej */
2369 1.185 matt if ((ucp->uc_flags & _UC_STACK) != 0) {
2370 1.185 matt if (ucp->uc_stack.ss_flags & SS_ONSTACK)
2371 1.185 matt p->p_sigctx.ps_sigstk.ss_flags |= SS_ONSTACK;
2372 1.185 matt else
2373 1.185 matt p->p_sigctx.ps_sigstk.ss_flags &= ~SS_ONSTACK;
2374 1.185 matt }
2375 1.130 thorpej
2376 1.130 thorpej return 0;
2377 1.130 thorpej }
2378 1.130 thorpej
2379 1.130 thorpej /* ARGSUSED */
2380 1.130 thorpej int
2381 1.230 christos sys_setcontext(struct lwp *l, void *v, register_t *retval __unused)
2382 1.130 thorpej {
2383 1.130 thorpej struct sys_setcontext_args /* {
2384 1.130 thorpej syscallarg(const ucontext_t *) ucp;
2385 1.130 thorpej } */ *uap = v;
2386 1.130 thorpej ucontext_t uc;
2387 1.130 thorpej int error;
2388 1.130 thorpej
2389 1.130 thorpej if (SCARG(uap, ucp) == NULL) /* i.e. end of uc_link chain */
2390 1.130 thorpej exit1(l, W_EXITCODE(0, 0));
2391 1.130 thorpej else if ((error = copyin(SCARG(uap, ucp), &uc, sizeof (uc))) != 0 ||
2392 1.130 thorpej (error = setucontext(l, &uc)) != 0)
2393 1.130 thorpej return (error);
2394 1.130 thorpej
2395 1.130 thorpej return (EJUSTRETURN);
2396 1.108 jdolecek }
2397 1.130 thorpej
2398 1.135 jdolecek /*
2399 1.135 jdolecek * sigtimedwait(2) system call, used also for implementation
2400 1.135 jdolecek * of sigwaitinfo() and sigwait().
2401 1.135 jdolecek *
2402 1.135 jdolecek * This only handles single LWP in signal wait. libpthread provides
2403 1.135 jdolecek * it's own sigtimedwait() wrapper to DTRT WRT individual threads.
2404 1.135 jdolecek */
2405 1.135 jdolecek int
2406 1.135 jdolecek sys___sigtimedwait(struct lwp *l, void *v, register_t *retval)
2407 1.135 jdolecek {
2408 1.208 cube return __sigtimedwait1(l, v, retval, copyout, copyin, copyout);
2409 1.208 cube }
2410 1.208 cube
2411 1.208 cube int
2412 1.230 christos __sigtimedwait1(struct lwp *l, void *v, register_t *retval __unused,
2413 1.210 cube copyout_t put_info, copyin_t fetch_timeout, copyout_t put_timeout)
2414 1.208 cube {
2415 1.135 jdolecek struct sys___sigtimedwait_args /* {
2416 1.135 jdolecek syscallarg(const sigset_t *) set;
2417 1.135 jdolecek syscallarg(siginfo_t *) info;
2418 1.135 jdolecek syscallarg(struct timespec *) timeout;
2419 1.135 jdolecek } */ *uap = v;
2420 1.173 jdolecek sigset_t *waitset, twaitset;
2421 1.135 jdolecek struct proc *p = l->l_proc;
2422 1.221 kardel int error, signum;
2423 1.135 jdolecek int timo = 0;
2424 1.221 kardel struct timespec ts, tsstart;
2425 1.171 jdolecek ksiginfo_t *ksi;
2426 1.135 jdolecek
2427 1.221 kardel memset(&tsstart, 0, sizeof tsstart); /* XXX gcc */
2428 1.219 mrg
2429 1.173 jdolecek MALLOC(waitset, sigset_t *, sizeof(sigset_t), M_TEMP, M_WAITOK);
2430 1.173 jdolecek
2431 1.173 jdolecek if ((error = copyin(SCARG(uap, set), waitset, sizeof(sigset_t)))) {
2432 1.173 jdolecek FREE(waitset, M_TEMP);
2433 1.135 jdolecek return (error);
2434 1.173 jdolecek }
2435 1.135 jdolecek
2436 1.135 jdolecek /*
2437 1.135 jdolecek * Silently ignore SA_CANTMASK signals. psignal1() would
2438 1.135 jdolecek * ignore SA_CANTMASK signals in waitset, we do this
2439 1.135 jdolecek * only for the below siglist check.
2440 1.135 jdolecek */
2441 1.173 jdolecek sigminusset(&sigcantmask, waitset);
2442 1.135 jdolecek
2443 1.135 jdolecek /*
2444 1.135 jdolecek * First scan siglist and check if there is signal from
2445 1.135 jdolecek * our waitset already pending.
2446 1.135 jdolecek */
2447 1.173 jdolecek twaitset = *waitset;
2448 1.135 jdolecek __sigandset(&p->p_sigctx.ps_siglist, &twaitset);
2449 1.135 jdolecek if ((signum = firstsig(&twaitset))) {
2450 1.135 jdolecek /* found pending signal */
2451 1.135 jdolecek sigdelset(&p->p_sigctx.ps_siglist, signum);
2452 1.231 mrg ksi = ksiginfo_dequeue(p, signum);
2453 1.171 jdolecek if (!ksi) {
2454 1.171 jdolecek /* No queued siginfo, manufacture one */
2455 1.171 jdolecek ksi = pool_get(&ksiginfo_pool, PR_WAITOK);
2456 1.171 jdolecek KSI_INIT(ksi);
2457 1.171 jdolecek ksi->ksi_info._signo = signum;
2458 1.171 jdolecek ksi->ksi_info._code = SI_USER;
2459 1.171 jdolecek }
2460 1.202 perry
2461 1.135 jdolecek goto sig;
2462 1.135 jdolecek }
2463 1.135 jdolecek
2464 1.135 jdolecek /*
2465 1.135 jdolecek * Calculate timeout, if it was specified.
2466 1.135 jdolecek */
2467 1.135 jdolecek if (SCARG(uap, timeout)) {
2468 1.135 jdolecek uint64_t ms;
2469 1.135 jdolecek
2470 1.208 cube if ((error = (*fetch_timeout)(SCARG(uap, timeout), &ts, sizeof(ts))))
2471 1.135 jdolecek return (error);
2472 1.135 jdolecek
2473 1.135 jdolecek ms = (ts.tv_sec * 1000) + (ts.tv_nsec / 1000000);
2474 1.135 jdolecek timo = mstohz(ms);
2475 1.135 jdolecek if (timo == 0 && ts.tv_sec == 0 && ts.tv_nsec > 0)
2476 1.135 jdolecek timo = 1;
2477 1.135 jdolecek if (timo <= 0)
2478 1.135 jdolecek return (EAGAIN);
2479 1.135 jdolecek
2480 1.135 jdolecek /*
2481 1.221 kardel * Remember current uptime, it would be used in
2482 1.135 jdolecek * ECANCELED/ERESTART case.
2483 1.135 jdolecek */
2484 1.221 kardel getnanouptime(&tsstart);
2485 1.135 jdolecek }
2486 1.135 jdolecek
2487 1.135 jdolecek /*
2488 1.173 jdolecek * Setup ps_sigwait list. Pass pointer to malloced memory
2489 1.173 jdolecek * here; it's not possible to pass pointer to a structure
2490 1.173 jdolecek * on current process's stack, the current process might
2491 1.173 jdolecek * be swapped out at the time the signal would get delivered.
2492 1.135 jdolecek */
2493 1.171 jdolecek ksi = pool_get(&ksiginfo_pool, PR_WAITOK);
2494 1.171 jdolecek p->p_sigctx.ps_sigwaited = ksi;
2495 1.173 jdolecek p->p_sigctx.ps_sigwait = waitset;
2496 1.135 jdolecek
2497 1.135 jdolecek /*
2498 1.135 jdolecek * Wait for signal to arrive. We can either be woken up or
2499 1.135 jdolecek * time out.
2500 1.135 jdolecek */
2501 1.135 jdolecek error = tsleep(&p->p_sigctx.ps_sigwait, PPAUSE|PCATCH, "sigwait", timo);
2502 1.135 jdolecek
2503 1.135 jdolecek /*
2504 1.171 jdolecek * Need to find out if we woke as a result of lwp_wakeup()
2505 1.171 jdolecek * or a signal outside our wait set.
2506 1.135 jdolecek */
2507 1.171 jdolecek if (error == EINTR && p->p_sigctx.ps_sigwaited
2508 1.171 jdolecek && !firstsig(&p->p_sigctx.ps_siglist)) {
2509 1.171 jdolecek /* wakeup via _lwp_wakeup() */
2510 1.171 jdolecek error = ECANCELED;
2511 1.171 jdolecek } else if (!error && p->p_sigctx.ps_sigwaited) {
2512 1.171 jdolecek /* spurious wakeup - arrange for syscall restart */
2513 1.171 jdolecek error = ERESTART;
2514 1.171 jdolecek goto fail;
2515 1.135 jdolecek }
2516 1.135 jdolecek
2517 1.135 jdolecek /*
2518 1.171 jdolecek * On error, clear sigwait indication. psignal1() clears it
2519 1.135 jdolecek * in !error case.
2520 1.135 jdolecek */
2521 1.135 jdolecek if (error) {
2522 1.171 jdolecek p->p_sigctx.ps_sigwaited = NULL;
2523 1.135 jdolecek
2524 1.135 jdolecek /*
2525 1.135 jdolecek * If the sleep was interrupted (either by signal or wakeup),
2526 1.135 jdolecek * update the timeout and copyout new value back.
2527 1.135 jdolecek * It would be used when the syscall would be restarted
2528 1.135 jdolecek * or called again.
2529 1.135 jdolecek */
2530 1.135 jdolecek if (timo && (error == ERESTART || error == ECANCELED)) {
2531 1.221 kardel struct timespec tsnow;
2532 1.135 jdolecek int err;
2533 1.135 jdolecek
2534 1.221 kardel /* XXX double check the following change */
2535 1.221 kardel getnanouptime(&tsnow);
2536 1.135 jdolecek
2537 1.135 jdolecek /* compute how much time has passed since start */
2538 1.221 kardel timespecsub(&tsnow, &tsstart, &tsnow);
2539 1.135 jdolecek /* substract passed time from timeout */
2540 1.221 kardel timespecsub(&ts, &tsnow, &ts);
2541 1.135 jdolecek
2542 1.221 kardel if (ts.tv_sec < 0) {
2543 1.171 jdolecek error = EAGAIN;
2544 1.171 jdolecek goto fail;
2545 1.171 jdolecek }
2546 1.221 kardel /* XXX double check the previous change */
2547 1.135 jdolecek
2548 1.135 jdolecek /* copy updated timeout to userland */
2549 1.208 cube if ((err = (*put_timeout)(&ts, SCARG(uap, timeout),
2550 1.208 cube sizeof(ts)))) {
2551 1.171 jdolecek error = err;
2552 1.171 jdolecek goto fail;
2553 1.171 jdolecek }
2554 1.135 jdolecek }
2555 1.135 jdolecek
2556 1.171 jdolecek goto fail;
2557 1.135 jdolecek }
2558 1.135 jdolecek
2559 1.135 jdolecek /*
2560 1.135 jdolecek * If a signal from the wait set arrived, copy it to userland.
2561 1.171 jdolecek * Copy only the used part of siginfo, the padding part is
2562 1.171 jdolecek * left unchanged (userland is not supposed to touch it anyway).
2563 1.135 jdolecek */
2564 1.135 jdolecek sig:
2565 1.208 cube return (*put_info)(&ksi->ksi_info, SCARG(uap, info), sizeof(ksi->ksi_info));
2566 1.135 jdolecek
2567 1.171 jdolecek fail:
2568 1.173 jdolecek FREE(waitset, M_TEMP);
2569 1.171 jdolecek pool_put(&ksiginfo_pool, ksi);
2570 1.171 jdolecek p->p_sigctx.ps_sigwait = NULL;
2571 1.135 jdolecek
2572 1.171 jdolecek return (error);
2573 1.135 jdolecek }
2574 1.108 jdolecek
2575 1.108 jdolecek /*
2576 1.108 jdolecek * Returns true if signal is ignored or masked for passed process.
2577 1.108 jdolecek */
2578 1.108 jdolecek int
2579 1.112 lukem sigismasked(struct proc *p, int sig)
2580 1.108 jdolecek {
2581 1.112 lukem
2582 1.117 enami return (sigismember(&p->p_sigctx.ps_sigignore, sig) ||
2583 1.117 enami sigismember(&p->p_sigctx.ps_sigmask, sig));
2584 1.29 cgd }
2585 1.126 jdolecek
2586 1.126 jdolecek static int
2587 1.126 jdolecek filt_sigattach(struct knote *kn)
2588 1.126 jdolecek {
2589 1.126 jdolecek struct proc *p = curproc;
2590 1.126 jdolecek
2591 1.126 jdolecek kn->kn_ptr.p_proc = p;
2592 1.126 jdolecek kn->kn_flags |= EV_CLEAR; /* automatically set */
2593 1.126 jdolecek
2594 1.126 jdolecek SLIST_INSERT_HEAD(&p->p_klist, kn, kn_selnext);
2595 1.126 jdolecek
2596 1.126 jdolecek return (0);
2597 1.126 jdolecek }
2598 1.126 jdolecek
2599 1.126 jdolecek static void
2600 1.126 jdolecek filt_sigdetach(struct knote *kn)
2601 1.126 jdolecek {
2602 1.126 jdolecek struct proc *p = kn->kn_ptr.p_proc;
2603 1.126 jdolecek
2604 1.126 jdolecek SLIST_REMOVE(&p->p_klist, kn, knote, kn_selnext);
2605 1.126 jdolecek }
2606 1.126 jdolecek
2607 1.126 jdolecek /*
2608 1.126 jdolecek * signal knotes are shared with proc knotes, so we apply a mask to
2609 1.126 jdolecek * the hint in order to differentiate them from process hints. This
2610 1.126 jdolecek * could be avoided by using a signal-specific knote list, but probably
2611 1.126 jdolecek * isn't worth the trouble.
2612 1.126 jdolecek */
2613 1.126 jdolecek static int
2614 1.126 jdolecek filt_signal(struct knote *kn, long hint)
2615 1.126 jdolecek {
2616 1.126 jdolecek
2617 1.126 jdolecek if (hint & NOTE_SIGNAL) {
2618 1.126 jdolecek hint &= ~NOTE_SIGNAL;
2619 1.126 jdolecek
2620 1.126 jdolecek if (kn->kn_id == hint)
2621 1.126 jdolecek kn->kn_data++;
2622 1.126 jdolecek }
2623 1.126 jdolecek return (kn->kn_data != 0);
2624 1.126 jdolecek }
2625 1.126 jdolecek
2626 1.126 jdolecek const struct filterops sig_filtops = {
2627 1.126 jdolecek 0, filt_sigattach, filt_sigdetach, filt_signal
2628 1.126 jdolecek };
2629