Home | History | Annotate | Line # | Download | only in kern
kern_proc.c revision 1.185
      1  1.185    martin /*	$NetBSD: kern_proc.c,v 1.185 2012/06/06 11:20:21 martin Exp $	*/
      2   1.33   thorpej 
      3   1.33   thorpej /*-
      4  1.131        ad  * Copyright (c) 1999, 2006, 2007, 2008 The NetBSD Foundation, Inc.
      5   1.33   thorpej  * All rights reserved.
      6   1.33   thorpej  *
      7   1.33   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8   1.33   thorpej  * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
      9  1.100        ad  * NASA Ames Research Center, and by Andrew Doran.
     10   1.33   thorpej  *
     11   1.33   thorpej  * Redistribution and use in source and binary forms, with or without
     12   1.33   thorpej  * modification, are permitted provided that the following conditions
     13   1.33   thorpej  * are met:
     14   1.33   thorpej  * 1. Redistributions of source code must retain the above copyright
     15   1.33   thorpej  *    notice, this list of conditions and the following disclaimer.
     16   1.33   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.33   thorpej  *    notice, this list of conditions and the following disclaimer in the
     18   1.33   thorpej  *    documentation and/or other materials provided with the distribution.
     19   1.33   thorpej  *
     20   1.33   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.33   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.33   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.33   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.33   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.33   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.33   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.33   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.33   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.33   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.33   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     31   1.33   thorpej  */
     32    1.9       cgd 
     33    1.1       cgd /*
     34    1.7       cgd  * Copyright (c) 1982, 1986, 1989, 1991, 1993
     35    1.7       cgd  *	The Regents of the University of California.  All rights reserved.
     36    1.1       cgd  *
     37    1.1       cgd  * Redistribution and use in source and binary forms, with or without
     38    1.1       cgd  * modification, are permitted provided that the following conditions
     39    1.1       cgd  * are met:
     40    1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     41    1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     42    1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     43    1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     44    1.1       cgd  *    documentation and/or other materials provided with the distribution.
     45   1.65       agc  * 3. Neither the name of the University nor the names of its contributors
     46    1.1       cgd  *    may be used to endorse or promote products derived from this software
     47    1.1       cgd  *    without specific prior written permission.
     48    1.1       cgd  *
     49    1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     50    1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     51    1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     52    1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     53    1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     54    1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     55    1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     56    1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     57    1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     58    1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     59    1.1       cgd  * SUCH DAMAGE.
     60    1.1       cgd  *
     61   1.23      fvdl  *	@(#)kern_proc.c	8.7 (Berkeley) 2/14/95
     62    1.1       cgd  */
     63   1.45     lukem 
     64   1.45     lukem #include <sys/cdefs.h>
     65  1.185    martin __KERNEL_RCSID(0, "$NetBSD: kern_proc.c,v 1.185 2012/06/06 11:20:21 martin Exp $");
     66   1.48      yamt 
     67  1.165     pooka #ifdef _KERNEL_OPT
     68   1.48      yamt #include "opt_kstack.h"
     69   1.88      onoe #include "opt_maxuprc.h"
     70  1.161    darran #include "opt_dtrace.h"
     71  1.171     pooka #include "opt_compat_netbsd32.h"
     72  1.165     pooka #endif
     73    1.1       cgd 
     74    1.5   mycroft #include <sys/param.h>
     75    1.5   mycroft #include <sys/systm.h>
     76    1.5   mycroft #include <sys/kernel.h>
     77    1.5   mycroft #include <sys/proc.h>
     78   1.28   thorpej #include <sys/resourcevar.h>
     79    1.5   mycroft #include <sys/buf.h>
     80    1.5   mycroft #include <sys/acct.h>
     81    1.5   mycroft #include <sys/wait.h>
     82    1.5   mycroft #include <sys/file.h>
     83    1.8   mycroft #include <ufs/ufs/quota.h>
     84    1.5   mycroft #include <sys/uio.h>
     85   1.24   thorpej #include <sys/pool.h>
     86  1.147     rmind #include <sys/pset.h>
     87    1.5   mycroft #include <sys/mbuf.h>
     88    1.5   mycroft #include <sys/ioctl.h>
     89    1.5   mycroft #include <sys/tty.h>
     90   1.11       cgd #include <sys/signalvar.h>
     91   1.51  gmcgarry #include <sys/ras.h>
     92   1.81  junyoung #include <sys/filedesc.h>
     93  1.185    martin #include <sys/syscall_stats.h>
     94   1.89      elad #include <sys/kauth.h>
     95  1.100        ad #include <sys/sleepq.h>
     96  1.126        ad #include <sys/atomic.h>
     97  1.131        ad #include <sys/kmem.h>
     98  1.160    darran #include <sys/dtrace_bsd.h>
     99  1.170     pooka #include <sys/sysctl.h>
    100  1.170     pooka #include <sys/exec.h>
    101  1.170     pooka #include <sys/cpu.h>
    102  1.160    darran 
    103  1.169  uebayasi #include <uvm/uvm_extern.h>
    104    1.5   mycroft 
    105  1.171     pooka #ifdef COMPAT_NETBSD32
    106  1.171     pooka #include <compat/netbsd32/netbsd32.h>
    107  1.171     pooka #endif
    108  1.171     pooka 
    109    1.7       cgd /*
    110  1.180     rmind  * Process lists.
    111    1.7       cgd  */
    112   1.31   thorpej 
    113  1.180     rmind struct proclist		allproc		__cacheline_aligned;
    114  1.180     rmind struct proclist		zombproc	__cacheline_aligned;
    115   1.32   thorpej 
    116  1.180     rmind kmutex_t *		proc_lock	__cacheline_aligned;
    117   1.33   thorpej 
    118   1.33   thorpej /*
    119   1.72  junyoung  * pid to proc lookup is done by indexing the pid_table array.
    120   1.61       dsl  * Since pid numbers are only allocated when an empty slot
    121   1.61       dsl  * has been found, there is no need to search any lists ever.
    122   1.61       dsl  * (an orphaned pgrp will lock the slot, a session will lock
    123   1.61       dsl  * the pgrp with the same number.)
    124   1.61       dsl  * If the table is too small it is reallocated with twice the
    125   1.61       dsl  * previous size and the entries 'unzipped' into the two halves.
    126   1.61       dsl  * A linked list of free entries is passed through the pt_proc
    127   1.61       dsl  * field of 'free' items - set odd to be an invalid ptr.
    128   1.61       dsl  */
    129   1.61       dsl 
    130   1.61       dsl struct pid_table {
    131   1.61       dsl 	struct proc	*pt_proc;
    132   1.61       dsl 	struct pgrp	*pt_pgrp;
    133  1.168       chs 	pid_t		pt_pid;
    134   1.72  junyoung };
    135   1.61       dsl #if 1	/* strongly typed cast - should be a noop */
    136   1.84     perry static inline uint p2u(struct proc *p) { return (uint)(uintptr_t)p; }
    137   1.61       dsl #else
    138   1.61       dsl #define p2u(p) ((uint)p)
    139   1.72  junyoung #endif
    140   1.61       dsl #define P_VALID(p) (!(p2u(p) & 1))
    141   1.61       dsl #define P_NEXT(p) (p2u(p) >> 1)
    142   1.61       dsl #define P_FREE(pid) ((struct proc *)(uintptr_t)((pid) << 1 | 1))
    143   1.61       dsl 
    144  1.180     rmind /*
    145  1.180     rmind  * Table of process IDs (PIDs).
    146  1.180     rmind  */
    147  1.180     rmind static struct pid_table *pid_table	__read_mostly;
    148  1.180     rmind 
    149  1.180     rmind #define	INITIAL_PID_TABLE_SIZE		(1 << 5)
    150  1.180     rmind 
    151  1.180     rmind /* Table mask, threshold for growing and number of allocated PIDs. */
    152  1.180     rmind static u_int		pid_tbl_mask	__read_mostly;
    153  1.180     rmind static u_int		pid_alloc_lim	__read_mostly;
    154  1.180     rmind static u_int		pid_alloc_cnt	__cacheline_aligned;
    155  1.180     rmind 
    156  1.180     rmind /* Next free, last free and maximum PIDs. */
    157  1.180     rmind static u_int		next_free_pt	__cacheline_aligned;
    158  1.180     rmind static u_int		last_free_pt	__cacheline_aligned;
    159  1.180     rmind static pid_t		pid_max		__read_mostly;
    160   1.31   thorpej 
    161   1.81  junyoung /* Components of the first process -- never freed. */
    162  1.123      matt 
    163  1.145        ad extern struct emul emul_netbsd;	/* defined in kern_exec.c */
    164  1.123      matt 
    165  1.123      matt struct session session0 = {
    166  1.123      matt 	.s_count = 1,
    167  1.123      matt 	.s_sid = 0,
    168  1.123      matt };
    169  1.123      matt struct pgrp pgrp0 = {
    170  1.123      matt 	.pg_members = LIST_HEAD_INITIALIZER(&pgrp0.pg_members),
    171  1.123      matt 	.pg_session = &session0,
    172  1.123      matt };
    173  1.132        ad filedesc_t filedesc0;
    174  1.123      matt struct cwdinfo cwdi0 = {
    175  1.123      matt 	.cwdi_cmask = CMASK,		/* see cmask below */
    176  1.123      matt 	.cwdi_refcnt = 1,
    177  1.123      matt };
    178  1.143  gmcgarry struct plimit limit0;
    179   1.81  junyoung struct pstats pstat0;
    180   1.81  junyoung struct vmspace vmspace0;
    181   1.81  junyoung struct sigacts sigacts0;
    182  1.123      matt struct proc proc0 = {
    183  1.123      matt 	.p_lwps = LIST_HEAD_INITIALIZER(&proc0.p_lwps),
    184  1.123      matt 	.p_sigwaiters = LIST_HEAD_INITIALIZER(&proc0.p_sigwaiters),
    185  1.123      matt 	.p_nlwps = 1,
    186  1.123      matt 	.p_nrlwps = 1,
    187  1.123      matt 	.p_nlwpid = 1,		/* must match lwp0.l_lid */
    188  1.123      matt 	.p_pgrp = &pgrp0,
    189  1.123      matt 	.p_comm = "system",
    190  1.123      matt 	/*
    191  1.123      matt 	 * Set P_NOCLDWAIT so that kernel threads are reparented to init(8)
    192  1.123      matt 	 * when they exit.  init(8) can easily wait them out for us.
    193  1.123      matt 	 */
    194  1.123      matt 	.p_flag = PK_SYSTEM | PK_NOCLDWAIT,
    195  1.123      matt 	.p_stat = SACTIVE,
    196  1.123      matt 	.p_nice = NZERO,
    197  1.123      matt 	.p_emul = &emul_netbsd,
    198  1.123      matt 	.p_cwdi = &cwdi0,
    199  1.123      matt 	.p_limit = &limit0,
    200  1.132        ad 	.p_fd = &filedesc0,
    201  1.123      matt 	.p_vmspace = &vmspace0,
    202  1.123      matt 	.p_stats = &pstat0,
    203  1.123      matt 	.p_sigacts = &sigacts0,
    204  1.123      matt };
    205  1.123      matt kauth_cred_t cred0;
    206   1.81  junyoung 
    207  1.180     rmind static const int	nofile	= NOFILE;
    208  1.180     rmind static const int	maxuprc	= MAXUPRC;
    209  1.180     rmind static const int	cmask	= CMASK;
    210   1.81  junyoung 
    211  1.170     pooka static int sysctl_doeproc(SYSCTLFN_PROTO);
    212  1.170     pooka static int sysctl_kern_proc_args(SYSCTLFN_PROTO);
    213  1.170     pooka static void fill_kproc2(struct proc *, struct kinfo_proc2 *, bool);
    214  1.170     pooka 
    215   1.31   thorpej /*
    216   1.31   thorpej  * The process list descriptors, used during pid allocation and
    217   1.31   thorpej  * by sysctl.  No locking on this data structure is needed since
    218   1.31   thorpej  * it is completely static.
    219   1.31   thorpej  */
    220   1.31   thorpej const struct proclist_desc proclists[] = {
    221   1.31   thorpej 	{ &allproc	},
    222   1.31   thorpej 	{ &zombproc	},
    223   1.31   thorpej 	{ NULL		},
    224   1.31   thorpej };
    225   1.31   thorpej 
    226  1.151     rmind static struct pgrp *	pg_remove(pid_t);
    227  1.151     rmind static void		pg_delete(pid_t);
    228  1.151     rmind static void		orphanpg(struct pgrp *);
    229   1.13  christos 
    230   1.95   thorpej static specificdata_domain_t proc_specificdata_domain;
    231   1.95   thorpej 
    232  1.128        ad static pool_cache_t proc_cache;
    233  1.128        ad 
    234  1.153      elad static kauth_listener_t proc_listener;
    235  1.153      elad 
    236  1.153      elad static int
    237  1.153      elad proc_listener_cb(kauth_cred_t cred, kauth_action_t action, void *cookie,
    238  1.153      elad     void *arg0, void *arg1, void *arg2, void *arg3)
    239  1.153      elad {
    240  1.153      elad 	struct proc *p;
    241  1.153      elad 	int result;
    242  1.153      elad 
    243  1.153      elad 	result = KAUTH_RESULT_DEFER;
    244  1.153      elad 	p = arg0;
    245  1.153      elad 
    246  1.153      elad 	switch (action) {
    247  1.153      elad 	case KAUTH_PROCESS_CANSEE: {
    248  1.153      elad 		enum kauth_process_req req;
    249  1.153      elad 
    250  1.153      elad 		req = (enum kauth_process_req)arg1;
    251  1.153      elad 
    252  1.153      elad 		switch (req) {
    253  1.153      elad 		case KAUTH_REQ_PROCESS_CANSEE_ARGS:
    254  1.153      elad 		case KAUTH_REQ_PROCESS_CANSEE_ENTRY:
    255  1.153      elad 		case KAUTH_REQ_PROCESS_CANSEE_OPENFILES:
    256  1.153      elad 			result = KAUTH_RESULT_ALLOW;
    257  1.153      elad 
    258  1.153      elad 			break;
    259  1.153      elad 
    260  1.153      elad 		case KAUTH_REQ_PROCESS_CANSEE_ENV:
    261  1.153      elad 			if (kauth_cred_getuid(cred) !=
    262  1.153      elad 			    kauth_cred_getuid(p->p_cred) ||
    263  1.153      elad 			    kauth_cred_getuid(cred) !=
    264  1.153      elad 			    kauth_cred_getsvuid(p->p_cred))
    265  1.153      elad 				break;
    266  1.153      elad 
    267  1.153      elad 			result = KAUTH_RESULT_ALLOW;
    268  1.153      elad 
    269  1.153      elad 			break;
    270  1.153      elad 
    271  1.153      elad 		default:
    272  1.153      elad 			break;
    273  1.153      elad 		}
    274  1.153      elad 
    275  1.153      elad 		break;
    276  1.153      elad 		}
    277  1.153      elad 
    278  1.153      elad 	case KAUTH_PROCESS_FORK: {
    279  1.153      elad 		int lnprocs = (int)(unsigned long)arg2;
    280  1.153      elad 
    281  1.153      elad 		/*
    282  1.153      elad 		 * Don't allow a nonprivileged user to use the last few
    283  1.153      elad 		 * processes. The variable lnprocs is the current number of
    284  1.153      elad 		 * processes, maxproc is the limit.
    285  1.153      elad 		 */
    286  1.153      elad 		if (__predict_false((lnprocs >= maxproc - 5)))
    287  1.153      elad 			break;
    288  1.153      elad 
    289  1.153      elad 		result = KAUTH_RESULT_ALLOW;
    290  1.153      elad 
    291  1.153      elad 		break;
    292  1.153      elad 		}
    293  1.153      elad 
    294  1.153      elad 	case KAUTH_PROCESS_CORENAME:
    295  1.153      elad 	case KAUTH_PROCESS_STOPFLAG:
    296  1.153      elad 		if (proc_uidmatch(cred, p->p_cred) == 0)
    297  1.153      elad 			result = KAUTH_RESULT_ALLOW;
    298  1.153      elad 
    299  1.153      elad 		break;
    300  1.153      elad 
    301  1.153      elad 	default:
    302  1.153      elad 		break;
    303  1.153      elad 	}
    304  1.153      elad 
    305  1.153      elad 	return result;
    306  1.153      elad }
    307  1.153      elad 
    308   1.10   mycroft /*
    309   1.10   mycroft  * Initialize global process hashing structures.
    310   1.10   mycroft  */
    311   1.11       cgd void
    312   1.59       dsl procinit(void)
    313    1.7       cgd {
    314   1.31   thorpej 	const struct proclist_desc *pd;
    315  1.150     rmind 	u_int i;
    316   1.61       dsl #define	LINK_EMPTY ((PID_MAX + INITIAL_PID_TABLE_SIZE) & ~(INITIAL_PID_TABLE_SIZE - 1))
    317   1.31   thorpej 
    318   1.31   thorpej 	for (pd = proclists; pd->pd_list != NULL; pd++)
    319   1.31   thorpej 		LIST_INIT(pd->pd_list);
    320    1.7       cgd 
    321  1.136        ad 	proc_lock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    322  1.150     rmind 	pid_table = kmem_alloc(INITIAL_PID_TABLE_SIZE
    323  1.150     rmind 	    * sizeof(struct pid_table), KM_SLEEP);
    324  1.180     rmind 	pid_tbl_mask = INITIAL_PID_TABLE_SIZE - 1;
    325  1.180     rmind 	pid_max = PID_MAX;
    326   1.33   thorpej 
    327   1.61       dsl 	/* Set free list running through table...
    328   1.61       dsl 	   Preset 'use count' above PID_MAX so we allocate pid 1 next. */
    329   1.61       dsl 	for (i = 0; i <= pid_tbl_mask; i++) {
    330   1.61       dsl 		pid_table[i].pt_proc = P_FREE(LINK_EMPTY + i + 1);
    331   1.61       dsl 		pid_table[i].pt_pgrp = 0;
    332  1.168       chs 		pid_table[i].pt_pid = 0;
    333   1.61       dsl 	}
    334   1.61       dsl 	/* slot 0 is just grabbed */
    335   1.61       dsl 	next_free_pt = 1;
    336   1.61       dsl 	/* Need to fix last entry. */
    337   1.61       dsl 	last_free_pt = pid_tbl_mask;
    338   1.61       dsl 	pid_table[last_free_pt].pt_proc = P_FREE(LINK_EMPTY);
    339   1.61       dsl 	/* point at which we grow table - to avoid reusing pids too often */
    340   1.61       dsl 	pid_alloc_lim = pid_tbl_mask - 1;
    341   1.61       dsl #undef LINK_EMPTY
    342   1.61       dsl 
    343   1.95   thorpej 	proc_specificdata_domain = specificdata_domain_create();
    344   1.95   thorpej 	KASSERT(proc_specificdata_domain != NULL);
    345  1.128        ad 
    346  1.128        ad 	proc_cache = pool_cache_init(sizeof(struct proc), 0, 0, 0,
    347  1.128        ad 	    "procpl", NULL, IPL_NONE, NULL, NULL, NULL);
    348  1.153      elad 
    349  1.153      elad 	proc_listener = kauth_listen_scope(KAUTH_SCOPE_PROCESS,
    350  1.153      elad 	    proc_listener_cb, NULL);
    351    1.7       cgd }
    352    1.1       cgd 
    353  1.170     pooka void
    354  1.170     pooka procinit_sysctl(void)
    355  1.170     pooka {
    356  1.170     pooka 	static struct sysctllog *clog;
    357  1.170     pooka 
    358  1.170     pooka 	sysctl_createv(&clog, 0, NULL, NULL,
    359  1.170     pooka 		       CTLFLAG_PERMANENT,
    360  1.170     pooka 		       CTLTYPE_NODE, "kern", NULL,
    361  1.170     pooka 		       NULL, 0, NULL, 0,
    362  1.170     pooka 		       CTL_KERN, CTL_EOL);
    363  1.170     pooka 
    364  1.170     pooka 	sysctl_createv(&clog, 0, NULL, NULL,
    365  1.170     pooka 		       CTLFLAG_PERMANENT,
    366  1.170     pooka 		       CTLTYPE_NODE, "proc",
    367  1.170     pooka 		       SYSCTL_DESCR("System-wide process information"),
    368  1.170     pooka 		       sysctl_doeproc, 0, NULL, 0,
    369  1.170     pooka 		       CTL_KERN, KERN_PROC, CTL_EOL);
    370  1.170     pooka 	sysctl_createv(&clog, 0, NULL, NULL,
    371  1.170     pooka 		       CTLFLAG_PERMANENT,
    372  1.170     pooka 		       CTLTYPE_NODE, "proc2",
    373  1.170     pooka 		       SYSCTL_DESCR("Machine-independent process information"),
    374  1.170     pooka 		       sysctl_doeproc, 0, NULL, 0,
    375  1.170     pooka 		       CTL_KERN, KERN_PROC2, CTL_EOL);
    376  1.170     pooka 	sysctl_createv(&clog, 0, NULL, NULL,
    377  1.170     pooka 		       CTLFLAG_PERMANENT,
    378  1.170     pooka 		       CTLTYPE_NODE, "proc_args",
    379  1.170     pooka 		       SYSCTL_DESCR("Process argument information"),
    380  1.170     pooka 		       sysctl_kern_proc_args, 0, NULL, 0,
    381  1.170     pooka 		       CTL_KERN, KERN_PROC_ARGS, CTL_EOL);
    382  1.170     pooka 
    383  1.170     pooka 	/*
    384  1.170     pooka 	  "nodes" under these:
    385  1.170     pooka 
    386  1.170     pooka 	  KERN_PROC_ALL
    387  1.170     pooka 	  KERN_PROC_PID pid
    388  1.170     pooka 	  KERN_PROC_PGRP pgrp
    389  1.170     pooka 	  KERN_PROC_SESSION sess
    390  1.170     pooka 	  KERN_PROC_TTY tty
    391  1.170     pooka 	  KERN_PROC_UID uid
    392  1.170     pooka 	  KERN_PROC_RUID uid
    393  1.170     pooka 	  KERN_PROC_GID gid
    394  1.170     pooka 	  KERN_PROC_RGID gid
    395  1.170     pooka 
    396  1.170     pooka 	  all in all, probably not worth the effort...
    397  1.170     pooka 	*/
    398  1.170     pooka }
    399  1.170     pooka 
    400    1.7       cgd /*
    401   1.81  junyoung  * Initialize process 0.
    402   1.81  junyoung  */
    403   1.81  junyoung void
    404   1.81  junyoung proc0_init(void)
    405   1.81  junyoung {
    406   1.81  junyoung 	struct proc *p;
    407   1.81  junyoung 	struct pgrp *pg;
    408  1.177     rmind 	struct rlimit *rlim;
    409   1.81  junyoung 	rlim_t lim;
    410  1.143  gmcgarry 	int i;
    411   1.81  junyoung 
    412   1.81  junyoung 	p = &proc0;
    413   1.81  junyoung 	pg = &pgrp0;
    414  1.123      matt 
    415  1.127        ad 	mutex_init(&p->p_stmutex, MUTEX_DEFAULT, IPL_HIGH);
    416  1.129        ad 	mutex_init(&p->p_auxlock, MUTEX_DEFAULT, IPL_NONE);
    417  1.137        ad 	p->p_lock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    418  1.107        ad 
    419  1.122        ad 	rw_init(&p->p_reflock);
    420  1.100        ad 	cv_init(&p->p_waitcv, "wait");
    421  1.100        ad 	cv_init(&p->p_lwpcv, "lwpwait");
    422  1.100        ad 
    423  1.166     pooka 	LIST_INSERT_HEAD(&p->p_lwps, &lwp0, l_sibling);
    424  1.100        ad 
    425   1.81  junyoung 	pid_table[0].pt_proc = p;
    426   1.81  junyoung 	LIST_INSERT_HEAD(&allproc, p, p_list);
    427   1.81  junyoung 
    428   1.81  junyoung 	pid_table[0].pt_pgrp = pg;
    429   1.81  junyoung 	LIST_INSERT_HEAD(&pg->pg_members, p, p_pglist);
    430   1.81  junyoung 
    431   1.81  junyoung #ifdef __HAVE_SYSCALL_INTERN
    432   1.81  junyoung 	(*p->p_emul->e_syscall_intern)(p);
    433   1.81  junyoung #endif
    434   1.81  junyoung 
    435   1.81  junyoung 	/* Create credentials. */
    436   1.89      elad 	cred0 = kauth_cred_alloc();
    437   1.89      elad 	p->p_cred = cred0;
    438   1.81  junyoung 
    439   1.81  junyoung 	/* Create the CWD info. */
    440  1.113        ad 	rw_init(&cwdi0.cwdi_lock);
    441   1.81  junyoung 
    442   1.81  junyoung 	/* Create the limits structures. */
    443  1.116       dsl 	mutex_init(&limit0.pl_lock, MUTEX_DEFAULT, IPL_NONE);
    444  1.177     rmind 
    445  1.177     rmind 	rlim = limit0.pl_rlimit;
    446  1.177     rmind 	for (i = 0; i < __arraycount(limit0.pl_rlimit); i++) {
    447  1.177     rmind 		rlim[i].rlim_cur = RLIM_INFINITY;
    448  1.177     rmind 		rlim[i].rlim_max = RLIM_INFINITY;
    449  1.177     rmind 	}
    450  1.177     rmind 
    451  1.177     rmind 	rlim[RLIMIT_NOFILE].rlim_max = maxfiles;
    452  1.177     rmind 	rlim[RLIMIT_NOFILE].rlim_cur = maxfiles < nofile ? maxfiles : nofile;
    453  1.177     rmind 
    454  1.177     rmind 	rlim[RLIMIT_NPROC].rlim_max = maxproc;
    455  1.177     rmind 	rlim[RLIMIT_NPROC].rlim_cur = maxproc < maxuprc ? maxproc : maxuprc;
    456   1.81  junyoung 
    457  1.163       jym 	lim = MIN(VM_MAXUSER_ADDRESS, ctob((rlim_t)uvmexp.free));
    458  1.177     rmind 	rlim[RLIMIT_RSS].rlim_max = lim;
    459  1.177     rmind 	rlim[RLIMIT_MEMLOCK].rlim_max = lim;
    460  1.177     rmind 	rlim[RLIMIT_MEMLOCK].rlim_cur = lim / 3;
    461  1.177     rmind 
    462  1.179     rmind 	/* Note that default core name has zero length. */
    463  1.177     rmind 	limit0.pl_corename = defcorename;
    464  1.179     rmind 	limit0.pl_cnlen = 0;
    465  1.177     rmind 	limit0.pl_refcnt = 1;
    466  1.179     rmind 	limit0.pl_writeable = false;
    467  1.143  gmcgarry 	limit0.pl_sv_limit = NULL;
    468   1.81  junyoung 
    469   1.81  junyoung 	/* Configure virtual memory system, set vm rlimits. */
    470   1.81  junyoung 	uvm_init_limits(p);
    471   1.81  junyoung 
    472   1.81  junyoung 	/* Initialize file descriptor table for proc0. */
    473  1.132        ad 	fd_init(&filedesc0);
    474   1.81  junyoung 
    475   1.81  junyoung 	/*
    476   1.81  junyoung 	 * Initialize proc0's vmspace, which uses the kernel pmap.
    477   1.81  junyoung 	 * All kernel processes (which never have user space mappings)
    478   1.81  junyoung 	 * share proc0's vmspace, and thus, the kernel pmap.
    479   1.81  junyoung 	 */
    480   1.81  junyoung 	uvmspace_init(&vmspace0, pmap_kernel(), round_page(VM_MIN_ADDRESS),
    481   1.81  junyoung 	    trunc_page(VM_MAX_ADDRESS));
    482   1.81  junyoung 
    483  1.127        ad 	/* Initialize signal state for proc0. XXX IPL_SCHED */
    484  1.127        ad 	mutex_init(&p->p_sigacts->sa_mutex, MUTEX_DEFAULT, IPL_SCHED);
    485   1.81  junyoung 	siginit(p);
    486   1.96  christos 
    487  1.164     rmind 	proc_initspecific(p);
    488  1.160    darran 	kdtrace_proc_ctor(NULL, p);
    489   1.81  junyoung }
    490   1.81  junyoung 
    491   1.81  junyoung /*
    492  1.151     rmind  * Session reference counting.
    493  1.151     rmind  */
    494  1.151     rmind 
    495  1.151     rmind void
    496  1.151     rmind proc_sesshold(struct session *ss)
    497  1.151     rmind {
    498  1.151     rmind 
    499  1.151     rmind 	KASSERT(mutex_owned(proc_lock));
    500  1.151     rmind 	ss->s_count++;
    501  1.151     rmind }
    502  1.151     rmind 
    503  1.151     rmind void
    504  1.151     rmind proc_sessrele(struct session *ss)
    505  1.151     rmind {
    506  1.151     rmind 
    507  1.151     rmind 	KASSERT(mutex_owned(proc_lock));
    508  1.151     rmind 	/*
    509  1.151     rmind 	 * We keep the pgrp with the same id as the session in order to
    510  1.151     rmind 	 * stop a process being given the same pid.  Since the pgrp holds
    511  1.151     rmind 	 * a reference to the session, it must be a 'zombie' pgrp by now.
    512  1.151     rmind 	 */
    513  1.151     rmind 	if (--ss->s_count == 0) {
    514  1.151     rmind 		struct pgrp *pg;
    515  1.151     rmind 
    516  1.151     rmind 		pg = pg_remove(ss->s_sid);
    517  1.151     rmind 		mutex_exit(proc_lock);
    518  1.151     rmind 
    519  1.151     rmind 		kmem_free(pg, sizeof(struct pgrp));
    520  1.151     rmind 		kmem_free(ss, sizeof(struct session));
    521  1.151     rmind 	} else {
    522  1.151     rmind 		mutex_exit(proc_lock);
    523  1.151     rmind 	}
    524  1.151     rmind }
    525  1.151     rmind 
    526  1.151     rmind /*
    527   1.74  junyoung  * Check that the specified process group is in the session of the
    528   1.60       dsl  * specified process.
    529   1.60       dsl  * Treats -ve ids as process ids.
    530   1.60       dsl  * Used to validate TIOCSPGRP requests.
    531   1.60       dsl  */
    532   1.60       dsl int
    533   1.60       dsl pgid_in_session(struct proc *p, pid_t pg_id)
    534   1.60       dsl {
    535   1.60       dsl 	struct pgrp *pgrp;
    536  1.101       dsl 	struct session *session;
    537  1.107        ad 	int error;
    538  1.101       dsl 
    539  1.136        ad 	mutex_enter(proc_lock);
    540   1.60       dsl 	if (pg_id < 0) {
    541  1.167     rmind 		struct proc *p1 = proc_find(-pg_id);
    542  1.167     rmind 		if (p1 == NULL) {
    543  1.167     rmind 			error = EINVAL;
    544  1.167     rmind 			goto fail;
    545  1.167     rmind 		}
    546   1.60       dsl 		pgrp = p1->p_pgrp;
    547   1.60       dsl 	} else {
    548  1.167     rmind 		pgrp = pgrp_find(pg_id);
    549  1.167     rmind 		if (pgrp == NULL) {
    550  1.167     rmind 			error = EINVAL;
    551  1.167     rmind 			goto fail;
    552  1.167     rmind 		}
    553   1.60       dsl 	}
    554  1.101       dsl 	session = pgrp->pg_session;
    555  1.167     rmind 	error = (session != p->p_pgrp->pg_session) ? EPERM : 0;
    556  1.167     rmind fail:
    557  1.136        ad 	mutex_exit(proc_lock);
    558  1.107        ad 	return error;
    559    1.7       cgd }
    560    1.4    andrew 
    561    1.1       cgd /*
    562  1.148     rmind  * p_inferior: is p an inferior of q?
    563    1.1       cgd  */
    564  1.148     rmind static inline bool
    565  1.148     rmind p_inferior(struct proc *p, struct proc *q)
    566    1.1       cgd {
    567    1.1       cgd 
    568  1.148     rmind 	KASSERT(mutex_owned(proc_lock));
    569  1.148     rmind 
    570   1.41  sommerfe 	for (; p != q; p = p->p_pptr)
    571    1.1       cgd 		if (p->p_pid == 0)
    572  1.148     rmind 			return false;
    573  1.148     rmind 	return true;
    574    1.1       cgd }
    575    1.1       cgd 
    576    1.1       cgd /*
    577  1.167     rmind  * proc_find: locate a process by the ID.
    578  1.167     rmind  *
    579  1.167     rmind  * => Must be called with proc_lock held.
    580    1.1       cgd  */
    581  1.167     rmind proc_t *
    582  1.167     rmind proc_find_raw(pid_t pid)
    583    1.1       cgd {
    584  1.168       chs 	struct pid_table *pt;
    585  1.168       chs 	proc_t *p;
    586  1.167     rmind 
    587  1.168       chs 	KASSERT(mutex_owned(proc_lock));
    588  1.168       chs 	pt = &pid_table[pid & pid_tbl_mask];
    589  1.168       chs 	p = pt->pt_proc;
    590  1.168       chs 	if (__predict_false(!P_VALID(p) || pt->pt_pid != pid)) {
    591  1.167     rmind 		return NULL;
    592  1.167     rmind 	}
    593  1.167     rmind 	return p;
    594  1.167     rmind }
    595    1.1       cgd 
    596  1.167     rmind proc_t *
    597  1.167     rmind proc_find(pid_t pid)
    598  1.167     rmind {
    599  1.167     rmind 	proc_t *p;
    600  1.100        ad 
    601  1.167     rmind 	p = proc_find_raw(pid);
    602  1.167     rmind 	if (__predict_false(p == NULL)) {
    603  1.167     rmind 		return NULL;
    604  1.167     rmind 	}
    605  1.168       chs 
    606  1.167     rmind 	/*
    607  1.167     rmind 	 * Only allow live processes to be found by PID.
    608  1.167     rmind 	 * XXX: p_stat might change, since unlocked.
    609  1.167     rmind 	 */
    610  1.167     rmind 	if (__predict_true(p->p_stat == SACTIVE || p->p_stat == SSTOP)) {
    611   1.68       dsl 		return p;
    612   1.68       dsl 	}
    613   1.68       dsl 	return NULL;
    614    1.1       cgd }
    615    1.1       cgd 
    616    1.1       cgd /*
    617  1.167     rmind  * pgrp_find: locate a process group by the ID.
    618  1.167     rmind  *
    619  1.167     rmind  * => Must be called with proc_lock held.
    620    1.1       cgd  */
    621    1.1       cgd struct pgrp *
    622  1.167     rmind pgrp_find(pid_t pgid)
    623    1.1       cgd {
    624   1.68       dsl 	struct pgrp *pg;
    625    1.1       cgd 
    626  1.167     rmind 	KASSERT(mutex_owned(proc_lock));
    627  1.167     rmind 
    628   1.68       dsl 	pg = pid_table[pgid & pid_tbl_mask].pt_pgrp;
    629  1.168       chs 
    630   1.61       dsl 	/*
    631  1.167     rmind 	 * Cannot look up a process group that only exists because the
    632  1.167     rmind 	 * session has not died yet (traditional).
    633   1.61       dsl 	 */
    634   1.68       dsl 	if (pg == NULL || pg->pg_id != pgid || LIST_EMPTY(&pg->pg_members)) {
    635   1.68       dsl 		return NULL;
    636   1.68       dsl 	}
    637   1.68       dsl 	return pg;
    638    1.1       cgd }
    639    1.1       cgd 
    640   1.61       dsl static void
    641   1.61       dsl expand_pid_table(void)
    642    1.1       cgd {
    643  1.150     rmind 	size_t pt_size, tsz;
    644   1.61       dsl 	struct pid_table *n_pt, *new_pt;
    645   1.61       dsl 	struct proc *proc;
    646   1.61       dsl 	struct pgrp *pgrp;
    647  1.168       chs 	pid_t pid, rpid;
    648  1.150     rmind 	u_int i;
    649  1.168       chs 	uint new_pt_mask;
    650    1.1       cgd 
    651  1.150     rmind 	pt_size = pid_tbl_mask + 1;
    652  1.150     rmind 	tsz = pt_size * 2 * sizeof(struct pid_table);
    653  1.150     rmind 	new_pt = kmem_alloc(tsz, KM_SLEEP);
    654  1.168       chs 	new_pt_mask = pt_size * 2 - 1;
    655   1.61       dsl 
    656  1.136        ad 	mutex_enter(proc_lock);
    657   1.61       dsl 	if (pt_size != pid_tbl_mask + 1) {
    658   1.61       dsl 		/* Another process beat us to it... */
    659  1.136        ad 		mutex_exit(proc_lock);
    660  1.150     rmind 		kmem_free(new_pt, tsz);
    661   1.61       dsl 		return;
    662   1.61       dsl 	}
    663   1.72  junyoung 
    664   1.61       dsl 	/*
    665   1.61       dsl 	 * Copy entries from old table into new one.
    666   1.61       dsl 	 * If 'pid' is 'odd' we need to place in the upper half,
    667   1.61       dsl 	 * even pid's to the lower half.
    668   1.61       dsl 	 * Free items stay in the low half so we don't have to
    669   1.61       dsl 	 * fixup the reference to them.
    670   1.61       dsl 	 * We stuff free items on the front of the freelist
    671   1.61       dsl 	 * because we can't write to unmodified entries.
    672   1.74  junyoung 	 * Processing the table backwards maintains a semblance
    673  1.168       chs 	 * of issuing pid numbers that increase with time.
    674   1.61       dsl 	 */
    675   1.61       dsl 	i = pt_size - 1;
    676   1.61       dsl 	n_pt = new_pt + i;
    677   1.61       dsl 	for (; ; i--, n_pt--) {
    678   1.61       dsl 		proc = pid_table[i].pt_proc;
    679   1.61       dsl 		pgrp = pid_table[i].pt_pgrp;
    680   1.61       dsl 		if (!P_VALID(proc)) {
    681   1.61       dsl 			/* Up 'use count' so that link is valid */
    682   1.61       dsl 			pid = (P_NEXT(proc) + pt_size) & ~pt_size;
    683  1.168       chs 			rpid = 0;
    684   1.61       dsl 			proc = P_FREE(pid);
    685   1.61       dsl 			if (pgrp)
    686   1.61       dsl 				pid = pgrp->pg_id;
    687  1.168       chs 		} else {
    688  1.168       chs 			pid = pid_table[i].pt_pid;
    689  1.168       chs 			rpid = pid;
    690  1.168       chs 		}
    691   1.72  junyoung 
    692   1.61       dsl 		/* Save entry in appropriate half of table */
    693   1.61       dsl 		n_pt[pid & pt_size].pt_proc = proc;
    694   1.61       dsl 		n_pt[pid & pt_size].pt_pgrp = pgrp;
    695  1.168       chs 		n_pt[pid & pt_size].pt_pid = rpid;
    696   1.61       dsl 
    697   1.61       dsl 		/* Put other piece on start of free list */
    698   1.61       dsl 		pid = (pid ^ pt_size) & ~pid_tbl_mask;
    699   1.61       dsl 		n_pt[pid & pt_size].pt_proc =
    700  1.168       chs 			P_FREE((pid & ~pt_size) | next_free_pt);
    701   1.61       dsl 		n_pt[pid & pt_size].pt_pgrp = 0;
    702  1.168       chs 		n_pt[pid & pt_size].pt_pid = 0;
    703  1.168       chs 
    704   1.61       dsl 		next_free_pt = i | (pid & pt_size);
    705   1.61       dsl 		if (i == 0)
    706   1.61       dsl 			break;
    707   1.61       dsl 	}
    708   1.61       dsl 
    709  1.150     rmind 	/* Save old table size and switch tables */
    710  1.150     rmind 	tsz = pt_size * sizeof(struct pid_table);
    711   1.61       dsl 	n_pt = pid_table;
    712   1.61       dsl 	pid_table = new_pt;
    713  1.168       chs 	pid_tbl_mask = new_pt_mask;
    714   1.61       dsl 
    715   1.61       dsl 	/*
    716   1.61       dsl 	 * pid_max starts as PID_MAX (= 30000), once we have 16384
    717   1.61       dsl 	 * allocated pids we need it to be larger!
    718   1.61       dsl 	 */
    719   1.61       dsl 	if (pid_tbl_mask > PID_MAX) {
    720   1.61       dsl 		pid_max = pid_tbl_mask * 2 + 1;
    721   1.61       dsl 		pid_alloc_lim |= pid_alloc_lim << 1;
    722   1.61       dsl 	} else
    723   1.61       dsl 		pid_alloc_lim <<= 1;	/* doubles number of free slots... */
    724   1.61       dsl 
    725  1.136        ad 	mutex_exit(proc_lock);
    726  1.150     rmind 	kmem_free(n_pt, tsz);
    727   1.61       dsl }
    728   1.61       dsl 
    729   1.61       dsl struct proc *
    730   1.61       dsl proc_alloc(void)
    731   1.61       dsl {
    732   1.61       dsl 	struct proc *p;
    733   1.61       dsl 
    734  1.128        ad 	p = pool_cache_get(proc_cache, PR_WAITOK);
    735   1.61       dsl 	p->p_stat = SIDL;			/* protect against others */
    736   1.96  christos 	proc_initspecific(p);
    737  1.164     rmind 	kdtrace_proc_ctor(NULL, p);
    738  1.168       chs 	p->p_pid = -1;
    739  1.168       chs 	proc_alloc_pid(p);
    740  1.168       chs 	return p;
    741  1.168       chs }
    742  1.168       chs 
    743  1.183      yamt /*
    744  1.183      yamt  * proc_alloc_pid: allocate PID and record the given proc 'p' so that
    745  1.183      yamt  * proc_find_raw() can find it by the PID.
    746  1.183      yamt  */
    747  1.183      yamt 
    748  1.168       chs pid_t
    749  1.168       chs proc_alloc_pid(struct proc *p)
    750  1.168       chs {
    751  1.168       chs 	struct pid_table *pt;
    752  1.168       chs 	pid_t pid;
    753  1.168       chs 	int nxt;
    754   1.61       dsl 
    755   1.61       dsl 	for (;;expand_pid_table()) {
    756   1.61       dsl 		if (__predict_false(pid_alloc_cnt >= pid_alloc_lim))
    757   1.61       dsl 			/* ensure pids cycle through 2000+ values */
    758   1.61       dsl 			continue;
    759  1.136        ad 		mutex_enter(proc_lock);
    760   1.61       dsl 		pt = &pid_table[next_free_pt];
    761    1.1       cgd #ifdef DIAGNOSTIC
    762   1.63  christos 		if (__predict_false(P_VALID(pt->pt_proc) || pt->pt_pgrp))
    763   1.61       dsl 			panic("proc_alloc: slot busy");
    764    1.1       cgd #endif
    765   1.61       dsl 		nxt = P_NEXT(pt->pt_proc);
    766   1.61       dsl 		if (nxt & pid_tbl_mask)
    767   1.61       dsl 			break;
    768   1.61       dsl 		/* Table full - expand (NB last entry not used....) */
    769  1.136        ad 		mutex_exit(proc_lock);
    770   1.61       dsl 	}
    771   1.61       dsl 
    772   1.61       dsl 	/* pid is 'saved use count' + 'size' + entry */
    773   1.61       dsl 	pid = (nxt & ~pid_tbl_mask) + pid_tbl_mask + 1 + next_free_pt;
    774   1.61       dsl 	if ((uint)pid > (uint)pid_max)
    775   1.61       dsl 		pid &= pid_tbl_mask;
    776   1.61       dsl 	next_free_pt = nxt & pid_tbl_mask;
    777   1.61       dsl 
    778   1.61       dsl 	/* Grab table slot */
    779   1.61       dsl 	pt->pt_proc = p;
    780  1.168       chs 
    781  1.168       chs 	KASSERT(pt->pt_pid == 0);
    782  1.168       chs 	pt->pt_pid = pid;
    783  1.168       chs 	if (p->p_pid == -1) {
    784  1.168       chs 		p->p_pid = pid;
    785  1.168       chs 	}
    786   1.61       dsl 	pid_alloc_cnt++;
    787  1.136        ad 	mutex_exit(proc_lock);
    788   1.61       dsl 
    789  1.168       chs 	return pid;
    790   1.61       dsl }
    791   1.61       dsl 
    792   1.61       dsl /*
    793  1.118        ad  * Free a process id - called from proc_free (in kern_exit.c)
    794  1.100        ad  *
    795  1.136        ad  * Called with the proc_lock held.
    796   1.61       dsl  */
    797   1.61       dsl void
    798  1.168       chs proc_free_pid(pid_t pid)
    799   1.61       dsl {
    800   1.61       dsl 	struct pid_table *pt;
    801   1.61       dsl 
    802  1.136        ad 	KASSERT(mutex_owned(proc_lock));
    803   1.61       dsl 
    804   1.61       dsl 	pt = &pid_table[pid & pid_tbl_mask];
    805  1.168       chs 
    806   1.61       dsl 	/* save pid use count in slot */
    807   1.61       dsl 	pt->pt_proc = P_FREE(pid & ~pid_tbl_mask);
    808  1.168       chs 	KASSERT(pt->pt_pid == pid);
    809  1.168       chs 	pt->pt_pid = 0;
    810   1.61       dsl 
    811   1.61       dsl 	if (pt->pt_pgrp == NULL) {
    812   1.61       dsl 		/* link last freed entry onto ours */
    813   1.61       dsl 		pid &= pid_tbl_mask;
    814   1.61       dsl 		pt = &pid_table[last_free_pt];
    815   1.61       dsl 		pt->pt_proc = P_FREE(P_NEXT(pt->pt_proc) | pid);
    816  1.168       chs 		pt->pt_pid = 0;
    817   1.61       dsl 		last_free_pt = pid;
    818   1.61       dsl 		pid_alloc_cnt--;
    819   1.61       dsl 	}
    820   1.61       dsl 
    821  1.126        ad 	atomic_dec_uint(&nprocs);
    822   1.61       dsl }
    823   1.61       dsl 
    824  1.128        ad void
    825  1.128        ad proc_free_mem(struct proc *p)
    826  1.128        ad {
    827  1.128        ad 
    828  1.160    darran 	kdtrace_proc_dtor(NULL, p);
    829  1.128        ad 	pool_cache_put(proc_cache, p);
    830  1.128        ad }
    831  1.128        ad 
    832   1.61       dsl /*
    833  1.151     rmind  * proc_enterpgrp: move p to a new or existing process group (and session).
    834   1.61       dsl  *
    835   1.61       dsl  * If we are creating a new pgrp, the pgid should equal
    836   1.72  junyoung  * the calling process' pid.
    837   1.61       dsl  * If is only valid to enter a process group that is in the session
    838   1.61       dsl  * of the process.
    839   1.61       dsl  * Also mksess should only be set if we are creating a process group
    840   1.61       dsl  *
    841  1.181    martin  * Only called from sys_setsid, sys_setpgid and posix_spawn/spawn_return.
    842   1.61       dsl  */
    843   1.61       dsl int
    844  1.151     rmind proc_enterpgrp(struct proc *curp, pid_t pid, pid_t pgid, bool mksess)
    845   1.61       dsl {
    846   1.61       dsl 	struct pgrp *new_pgrp, *pgrp;
    847   1.61       dsl 	struct session *sess;
    848  1.100        ad 	struct proc *p;
    849   1.61       dsl 	int rval;
    850   1.61       dsl 	pid_t pg_id = NO_PGID;
    851   1.61       dsl 
    852  1.151     rmind 	sess = mksess ? kmem_alloc(sizeof(*sess), KM_SLEEP) : NULL;
    853   1.61       dsl 
    854  1.107        ad 	/* Allocate data areas we might need before doing any validity checks */
    855  1.136        ad 	mutex_enter(proc_lock);		/* Because pid_table might change */
    856  1.107        ad 	if (pid_table[pgid & pid_tbl_mask].pt_pgrp == 0) {
    857  1.136        ad 		mutex_exit(proc_lock);
    858  1.131        ad 		new_pgrp = kmem_alloc(sizeof(*new_pgrp), KM_SLEEP);
    859  1.136        ad 		mutex_enter(proc_lock);
    860  1.107        ad 	} else
    861  1.107        ad 		new_pgrp = NULL;
    862   1.61       dsl 	rval = EPERM;	/* most common error (to save typing) */
    863   1.61       dsl 
    864   1.61       dsl 	/* Check pgrp exists or can be created */
    865   1.61       dsl 	pgrp = pid_table[pgid & pid_tbl_mask].pt_pgrp;
    866   1.61       dsl 	if (pgrp != NULL && pgrp->pg_id != pgid)
    867   1.61       dsl 		goto done;
    868   1.61       dsl 
    869   1.61       dsl 	/* Can only set another process under restricted circumstances. */
    870  1.100        ad 	if (pid != curp->p_pid) {
    871  1.167     rmind 		/* Must exist and be one of our children... */
    872  1.167     rmind 		p = proc_find(pid);
    873  1.167     rmind 		if (p == NULL || !p_inferior(p, curp)) {
    874   1.61       dsl 			rval = ESRCH;
    875   1.61       dsl 			goto done;
    876   1.61       dsl 		}
    877   1.61       dsl 		/* ... in the same session... */
    878   1.61       dsl 		if (sess != NULL || p->p_session != curp->p_session)
    879   1.61       dsl 			goto done;
    880   1.61       dsl 		/* ... existing pgid must be in same session ... */
    881   1.61       dsl 		if (pgrp != NULL && pgrp->pg_session != p->p_session)
    882   1.61       dsl 			goto done;
    883   1.61       dsl 		/* ... and not done an exec. */
    884  1.102     pavel 		if (p->p_flag & PK_EXEC) {
    885   1.61       dsl 			rval = EACCES;
    886   1.61       dsl 			goto done;
    887   1.49     enami 		}
    888  1.100        ad 	} else {
    889  1.100        ad 		/* ... setsid() cannot re-enter a pgrp */
    890  1.100        ad 		if (mksess && (curp->p_pgid == curp->p_pid ||
    891  1.167     rmind 		    pgrp_find(curp->p_pid)))
    892  1.100        ad 			goto done;
    893  1.100        ad 		p = curp;
    894   1.61       dsl 	}
    895    1.1       cgd 
    896   1.61       dsl 	/* Changing the process group/session of a session
    897   1.61       dsl 	   leader is definitely off limits. */
    898   1.61       dsl 	if (SESS_LEADER(p)) {
    899   1.61       dsl 		if (sess == NULL && p->p_pgrp == pgrp)
    900   1.61       dsl 			/* unless it's a definite noop */
    901   1.61       dsl 			rval = 0;
    902   1.61       dsl 		goto done;
    903   1.61       dsl 	}
    904   1.61       dsl 
    905   1.61       dsl 	/* Can only create a process group with id of process */
    906   1.61       dsl 	if (pgrp == NULL && pgid != pid)
    907   1.61       dsl 		goto done;
    908   1.61       dsl 
    909   1.61       dsl 	/* Can only create a session if creating pgrp */
    910   1.61       dsl 	if (sess != NULL && pgrp != NULL)
    911   1.61       dsl 		goto done;
    912   1.61       dsl 
    913   1.61       dsl 	/* Check we allocated memory for a pgrp... */
    914   1.61       dsl 	if (pgrp == NULL && new_pgrp == NULL)
    915   1.61       dsl 		goto done;
    916   1.61       dsl 
    917   1.61       dsl 	/* Don't attach to 'zombie' pgrp */
    918   1.61       dsl 	if (pgrp != NULL && LIST_EMPTY(&pgrp->pg_members))
    919   1.61       dsl 		goto done;
    920   1.61       dsl 
    921   1.61       dsl 	/* Expect to succeed now */
    922   1.61       dsl 	rval = 0;
    923   1.61       dsl 
    924   1.61       dsl 	if (pgrp == p->p_pgrp)
    925   1.61       dsl 		/* nothing to do */
    926   1.61       dsl 		goto done;
    927   1.61       dsl 
    928   1.61       dsl 	/* Ok all setup, link up required structures */
    929  1.100        ad 
    930   1.61       dsl 	if (pgrp == NULL) {
    931   1.61       dsl 		pgrp = new_pgrp;
    932  1.141      yamt 		new_pgrp = NULL;
    933   1.61       dsl 		if (sess != NULL) {
    934   1.21   thorpej 			sess->s_sid = p->p_pid;
    935    1.1       cgd 			sess->s_leader = p;
    936    1.1       cgd 			sess->s_count = 1;
    937    1.1       cgd 			sess->s_ttyvp = NULL;
    938    1.1       cgd 			sess->s_ttyp = NULL;
    939   1.58       dsl 			sess->s_flags = p->p_session->s_flags & ~S_LOGIN_SET;
    940   1.25     perry 			memcpy(sess->s_login, p->p_session->s_login,
    941    1.1       cgd 			    sizeof(sess->s_login));
    942  1.100        ad 			p->p_lflag &= ~PL_CONTROLT;
    943    1.1       cgd 		} else {
    944   1.61       dsl 			sess = p->p_pgrp->pg_session;
    945  1.151     rmind 			proc_sesshold(sess);
    946    1.1       cgd 		}
    947   1.61       dsl 		pgrp->pg_session = sess;
    948  1.141      yamt 		sess = NULL;
    949   1.61       dsl 
    950    1.1       cgd 		pgrp->pg_id = pgid;
    951   1.10   mycroft 		LIST_INIT(&pgrp->pg_members);
    952   1.61       dsl #ifdef DIAGNOSTIC
    953   1.63  christos 		if (__predict_false(pid_table[pgid & pid_tbl_mask].pt_pgrp))
    954   1.61       dsl 			panic("enterpgrp: pgrp table slot in use");
    955   1.63  christos 		if (__predict_false(mksess && p != curp))
    956   1.63  christos 			panic("enterpgrp: mksession and p != curproc");
    957   1.61       dsl #endif
    958   1.61       dsl 		pid_table[pgid & pid_tbl_mask].pt_pgrp = pgrp;
    959    1.1       cgd 		pgrp->pg_jobc = 0;
    960  1.136        ad 	}
    961    1.1       cgd 
    962    1.1       cgd 	/*
    963    1.1       cgd 	 * Adjust eligibility of affected pgrps to participate in job control.
    964    1.1       cgd 	 * Increment eligibility counts before decrementing, otherwise we
    965    1.1       cgd 	 * could reach 0 spuriously during the first call.
    966    1.1       cgd 	 */
    967    1.1       cgd 	fixjobc(p, pgrp, 1);
    968    1.1       cgd 	fixjobc(p, p->p_pgrp, 0);
    969    1.1       cgd 
    970  1.139        ad 	/* Interlock with ttread(). */
    971  1.139        ad 	mutex_spin_enter(&tty_lock);
    972  1.139        ad 
    973  1.100        ad 	/* Move process to requested group. */
    974   1.10   mycroft 	LIST_REMOVE(p, p_pglist);
    975   1.52      matt 	if (LIST_EMPTY(&p->p_pgrp->pg_members))
    976   1.61       dsl 		/* defer delete until we've dumped the lock */
    977   1.61       dsl 		pg_id = p->p_pgrp->pg_id;
    978    1.1       cgd 	p->p_pgrp = pgrp;
    979   1.10   mycroft 	LIST_INSERT_HEAD(&pgrp->pg_members, p, p_pglist);
    980  1.100        ad 
    981  1.100        ad 	/* Done with the swap; we can release the tty mutex. */
    982  1.128        ad 	mutex_spin_exit(&tty_lock);
    983  1.128        ad 
    984   1.61       dsl     done:
    985  1.151     rmind 	if (pg_id != NO_PGID) {
    986  1.151     rmind 		/* Releases proc_lock. */
    987  1.100        ad 		pg_delete(pg_id);
    988  1.151     rmind 	} else {
    989  1.151     rmind 		mutex_exit(proc_lock);
    990  1.151     rmind 	}
    991   1.61       dsl 	if (sess != NULL)
    992  1.131        ad 		kmem_free(sess, sizeof(*sess));
    993   1.61       dsl 	if (new_pgrp != NULL)
    994  1.131        ad 		kmem_free(new_pgrp, sizeof(*new_pgrp));
    995   1.63  christos #ifdef DEBUG_PGRP
    996   1.63  christos 	if (__predict_false(rval))
    997   1.61       dsl 		printf("enterpgrp(%d,%d,%d), curproc %d, rval %d\n",
    998   1.61       dsl 			pid, pgid, mksess, curp->p_pid, rval);
    999   1.61       dsl #endif
   1000   1.61       dsl 	return rval;
   1001    1.1       cgd }
   1002    1.1       cgd 
   1003    1.1       cgd /*
   1004  1.151     rmind  * proc_leavepgrp: remove a process from its process group.
   1005  1.151     rmind  *  => must be called with the proc_lock held, which will be released;
   1006    1.1       cgd  */
   1007  1.100        ad void
   1008  1.151     rmind proc_leavepgrp(struct proc *p)
   1009    1.1       cgd {
   1010   1.61       dsl 	struct pgrp *pgrp;
   1011    1.1       cgd 
   1012  1.136        ad 	KASSERT(mutex_owned(proc_lock));
   1013  1.100        ad 
   1014  1.139        ad 	/* Interlock with ttread() */
   1015  1.128        ad 	mutex_spin_enter(&tty_lock);
   1016   1.61       dsl 	pgrp = p->p_pgrp;
   1017   1.10   mycroft 	LIST_REMOVE(p, p_pglist);
   1018   1.94        ad 	p->p_pgrp = NULL;
   1019  1.128        ad 	mutex_spin_exit(&tty_lock);
   1020  1.100        ad 
   1021  1.151     rmind 	if (LIST_EMPTY(&pgrp->pg_members)) {
   1022  1.151     rmind 		/* Releases proc_lock. */
   1023  1.100        ad 		pg_delete(pgrp->pg_id);
   1024  1.151     rmind 	} else {
   1025  1.151     rmind 		mutex_exit(proc_lock);
   1026  1.151     rmind 	}
   1027   1.61       dsl }
   1028   1.61       dsl 
   1029  1.100        ad /*
   1030  1.151     rmind  * pg_remove: remove a process group from the table.
   1031  1.151     rmind  *  => must be called with the proc_lock held;
   1032  1.151     rmind  *  => returns process group to free;
   1033  1.100        ad  */
   1034  1.151     rmind static struct pgrp *
   1035  1.151     rmind pg_remove(pid_t pg_id)
   1036   1.61       dsl {
   1037   1.61       dsl 	struct pgrp *pgrp;
   1038   1.61       dsl 	struct pid_table *pt;
   1039   1.61       dsl 
   1040  1.136        ad 	KASSERT(mutex_owned(proc_lock));
   1041  1.100        ad 
   1042   1.61       dsl 	pt = &pid_table[pg_id & pid_tbl_mask];
   1043   1.61       dsl 	pgrp = pt->pt_pgrp;
   1044  1.151     rmind 
   1045  1.151     rmind 	KASSERT(pgrp != NULL);
   1046  1.151     rmind 	KASSERT(pgrp->pg_id == pg_id);
   1047  1.151     rmind 	KASSERT(LIST_EMPTY(&pgrp->pg_members));
   1048  1.151     rmind 
   1049  1.151     rmind 	pt->pt_pgrp = NULL;
   1050   1.61       dsl 
   1051   1.61       dsl 	if (!P_VALID(pt->pt_proc)) {
   1052  1.151     rmind 		/* Orphaned pgrp, put slot onto free list. */
   1053  1.151     rmind 		KASSERT((P_NEXT(pt->pt_proc) & pid_tbl_mask) == 0);
   1054   1.61       dsl 		pg_id &= pid_tbl_mask;
   1055   1.61       dsl 		pt = &pid_table[last_free_pt];
   1056   1.61       dsl 		pt->pt_proc = P_FREE(P_NEXT(pt->pt_proc) | pg_id);
   1057  1.168       chs 		KASSERT(pt->pt_pid == 0);
   1058   1.61       dsl 		last_free_pt = pg_id;
   1059   1.61       dsl 		pid_alloc_cnt--;
   1060   1.61       dsl 	}
   1061  1.151     rmind 	return pgrp;
   1062    1.1       cgd }
   1063    1.1       cgd 
   1064    1.1       cgd /*
   1065  1.151     rmind  * pg_delete: delete and free a process group.
   1066  1.151     rmind  *  => must be called with the proc_lock held, which will be released.
   1067    1.1       cgd  */
   1068   1.61       dsl static void
   1069   1.61       dsl pg_delete(pid_t pg_id)
   1070   1.61       dsl {
   1071  1.151     rmind 	struct pgrp *pg;
   1072   1.61       dsl 	struct tty *ttyp;
   1073   1.61       dsl 	struct session *ss;
   1074  1.100        ad 
   1075  1.136        ad 	KASSERT(mutex_owned(proc_lock));
   1076   1.61       dsl 
   1077  1.151     rmind 	pg = pid_table[pg_id & pid_tbl_mask].pt_pgrp;
   1078  1.151     rmind 	if (pg == NULL || pg->pg_id != pg_id || !LIST_EMPTY(&pg->pg_members)) {
   1079  1.151     rmind 		mutex_exit(proc_lock);
   1080   1.61       dsl 		return;
   1081  1.151     rmind 	}
   1082   1.61       dsl 
   1083  1.151     rmind 	ss = pg->pg_session;
   1084   1.71        pk 
   1085   1.61       dsl 	/* Remove reference (if any) from tty to this process group */
   1086  1.128        ad 	mutex_spin_enter(&tty_lock);
   1087   1.71        pk 	ttyp = ss->s_ttyp;
   1088  1.151     rmind 	if (ttyp != NULL && ttyp->t_pgrp == pg) {
   1089   1.61       dsl 		ttyp->t_pgrp = NULL;
   1090  1.151     rmind 		KASSERT(ttyp->t_session == ss);
   1091   1.71        pk 	}
   1092  1.128        ad 	mutex_spin_exit(&tty_lock);
   1093   1.61       dsl 
   1094   1.71        pk 	/*
   1095  1.151     rmind 	 * The leading process group in a session is freed by proc_sessrele(),
   1096  1.151     rmind 	 * if last reference.  Note: proc_sessrele() releases proc_lock.
   1097   1.71        pk 	 */
   1098  1.151     rmind 	pg = (ss->s_sid != pg->pg_id) ? pg_remove(pg_id) : NULL;
   1099  1.151     rmind 	proc_sessrele(ss);
   1100   1.61       dsl 
   1101  1.151     rmind 	if (pg != NULL) {
   1102  1.151     rmind 		/* Free it, if was not done by proc_sessrele(). */
   1103  1.151     rmind 		kmem_free(pg, sizeof(struct pgrp));
   1104  1.151     rmind 	}
   1105    1.1       cgd }
   1106    1.1       cgd 
   1107    1.1       cgd /*
   1108    1.1       cgd  * Adjust pgrp jobc counters when specified process changes process group.
   1109    1.1       cgd  * We count the number of processes in each process group that "qualify"
   1110    1.1       cgd  * the group for terminal job control (those with a parent in a different
   1111    1.1       cgd  * process group of the same session).  If that count reaches zero, the
   1112    1.1       cgd  * process group becomes orphaned.  Check both the specified process'
   1113    1.1       cgd  * process group and that of its children.
   1114    1.1       cgd  * entering == 0 => p is leaving specified group.
   1115    1.1       cgd  * entering == 1 => p is entering specified group.
   1116   1.68       dsl  *
   1117  1.136        ad  * Call with proc_lock held.
   1118    1.1       cgd  */
   1119    1.4    andrew void
   1120   1.59       dsl fixjobc(struct proc *p, struct pgrp *pgrp, int entering)
   1121    1.1       cgd {
   1122   1.39  augustss 	struct pgrp *hispgrp;
   1123   1.39  augustss 	struct session *mysession = pgrp->pg_session;
   1124   1.68       dsl 	struct proc *child;
   1125    1.1       cgd 
   1126  1.136        ad 	KASSERT(mutex_owned(proc_lock));
   1127  1.100        ad 
   1128    1.1       cgd 	/*
   1129    1.1       cgd 	 * Check p's parent to see whether p qualifies its own process
   1130    1.1       cgd 	 * group; if so, adjust count for p's process group.
   1131    1.1       cgd 	 */
   1132   1.68       dsl 	hispgrp = p->p_pptr->p_pgrp;
   1133   1.68       dsl 	if (hispgrp != pgrp && hispgrp->pg_session == mysession) {
   1134  1.100        ad 		if (entering) {
   1135    1.1       cgd 			pgrp->pg_jobc++;
   1136  1.136        ad 			p->p_lflag &= ~PL_ORPHANPG;
   1137  1.100        ad 		} else if (--pgrp->pg_jobc == 0)
   1138    1.1       cgd 			orphanpg(pgrp);
   1139   1.26   thorpej 	}
   1140    1.1       cgd 
   1141    1.1       cgd 	/*
   1142    1.1       cgd 	 * Check this process' children to see whether they qualify
   1143    1.1       cgd 	 * their process groups; if so, adjust counts for children's
   1144    1.1       cgd 	 * process groups.
   1145    1.1       cgd 	 */
   1146   1.68       dsl 	LIST_FOREACH(child, &p->p_children, p_sibling) {
   1147   1.68       dsl 		hispgrp = child->p_pgrp;
   1148   1.68       dsl 		if (hispgrp != pgrp && hispgrp->pg_session == mysession &&
   1149   1.68       dsl 		    !P_ZOMBIE(child)) {
   1150  1.100        ad 			if (entering) {
   1151  1.136        ad 				child->p_lflag &= ~PL_ORPHANPG;
   1152    1.1       cgd 				hispgrp->pg_jobc++;
   1153  1.100        ad 			} else if (--hispgrp->pg_jobc == 0)
   1154    1.1       cgd 				orphanpg(hispgrp);
   1155   1.26   thorpej 		}
   1156   1.26   thorpej 	}
   1157    1.1       cgd }
   1158    1.1       cgd 
   1159   1.72  junyoung /*
   1160    1.1       cgd  * A process group has become orphaned;
   1161    1.1       cgd  * if there are any stopped processes in the group,
   1162    1.1       cgd  * hang-up all process in that group.
   1163   1.68       dsl  *
   1164  1.136        ad  * Call with proc_lock held.
   1165    1.1       cgd  */
   1166    1.4    andrew static void
   1167   1.59       dsl orphanpg(struct pgrp *pg)
   1168    1.1       cgd {
   1169   1.39  augustss 	struct proc *p;
   1170  1.100        ad 
   1171  1.136        ad 	KASSERT(mutex_owned(proc_lock));
   1172  1.100        ad 
   1173   1.52      matt 	LIST_FOREACH(p, &pg->pg_members, p_pglist) {
   1174    1.1       cgd 		if (p->p_stat == SSTOP) {
   1175  1.136        ad 			p->p_lflag |= PL_ORPHANPG;
   1176  1.100        ad 			psignal(p, SIGHUP);
   1177  1.100        ad 			psignal(p, SIGCONT);
   1178   1.35    bouyer 		}
   1179   1.35    bouyer 	}
   1180   1.35    bouyer }
   1181    1.1       cgd 
   1182   1.61       dsl #ifdef DDB
   1183   1.61       dsl #include <ddb/db_output.h>
   1184   1.61       dsl void pidtbl_dump(void);
   1185   1.14  christos void
   1186   1.61       dsl pidtbl_dump(void)
   1187    1.1       cgd {
   1188   1.61       dsl 	struct pid_table *pt;
   1189   1.61       dsl 	struct proc *p;
   1190   1.39  augustss 	struct pgrp *pgrp;
   1191   1.61       dsl 	int id;
   1192    1.1       cgd 
   1193   1.61       dsl 	db_printf("pid table %p size %x, next %x, last %x\n",
   1194   1.61       dsl 		pid_table, pid_tbl_mask+1,
   1195   1.61       dsl 		next_free_pt, last_free_pt);
   1196   1.61       dsl 	for (pt = pid_table, id = 0; id <= pid_tbl_mask; id++, pt++) {
   1197   1.61       dsl 		p = pt->pt_proc;
   1198   1.61       dsl 		if (!P_VALID(p) && !pt->pt_pgrp)
   1199   1.61       dsl 			continue;
   1200   1.61       dsl 		db_printf("  id %x: ", id);
   1201   1.61       dsl 		if (P_VALID(p))
   1202  1.168       chs 			db_printf("slotpid %d proc %p id %d (0x%x) %s\n",
   1203  1.168       chs 				pt->pt_pid, p, p->p_pid, p->p_pid, p->p_comm);
   1204   1.61       dsl 		else
   1205   1.61       dsl 			db_printf("next %x use %x\n",
   1206   1.61       dsl 				P_NEXT(p) & pid_tbl_mask,
   1207   1.61       dsl 				P_NEXT(p) & ~pid_tbl_mask);
   1208   1.61       dsl 		if ((pgrp = pt->pt_pgrp)) {
   1209   1.61       dsl 			db_printf("\tsession %p, sid %d, count %d, login %s\n",
   1210   1.61       dsl 			    pgrp->pg_session, pgrp->pg_session->s_sid,
   1211   1.61       dsl 			    pgrp->pg_session->s_count,
   1212   1.61       dsl 			    pgrp->pg_session->s_login);
   1213   1.61       dsl 			db_printf("\tpgrp %p, pg_id %d, pg_jobc %d, members %p\n",
   1214   1.61       dsl 			    pgrp, pgrp->pg_id, pgrp->pg_jobc,
   1215  1.135      yamt 			    LIST_FIRST(&pgrp->pg_members));
   1216  1.135      yamt 			LIST_FOREACH(p, &pgrp->pg_members, p_pglist) {
   1217   1.72  junyoung 				db_printf("\t\tpid %d addr %p pgrp %p %s\n",
   1218   1.61       dsl 				    p->p_pid, p, p->p_pgrp, p->p_comm);
   1219   1.10   mycroft 			}
   1220    1.1       cgd 		}
   1221    1.1       cgd 	}
   1222    1.1       cgd }
   1223   1.61       dsl #endif /* DDB */
   1224   1.48      yamt 
   1225   1.48      yamt #ifdef KSTACK_CHECK_MAGIC
   1226   1.48      yamt 
   1227   1.48      yamt #define	KSTACK_MAGIC	0xdeadbeaf
   1228   1.48      yamt 
   1229   1.48      yamt /* XXX should be per process basis? */
   1230  1.149     rmind static int	kstackleftmin = KSTACK_SIZE;
   1231  1.149     rmind static int	kstackleftthres = KSTACK_SIZE / 8;
   1232   1.48      yamt 
   1233   1.48      yamt void
   1234   1.56      yamt kstack_setup_magic(const struct lwp *l)
   1235   1.48      yamt {
   1236   1.85     perry 	uint32_t *ip;
   1237   1.85     perry 	uint32_t const *end;
   1238   1.48      yamt 
   1239   1.56      yamt 	KASSERT(l != NULL);
   1240   1.56      yamt 	KASSERT(l != &lwp0);
   1241   1.48      yamt 
   1242   1.48      yamt 	/*
   1243   1.48      yamt 	 * fill all the stack with magic number
   1244   1.48      yamt 	 * so that later modification on it can be detected.
   1245   1.48      yamt 	 */
   1246   1.85     perry 	ip = (uint32_t *)KSTACK_LOWEST_ADDR(l);
   1247  1.114    dyoung 	end = (uint32_t *)((char *)KSTACK_LOWEST_ADDR(l) + KSTACK_SIZE);
   1248   1.48      yamt 	for (; ip < end; ip++) {
   1249   1.48      yamt 		*ip = KSTACK_MAGIC;
   1250   1.48      yamt 	}
   1251   1.48      yamt }
   1252   1.48      yamt 
   1253   1.48      yamt void
   1254   1.56      yamt kstack_check_magic(const struct lwp *l)
   1255   1.48      yamt {
   1256   1.85     perry 	uint32_t const *ip, *end;
   1257   1.48      yamt 	int stackleft;
   1258   1.48      yamt 
   1259   1.56      yamt 	KASSERT(l != NULL);
   1260   1.48      yamt 
   1261   1.48      yamt 	/* don't check proc0 */ /*XXX*/
   1262   1.56      yamt 	if (l == &lwp0)
   1263   1.48      yamt 		return;
   1264   1.48      yamt 
   1265   1.48      yamt #ifdef __MACHINE_STACK_GROWS_UP
   1266   1.48      yamt 	/* stack grows upwards (eg. hppa) */
   1267  1.106  christos 	ip = (uint32_t *)((void *)KSTACK_LOWEST_ADDR(l) + KSTACK_SIZE);
   1268   1.85     perry 	end = (uint32_t *)KSTACK_LOWEST_ADDR(l);
   1269   1.48      yamt 	for (ip--; ip >= end; ip--)
   1270   1.48      yamt 		if (*ip != KSTACK_MAGIC)
   1271   1.48      yamt 			break;
   1272   1.72  junyoung 
   1273  1.106  christos 	stackleft = (void *)KSTACK_LOWEST_ADDR(l) + KSTACK_SIZE - (void *)ip;
   1274   1.48      yamt #else /* __MACHINE_STACK_GROWS_UP */
   1275   1.48      yamt 	/* stack grows downwards (eg. i386) */
   1276   1.85     perry 	ip = (uint32_t *)KSTACK_LOWEST_ADDR(l);
   1277  1.114    dyoung 	end = (uint32_t *)((char *)KSTACK_LOWEST_ADDR(l) + KSTACK_SIZE);
   1278   1.48      yamt 	for (; ip < end; ip++)
   1279   1.48      yamt 		if (*ip != KSTACK_MAGIC)
   1280   1.48      yamt 			break;
   1281   1.48      yamt 
   1282   1.93  christos 	stackleft = ((const char *)ip) - (const char *)KSTACK_LOWEST_ADDR(l);
   1283   1.48      yamt #endif /* __MACHINE_STACK_GROWS_UP */
   1284   1.48      yamt 
   1285   1.48      yamt 	if (kstackleftmin > stackleft) {
   1286   1.48      yamt 		kstackleftmin = stackleft;
   1287   1.48      yamt 		if (stackleft < kstackleftthres)
   1288   1.56      yamt 			printf("warning: kernel stack left %d bytes"
   1289   1.56      yamt 			    "(pid %u:lid %u)\n", stackleft,
   1290   1.56      yamt 			    (u_int)l->l_proc->p_pid, (u_int)l->l_lid);
   1291   1.48      yamt 	}
   1292   1.48      yamt 
   1293   1.48      yamt 	if (stackleft <= 0) {
   1294   1.56      yamt 		panic("magic on the top of kernel stack changed for "
   1295   1.56      yamt 		    "pid %u, lid %u: maybe kernel stack overflow",
   1296   1.56      yamt 		    (u_int)l->l_proc->p_pid, (u_int)l->l_lid);
   1297   1.48      yamt 	}
   1298   1.48      yamt }
   1299   1.50     enami #endif /* KSTACK_CHECK_MAGIC */
   1300   1.79      yamt 
   1301   1.79      yamt int
   1302   1.79      yamt proclist_foreach_call(struct proclist *list,
   1303   1.79      yamt     int (*callback)(struct proc *, void *arg), void *arg)
   1304   1.79      yamt {
   1305   1.79      yamt 	struct proc marker;
   1306   1.79      yamt 	struct proc *p;
   1307   1.79      yamt 	int ret = 0;
   1308   1.79      yamt 
   1309  1.102     pavel 	marker.p_flag = PK_MARKER;
   1310  1.136        ad 	mutex_enter(proc_lock);
   1311   1.79      yamt 	for (p = LIST_FIRST(list); ret == 0 && p != NULL;) {
   1312  1.102     pavel 		if (p->p_flag & PK_MARKER) {
   1313   1.79      yamt 			p = LIST_NEXT(p, p_list);
   1314   1.79      yamt 			continue;
   1315   1.79      yamt 		}
   1316   1.79      yamt 		LIST_INSERT_AFTER(p, &marker, p_list);
   1317   1.79      yamt 		ret = (*callback)(p, arg);
   1318  1.136        ad 		KASSERT(mutex_owned(proc_lock));
   1319   1.79      yamt 		p = LIST_NEXT(&marker, p_list);
   1320   1.79      yamt 		LIST_REMOVE(&marker, p_list);
   1321   1.79      yamt 	}
   1322  1.136        ad 	mutex_exit(proc_lock);
   1323   1.79      yamt 
   1324   1.79      yamt 	return ret;
   1325   1.79      yamt }
   1326   1.86      yamt 
   1327   1.86      yamt int
   1328   1.86      yamt proc_vmspace_getref(struct proc *p, struct vmspace **vm)
   1329   1.86      yamt {
   1330   1.86      yamt 
   1331   1.86      yamt 	/* XXXCDC: how should locking work here? */
   1332   1.86      yamt 
   1333   1.87      yamt 	/* curproc exception is for coredump. */
   1334   1.87      yamt 
   1335  1.100        ad 	if ((p != curproc && (p->p_sflag & PS_WEXIT) != 0) ||
   1336   1.86      yamt 	    (p->p_vmspace->vm_refcnt < 1)) { /* XXX */
   1337   1.86      yamt 		return EFAULT;
   1338   1.86      yamt 	}
   1339   1.86      yamt 
   1340   1.86      yamt 	uvmspace_addref(p->p_vmspace);
   1341   1.86      yamt 	*vm = p->p_vmspace;
   1342   1.86      yamt 
   1343   1.86      yamt 	return 0;
   1344   1.86      yamt }
   1345   1.94        ad 
   1346   1.94        ad /*
   1347   1.94        ad  * Acquire a write lock on the process credential.
   1348   1.94        ad  */
   1349   1.94        ad void
   1350  1.100        ad proc_crmod_enter(void)
   1351   1.94        ad {
   1352  1.100        ad 	struct lwp *l = curlwp;
   1353  1.100        ad 	struct proc *p = l->l_proc;
   1354  1.100        ad 	kauth_cred_t oc;
   1355   1.94        ad 
   1356  1.117       dsl 	/* Reset what needs to be reset in plimit. */
   1357  1.117       dsl 	if (p->p_limit->pl_corename != defcorename) {
   1358  1.178     rmind 		lim_setcorename(p, defcorename, 0);
   1359  1.117       dsl 	}
   1360  1.117       dsl 
   1361  1.137        ad 	mutex_enter(p->p_lock);
   1362  1.100        ad 
   1363  1.100        ad 	/* Ensure the LWP cached credentials are up to date. */
   1364  1.100        ad 	if ((oc = l->l_cred) != p->p_cred) {
   1365  1.100        ad 		kauth_cred_hold(p->p_cred);
   1366  1.100        ad 		l->l_cred = p->p_cred;
   1367  1.100        ad 		kauth_cred_free(oc);
   1368  1.100        ad 	}
   1369   1.94        ad }
   1370   1.94        ad 
   1371   1.94        ad /*
   1372  1.100        ad  * Set in a new process credential, and drop the write lock.  The credential
   1373  1.100        ad  * must have a reference already.  Optionally, free a no-longer required
   1374  1.100        ad  * credential.  The scheduler also needs to inspect p_cred, so we also
   1375  1.100        ad  * briefly acquire the sched state mutex.
   1376   1.94        ad  */
   1377   1.94        ad void
   1378  1.104   thorpej proc_crmod_leave(kauth_cred_t scred, kauth_cred_t fcred, bool sugid)
   1379   1.94        ad {
   1380  1.133        ad 	struct lwp *l = curlwp, *l2;
   1381  1.100        ad 	struct proc *p = l->l_proc;
   1382  1.100        ad 	kauth_cred_t oc;
   1383  1.100        ad 
   1384  1.137        ad 	KASSERT(mutex_owned(p->p_lock));
   1385  1.137        ad 
   1386  1.100        ad 	/* Is there a new credential to set in? */
   1387  1.100        ad 	if (scred != NULL) {
   1388  1.100        ad 		p->p_cred = scred;
   1389  1.133        ad 		LIST_FOREACH(l2, &p->p_lwps, l_sibling) {
   1390  1.133        ad 			if (l2 != l)
   1391  1.133        ad 				l2->l_prflag |= LPR_CRMOD;
   1392  1.133        ad 		}
   1393  1.100        ad 
   1394  1.100        ad 		/* Ensure the LWP cached credentials are up to date. */
   1395  1.100        ad 		if ((oc = l->l_cred) != scred) {
   1396  1.100        ad 			kauth_cred_hold(scred);
   1397  1.100        ad 			l->l_cred = scred;
   1398  1.100        ad 		}
   1399  1.100        ad 	} else
   1400  1.100        ad 		oc = NULL;	/* XXXgcc */
   1401  1.100        ad 
   1402  1.100        ad 	if (sugid) {
   1403  1.100        ad 		/*
   1404  1.100        ad 		 * Mark process as having changed credentials, stops
   1405  1.100        ad 		 * tracing etc.
   1406  1.100        ad 		 */
   1407  1.102     pavel 		p->p_flag |= PK_SUGID;
   1408  1.100        ad 	}
   1409   1.94        ad 
   1410  1.137        ad 	mutex_exit(p->p_lock);
   1411  1.100        ad 
   1412  1.100        ad 	/* If there is a credential to be released, free it now. */
   1413  1.100        ad 	if (fcred != NULL) {
   1414  1.100        ad 		KASSERT(scred != NULL);
   1415   1.94        ad 		kauth_cred_free(fcred);
   1416  1.100        ad 		if (oc != scred)
   1417  1.100        ad 			kauth_cred_free(oc);
   1418  1.100        ad 	}
   1419  1.100        ad }
   1420  1.100        ad 
   1421  1.100        ad /*
   1422   1.95   thorpej  * proc_specific_key_create --
   1423   1.95   thorpej  *	Create a key for subsystem proc-specific data.
   1424   1.95   thorpej  */
   1425   1.95   thorpej int
   1426   1.95   thorpej proc_specific_key_create(specificdata_key_t *keyp, specificdata_dtor_t dtor)
   1427   1.95   thorpej {
   1428   1.95   thorpej 
   1429   1.98   thorpej 	return (specificdata_key_create(proc_specificdata_domain, keyp, dtor));
   1430   1.95   thorpej }
   1431   1.95   thorpej 
   1432   1.95   thorpej /*
   1433   1.95   thorpej  * proc_specific_key_delete --
   1434   1.95   thorpej  *	Delete a key for subsystem proc-specific data.
   1435   1.95   thorpej  */
   1436   1.95   thorpej void
   1437   1.95   thorpej proc_specific_key_delete(specificdata_key_t key)
   1438   1.95   thorpej {
   1439   1.95   thorpej 
   1440   1.95   thorpej 	specificdata_key_delete(proc_specificdata_domain, key);
   1441   1.95   thorpej }
   1442   1.95   thorpej 
   1443   1.98   thorpej /*
   1444   1.98   thorpej  * proc_initspecific --
   1445   1.98   thorpej  *	Initialize a proc's specificdata container.
   1446   1.98   thorpej  */
   1447   1.96  christos void
   1448   1.96  christos proc_initspecific(struct proc *p)
   1449   1.96  christos {
   1450   1.96  christos 	int error;
   1451   1.98   thorpej 
   1452   1.96  christos 	error = specificdata_init(proc_specificdata_domain, &p->p_specdataref);
   1453   1.96  christos 	KASSERT(error == 0);
   1454   1.96  christos }
   1455   1.96  christos 
   1456   1.95   thorpej /*
   1457   1.98   thorpej  * proc_finispecific --
   1458   1.98   thorpej  *	Finalize a proc's specificdata container.
   1459   1.98   thorpej  */
   1460   1.98   thorpej void
   1461   1.98   thorpej proc_finispecific(struct proc *p)
   1462   1.98   thorpej {
   1463   1.98   thorpej 
   1464   1.98   thorpej 	specificdata_fini(proc_specificdata_domain, &p->p_specdataref);
   1465   1.98   thorpej }
   1466   1.98   thorpej 
   1467   1.98   thorpej /*
   1468   1.95   thorpej  * proc_getspecific --
   1469   1.95   thorpej  *	Return proc-specific data corresponding to the specified key.
   1470   1.95   thorpej  */
   1471   1.95   thorpej void *
   1472   1.95   thorpej proc_getspecific(struct proc *p, specificdata_key_t key)
   1473   1.95   thorpej {
   1474   1.95   thorpej 
   1475   1.95   thorpej 	return (specificdata_getspecific(proc_specificdata_domain,
   1476   1.95   thorpej 					 &p->p_specdataref, key));
   1477   1.95   thorpej }
   1478   1.95   thorpej 
   1479   1.95   thorpej /*
   1480   1.95   thorpej  * proc_setspecific --
   1481   1.95   thorpej  *	Set proc-specific data corresponding to the specified key.
   1482   1.95   thorpej  */
   1483   1.95   thorpej void
   1484   1.95   thorpej proc_setspecific(struct proc *p, specificdata_key_t key, void *data)
   1485   1.95   thorpej {
   1486   1.95   thorpej 
   1487   1.95   thorpej 	specificdata_setspecific(proc_specificdata_domain,
   1488   1.95   thorpej 				 &p->p_specdataref, key, data);
   1489   1.95   thorpej }
   1490  1.154      elad 
   1491  1.154      elad int
   1492  1.154      elad proc_uidmatch(kauth_cred_t cred, kauth_cred_t target)
   1493  1.154      elad {
   1494  1.154      elad 	int r = 0;
   1495  1.154      elad 
   1496  1.154      elad 	if (kauth_cred_getuid(cred) != kauth_cred_getuid(target) ||
   1497  1.154      elad 	    kauth_cred_getuid(cred) != kauth_cred_getsvuid(target)) {
   1498  1.154      elad 		/*
   1499  1.154      elad 		 * suid proc of ours or proc not ours
   1500  1.154      elad 		 */
   1501  1.154      elad 		r = EPERM;
   1502  1.154      elad 	} else if (kauth_cred_getgid(target) != kauth_cred_getsvgid(target)) {
   1503  1.154      elad 		/*
   1504  1.154      elad 		 * sgid proc has sgid back to us temporarily
   1505  1.154      elad 		 */
   1506  1.154      elad 		r = EPERM;
   1507  1.154      elad 	} else {
   1508  1.154      elad 		/*
   1509  1.154      elad 		 * our rgid must be in target's group list (ie,
   1510  1.154      elad 		 * sub-processes started by a sgid process)
   1511  1.154      elad 		 */
   1512  1.154      elad 		int ismember = 0;
   1513  1.154      elad 
   1514  1.154      elad 		if (kauth_cred_ismember_gid(cred,
   1515  1.154      elad 		    kauth_cred_getgid(target), &ismember) != 0 ||
   1516  1.154      elad 		    !ismember)
   1517  1.154      elad 			r = EPERM;
   1518  1.154      elad 	}
   1519  1.154      elad 
   1520  1.154      elad 	return (r);
   1521  1.154      elad }
   1522  1.170     pooka 
   1523  1.170     pooka /*
   1524  1.170     pooka  * sysctl stuff
   1525  1.170     pooka  */
   1526  1.170     pooka 
   1527  1.170     pooka #define KERN_PROCSLOP	(5 * sizeof(struct kinfo_proc))
   1528  1.170     pooka 
   1529  1.170     pooka static const u_int sysctl_flagmap[] = {
   1530  1.170     pooka 	PK_ADVLOCK, P_ADVLOCK,
   1531  1.170     pooka 	PK_EXEC, P_EXEC,
   1532  1.170     pooka 	PK_NOCLDWAIT, P_NOCLDWAIT,
   1533  1.170     pooka 	PK_32, P_32,
   1534  1.170     pooka 	PK_CLDSIGIGN, P_CLDSIGIGN,
   1535  1.170     pooka 	PK_SUGID, P_SUGID,
   1536  1.170     pooka 	0
   1537  1.170     pooka };
   1538  1.170     pooka 
   1539  1.170     pooka static const u_int sysctl_sflagmap[] = {
   1540  1.170     pooka 	PS_NOCLDSTOP, P_NOCLDSTOP,
   1541  1.170     pooka 	PS_WEXIT, P_WEXIT,
   1542  1.170     pooka 	PS_STOPFORK, P_STOPFORK,
   1543  1.170     pooka 	PS_STOPEXEC, P_STOPEXEC,
   1544  1.170     pooka 	PS_STOPEXIT, P_STOPEXIT,
   1545  1.170     pooka 	0
   1546  1.170     pooka };
   1547  1.170     pooka 
   1548  1.170     pooka static const u_int sysctl_slflagmap[] = {
   1549  1.170     pooka 	PSL_TRACED, P_TRACED,
   1550  1.170     pooka 	PSL_FSTRACE, P_FSTRACE,
   1551  1.170     pooka 	PSL_CHTRACED, P_CHTRACED,
   1552  1.170     pooka 	PSL_SYSCALL, P_SYSCALL,
   1553  1.170     pooka 	0
   1554  1.170     pooka };
   1555  1.170     pooka 
   1556  1.170     pooka static const u_int sysctl_lflagmap[] = {
   1557  1.170     pooka 	PL_CONTROLT, P_CONTROLT,
   1558  1.170     pooka 	PL_PPWAIT, P_PPWAIT,
   1559  1.170     pooka 	0
   1560  1.170     pooka };
   1561  1.170     pooka 
   1562  1.170     pooka static const u_int sysctl_stflagmap[] = {
   1563  1.170     pooka 	PST_PROFIL, P_PROFIL,
   1564  1.170     pooka 	0
   1565  1.170     pooka 
   1566  1.170     pooka };
   1567  1.170     pooka 
   1568  1.170     pooka /* used by kern_lwp also */
   1569  1.170     pooka const u_int sysctl_lwpflagmap[] = {
   1570  1.170     pooka 	LW_SINTR, L_SINTR,
   1571  1.170     pooka 	LW_SYSTEM, L_SYSTEM,
   1572  1.170     pooka 	0
   1573  1.170     pooka };
   1574  1.170     pooka 
   1575  1.170     pooka /*
   1576  1.170     pooka  * Find the most ``active'' lwp of a process and return it for ps display
   1577  1.170     pooka  * purposes
   1578  1.170     pooka  */
   1579  1.170     pooka static struct lwp *
   1580  1.170     pooka proc_active_lwp(struct proc *p)
   1581  1.170     pooka {
   1582  1.170     pooka 	static const int ostat[] = {
   1583  1.170     pooka 		0,
   1584  1.170     pooka 		2,	/* LSIDL */
   1585  1.170     pooka 		6,	/* LSRUN */
   1586  1.170     pooka 		5,	/* LSSLEEP */
   1587  1.170     pooka 		4,	/* LSSTOP */
   1588  1.170     pooka 		0,	/* LSZOMB */
   1589  1.170     pooka 		1,	/* LSDEAD */
   1590  1.170     pooka 		7,	/* LSONPROC */
   1591  1.170     pooka 		3	/* LSSUSPENDED */
   1592  1.170     pooka 	};
   1593  1.170     pooka 
   1594  1.170     pooka 	struct lwp *l, *lp = NULL;
   1595  1.170     pooka 	LIST_FOREACH(l, &p->p_lwps, l_sibling) {
   1596  1.170     pooka 		KASSERT(l->l_stat >= 0 && l->l_stat < __arraycount(ostat));
   1597  1.170     pooka 		if (lp == NULL ||
   1598  1.170     pooka 		    ostat[l->l_stat] > ostat[lp->l_stat] ||
   1599  1.170     pooka 		    (ostat[l->l_stat] == ostat[lp->l_stat] &&
   1600  1.170     pooka 		    l->l_cpticks > lp->l_cpticks)) {
   1601  1.170     pooka 			lp = l;
   1602  1.170     pooka 			continue;
   1603  1.170     pooka 		}
   1604  1.170     pooka 	}
   1605  1.170     pooka 	return lp;
   1606  1.170     pooka }
   1607  1.170     pooka 
   1608  1.170     pooka static int
   1609  1.170     pooka sysctl_doeproc(SYSCTLFN_ARGS)
   1610  1.170     pooka {
   1611  1.170     pooka 	union {
   1612  1.170     pooka 		struct kinfo_proc kproc;
   1613  1.170     pooka 		struct kinfo_proc2 kproc2;
   1614  1.170     pooka 	} *kbuf;
   1615  1.170     pooka 	struct proc *p, *next, *marker;
   1616  1.170     pooka 	char *where, *dp;
   1617  1.170     pooka 	int type, op, arg, error;
   1618  1.170     pooka 	u_int elem_size, kelem_size, elem_count;
   1619  1.170     pooka 	size_t buflen, needed;
   1620  1.170     pooka 	bool match, zombie, mmmbrains;
   1621  1.170     pooka 
   1622  1.170     pooka 	if (namelen == 1 && name[0] == CTL_QUERY)
   1623  1.170     pooka 		return (sysctl_query(SYSCTLFN_CALL(rnode)));
   1624  1.170     pooka 
   1625  1.170     pooka 	dp = where = oldp;
   1626  1.170     pooka 	buflen = where != NULL ? *oldlenp : 0;
   1627  1.170     pooka 	error = 0;
   1628  1.170     pooka 	needed = 0;
   1629  1.170     pooka 	type = rnode->sysctl_num;
   1630  1.170     pooka 
   1631  1.170     pooka 	if (type == KERN_PROC) {
   1632  1.170     pooka 		if (namelen != 2 && !(namelen == 1 && name[0] == KERN_PROC_ALL))
   1633  1.170     pooka 			return (EINVAL);
   1634  1.170     pooka 		op = name[0];
   1635  1.170     pooka 		if (op != KERN_PROC_ALL)
   1636  1.170     pooka 			arg = name[1];
   1637  1.170     pooka 		else
   1638  1.170     pooka 			arg = 0;		/* Quell compiler warning */
   1639  1.170     pooka 		elem_count = 0;	/* Ditto */
   1640  1.170     pooka 		kelem_size = elem_size = sizeof(kbuf->kproc);
   1641  1.170     pooka 	} else {
   1642  1.170     pooka 		if (namelen != 4)
   1643  1.170     pooka 			return (EINVAL);
   1644  1.170     pooka 		op = name[0];
   1645  1.170     pooka 		arg = name[1];
   1646  1.170     pooka 		elem_size = name[2];
   1647  1.170     pooka 		elem_count = name[3];
   1648  1.170     pooka 		kelem_size = sizeof(kbuf->kproc2);
   1649  1.170     pooka 	}
   1650  1.170     pooka 
   1651  1.170     pooka 	sysctl_unlock();
   1652  1.170     pooka 
   1653  1.170     pooka 	kbuf = kmem_alloc(sizeof(*kbuf), KM_SLEEP);
   1654  1.170     pooka 	marker = kmem_alloc(sizeof(*marker), KM_SLEEP);
   1655  1.170     pooka 	marker->p_flag = PK_MARKER;
   1656  1.170     pooka 
   1657  1.170     pooka 	mutex_enter(proc_lock);
   1658  1.170     pooka 	mmmbrains = false;
   1659  1.170     pooka 	for (p = LIST_FIRST(&allproc);; p = next) {
   1660  1.170     pooka 		if (p == NULL) {
   1661  1.170     pooka 			if (!mmmbrains) {
   1662  1.170     pooka 				p = LIST_FIRST(&zombproc);
   1663  1.170     pooka 				mmmbrains = true;
   1664  1.170     pooka 			}
   1665  1.170     pooka 			if (p == NULL)
   1666  1.170     pooka 				break;
   1667  1.170     pooka 		}
   1668  1.170     pooka 		next = LIST_NEXT(p, p_list);
   1669  1.170     pooka 		if ((p->p_flag & PK_MARKER) != 0)
   1670  1.170     pooka 			continue;
   1671  1.170     pooka 
   1672  1.170     pooka 		/*
   1673  1.170     pooka 		 * Skip embryonic processes.
   1674  1.170     pooka 		 */
   1675  1.170     pooka 		if (p->p_stat == SIDL)
   1676  1.170     pooka 			continue;
   1677  1.170     pooka 
   1678  1.170     pooka 		mutex_enter(p->p_lock);
   1679  1.170     pooka 		error = kauth_authorize_process(l->l_cred,
   1680  1.170     pooka 		    KAUTH_PROCESS_CANSEE, p,
   1681  1.170     pooka 		    KAUTH_ARG(KAUTH_REQ_PROCESS_CANSEE_ENTRY), NULL, NULL);
   1682  1.170     pooka 		if (error != 0) {
   1683  1.170     pooka 			mutex_exit(p->p_lock);
   1684  1.170     pooka 			continue;
   1685  1.170     pooka 		}
   1686  1.170     pooka 
   1687  1.170     pooka 		/*
   1688  1.170     pooka 		 * TODO - make more efficient (see notes below).
   1689  1.170     pooka 		 * do by session.
   1690  1.170     pooka 		 */
   1691  1.170     pooka 		switch (op) {
   1692  1.170     pooka 		case KERN_PROC_PID:
   1693  1.170     pooka 			/* could do this with just a lookup */
   1694  1.170     pooka 			match = (p->p_pid == (pid_t)arg);
   1695  1.170     pooka 			break;
   1696  1.170     pooka 
   1697  1.170     pooka 		case KERN_PROC_PGRP:
   1698  1.170     pooka 			/* could do this by traversing pgrp */
   1699  1.170     pooka 			match = (p->p_pgrp->pg_id == (pid_t)arg);
   1700  1.170     pooka 			break;
   1701  1.170     pooka 
   1702  1.170     pooka 		case KERN_PROC_SESSION:
   1703  1.170     pooka 			match = (p->p_session->s_sid == (pid_t)arg);
   1704  1.170     pooka 			break;
   1705  1.170     pooka 
   1706  1.170     pooka 		case KERN_PROC_TTY:
   1707  1.170     pooka 			match = true;
   1708  1.170     pooka 			if (arg == (int) KERN_PROC_TTY_REVOKE) {
   1709  1.170     pooka 				if ((p->p_lflag & PL_CONTROLT) == 0 ||
   1710  1.170     pooka 				    p->p_session->s_ttyp == NULL ||
   1711  1.170     pooka 				    p->p_session->s_ttyvp != NULL) {
   1712  1.170     pooka 				    	match = false;
   1713  1.170     pooka 				}
   1714  1.170     pooka 			} else if ((p->p_lflag & PL_CONTROLT) == 0 ||
   1715  1.170     pooka 			    p->p_session->s_ttyp == NULL) {
   1716  1.170     pooka 				if ((dev_t)arg != KERN_PROC_TTY_NODEV) {
   1717  1.170     pooka 					match = false;
   1718  1.170     pooka 				}
   1719  1.170     pooka 			} else if (p->p_session->s_ttyp->t_dev != (dev_t)arg) {
   1720  1.170     pooka 				match = false;
   1721  1.170     pooka 			}
   1722  1.170     pooka 			break;
   1723  1.170     pooka 
   1724  1.170     pooka 		case KERN_PROC_UID:
   1725  1.170     pooka 			match = (kauth_cred_geteuid(p->p_cred) == (uid_t)arg);
   1726  1.170     pooka 			break;
   1727  1.170     pooka 
   1728  1.170     pooka 		case KERN_PROC_RUID:
   1729  1.170     pooka 			match = (kauth_cred_getuid(p->p_cred) == (uid_t)arg);
   1730  1.170     pooka 			break;
   1731  1.170     pooka 
   1732  1.170     pooka 		case KERN_PROC_GID:
   1733  1.170     pooka 			match = (kauth_cred_getegid(p->p_cred) == (uid_t)arg);
   1734  1.170     pooka 			break;
   1735  1.170     pooka 
   1736  1.170     pooka 		case KERN_PROC_RGID:
   1737  1.170     pooka 			match = (kauth_cred_getgid(p->p_cred) == (uid_t)arg);
   1738  1.170     pooka 			break;
   1739  1.170     pooka 
   1740  1.170     pooka 		case KERN_PROC_ALL:
   1741  1.170     pooka 			match = true;
   1742  1.170     pooka 			/* allow everything */
   1743  1.170     pooka 			break;
   1744  1.170     pooka 
   1745  1.170     pooka 		default:
   1746  1.170     pooka 			error = EINVAL;
   1747  1.170     pooka 			mutex_exit(p->p_lock);
   1748  1.170     pooka 			goto cleanup;
   1749  1.170     pooka 		}
   1750  1.170     pooka 		if (!match) {
   1751  1.170     pooka 			mutex_exit(p->p_lock);
   1752  1.170     pooka 			continue;
   1753  1.170     pooka 		}
   1754  1.170     pooka 
   1755  1.170     pooka 		/*
   1756  1.170     pooka 		 * Grab a hold on the process.
   1757  1.170     pooka 		 */
   1758  1.170     pooka 		if (mmmbrains) {
   1759  1.170     pooka 			zombie = true;
   1760  1.170     pooka 		} else {
   1761  1.170     pooka 			zombie = !rw_tryenter(&p->p_reflock, RW_READER);
   1762  1.170     pooka 		}
   1763  1.170     pooka 		if (zombie) {
   1764  1.170     pooka 			LIST_INSERT_AFTER(p, marker, p_list);
   1765  1.170     pooka 		}
   1766  1.170     pooka 
   1767  1.170     pooka 		if (buflen >= elem_size &&
   1768  1.170     pooka 		    (type == KERN_PROC || elem_count > 0)) {
   1769  1.170     pooka 			if (type == KERN_PROC) {
   1770  1.170     pooka 				kbuf->kproc.kp_proc = *p;
   1771  1.170     pooka 				fill_eproc(p, &kbuf->kproc.kp_eproc, zombie);
   1772  1.170     pooka 			} else {
   1773  1.170     pooka 				fill_kproc2(p, &kbuf->kproc2, zombie);
   1774  1.170     pooka 				elem_count--;
   1775  1.170     pooka 			}
   1776  1.170     pooka 			mutex_exit(p->p_lock);
   1777  1.170     pooka 			mutex_exit(proc_lock);
   1778  1.170     pooka 			/*
   1779  1.170     pooka 			 * Copy out elem_size, but not larger than kelem_size
   1780  1.170     pooka 			 */
   1781  1.170     pooka 			error = sysctl_copyout(l, kbuf, dp,
   1782  1.170     pooka 			    min(kelem_size, elem_size));
   1783  1.170     pooka 			mutex_enter(proc_lock);
   1784  1.170     pooka 			if (error) {
   1785  1.170     pooka 				goto bah;
   1786  1.170     pooka 			}
   1787  1.170     pooka 			dp += elem_size;
   1788  1.170     pooka 			buflen -= elem_size;
   1789  1.170     pooka 		} else {
   1790  1.170     pooka 			mutex_exit(p->p_lock);
   1791  1.170     pooka 		}
   1792  1.170     pooka 		needed += elem_size;
   1793  1.170     pooka 
   1794  1.170     pooka 		/*
   1795  1.170     pooka 		 * Release reference to process.
   1796  1.170     pooka 		 */
   1797  1.170     pooka 	 	if (zombie) {
   1798  1.170     pooka 			next = LIST_NEXT(marker, p_list);
   1799  1.170     pooka  			LIST_REMOVE(marker, p_list);
   1800  1.170     pooka 		} else {
   1801  1.170     pooka 			rw_exit(&p->p_reflock);
   1802  1.170     pooka 			next = LIST_NEXT(p, p_list);
   1803  1.170     pooka 		}
   1804  1.170     pooka 	}
   1805  1.170     pooka 	mutex_exit(proc_lock);
   1806  1.170     pooka 
   1807  1.170     pooka 	if (where != NULL) {
   1808  1.170     pooka 		*oldlenp = dp - where;
   1809  1.170     pooka 		if (needed > *oldlenp) {
   1810  1.170     pooka 			error = ENOMEM;
   1811  1.170     pooka 			goto out;
   1812  1.170     pooka 		}
   1813  1.170     pooka 	} else {
   1814  1.170     pooka 		needed += KERN_PROCSLOP;
   1815  1.170     pooka 		*oldlenp = needed;
   1816  1.170     pooka 	}
   1817  1.170     pooka 	if (kbuf)
   1818  1.170     pooka 		kmem_free(kbuf, sizeof(*kbuf));
   1819  1.170     pooka 	if (marker)
   1820  1.170     pooka 		kmem_free(marker, sizeof(*marker));
   1821  1.170     pooka 	sysctl_relock();
   1822  1.170     pooka 	return 0;
   1823  1.170     pooka  bah:
   1824  1.170     pooka  	if (zombie)
   1825  1.170     pooka  		LIST_REMOVE(marker, p_list);
   1826  1.170     pooka 	else
   1827  1.170     pooka 		rw_exit(&p->p_reflock);
   1828  1.170     pooka  cleanup:
   1829  1.170     pooka 	mutex_exit(proc_lock);
   1830  1.170     pooka  out:
   1831  1.170     pooka 	if (kbuf)
   1832  1.170     pooka 		kmem_free(kbuf, sizeof(*kbuf));
   1833  1.170     pooka 	if (marker)
   1834  1.170     pooka 		kmem_free(marker, sizeof(*marker));
   1835  1.170     pooka 	sysctl_relock();
   1836  1.170     pooka 	return error;
   1837  1.170     pooka }
   1838  1.170     pooka 
   1839  1.172     joerg int
   1840  1.172     joerg copyin_psstrings(struct proc *p, struct ps_strings *arginfo)
   1841  1.172     joerg {
   1842  1.172     joerg 
   1843  1.172     joerg #ifdef COMPAT_NETBSD32
   1844  1.172     joerg 	if (p->p_flag & PK_32) {
   1845  1.172     joerg 		struct ps_strings32 arginfo32;
   1846  1.172     joerg 
   1847  1.173      matt 		int error = copyin_proc(p, (void *)p->p_psstrp, &arginfo32,
   1848  1.172     joerg 		    sizeof(arginfo32));
   1849  1.172     joerg 		if (error)
   1850  1.172     joerg 			return error;
   1851  1.172     joerg 		arginfo->ps_argvstr = (void *)(uintptr_t)arginfo32.ps_argvstr;
   1852  1.172     joerg 		arginfo->ps_nargvstr = arginfo32.ps_nargvstr;
   1853  1.172     joerg 		arginfo->ps_envstr = (void *)(uintptr_t)arginfo32.ps_envstr;
   1854  1.172     joerg 		arginfo->ps_nenvstr = arginfo32.ps_nenvstr;
   1855  1.173      matt 		return 0;
   1856  1.173      matt 	}
   1857  1.172     joerg #endif
   1858  1.173      matt 	return copyin_proc(p, (void *)p->p_psstrp, arginfo, sizeof(*arginfo));
   1859  1.172     joerg }
   1860  1.172     joerg 
   1861  1.172     joerg static int
   1862  1.172     joerg copy_procargs_sysctl_cb(void *cookie_, const void *src, size_t off, size_t len)
   1863  1.172     joerg {
   1864  1.172     joerg 	void **cookie = cookie_;
   1865  1.172     joerg 	struct lwp *l = cookie[0];
   1866  1.172     joerg 	char *dst = cookie[1];
   1867  1.172     joerg 
   1868  1.172     joerg 	return sysctl_copyout(l, src, dst + off, len);
   1869  1.172     joerg }
   1870  1.172     joerg 
   1871  1.170     pooka /*
   1872  1.170     pooka  * sysctl helper routine for kern.proc_args pseudo-subtree.
   1873  1.170     pooka  */
   1874  1.170     pooka static int
   1875  1.170     pooka sysctl_kern_proc_args(SYSCTLFN_ARGS)
   1876  1.170     pooka {
   1877  1.170     pooka 	struct ps_strings pss;
   1878  1.170     pooka 	struct proc *p;
   1879  1.170     pooka 	pid_t pid;
   1880  1.172     joerg 	int type, error;
   1881  1.172     joerg 	void *cookie[2];
   1882  1.170     pooka 
   1883  1.170     pooka 	if (namelen == 1 && name[0] == CTL_QUERY)
   1884  1.170     pooka 		return (sysctl_query(SYSCTLFN_CALL(rnode)));
   1885  1.170     pooka 
   1886  1.170     pooka 	if (newp != NULL || namelen != 2)
   1887  1.170     pooka 		return (EINVAL);
   1888  1.170     pooka 	pid = name[0];
   1889  1.170     pooka 	type = name[1];
   1890  1.170     pooka 
   1891  1.170     pooka 	switch (type) {
   1892  1.170     pooka 	case KERN_PROC_ARGV:
   1893  1.170     pooka 	case KERN_PROC_NARGV:
   1894  1.170     pooka 	case KERN_PROC_ENV:
   1895  1.170     pooka 	case KERN_PROC_NENV:
   1896  1.170     pooka 		/* ok */
   1897  1.170     pooka 		break;
   1898  1.170     pooka 	default:
   1899  1.170     pooka 		return (EINVAL);
   1900  1.170     pooka 	}
   1901  1.170     pooka 
   1902  1.170     pooka 	sysctl_unlock();
   1903  1.170     pooka 
   1904  1.170     pooka 	/* check pid */
   1905  1.170     pooka 	mutex_enter(proc_lock);
   1906  1.170     pooka 	if ((p = proc_find(pid)) == NULL) {
   1907  1.170     pooka 		error = EINVAL;
   1908  1.170     pooka 		goto out_locked;
   1909  1.170     pooka 	}
   1910  1.170     pooka 	mutex_enter(p->p_lock);
   1911  1.170     pooka 
   1912  1.170     pooka 	/* Check permission. */
   1913  1.170     pooka 	if (type == KERN_PROC_ARGV || type == KERN_PROC_NARGV)
   1914  1.170     pooka 		error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CANSEE,
   1915  1.170     pooka 		    p, KAUTH_ARG(KAUTH_REQ_PROCESS_CANSEE_ARGS), NULL, NULL);
   1916  1.170     pooka 	else if (type == KERN_PROC_ENV || type == KERN_PROC_NENV)
   1917  1.170     pooka 		error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CANSEE,
   1918  1.170     pooka 		    p, KAUTH_ARG(KAUTH_REQ_PROCESS_CANSEE_ENV), NULL, NULL);
   1919  1.170     pooka 	else
   1920  1.170     pooka 		error = EINVAL; /* XXXGCC */
   1921  1.170     pooka 	if (error) {
   1922  1.170     pooka 		mutex_exit(p->p_lock);
   1923  1.170     pooka 		goto out_locked;
   1924  1.170     pooka 	}
   1925  1.170     pooka 
   1926  1.170     pooka 	if (oldp == NULL) {
   1927  1.170     pooka 		if (type == KERN_PROC_NARGV || type == KERN_PROC_NENV)
   1928  1.170     pooka 			*oldlenp = sizeof (int);
   1929  1.170     pooka 		else
   1930  1.170     pooka 			*oldlenp = ARG_MAX;	/* XXX XXX XXX */
   1931  1.170     pooka 		error = 0;
   1932  1.170     pooka 		mutex_exit(p->p_lock);
   1933  1.170     pooka 		goto out_locked;
   1934  1.170     pooka 	}
   1935  1.170     pooka 
   1936  1.170     pooka 	/*
   1937  1.170     pooka 	 * Zombies don't have a stack, so we can't read their psstrings.
   1938  1.170     pooka 	 * System processes also don't have a user stack.
   1939  1.170     pooka 	 */
   1940  1.170     pooka 	if (P_ZOMBIE(p) || (p->p_flag & PK_SYSTEM) != 0) {
   1941  1.170     pooka 		error = EINVAL;
   1942  1.170     pooka 		mutex_exit(p->p_lock);
   1943  1.170     pooka 		goto out_locked;
   1944  1.170     pooka 	}
   1945  1.170     pooka 
   1946  1.174     rmind 	error = rw_tryenter(&p->p_reflock, RW_READER) ? 0 : EBUSY;
   1947  1.172     joerg 	mutex_exit(p->p_lock);
   1948  1.174     rmind 	if (error) {
   1949  1.174     rmind 		goto out_locked;
   1950  1.174     rmind 	}
   1951  1.172     joerg 	mutex_exit(proc_lock);
   1952  1.172     joerg 
   1953  1.172     joerg 	if (type == KERN_PROC_NARGV || type == KERN_PROC_NENV) {
   1954  1.172     joerg 		int value;
   1955  1.172     joerg 		if ((error = copyin_psstrings(p, &pss)) == 0) {
   1956  1.172     joerg 			if (type == KERN_PROC_NARGV)
   1957  1.172     joerg 				value = pss.ps_nargvstr;
   1958  1.172     joerg 			else
   1959  1.172     joerg 				value = pss.ps_nenvstr;
   1960  1.172     joerg 			error = sysctl_copyout(l, &value, oldp, sizeof(value));
   1961  1.172     joerg 			*oldlenp = sizeof(value);
   1962  1.172     joerg 		}
   1963  1.170     pooka 	} else {
   1964  1.172     joerg 		cookie[0] = l;
   1965  1.172     joerg 		cookie[1] = oldp;
   1966  1.172     joerg 		error = copy_procargs(p, type, oldlenp,
   1967  1.172     joerg 		    copy_procargs_sysctl_cb, cookie);
   1968  1.170     pooka 	}
   1969  1.172     joerg 	rw_exit(&p->p_reflock);
   1970  1.172     joerg 	sysctl_relock();
   1971  1.172     joerg 	return error;
   1972  1.172     joerg 
   1973  1.172     joerg out_locked:
   1974  1.170     pooka 	mutex_exit(proc_lock);
   1975  1.172     joerg 	sysctl_relock();
   1976  1.172     joerg 	return error;
   1977  1.172     joerg }
   1978  1.172     joerg 
   1979  1.172     joerg int
   1980  1.172     joerg copy_procargs(struct proc *p, int oid, size_t *limit,
   1981  1.172     joerg     int (*cb)(void *, const void *, size_t, size_t), void *cookie)
   1982  1.172     joerg {
   1983  1.172     joerg 	struct ps_strings pss;
   1984  1.172     joerg 	size_t len, i, loaded, entry_len;
   1985  1.172     joerg 	struct uio auio;
   1986  1.172     joerg 	struct iovec aiov;
   1987  1.172     joerg 	int error, argvlen;
   1988  1.172     joerg 	char *arg;
   1989  1.172     joerg 	char **argv;
   1990  1.172     joerg 	vaddr_t user_argv;
   1991  1.172     joerg 	struct vmspace *vmspace;
   1992  1.170     pooka 
   1993  1.170     pooka 	/*
   1994  1.172     joerg 	 * Allocate a temporary buffer to hold the argument vector and
   1995  1.172     joerg 	 * the arguments themselve.
   1996  1.170     pooka 	 */
   1997  1.170     pooka 	arg = kmem_alloc(PAGE_SIZE, KM_SLEEP);
   1998  1.172     joerg 	argv = kmem_alloc(PAGE_SIZE, KM_SLEEP);
   1999  1.172     joerg 
   2000  1.172     joerg 	/*
   2001  1.172     joerg 	 * Lock the process down in memory.
   2002  1.172     joerg 	 */
   2003  1.172     joerg 	vmspace = p->p_vmspace;
   2004  1.172     joerg 	uvmspace_addref(vmspace);
   2005  1.170     pooka 
   2006  1.170     pooka 	/*
   2007  1.170     pooka 	 * Read in the ps_strings structure.
   2008  1.170     pooka 	 */
   2009  1.172     joerg 	if ((error = copyin_psstrings(p, &pss)) != 0)
   2010  1.170     pooka 		goto done;
   2011  1.170     pooka 
   2012  1.170     pooka 	/*
   2013  1.170     pooka 	 * Now read the address of the argument vector.
   2014  1.170     pooka 	 */
   2015  1.172     joerg 	switch (oid) {
   2016  1.170     pooka 	case KERN_PROC_ARGV:
   2017  1.172     joerg 		user_argv = (uintptr_t)pss.ps_argvstr;
   2018  1.172     joerg 		argvlen = pss.ps_nargvstr;
   2019  1.172     joerg 		break;
   2020  1.170     pooka 	case KERN_PROC_ENV:
   2021  1.172     joerg 		user_argv = (uintptr_t)pss.ps_envstr;
   2022  1.172     joerg 		argvlen = pss.ps_nenvstr;
   2023  1.170     pooka 		break;
   2024  1.170     pooka 	default:
   2025  1.170     pooka 		error = EINVAL;
   2026  1.170     pooka 		goto done;
   2027  1.170     pooka 	}
   2028  1.170     pooka 
   2029  1.172     joerg 	if (argvlen < 0) {
   2030  1.172     joerg 		error = EIO;
   2031  1.172     joerg 		goto done;
   2032  1.172     joerg 	}
   2033  1.172     joerg 
   2034  1.170     pooka #ifdef COMPAT_NETBSD32
   2035  1.170     pooka 	if (p->p_flag & PK_32)
   2036  1.172     joerg 		entry_len = sizeof(netbsd32_charp);
   2037  1.170     pooka 	else
   2038  1.170     pooka #endif
   2039  1.172     joerg 		entry_len = sizeof(char *);
   2040  1.170     pooka 
   2041  1.170     pooka 	/*
   2042  1.170     pooka 	 * Now copy each string.
   2043  1.170     pooka 	 */
   2044  1.170     pooka 	len = 0; /* bytes written to user buffer */
   2045  1.172     joerg 	loaded = 0; /* bytes from argv already processed */
   2046  1.172     joerg 	i = 0; /* To make compiler happy */
   2047  1.172     joerg 
   2048  1.172     joerg 	for (; argvlen; --argvlen) {
   2049  1.170     pooka 		int finished = 0;
   2050  1.170     pooka 		vaddr_t base;
   2051  1.170     pooka 		size_t xlen;
   2052  1.170     pooka 		int j;
   2053  1.170     pooka 
   2054  1.172     joerg 		if (loaded == 0) {
   2055  1.172     joerg 			size_t rem = entry_len * argvlen;
   2056  1.172     joerg 			loaded = MIN(rem, PAGE_SIZE);
   2057  1.172     joerg 			error = copyin_vmspace(vmspace,
   2058  1.172     joerg 			    (const void *)user_argv, argv, loaded);
   2059  1.172     joerg 			if (error)
   2060  1.172     joerg 				break;
   2061  1.172     joerg 			user_argv += loaded;
   2062  1.172     joerg 			i = 0;
   2063  1.172     joerg 		}
   2064  1.172     joerg 
   2065  1.170     pooka #ifdef COMPAT_NETBSD32
   2066  1.170     pooka 		if (p->p_flag & PK_32) {
   2067  1.170     pooka 			netbsd32_charp *argv32;
   2068  1.170     pooka 
   2069  1.170     pooka 			argv32 = (netbsd32_charp *)argv;
   2070  1.172     joerg 			base = (vaddr_t)NETBSD32PTR64(argv32[i++]);
   2071  1.170     pooka 		} else
   2072  1.170     pooka #endif
   2073  1.172     joerg 			base = (vaddr_t)argv[i++];
   2074  1.172     joerg 		loaded -= entry_len;
   2075  1.170     pooka 
   2076  1.170     pooka 		/*
   2077  1.170     pooka 		 * The program has messed around with its arguments,
   2078  1.170     pooka 		 * possibly deleting some, and replacing them with
   2079  1.170     pooka 		 * NULL's. Treat this as the last argument and not
   2080  1.170     pooka 		 * a failure.
   2081  1.170     pooka 		 */
   2082  1.170     pooka 		if (base == 0)
   2083  1.170     pooka 			break;
   2084  1.170     pooka 
   2085  1.170     pooka 		while (!finished) {
   2086  1.170     pooka 			xlen = PAGE_SIZE - (base & PAGE_MASK);
   2087  1.170     pooka 
   2088  1.170     pooka 			aiov.iov_base = arg;
   2089  1.170     pooka 			aiov.iov_len = PAGE_SIZE;
   2090  1.170     pooka 			auio.uio_iov = &aiov;
   2091  1.170     pooka 			auio.uio_iovcnt = 1;
   2092  1.170     pooka 			auio.uio_offset = base;
   2093  1.170     pooka 			auio.uio_resid = xlen;
   2094  1.170     pooka 			auio.uio_rw = UIO_READ;
   2095  1.170     pooka 			UIO_SETUP_SYSSPACE(&auio);
   2096  1.170     pooka 			error = uvm_io(&vmspace->vm_map, &auio);
   2097  1.170     pooka 			if (error)
   2098  1.170     pooka 				goto done;
   2099  1.170     pooka 
   2100  1.170     pooka 			/* Look for the end of the string */
   2101  1.170     pooka 			for (j = 0; j < xlen; j++) {
   2102  1.170     pooka 				if (arg[j] == '\0') {
   2103  1.170     pooka 					xlen = j + 1;
   2104  1.170     pooka 					finished = 1;
   2105  1.170     pooka 					break;
   2106  1.170     pooka 				}
   2107  1.170     pooka 			}
   2108  1.170     pooka 
   2109  1.170     pooka 			/* Check for user buffer overflow */
   2110  1.172     joerg 			if (len + xlen > *limit) {
   2111  1.170     pooka 				finished = 1;
   2112  1.172     joerg 				if (len > *limit)
   2113  1.170     pooka 					xlen = 0;
   2114  1.170     pooka 				else
   2115  1.172     joerg 					xlen = *limit - len;
   2116  1.170     pooka 			}
   2117  1.170     pooka 
   2118  1.170     pooka 			/* Copyout the page */
   2119  1.172     joerg 			error = (*cb)(cookie, arg, len, xlen);
   2120  1.170     pooka 			if (error)
   2121  1.170     pooka 				goto done;
   2122  1.170     pooka 
   2123  1.170     pooka 			len += xlen;
   2124  1.170     pooka 			base += xlen;
   2125  1.170     pooka 		}
   2126  1.170     pooka 	}
   2127  1.172     joerg 	*limit = len;
   2128  1.170     pooka 
   2129  1.170     pooka done:
   2130  1.172     joerg 	kmem_free(argv, PAGE_SIZE);
   2131  1.172     joerg 	kmem_free(arg, PAGE_SIZE);
   2132  1.170     pooka 	uvmspace_free(vmspace);
   2133  1.170     pooka 	return error;
   2134  1.170     pooka }
   2135  1.170     pooka 
   2136  1.170     pooka /*
   2137  1.170     pooka  * Fill in an eproc structure for the specified process.
   2138  1.170     pooka  */
   2139  1.170     pooka void
   2140  1.170     pooka fill_eproc(struct proc *p, struct eproc *ep, bool zombie)
   2141  1.170     pooka {
   2142  1.170     pooka 	struct tty *tp;
   2143  1.170     pooka 	struct lwp *l;
   2144  1.170     pooka 
   2145  1.170     pooka 	KASSERT(mutex_owned(proc_lock));
   2146  1.170     pooka 	KASSERT(mutex_owned(p->p_lock));
   2147  1.170     pooka 
   2148  1.170     pooka 	memset(ep, 0, sizeof(*ep));
   2149  1.170     pooka 
   2150  1.170     pooka 	ep->e_paddr = p;
   2151  1.170     pooka 	ep->e_sess = p->p_session;
   2152  1.170     pooka 	if (p->p_cred) {
   2153  1.170     pooka 		kauth_cred_topcred(p->p_cred, &ep->e_pcred);
   2154  1.170     pooka 		kauth_cred_toucred(p->p_cred, &ep->e_ucred);
   2155  1.170     pooka 	}
   2156  1.170     pooka 	if (p->p_stat != SIDL && !P_ZOMBIE(p) && !zombie) {
   2157  1.170     pooka 		struct vmspace *vm = p->p_vmspace;
   2158  1.170     pooka 
   2159  1.170     pooka 		ep->e_vm.vm_rssize = vm_resident_count(vm);
   2160  1.170     pooka 		ep->e_vm.vm_tsize = vm->vm_tsize;
   2161  1.170     pooka 		ep->e_vm.vm_dsize = vm->vm_dsize;
   2162  1.170     pooka 		ep->e_vm.vm_ssize = vm->vm_ssize;
   2163  1.170     pooka 		ep->e_vm.vm_map.size = vm->vm_map.size;
   2164  1.170     pooka 
   2165  1.170     pooka 		/* Pick the primary (first) LWP */
   2166  1.170     pooka 		l = proc_active_lwp(p);
   2167  1.170     pooka 		KASSERT(l != NULL);
   2168  1.170     pooka 		lwp_lock(l);
   2169  1.170     pooka 		if (l->l_wchan)
   2170  1.170     pooka 			strncpy(ep->e_wmesg, l->l_wmesg, WMESGLEN);
   2171  1.170     pooka 		lwp_unlock(l);
   2172  1.170     pooka 	}
   2173  1.170     pooka 	if (p->p_pptr)
   2174  1.170     pooka 		ep->e_ppid = p->p_pptr->p_pid;
   2175  1.170     pooka 	if (p->p_pgrp && p->p_session) {
   2176  1.170     pooka 		ep->e_pgid = p->p_pgrp->pg_id;
   2177  1.170     pooka 		ep->e_jobc = p->p_pgrp->pg_jobc;
   2178  1.170     pooka 		ep->e_sid = p->p_session->s_sid;
   2179  1.170     pooka 		if ((p->p_lflag & PL_CONTROLT) &&
   2180  1.170     pooka 		    (tp = ep->e_sess->s_ttyp)) {
   2181  1.170     pooka 			ep->e_tdev = tp->t_dev;
   2182  1.170     pooka 			ep->e_tpgid = tp->t_pgrp ? tp->t_pgrp->pg_id : NO_PGID;
   2183  1.170     pooka 			ep->e_tsess = tp->t_session;
   2184  1.170     pooka 		} else
   2185  1.170     pooka 			ep->e_tdev = (uint32_t)NODEV;
   2186  1.170     pooka 		ep->e_flag = ep->e_sess->s_ttyvp ? EPROC_CTTY : 0;
   2187  1.170     pooka 		if (SESS_LEADER(p))
   2188  1.170     pooka 			ep->e_flag |= EPROC_SLEADER;
   2189  1.170     pooka 		strncpy(ep->e_login, ep->e_sess->s_login, MAXLOGNAME);
   2190  1.170     pooka 	}
   2191  1.170     pooka 	ep->e_xsize = ep->e_xrssize = 0;
   2192  1.170     pooka 	ep->e_xccount = ep->e_xswrss = 0;
   2193  1.170     pooka }
   2194  1.170     pooka 
   2195  1.170     pooka /*
   2196  1.170     pooka  * Fill in a kinfo_proc2 structure for the specified process.
   2197  1.170     pooka  */
   2198  1.170     pooka static void
   2199  1.170     pooka fill_kproc2(struct proc *p, struct kinfo_proc2 *ki, bool zombie)
   2200  1.170     pooka {
   2201  1.170     pooka 	struct tty *tp;
   2202  1.170     pooka 	struct lwp *l, *l2;
   2203  1.170     pooka 	struct timeval ut, st, rt;
   2204  1.170     pooka 	sigset_t ss1, ss2;
   2205  1.170     pooka 	struct rusage ru;
   2206  1.170     pooka 	struct vmspace *vm;
   2207  1.170     pooka 
   2208  1.170     pooka 	KASSERT(mutex_owned(proc_lock));
   2209  1.170     pooka 	KASSERT(mutex_owned(p->p_lock));
   2210  1.170     pooka 
   2211  1.170     pooka 	sigemptyset(&ss1);
   2212  1.170     pooka 	sigemptyset(&ss2);
   2213  1.170     pooka 	memset(ki, 0, sizeof(*ki));
   2214  1.170     pooka 
   2215  1.170     pooka 	ki->p_paddr = PTRTOUINT64(p);
   2216  1.170     pooka 	ki->p_fd = PTRTOUINT64(p->p_fd);
   2217  1.170     pooka 	ki->p_cwdi = PTRTOUINT64(p->p_cwdi);
   2218  1.170     pooka 	ki->p_stats = PTRTOUINT64(p->p_stats);
   2219  1.170     pooka 	ki->p_limit = PTRTOUINT64(p->p_limit);
   2220  1.170     pooka 	ki->p_vmspace = PTRTOUINT64(p->p_vmspace);
   2221  1.170     pooka 	ki->p_sigacts = PTRTOUINT64(p->p_sigacts);
   2222  1.170     pooka 	ki->p_sess = PTRTOUINT64(p->p_session);
   2223  1.170     pooka 	ki->p_tsess = 0;	/* may be changed if controlling tty below */
   2224  1.170     pooka 	ki->p_ru = PTRTOUINT64(&p->p_stats->p_ru);
   2225  1.170     pooka 	ki->p_eflag = 0;
   2226  1.170     pooka 	ki->p_exitsig = p->p_exitsig;
   2227  1.170     pooka 	ki->p_flag = L_INMEM;   /* Process never swapped out */
   2228  1.170     pooka 	ki->p_flag |= sysctl_map_flags(sysctl_flagmap, p->p_flag);
   2229  1.170     pooka 	ki->p_flag |= sysctl_map_flags(sysctl_sflagmap, p->p_sflag);
   2230  1.170     pooka 	ki->p_flag |= sysctl_map_flags(sysctl_slflagmap, p->p_slflag);
   2231  1.170     pooka 	ki->p_flag |= sysctl_map_flags(sysctl_lflagmap, p->p_lflag);
   2232  1.170     pooka 	ki->p_flag |= sysctl_map_flags(sysctl_stflagmap, p->p_stflag);
   2233  1.170     pooka 	ki->p_pid = p->p_pid;
   2234  1.170     pooka 	if (p->p_pptr)
   2235  1.170     pooka 		ki->p_ppid = p->p_pptr->p_pid;
   2236  1.170     pooka 	else
   2237  1.170     pooka 		ki->p_ppid = 0;
   2238  1.170     pooka 	ki->p_uid = kauth_cred_geteuid(p->p_cred);
   2239  1.170     pooka 	ki->p_ruid = kauth_cred_getuid(p->p_cred);
   2240  1.170     pooka 	ki->p_gid = kauth_cred_getegid(p->p_cred);
   2241  1.170     pooka 	ki->p_rgid = kauth_cred_getgid(p->p_cred);
   2242  1.170     pooka 	ki->p_svuid = kauth_cred_getsvuid(p->p_cred);
   2243  1.170     pooka 	ki->p_svgid = kauth_cred_getsvgid(p->p_cred);
   2244  1.170     pooka 	ki->p_ngroups = kauth_cred_ngroups(p->p_cred);
   2245  1.170     pooka 	kauth_cred_getgroups(p->p_cred, ki->p_groups,
   2246  1.170     pooka 	    min(ki->p_ngroups, sizeof(ki->p_groups) / sizeof(ki->p_groups[0])),
   2247  1.170     pooka 	    UIO_SYSSPACE);
   2248  1.170     pooka 
   2249  1.170     pooka 	ki->p_uticks = p->p_uticks;
   2250  1.170     pooka 	ki->p_sticks = p->p_sticks;
   2251  1.170     pooka 	ki->p_iticks = p->p_iticks;
   2252  1.170     pooka 	ki->p_tpgid = NO_PGID;	/* may be changed if controlling tty below */
   2253  1.170     pooka 	ki->p_tracep = PTRTOUINT64(p->p_tracep);
   2254  1.170     pooka 	ki->p_traceflag = p->p_traceflag;
   2255  1.170     pooka 
   2256  1.170     pooka 	memcpy(&ki->p_sigignore, &p->p_sigctx.ps_sigignore,sizeof(ki_sigset_t));
   2257  1.170     pooka 	memcpy(&ki->p_sigcatch, &p->p_sigctx.ps_sigcatch, sizeof(ki_sigset_t));
   2258  1.170     pooka 
   2259  1.170     pooka 	ki->p_cpticks = 0;
   2260  1.170     pooka 	ki->p_pctcpu = p->p_pctcpu;
   2261  1.170     pooka 	ki->p_estcpu = 0;
   2262  1.170     pooka 	ki->p_stat = p->p_stat; /* Will likely be overridden by LWP status */
   2263  1.170     pooka 	ki->p_realstat = p->p_stat;
   2264  1.170     pooka 	ki->p_nice = p->p_nice;
   2265  1.170     pooka 	ki->p_xstat = p->p_xstat;
   2266  1.170     pooka 	ki->p_acflag = p->p_acflag;
   2267  1.170     pooka 
   2268  1.170     pooka 	strncpy(ki->p_comm, p->p_comm,
   2269  1.170     pooka 	    min(sizeof(ki->p_comm), sizeof(p->p_comm)));
   2270  1.170     pooka 	strncpy(ki->p_ename, p->p_emul->e_name, sizeof(ki->p_ename));
   2271  1.170     pooka 
   2272  1.170     pooka 	ki->p_nlwps = p->p_nlwps;
   2273  1.170     pooka 	ki->p_realflag = ki->p_flag;
   2274  1.170     pooka 
   2275  1.170     pooka 	if (p->p_stat != SIDL && !P_ZOMBIE(p) && !zombie) {
   2276  1.170     pooka 		vm = p->p_vmspace;
   2277  1.170     pooka 		ki->p_vm_rssize = vm_resident_count(vm);
   2278  1.170     pooka 		ki->p_vm_tsize = vm->vm_tsize;
   2279  1.170     pooka 		ki->p_vm_dsize = vm->vm_dsize;
   2280  1.170     pooka 		ki->p_vm_ssize = vm->vm_ssize;
   2281  1.184    martin 		ki->p_vm_vsize = atop(vm->vm_map.size);
   2282  1.170     pooka 		/*
   2283  1.170     pooka 		 * Since the stack is initially mapped mostly with
   2284  1.170     pooka 		 * PROT_NONE and grown as needed, adjust the "mapped size"
   2285  1.170     pooka 		 * to skip the unused stack portion.
   2286  1.170     pooka 		 */
   2287  1.170     pooka 		ki->p_vm_msize =
   2288  1.170     pooka 		    atop(vm->vm_map.size) - vm->vm_issize + vm->vm_ssize;
   2289  1.170     pooka 
   2290  1.170     pooka 		/* Pick the primary (first) LWP */
   2291  1.170     pooka 		l = proc_active_lwp(p);
   2292  1.170     pooka 		KASSERT(l != NULL);
   2293  1.170     pooka 		lwp_lock(l);
   2294  1.170     pooka 		ki->p_nrlwps = p->p_nrlwps;
   2295  1.170     pooka 		ki->p_forw = 0;
   2296  1.170     pooka 		ki->p_back = 0;
   2297  1.170     pooka 		ki->p_addr = PTRTOUINT64(l->l_addr);
   2298  1.170     pooka 		ki->p_stat = l->l_stat;
   2299  1.170     pooka 		ki->p_flag |= sysctl_map_flags(sysctl_lwpflagmap, l->l_flag);
   2300  1.170     pooka 		ki->p_swtime = l->l_swtime;
   2301  1.170     pooka 		ki->p_slptime = l->l_slptime;
   2302  1.170     pooka 		if (l->l_stat == LSONPROC)
   2303  1.170     pooka 			ki->p_schedflags = l->l_cpu->ci_schedstate.spc_flags;
   2304  1.170     pooka 		else
   2305  1.170     pooka 			ki->p_schedflags = 0;
   2306  1.170     pooka 		ki->p_priority = lwp_eprio(l);
   2307  1.170     pooka 		ki->p_usrpri = l->l_priority;
   2308  1.170     pooka 		if (l->l_wchan)
   2309  1.170     pooka 			strncpy(ki->p_wmesg, l->l_wmesg, sizeof(ki->p_wmesg));
   2310  1.170     pooka 		ki->p_wchan = PTRTOUINT64(l->l_wchan);
   2311  1.170     pooka 		ki->p_cpuid = cpu_index(l->l_cpu);
   2312  1.170     pooka 		lwp_unlock(l);
   2313  1.170     pooka 		LIST_FOREACH(l, &p->p_lwps, l_sibling) {
   2314  1.170     pooka 			/* This is hardly correct, but... */
   2315  1.170     pooka 			sigplusset(&l->l_sigpend.sp_set, &ss1);
   2316  1.170     pooka 			sigplusset(&l->l_sigmask, &ss2);
   2317  1.170     pooka 			ki->p_cpticks += l->l_cpticks;
   2318  1.170     pooka 			ki->p_pctcpu += l->l_pctcpu;
   2319  1.170     pooka 			ki->p_estcpu += l->l_estcpu;
   2320  1.170     pooka 		}
   2321  1.170     pooka 	}
   2322  1.170     pooka 	sigplusset(&p->p_sigpend.sp_set, &ss2);
   2323  1.170     pooka 	memcpy(&ki->p_siglist, &ss1, sizeof(ki_sigset_t));
   2324  1.170     pooka 	memcpy(&ki->p_sigmask, &ss2, sizeof(ki_sigset_t));
   2325  1.170     pooka 
   2326  1.170     pooka 	if (p->p_session != NULL) {
   2327  1.170     pooka 		ki->p_sid = p->p_session->s_sid;
   2328  1.170     pooka 		ki->p__pgid = p->p_pgrp->pg_id;
   2329  1.170     pooka 		if (p->p_session->s_ttyvp)
   2330  1.170     pooka 			ki->p_eflag |= EPROC_CTTY;
   2331  1.170     pooka 		if (SESS_LEADER(p))
   2332  1.170     pooka 			ki->p_eflag |= EPROC_SLEADER;
   2333  1.170     pooka 		strncpy(ki->p_login, p->p_session->s_login,
   2334  1.170     pooka 		    min(sizeof ki->p_login - 1, sizeof p->p_session->s_login));
   2335  1.170     pooka 		ki->p_jobc = p->p_pgrp->pg_jobc;
   2336  1.170     pooka 		if ((p->p_lflag & PL_CONTROLT) && (tp = p->p_session->s_ttyp)) {
   2337  1.170     pooka 			ki->p_tdev = tp->t_dev;
   2338  1.170     pooka 			ki->p_tpgid = tp->t_pgrp ? tp->t_pgrp->pg_id : NO_PGID;
   2339  1.170     pooka 			ki->p_tsess = PTRTOUINT64(tp->t_session);
   2340  1.170     pooka 		} else {
   2341  1.170     pooka 			ki->p_tdev = (int32_t)NODEV;
   2342  1.170     pooka 		}
   2343  1.170     pooka 	}
   2344  1.170     pooka 
   2345  1.170     pooka 	if (!P_ZOMBIE(p) && !zombie) {
   2346  1.170     pooka 		ki->p_uvalid = 1;
   2347  1.170     pooka 		ki->p_ustart_sec = p->p_stats->p_start.tv_sec;
   2348  1.170     pooka 		ki->p_ustart_usec = p->p_stats->p_start.tv_usec;
   2349  1.170     pooka 
   2350  1.170     pooka 		calcru(p, &ut, &st, NULL, &rt);
   2351  1.170     pooka 		ki->p_rtime_sec = rt.tv_sec;
   2352  1.170     pooka 		ki->p_rtime_usec = rt.tv_usec;
   2353  1.170     pooka 		ki->p_uutime_sec = ut.tv_sec;
   2354  1.170     pooka 		ki->p_uutime_usec = ut.tv_usec;
   2355  1.170     pooka 		ki->p_ustime_sec = st.tv_sec;
   2356  1.170     pooka 		ki->p_ustime_usec = st.tv_usec;
   2357  1.170     pooka 
   2358  1.170     pooka 		memcpy(&ru, &p->p_stats->p_ru, sizeof(ru));
   2359  1.170     pooka 		ki->p_uru_nvcsw = 0;
   2360  1.170     pooka 		ki->p_uru_nivcsw = 0;
   2361  1.170     pooka 		LIST_FOREACH(l2, &p->p_lwps, l_sibling) {
   2362  1.170     pooka 			ki->p_uru_nvcsw += (l2->l_ncsw - l2->l_nivcsw);
   2363  1.170     pooka 			ki->p_uru_nivcsw += l2->l_nivcsw;
   2364  1.170     pooka 			ruadd(&ru, &l2->l_ru);
   2365  1.170     pooka 		}
   2366  1.170     pooka 		ki->p_uru_maxrss = ru.ru_maxrss;
   2367  1.170     pooka 		ki->p_uru_ixrss = ru.ru_ixrss;
   2368  1.170     pooka 		ki->p_uru_idrss = ru.ru_idrss;
   2369  1.170     pooka 		ki->p_uru_isrss = ru.ru_isrss;
   2370  1.170     pooka 		ki->p_uru_minflt = ru.ru_minflt;
   2371  1.170     pooka 		ki->p_uru_majflt = ru.ru_majflt;
   2372  1.170     pooka 		ki->p_uru_nswap = ru.ru_nswap;
   2373  1.170     pooka 		ki->p_uru_inblock = ru.ru_inblock;
   2374  1.170     pooka 		ki->p_uru_oublock = ru.ru_oublock;
   2375  1.170     pooka 		ki->p_uru_msgsnd = ru.ru_msgsnd;
   2376  1.170     pooka 		ki->p_uru_msgrcv = ru.ru_msgrcv;
   2377  1.170     pooka 		ki->p_uru_nsignals = ru.ru_nsignals;
   2378  1.170     pooka 
   2379  1.170     pooka 		timeradd(&p->p_stats->p_cru.ru_utime,
   2380  1.170     pooka 			 &p->p_stats->p_cru.ru_stime, &ut);
   2381  1.170     pooka 		ki->p_uctime_sec = ut.tv_sec;
   2382  1.170     pooka 		ki->p_uctime_usec = ut.tv_usec;
   2383  1.170     pooka 	}
   2384  1.170     pooka }
   2385