Home | History | Annotate | Line # | Download | only in kern
kern_resource.c revision 1.103.4.9
      1  1.103.4.9        ad /*	$NetBSD: kern_resource.c,v 1.103.4.9 2007/01/30 13:51:41 ad Exp $	*/
      2       1.20       cgd 
      3       1.17       cgd /*-
      4       1.19       cgd  * Copyright (c) 1982, 1986, 1991, 1993
      5       1.19       cgd  *	The Regents of the University of California.  All rights reserved.
      6       1.17       cgd  * (c) UNIX System Laboratories, Inc.
      7       1.17       cgd  * All or some portions of this file are derived from material licensed
      8       1.17       cgd  * to the University of California by American Telephone and Telegraph
      9       1.17       cgd  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     10       1.17       cgd  * the permission of UNIX System Laboratories, Inc.
     11       1.17       cgd  *
     12       1.17       cgd  * Redistribution and use in source and binary forms, with or without
     13       1.17       cgd  * modification, are permitted provided that the following conditions
     14       1.17       cgd  * are met:
     15       1.17       cgd  * 1. Redistributions of source code must retain the above copyright
     16       1.17       cgd  *    notice, this list of conditions and the following disclaimer.
     17       1.17       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     18       1.17       cgd  *    notice, this list of conditions and the following disclaimer in the
     19       1.17       cgd  *    documentation and/or other materials provided with the distribution.
     20       1.72       agc  * 3. Neither the name of the University nor the names of its contributors
     21       1.17       cgd  *    may be used to endorse or promote products derived from this software
     22       1.17       cgd  *    without specific prior written permission.
     23       1.17       cgd  *
     24       1.17       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     25       1.17       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     26       1.17       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     27       1.17       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     28       1.17       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     29       1.17       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     30       1.17       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     31       1.17       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     32       1.17       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     33       1.17       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     34       1.17       cgd  * SUCH DAMAGE.
     35       1.17       cgd  *
     36       1.45      fvdl  *	@(#)kern_resource.c	8.8 (Berkeley) 2/14/95
     37       1.17       cgd  */
     38       1.61     lukem 
     39       1.61     lukem #include <sys/cdefs.h>
     40  1.103.4.9        ad __KERNEL_RCSID(0, "$NetBSD: kern_resource.c,v 1.103.4.9 2007/01/30 13:51:41 ad Exp $");
     41       1.44       mrg 
     42       1.17       cgd #include <sys/param.h>
     43       1.22       cgd #include <sys/systm.h>
     44       1.17       cgd #include <sys/kernel.h>
     45       1.19       cgd #include <sys/file.h>
     46       1.17       cgd #include <sys/resourcevar.h>
     47       1.17       cgd #include <sys/malloc.h>
     48      1.100      yamt #include <sys/namei.h>
     49       1.49   thorpej #include <sys/pool.h>
     50       1.17       cgd #include <sys/proc.h>
     51       1.74    atatat #include <sys/sysctl.h>
     52      1.101      elad #include <sys/kauth.h>
     53       1.17       cgd 
     54       1.22       cgd #include <sys/mount.h>
     55       1.22       cgd #include <sys/syscallargs.h>
     56       1.17       cgd 
     57       1.43       mrg #include <uvm/uvm_extern.h>
     58       1.43       mrg 
     59       1.17       cgd /*
     60       1.60       eeh  * Maximum process data and stack limits.
     61       1.60       eeh  * They are variables so they are patchable.
     62       1.60       eeh  */
     63       1.60       eeh rlim_t maxdmap = MAXDSIZ;
     64       1.60       eeh rlim_t maxsmap = MAXSSIZ;
     65       1.60       eeh 
     66       1.82      matt struct uihashhead *uihashtbl;
     67       1.82      matt u_long uihash;		/* size of hash table - 1 */
     68       1.88  christos struct simplelock uihashtbl_slock = SIMPLELOCK_INITIALIZER;
     69       1.82      matt 
     70       1.79  christos 
     71       1.60       eeh /*
     72       1.17       cgd  * Resource controls and accounting.
     73       1.17       cgd  */
     74       1.17       cgd 
     75       1.25       cgd int
     76       1.98   thorpej sys_getpriority(struct lwp *l, void *v, register_t *retval)
     77       1.30   thorpej {
     78       1.54  augustss 	struct sys_getpriority_args /* {
     79       1.22       cgd 		syscallarg(int) which;
     80       1.81    kleink 		syscallarg(id_t) who;
     81       1.30   thorpej 	} */ *uap = v;
     82       1.68   thorpej 	struct proc *curp = l->l_proc, *p;
     83       1.54  augustss 	int low = NZERO + PRIO_MAX + 1;
     84  1.103.4.1        ad 	int who = SCARG(uap, who);
     85       1.17       cgd 
     86       1.22       cgd 	switch (SCARG(uap, which)) {
     87       1.17       cgd 
     88       1.17       cgd 	case PRIO_PROCESS:
     89  1.103.4.1        ad 		if (who == 0)
     90       1.17       cgd 			p = curp;
     91       1.17       cgd 		else
     92  1.103.4.1        ad 			p = p_find(who, 0);
     93  1.103.4.1        ad 		if (p != NULL)
     94  1.103.4.1        ad 			low = p->p_nice;
     95  1.103.4.1        ad 		if (who != 0)
     96  1.103.4.1        ad 			rw_exit(&proclist_lock);
     97       1.17       cgd 		break;
     98       1.17       cgd 
     99       1.17       cgd 	case PRIO_PGRP: {
    100       1.54  augustss 		struct pgrp *pg;
    101       1.17       cgd 
    102  1.103.4.1        ad 		rw_enter(&proclist_lock, RW_READER);
    103  1.103.4.1        ad 		if (who == 0)
    104       1.17       cgd 			pg = curp->p_pgrp;
    105  1.103.4.1        ad 		else if ((pg = pg_find(who, PFIND_LOCKED | PFIND_UNLOCK_FAIL))
    106  1.103.4.1        ad 		    == NULL)
    107       1.17       cgd 			break;
    108       1.64      matt 		LIST_FOREACH(p, &pg->pg_members, p_pglist) {
    109       1.17       cgd 			if (p->p_nice < low)
    110       1.17       cgd 				low = p->p_nice;
    111       1.17       cgd 		}
    112  1.103.4.1        ad 		rw_exit(&proclist_lock);
    113       1.17       cgd 		break;
    114       1.17       cgd 	}
    115       1.17       cgd 
    116       1.17       cgd 	case PRIO_USER:
    117  1.103.4.1        ad 		if (who == 0)
    118  1.103.4.1        ad 			who = (int)kauth_cred_geteuid(l->l_cred);
    119  1.103.4.1        ad 		rw_enter(&proclist_lock, RW_READER);
    120       1.86      yamt 		PROCLIST_FOREACH(p, &allproc) {
    121  1.103.4.4        ad 			mutex_enter(&p->p_mutex);
    122      1.102        ad 			if (kauth_cred_geteuid(p->p_cred) ==
    123  1.103.4.1        ad 			    (uid_t)who && p->p_nice < low)
    124       1.17       cgd 				low = p->p_nice;
    125  1.103.4.4        ad 			mutex_exit(&p->p_mutex);
    126       1.64      matt 		}
    127  1.103.4.1        ad 		rw_exit(&proclist_lock);
    128       1.17       cgd 		break;
    129       1.17       cgd 
    130       1.17       cgd 	default:
    131       1.17       cgd 		return (EINVAL);
    132       1.17       cgd 	}
    133       1.37        ws 	if (low == NZERO + PRIO_MAX + 1)
    134       1.17       cgd 		return (ESRCH);
    135       1.37        ws 	*retval = low - NZERO;
    136       1.17       cgd 	return (0);
    137       1.17       cgd }
    138       1.17       cgd 
    139       1.17       cgd /* ARGSUSED */
    140       1.25       cgd int
    141       1.98   thorpej sys_setpriority(struct lwp *l, void *v, register_t *retval)
    142       1.30   thorpej {
    143       1.54  augustss 	struct sys_setpriority_args /* {
    144       1.22       cgd 		syscallarg(int) which;
    145       1.81    kleink 		syscallarg(id_t) who;
    146       1.22       cgd 		syscallarg(int) prio;
    147       1.30   thorpej 	} */ *uap = v;
    148       1.68   thorpej 	struct proc *curp = l->l_proc, *p;
    149       1.17       cgd 	int found = 0, error = 0;
    150  1.103.4.1        ad 	int who = SCARG(uap, who);
    151       1.17       cgd 
    152       1.22       cgd 	switch (SCARG(uap, which)) {
    153       1.17       cgd 
    154       1.17       cgd 	case PRIO_PROCESS:
    155  1.103.4.1        ad 		if (who == 0)
    156       1.17       cgd 			p = curp;
    157       1.17       cgd 		else
    158  1.103.4.1        ad 			p = p_find(who, 0);
    159  1.103.4.1        ad 		if (p != 0) {
    160  1.103.4.4        ad 			mutex_enter(&p->p_mutex);
    161  1.103.4.1        ad 			error = donice(l, p, SCARG(uap, prio));
    162  1.103.4.4        ad 			mutex_exit(&p->p_mutex);
    163  1.103.4.1        ad 		}
    164  1.103.4.1        ad 		if (who != 0)
    165  1.103.4.1        ad 			rw_exit(&proclist_lock);
    166       1.17       cgd 		found++;
    167       1.17       cgd 		break;
    168       1.17       cgd 
    169       1.17       cgd 	case PRIO_PGRP: {
    170       1.54  augustss 		struct pgrp *pg;
    171       1.87     perry 
    172  1.103.4.1        ad 		rw_enter(&proclist_lock, RW_READER);
    173  1.103.4.1        ad 		if (who == 0)
    174       1.17       cgd 			pg = curp->p_pgrp;
    175  1.103.4.1        ad 		else if ((pg = pg_find(who, PFIND_LOCKED | PFIND_UNLOCK_FAIL)) == NULL)
    176       1.17       cgd 			break;
    177       1.64      matt 		LIST_FOREACH(p, &pg->pg_members, p_pglist) {
    178  1.103.4.4        ad 			mutex_enter(&p->p_mutex);
    179      1.102        ad 			error = donice(l, p, SCARG(uap, prio));
    180  1.103.4.4        ad 			mutex_exit(&p->p_mutex);
    181       1.17       cgd 			found++;
    182       1.17       cgd 		}
    183  1.103.4.1        ad 		rw_exit(&proclist_lock);
    184       1.17       cgd 		break;
    185       1.17       cgd 	}
    186       1.17       cgd 
    187       1.17       cgd 	case PRIO_USER:
    188  1.103.4.1        ad 		if (who == 0)
    189  1.103.4.1        ad 			who = (int)kauth_cred_geteuid(l->l_cred);
    190  1.103.4.1        ad 		rw_enter(&proclist_lock, RW_READER);
    191       1.86      yamt 		PROCLIST_FOREACH(p, &allproc) {
    192  1.103.4.4        ad 			mutex_enter(&p->p_mutex);
    193      1.102        ad 			if (kauth_cred_geteuid(p->p_cred) ==
    194      1.102        ad 			    (uid_t)SCARG(uap, who)) {
    195      1.102        ad 				error = donice(l, p, SCARG(uap, prio));
    196       1.17       cgd 				found++;
    197       1.17       cgd 			}
    198  1.103.4.4        ad 			mutex_exit(&p->p_mutex);
    199       1.64      matt 		}
    200  1.103.4.1        ad 		rw_exit(&proclist_lock);
    201       1.17       cgd 		break;
    202       1.17       cgd 
    203       1.17       cgd 	default:
    204       1.17       cgd 		return (EINVAL);
    205       1.17       cgd 	}
    206       1.17       cgd 	if (found == 0)
    207       1.17       cgd 		return (ESRCH);
    208       1.17       cgd 	return (error);
    209       1.17       cgd }
    210       1.17       cgd 
    211  1.103.4.1        ad /*
    212  1.103.4.1        ad  * Renice a process.
    213  1.103.4.1        ad  *
    214  1.103.4.1        ad  * Call with the target process' credentials locked.
    215  1.103.4.1        ad  */
    216       1.25       cgd int
    217      1.102        ad donice(struct lwp *l, struct proc *chgp, int n)
    218       1.17       cgd {
    219      1.102        ad 	kauth_cred_t cred = l->l_cred;
    220  1.103.4.2        ad 	int onice;
    221       1.17       cgd 
    222  1.103.4.4        ad 	LOCK_ASSERT(mutex_owned(&chgp->p_mutex));
    223  1.103.4.1        ad 
    224       1.17       cgd 	if (n > PRIO_MAX)
    225       1.17       cgd 		n = PRIO_MAX;
    226       1.17       cgd 	if (n < PRIO_MIN)
    227       1.17       cgd 		n = PRIO_MIN;
    228       1.37        ws 	n += NZERO;
    229  1.103.4.8        ad 	onice = chgp->p_nice;
    230  1.103.4.2        ad 
    231  1.103.4.2        ad   again:
    232  1.103.4.7        ad 	if (kauth_authorize_process(cred, KAUTH_PROCESS_RESOURCE, chgp,
    233  1.103.4.7        ad 	    (void *)KAUTH_REQ_PROCESS_RESOURCE_NICE, KAUTH_ARG(n), NULL))
    234       1.17       cgd 		return (EACCES);
    235  1.103.4.8        ad 	mutex_enter(&chgp->p_stmutex);
    236  1.103.4.2        ad 	if (onice != chgp->p_nice) {
    237  1.103.4.8        ad 		mutex_exit(&chgp->p_stmutex);
    238  1.103.4.2        ad 		goto again;
    239  1.103.4.2        ad 	}
    240       1.17       cgd 	chgp->p_nice = n;
    241       1.68   thorpej 	(void)resetprocpriority(chgp);
    242  1.103.4.8        ad 	mutex_exit(&chgp->p_stmutex);
    243       1.17       cgd 	return (0);
    244       1.17       cgd }
    245       1.17       cgd 
    246       1.17       cgd /* ARGSUSED */
    247       1.25       cgd int
    248       1.98   thorpej sys_setrlimit(struct lwp *l, void *v, register_t *retval)
    249       1.30   thorpej {
    250       1.54  augustss 	struct sys_setrlimit_args /* {
    251       1.42   mycroft 		syscallarg(int) which;
    252       1.39       cgd 		syscallarg(const struct rlimit *) rlp;
    253       1.30   thorpej 	} */ *uap = v;
    254       1.42   mycroft 	int which = SCARG(uap, which);
    255       1.19       cgd 	struct rlimit alim;
    256       1.17       cgd 	int error;
    257       1.17       cgd 
    258       1.46     perry 	error = copyin(SCARG(uap, rlp), &alim, sizeof(struct rlimit));
    259       1.33  christos 	if (error)
    260       1.17       cgd 		return (error);
    261      1.102        ad 	return (dosetrlimit(l, l->l_proc, which, &alim));
    262       1.17       cgd }
    263       1.17       cgd 
    264       1.17       cgd int
    265      1.102        ad dosetrlimit(struct lwp *l, struct proc *p, int which, struct rlimit *limp)
    266       1.17       cgd {
    267       1.54  augustss 	struct rlimit *alimp;
    268       1.83        pk 	struct plimit *oldplim;
    269       1.17       cgd 	int error;
    270       1.17       cgd 
    271       1.67    itojun 	if ((u_int)which >= RLIM_NLIMITS)
    272       1.17       cgd 		return (EINVAL);
    273       1.38  matthias 
    274       1.38  matthias 	if (limp->rlim_cur < 0 || limp->rlim_max < 0)
    275       1.38  matthias 		return (EINVAL);
    276       1.38  matthias 
    277       1.17       cgd 	alimp = &p->p_rlimit[which];
    278       1.53    bouyer 	/* if we don't change the value, no need to limcopy() */
    279       1.53    bouyer 	if (limp->rlim_cur == alimp->rlim_cur &&
    280       1.53    bouyer 	    limp->rlim_max == alimp->rlim_max)
    281       1.53    bouyer 		return 0;
    282       1.53    bouyer 
    283       1.62  jdolecek 	if (limp->rlim_cur > limp->rlim_max) {
    284       1.62  jdolecek 		/*
    285       1.62  jdolecek 		 * This is programming error. According to SUSv2, we should
    286       1.62  jdolecek 		 * return error in this case.
    287       1.62  jdolecek 		 */
    288       1.62  jdolecek 		return (EINVAL);
    289       1.62  jdolecek 	}
    290  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_RESOURCE,
    291  1.103.4.7        ad 	    p, KAUTH_ARG(KAUTH_REQ_PROCESS_RESOURCE_RLIMIT), limp,
    292  1.103.4.7        ad 	    KAUTH_ARG(which));
    293  1.103.4.7        ad 	if (error)
    294       1.17       cgd 			return (error);
    295       1.62  jdolecek 
    296       1.17       cgd 	if (p->p_limit->p_refcnt > 1 &&
    297       1.17       cgd 	    (p->p_limit->p_lflags & PL_SHAREMOD) == 0) {
    298       1.83        pk 		p->p_limit = limcopy(oldplim = p->p_limit);
    299       1.83        pk 		limfree(oldplim);
    300       1.17       cgd 		alimp = &p->p_rlimit[which];
    301       1.17       cgd 	}
    302       1.17       cgd 
    303       1.17       cgd 	switch (which) {
    304       1.17       cgd 
    305       1.17       cgd 	case RLIMIT_DATA:
    306       1.19       cgd 		if (limp->rlim_cur > maxdmap)
    307       1.19       cgd 			limp->rlim_cur = maxdmap;
    308       1.19       cgd 		if (limp->rlim_max > maxdmap)
    309       1.19       cgd 			limp->rlim_max = maxdmap;
    310       1.17       cgd 		break;
    311       1.17       cgd 
    312       1.17       cgd 	case RLIMIT_STACK:
    313       1.19       cgd 		if (limp->rlim_cur > maxsmap)
    314       1.19       cgd 			limp->rlim_cur = maxsmap;
    315       1.19       cgd 		if (limp->rlim_max > maxsmap)
    316       1.19       cgd 			limp->rlim_max = maxsmap;
    317       1.62  jdolecek 
    318       1.62  jdolecek 		/*
    319       1.62  jdolecek 		 * Return EINVAL if the new stack size limit is lower than
    320       1.62  jdolecek 		 * current usage. Otherwise, the process would get SIGSEGV the
    321       1.62  jdolecek 		 * moment it would try to access anything on it's current stack.
    322       1.62  jdolecek 		 * This conforms to SUSv2.
    323       1.62  jdolecek 		 */
    324       1.62  jdolecek 		if (limp->rlim_cur < p->p_vmspace->vm_ssize * PAGE_SIZE
    325       1.62  jdolecek 		    || limp->rlim_max < p->p_vmspace->vm_ssize * PAGE_SIZE)
    326       1.62  jdolecek 			return (EINVAL);
    327       1.40     enami 
    328       1.17       cgd 		/*
    329       1.40     enami 		 * Stack is allocated to the max at exec time with
    330       1.40     enami 		 * only "rlim_cur" bytes accessible (In other words,
    331       1.40     enami 		 * allocates stack dividing two contiguous regions at
    332       1.40     enami 		 * "rlim_cur" bytes boundary).
    333       1.40     enami 		 *
    334       1.40     enami 		 * Since allocation is done in terms of page, roundup
    335       1.40     enami 		 * "rlim_cur" (otherwise, contiguous regions
    336       1.40     enami 		 * overlap).  If stack limit is going up make more
    337       1.40     enami 		 * accessible, if going down make inaccessible.
    338       1.17       cgd 		 */
    339       1.40     enami 		limp->rlim_cur = round_page(limp->rlim_cur);
    340       1.17       cgd 		if (limp->rlim_cur != alimp->rlim_cur) {
    341       1.48       eeh 			vaddr_t addr;
    342       1.48       eeh 			vsize_t size;
    343       1.17       cgd 			vm_prot_t prot;
    344       1.17       cgd 
    345       1.17       cgd 			if (limp->rlim_cur > alimp->rlim_cur) {
    346       1.73       chs 				prot = VM_PROT_READ | VM_PROT_WRITE;
    347       1.17       cgd 				size = limp->rlim_cur - alimp->rlim_cur;
    348       1.91      fvdl 				addr = (vaddr_t)p->p_vmspace->vm_minsaddr -
    349       1.91      fvdl 				    limp->rlim_cur;
    350       1.17       cgd 			} else {
    351       1.17       cgd 				prot = VM_PROT_NONE;
    352       1.17       cgd 				size = alimp->rlim_cur - limp->rlim_cur;
    353       1.91      fvdl 				addr = (vaddr_t)p->p_vmspace->vm_minsaddr -
    354       1.91      fvdl 				     alimp->rlim_cur;
    355       1.17       cgd 			}
    356       1.43       mrg 			(void) uvm_map_protect(&p->p_vmspace->vm_map,
    357      1.102        ad 			    addr, addr+size, prot, FALSE);
    358       1.17       cgd 		}
    359       1.17       cgd 		break;
    360       1.19       cgd 
    361       1.19       cgd 	case RLIMIT_NOFILE:
    362       1.19       cgd 		if (limp->rlim_cur > maxfiles)
    363       1.19       cgd 			limp->rlim_cur = maxfiles;
    364       1.19       cgd 		if (limp->rlim_max > maxfiles)
    365       1.19       cgd 			limp->rlim_max = maxfiles;
    366       1.19       cgd 		break;
    367       1.19       cgd 
    368       1.19       cgd 	case RLIMIT_NPROC:
    369       1.19       cgd 		if (limp->rlim_cur > maxproc)
    370       1.19       cgd 			limp->rlim_cur = maxproc;
    371       1.19       cgd 		if (limp->rlim_max > maxproc)
    372       1.19       cgd 			limp->rlim_max = maxproc;
    373       1.19       cgd 		break;
    374       1.17       cgd 	}
    375       1.17       cgd 	*alimp = *limp;
    376       1.17       cgd 	return (0);
    377       1.17       cgd }
    378       1.17       cgd 
    379       1.17       cgd /* ARGSUSED */
    380       1.25       cgd int
    381       1.98   thorpej sys_getrlimit(struct lwp *l, void *v, register_t *retval)
    382       1.30   thorpej {
    383       1.54  augustss 	struct sys_getrlimit_args /* {
    384       1.42   mycroft 		syscallarg(int) which;
    385       1.22       cgd 		syscallarg(struct rlimit *) rlp;
    386       1.30   thorpej 	} */ *uap = v;
    387       1.68   thorpej 	struct proc *p = l->l_proc;
    388       1.42   mycroft 	int which = SCARG(uap, which);
    389       1.17       cgd 
    390       1.67    itojun 	if ((u_int)which >= RLIM_NLIMITS)
    391       1.17       cgd 		return (EINVAL);
    392       1.42   mycroft 	return (copyout(&p->p_rlimit[which], SCARG(uap, rlp),
    393       1.46     perry 	    sizeof(struct rlimit)));
    394       1.17       cgd }
    395       1.17       cgd 
    396       1.17       cgd /*
    397       1.17       cgd  * Transform the running time and tick information in proc p into user,
    398       1.17       cgd  * system, and interrupt time usage.
    399  1.103.4.6        ad  *
    400  1.103.4.6        ad  * Should be called with p->p_smutex held unless called from exit1().
    401       1.17       cgd  */
    402       1.25       cgd void
    403       1.98   thorpej calcru(struct proc *p, struct timeval *up, struct timeval *sp,
    404  1.103.4.2        ad     struct timeval *ip, struct timeval *rp)
    405       1.17       cgd {
    406       1.54  augustss 	u_quad_t u, st, ut, it, tot;
    407       1.70       dsl 	unsigned long sec;
    408       1.70       dsl 	long usec;
    409  1.103.4.6        ad  	struct timeval tv;
    410       1.68   thorpej 	struct lwp *l;
    411       1.17       cgd 
    412  1.103.4.6        ad 	mutex_enter(&p->p_stmutex);
    413       1.17       cgd 	st = p->p_sticks;
    414       1.17       cgd 	ut = p->p_uticks;
    415       1.17       cgd 	it = p->p_iticks;
    416  1.103.4.6        ad 	mutex_exit(&p->p_stmutex);
    417  1.103.4.6        ad 
    418  1.103.4.6        ad 	sec = p->p_rtime.tv_sec;
    419  1.103.4.6        ad 	usec = p->p_rtime.tv_usec;
    420       1.17       cgd 
    421       1.70       dsl 	LIST_FOREACH(l, &p->p_lwps, l_sibling) {
    422  1.103.4.2        ad 		lwp_lock(l);
    423  1.103.4.2        ad 		sec += l->l_rtime.tv_sec;
    424  1.103.4.6        ad 		if ((usec += l->l_rtime.tv_usec) >= 1000000) {
    425  1.103.4.6        ad 			sec++;
    426  1.103.4.6        ad 			usec -= 1000000;
    427  1.103.4.6        ad 		}
    428  1.103.4.6        ad 		if (l->l_cpu == curcpu()) {
    429       1.68   thorpej 			struct schedstate_percpu *spc;
    430       1.87     perry 
    431       1.68   thorpej 			KDASSERT(l->l_cpu != NULL);
    432       1.68   thorpej 			spc = &l->l_cpu->ci_schedstate;
    433       1.87     perry 
    434       1.68   thorpej 			/*
    435       1.68   thorpej 			 * Adjust for the current time slice.  This is
    436       1.68   thorpej 			 * actually fairly important since the error
    437       1.68   thorpej 			 * here is on the order of a time quantum,
    438       1.68   thorpej 			 * which is much greater than the sampling
    439       1.87     perry 			 * error.
    440       1.68   thorpej 			 */
    441       1.68   thorpej 			microtime(&tv);
    442       1.68   thorpej 			sec += tv.tv_sec - spc->spc_runtime.tv_sec;
    443       1.68   thorpej 			usec += tv.tv_usec - spc->spc_runtime.tv_usec;
    444  1.103.4.6        ad 			if (usec >= 1000000) {
    445  1.103.4.6        ad 				sec++;
    446  1.103.4.6        ad 				usec -= 1000000;
    447  1.103.4.6        ad 			}
    448       1.68   thorpej 		}
    449  1.103.4.2        ad 		lwp_unlock(l);
    450       1.17       cgd 	}
    451       1.69       dsl 
    452       1.69       dsl 	tot = st + ut + it;
    453       1.70       dsl 	u = sec * 1000000ull + usec;
    454       1.70       dsl 
    455       1.69       dsl 	if (tot == 0) {
    456       1.69       dsl 		/* No ticks, so can't use to share time out, split 50-50 */
    457       1.70       dsl 		st = ut = u / 2;
    458       1.70       dsl 	} else {
    459       1.70       dsl 		st = (u * st) / tot;
    460       1.70       dsl 		ut = (u * ut) / tot;
    461       1.69       dsl 	}
    462  1.103.4.2        ad 	if (sp != NULL) {
    463  1.103.4.2        ad 		sp->tv_sec = st / 1000000;
    464  1.103.4.2        ad 		sp->tv_usec = st % 1000000;
    465  1.103.4.2        ad 	}
    466  1.103.4.2        ad 	if (up != NULL) {
    467  1.103.4.2        ad 		up->tv_sec = ut / 1000000;
    468  1.103.4.2        ad 		up->tv_usec = ut % 1000000;
    469  1.103.4.2        ad 	}
    470       1.17       cgd 	if (ip != NULL) {
    471       1.70       dsl 		if (it != 0)
    472       1.70       dsl 			it = (u * it) / tot;
    473       1.17       cgd 		ip->tv_sec = it / 1000000;
    474       1.17       cgd 		ip->tv_usec = it % 1000000;
    475       1.17       cgd 	}
    476  1.103.4.2        ad 	if (rp != NULL) {
    477  1.103.4.2        ad 		rp->tv_sec = sec;
    478  1.103.4.2        ad 		rp->tv_usec = usec;
    479  1.103.4.2        ad 	}
    480       1.17       cgd }
    481       1.17       cgd 
    482       1.17       cgd /* ARGSUSED */
    483       1.25       cgd int
    484       1.98   thorpej sys_getrusage(struct lwp *l, void *v, register_t *retval)
    485       1.30   thorpej {
    486       1.54  augustss 	struct sys_getrusage_args /* {
    487       1.22       cgd 		syscallarg(int) who;
    488       1.22       cgd 		syscallarg(struct rusage *) rusage;
    489       1.30   thorpej 	} */ *uap = v;
    490       1.54  augustss 	struct rusage *rup;
    491       1.68   thorpej 	struct proc *p = l->l_proc;
    492       1.17       cgd 
    493       1.22       cgd 	switch (SCARG(uap, who)) {
    494       1.17       cgd 
    495       1.19       cgd 	case RUSAGE_SELF:
    496       1.17       cgd 		rup = &p->p_stats->p_ru;
    497  1.103.4.3        ad 		mutex_enter(&p->p_smutex);
    498  1.103.4.2        ad 		calcru(p, &rup->ru_utime, &rup->ru_stime, NULL, NULL);
    499  1.103.4.3        ad 		mutex_exit(&p->p_smutex);
    500       1.17       cgd 		break;
    501       1.17       cgd 
    502       1.17       cgd 	case RUSAGE_CHILDREN:
    503       1.17       cgd 		rup = &p->p_stats->p_cru;
    504       1.17       cgd 		break;
    505       1.17       cgd 
    506       1.17       cgd 	default:
    507       1.17       cgd 		return (EINVAL);
    508       1.17       cgd 	}
    509       1.46     perry 	return (copyout(rup, SCARG(uap, rusage), sizeof(struct rusage)));
    510       1.17       cgd }
    511       1.17       cgd 
    512       1.25       cgd void
    513       1.98   thorpej ruadd(struct rusage *ru, struct rusage *ru2)
    514       1.17       cgd {
    515       1.54  augustss 	long *ip, *ip2;
    516       1.54  augustss 	int i;
    517       1.17       cgd 
    518       1.27   mycroft 	timeradd(&ru->ru_utime, &ru2->ru_utime, &ru->ru_utime);
    519       1.27   mycroft 	timeradd(&ru->ru_stime, &ru2->ru_stime, &ru->ru_stime);
    520       1.17       cgd 	if (ru->ru_maxrss < ru2->ru_maxrss)
    521       1.17       cgd 		ru->ru_maxrss = ru2->ru_maxrss;
    522       1.17       cgd 	ip = &ru->ru_first; ip2 = &ru2->ru_first;
    523       1.17       cgd 	for (i = &ru->ru_last - &ru->ru_first; i >= 0; i--)
    524       1.17       cgd 		*ip++ += *ip2++;
    525       1.17       cgd }
    526       1.17       cgd 
    527       1.17       cgd /*
    528       1.17       cgd  * Make a copy of the plimit structure.
    529       1.17       cgd  * We share these structures copy-on-write after fork,
    530       1.17       cgd  * and copy when a limit is changed.
    531       1.17       cgd  */
    532       1.17       cgd struct plimit *
    533       1.98   thorpej limcopy(struct plimit *lim)
    534       1.17       cgd {
    535       1.54  augustss 	struct plimit *newlim;
    536       1.83        pk 	size_t l = 0;
    537       1.83        pk 
    538       1.83        pk 	simple_lock(&lim->p_slock);
    539       1.83        pk 	if (lim->pl_corename != defcorename)
    540       1.83        pk 		l = strlen(lim->pl_corename) + 1;
    541       1.83        pk 	simple_unlock(&lim->p_slock);
    542       1.17       cgd 
    543       1.49   thorpej 	newlim = pool_get(&plimit_pool, PR_WAITOK);
    544       1.83        pk 	simple_lock_init(&newlim->p_slock);
    545       1.83        pk 	newlim->p_lflags = 0;
    546       1.83        pk 	newlim->p_refcnt = 1;
    547       1.83        pk 	newlim->pl_corename = (l != 0)
    548       1.83        pk 		? malloc(l, M_TEMP, M_WAITOK)
    549       1.83        pk 		: defcorename;
    550       1.83        pk 
    551       1.83        pk 	simple_lock(&lim->p_slock);
    552       1.47     perry 	memcpy(newlim->pl_rlimit, lim->pl_rlimit,
    553       1.17       cgd 	    sizeof(struct rlimit) * RLIM_NLIMITS);
    554       1.83        pk 
    555       1.83        pk 	if (l != 0)
    556       1.71    itojun 		strlcpy(newlim->pl_corename, lim->pl_corename, l);
    557       1.83        pk 	simple_unlock(&lim->p_slock);
    558       1.83        pk 
    559       1.32   mycroft 	return (newlim);
    560       1.32   mycroft }
    561       1.32   mycroft 
    562       1.32   mycroft void
    563       1.98   thorpej limfree(struct plimit *lim)
    564       1.32   mycroft {
    565       1.84  christos 	int n;
    566       1.85    kleink 
    567       1.83        pk 	simple_lock(&lim->p_slock);
    568       1.84  christos 	n = --lim->p_refcnt;
    569       1.83        pk 	simple_unlock(&lim->p_slock);
    570       1.83        pk 	if (n > 0)
    571       1.32   mycroft 		return;
    572       1.53    bouyer #ifdef DIAGNOSTIC
    573       1.83        pk 	if (n < 0)
    574       1.53    bouyer 		panic("limfree");
    575       1.53    bouyer #endif
    576       1.53    bouyer 	if (lim->pl_corename != defcorename)
    577       1.53    bouyer 		free(lim->pl_corename, M_TEMP);
    578       1.49   thorpej 	pool_put(&plimit_pool, lim);
    579       1.68   thorpej }
    580       1.68   thorpej 
    581       1.68   thorpej struct pstats *
    582       1.98   thorpej pstatscopy(struct pstats *ps)
    583       1.68   thorpej {
    584       1.87     perry 
    585       1.68   thorpej 	struct pstats *newps;
    586       1.68   thorpej 
    587       1.68   thorpej 	newps = pool_get(&pstats_pool, PR_WAITOK);
    588       1.68   thorpej 
    589       1.68   thorpej 	memset(&newps->pstat_startzero, 0,
    590       1.68   thorpej 	(unsigned) ((caddr_t)&newps->pstat_endzero -
    591       1.68   thorpej 		    (caddr_t)&newps->pstat_startzero));
    592       1.68   thorpej 	memcpy(&newps->pstat_startcopy, &ps->pstat_startcopy,
    593       1.68   thorpej 	((caddr_t)&newps->pstat_endcopy -
    594       1.68   thorpej 	 (caddr_t)&newps->pstat_startcopy));
    595       1.68   thorpej 
    596       1.68   thorpej 	return (newps);
    597       1.68   thorpej 
    598       1.68   thorpej }
    599       1.68   thorpej 
    600       1.68   thorpej void
    601       1.98   thorpej pstatsfree(struct pstats *ps)
    602       1.68   thorpej {
    603       1.68   thorpej 
    604       1.68   thorpej 	pool_put(&pstats_pool, ps);
    605       1.74    atatat }
    606       1.74    atatat 
    607       1.74    atatat /*
    608       1.74    atatat  * sysctl interface in five parts
    609       1.74    atatat  */
    610       1.74    atatat 
    611       1.74    atatat /*
    612       1.74    atatat  * a routine for sysctl proc subtree helpers that need to pick a valid
    613       1.74    atatat  * process by pid.
    614       1.74    atatat  */
    615       1.74    atatat static int
    616      1.102        ad sysctl_proc_findproc(struct lwp *l, struct proc **p2, pid_t pid)
    617       1.74    atatat {
    618       1.74    atatat 	struct proc *ptmp;
    619      1.101      elad 	int error = 0;
    620       1.74    atatat 
    621       1.74    atatat 	if (pid == PROC_CURPROC)
    622      1.102        ad 		ptmp = l->l_proc;
    623       1.74    atatat 	else if ((ptmp = pfind(pid)) == NULL)
    624       1.74    atatat 		error = ESRCH;
    625       1.74    atatat 
    626       1.74    atatat 	*p2 = ptmp;
    627       1.74    atatat 	return (error);
    628       1.74    atatat }
    629       1.74    atatat 
    630       1.74    atatat /*
    631       1.74    atatat  * sysctl helper routine for setting a process's specific corefile
    632       1.74    atatat  * name.  picks the process based on the given pid and checks the
    633       1.74    atatat  * correctness of the new value.
    634       1.74    atatat  */
    635       1.74    atatat static int
    636       1.74    atatat sysctl_proc_corename(SYSCTLFN_ARGS)
    637       1.74    atatat {
    638      1.102        ad 	struct proc *ptmp;
    639       1.83        pk 	struct plimit *lim;
    640       1.74    atatat 	int error = 0, len;
    641      1.100      yamt 	char *cname;
    642      1.100      yamt 	char *tmp;
    643       1.74    atatat 	struct sysctlnode node;
    644       1.74    atatat 
    645       1.74    atatat 	/*
    646       1.74    atatat 	 * is this all correct?
    647       1.74    atatat 	 */
    648       1.74    atatat 	if (namelen != 0)
    649       1.74    atatat 		return (EINVAL);
    650       1.74    atatat 	if (name[-1] != PROC_PID_CORENAME)
    651       1.74    atatat 		return (EINVAL);
    652       1.74    atatat 
    653       1.74    atatat 	/*
    654       1.74    atatat 	 * whom are we tweaking?
    655       1.74    atatat 	 */
    656      1.102        ad 	error = sysctl_proc_findproc(l, &ptmp, (pid_t)name[-2]);
    657       1.74    atatat 	if (error)
    658       1.74    atatat 		return (error);
    659       1.74    atatat 
    660  1.103.4.7        ad 	/* XXX this should be in p_find() */
    661  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CANSEE,
    662  1.103.4.7        ad 	    ptmp, NULL, NULL, NULL);
    663  1.103.4.7        ad 	if (error)
    664  1.103.4.7        ad 		return (error);
    665  1.103.4.7        ad 
    666      1.100      yamt 	cname = PNBUF_GET();
    667       1.74    atatat 	/*
    668       1.74    atatat 	 * let them modify a temporary copy of the core name
    669       1.74    atatat 	 */
    670       1.74    atatat 	node = *rnode;
    671      1.100      yamt 	strlcpy(cname, ptmp->p_limit->pl_corename, MAXPATHLEN);
    672       1.74    atatat 	node.sysctl_data = cname;
    673       1.74    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
    674       1.74    atatat 
    675       1.74    atatat 	/*
    676       1.74    atatat 	 * if that failed, or they have nothing new to say, or we've
    677       1.74    atatat 	 * heard it before...
    678       1.74    atatat 	 */
    679       1.74    atatat 	if (error || newp == NULL ||
    680      1.100      yamt 	    strcmp(cname, ptmp->p_limit->pl_corename) == 0) {
    681      1.100      yamt 		goto done;
    682      1.100      yamt 	}
    683       1.74    atatat 
    684  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CORENAME,
    685  1.103.4.7        ad 	    ptmp, cname, NULL, NULL);
    686  1.103.4.7        ad 	if (error)
    687  1.103.4.7        ad 		return (error);
    688      1.103      elad 
    689       1.74    atatat 	/*
    690       1.74    atatat 	 * no error yet and cname now has the new core name in it.
    691       1.74    atatat 	 * let's see if it looks acceptable.  it must be either "core"
    692       1.74    atatat 	 * or end in ".core" or "/core".
    693       1.74    atatat 	 */
    694       1.74    atatat 	len = strlen(cname);
    695      1.100      yamt 	if (len < 4) {
    696      1.100      yamt 		error = EINVAL;
    697      1.100      yamt 	} else if (strcmp(cname + len - 4, "core") != 0) {
    698      1.100      yamt 		error = EINVAL;
    699      1.100      yamt 	} else if (len > 4 && cname[len - 5] != '/' && cname[len - 5] != '.') {
    700      1.100      yamt 		error = EINVAL;
    701      1.100      yamt 	}
    702      1.100      yamt 	if (error != 0) {
    703      1.100      yamt 		goto done;
    704      1.100      yamt 	}
    705       1.74    atatat 
    706       1.74    atatat 	/*
    707       1.74    atatat 	 * hmm...looks good.  now...where do we put it?
    708       1.74    atatat 	 */
    709       1.74    atatat 	tmp = malloc(len + 1, M_TEMP, M_WAITOK|M_CANFAIL);
    710      1.100      yamt 	if (tmp == NULL) {
    711      1.100      yamt 		error = ENOMEM;
    712      1.100      yamt 		goto done;
    713      1.100      yamt 	}
    714       1.74    atatat 	strlcpy(tmp, cname, len + 1);
    715       1.74    atatat 
    716       1.83        pk 	lim = ptmp->p_limit;
    717       1.83        pk 	if (lim->p_refcnt > 1 && (lim->p_lflags & PL_SHAREMOD) == 0) {
    718       1.83        pk 		ptmp->p_limit = limcopy(lim);
    719       1.83        pk 		limfree(lim);
    720       1.83        pk 		lim = ptmp->p_limit;
    721       1.83        pk 	}
    722       1.83        pk 	if (lim->pl_corename != defcorename)
    723       1.83        pk 		free(lim->pl_corename, M_TEMP);
    724       1.83        pk 	lim->pl_corename = tmp;
    725      1.100      yamt done:
    726      1.100      yamt 	PNBUF_PUT(cname);
    727      1.100      yamt 	return error;
    728       1.74    atatat }
    729       1.74    atatat 
    730       1.74    atatat /*
    731       1.74    atatat  * sysctl helper routine for checking/setting a process's stop flags,
    732       1.74    atatat  * one for fork and one for exec.
    733       1.74    atatat  */
    734       1.74    atatat static int
    735       1.74    atatat sysctl_proc_stop(SYSCTLFN_ARGS)
    736       1.74    atatat {
    737      1.102        ad 	struct proc *ptmp;
    738       1.74    atatat 	int i, f, error = 0;
    739       1.74    atatat 	struct sysctlnode node;
    740       1.74    atatat 
    741       1.74    atatat 	if (namelen != 0)
    742       1.74    atatat 		return (EINVAL);
    743       1.74    atatat 
    744      1.102        ad 	error = sysctl_proc_findproc(l, &ptmp, (pid_t)name[-2]);
    745       1.74    atatat 	if (error)
    746       1.74    atatat 		return (error);
    747       1.74    atatat 
    748  1.103.4.7        ad 	/* XXX this should be in p_find() */
    749  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CANSEE,
    750  1.103.4.7        ad 	    ptmp, NULL, NULL, NULL);
    751  1.103.4.7        ad 	if (error)
    752  1.103.4.7        ad 		return (error);
    753  1.103.4.7        ad 
    754       1.74    atatat 	switch (rnode->sysctl_num) {
    755       1.74    atatat 	case PROC_PID_STOPFORK:
    756  1.103.4.4        ad 		f = PS_STOPFORK;
    757       1.74    atatat 		break;
    758       1.74    atatat 	case PROC_PID_STOPEXEC:
    759  1.103.4.4        ad 		f = PS_STOPEXEC;
    760       1.74    atatat 		break;
    761       1.74    atatat 	case PROC_PID_STOPEXIT:
    762  1.103.4.4        ad 		f = PS_STOPEXIT;
    763       1.74    atatat 		break;
    764       1.74    atatat 	default:
    765       1.74    atatat 		return (EINVAL);
    766       1.74    atatat 	}
    767       1.74    atatat 
    768       1.74    atatat 	i = (ptmp->p_flag & f) ? 1 : 0;
    769       1.74    atatat 	node = *rnode;
    770       1.74    atatat 	node.sysctl_data = &i;
    771       1.74    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
    772       1.74    atatat 	if (error || newp == NULL)
    773       1.74    atatat 		return (error);
    774       1.74    atatat 
    775  1.103.4.4        ad 	mutex_enter(&ptmp->p_smutex);
    776  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_STOPFLAG,
    777  1.103.4.7        ad 	    ptmp, KAUTH_ARG(f), NULL, NULL);
    778  1.103.4.7        ad 	if (error)
    779  1.103.4.7        ad 		return (error);
    780       1.74    atatat 	if (i)
    781  1.103.4.4        ad 		ptmp->p_sflag |= f;
    782       1.74    atatat 	else
    783  1.103.4.4        ad 		ptmp->p_sflag &= ~f;
    784  1.103.4.4        ad 	mutex_exit(&ptmp->p_smutex);
    785       1.74    atatat 
    786       1.74    atatat 	return (0);
    787       1.74    atatat }
    788       1.74    atatat 
    789       1.74    atatat /*
    790       1.74    atatat  * sysctl helper routine for a process's rlimits as exposed by sysctl.
    791       1.74    atatat  */
    792       1.74    atatat static int
    793       1.74    atatat sysctl_proc_plimit(SYSCTLFN_ARGS)
    794       1.74    atatat {
    795      1.102        ad 	struct proc *ptmp;
    796       1.74    atatat 	u_int limitno;
    797       1.74    atatat 	int which, error = 0;
    798       1.74    atatat         struct rlimit alim;
    799       1.74    atatat 	struct sysctlnode node;
    800       1.74    atatat 
    801       1.74    atatat 	if (namelen != 0)
    802       1.74    atatat 		return (EINVAL);
    803       1.74    atatat 
    804       1.74    atatat 	which = name[-1];
    805       1.74    atatat 	if (which != PROC_PID_LIMIT_TYPE_SOFT &&
    806       1.74    atatat 	    which != PROC_PID_LIMIT_TYPE_HARD)
    807       1.74    atatat 		return (EINVAL);
    808       1.74    atatat 
    809       1.74    atatat 	limitno = name[-2] - 1;
    810       1.74    atatat 	if (limitno >= RLIM_NLIMITS)
    811       1.74    atatat 		return (EINVAL);
    812       1.74    atatat 
    813       1.74    atatat 	if (name[-3] != PROC_PID_LIMIT)
    814       1.74    atatat 		return (EINVAL);
    815       1.74    atatat 
    816      1.102        ad 	error = sysctl_proc_findproc(l, &ptmp, (pid_t)name[-4]);
    817       1.74    atatat 	if (error)
    818       1.74    atatat 		return (error);
    819       1.74    atatat 
    820  1.103.4.7        ad 	/* XXX this should be in p_find() */
    821  1.103.4.7        ad 	error = kauth_authorize_process(l->l_cred, KAUTH_PROCESS_CANSEE,
    822  1.103.4.7        ad 	    ptmp, NULL, NULL, NULL);
    823  1.103.4.7        ad 	if (error)
    824  1.103.4.7        ad 		return (error);
    825  1.103.4.7        ad 
    826       1.74    atatat 	node = *rnode;
    827       1.74    atatat 	memcpy(&alim, &ptmp->p_rlimit[limitno], sizeof(alim));
    828       1.74    atatat 	if (which == PROC_PID_LIMIT_TYPE_HARD)
    829       1.74    atatat 		node.sysctl_data = &alim.rlim_max;
    830       1.74    atatat 	else
    831       1.74    atatat 		node.sysctl_data = &alim.rlim_cur;
    832       1.74    atatat 
    833       1.74    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
    834       1.74    atatat 	if (error || newp == NULL)
    835       1.74    atatat 		return (error);
    836       1.74    atatat 
    837      1.102        ad 	return (dosetrlimit(l, ptmp, limitno, &alim));
    838       1.74    atatat }
    839       1.74    atatat 
    840       1.74    atatat /*
    841       1.74    atatat  * and finally, the actually glue that sticks it to the tree
    842       1.74    atatat  */
    843       1.74    atatat SYSCTL_SETUP(sysctl_proc_setup, "sysctl proc subtree setup")
    844       1.74    atatat {
    845       1.74    atatat 
    846       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    847       1.76    atatat 		       CTLFLAG_PERMANENT,
    848       1.74    atatat 		       CTLTYPE_NODE, "proc", NULL,
    849       1.74    atatat 		       NULL, 0, NULL, 0,
    850       1.74    atatat 		       CTL_PROC, CTL_EOL);
    851       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    852       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_ANYNUMBER,
    853       1.78    atatat 		       CTLTYPE_NODE, "curproc",
    854       1.78    atatat 		       SYSCTL_DESCR("Per-process settings"),
    855       1.74    atatat 		       NULL, 0, NULL, 0,
    856       1.74    atatat 		       CTL_PROC, PROC_CURPROC, CTL_EOL);
    857       1.74    atatat 
    858       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    859      1.103      elad 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE,
    860       1.78    atatat 		       CTLTYPE_STRING, "corename",
    861       1.78    atatat 		       SYSCTL_DESCR("Core file name"),
    862       1.74    atatat 		       sysctl_proc_corename, 0, NULL, MAXPATHLEN,
    863       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_CORENAME, CTL_EOL);
    864       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    865       1.76    atatat 		       CTLFLAG_PERMANENT,
    866       1.78    atatat 		       CTLTYPE_NODE, "rlimit",
    867       1.78    atatat 		       SYSCTL_DESCR("Process limits"),
    868       1.74    atatat 		       NULL, 0, NULL, 0,
    869       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_LIMIT, CTL_EOL);
    870       1.74    atatat 
    871       1.74    atatat #define create_proc_plimit(s, n) do {					\
    872       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,				\
    873       1.76    atatat 		       CTLFLAG_PERMANENT,				\
    874       1.78    atatat 		       CTLTYPE_NODE, s,					\
    875       1.78    atatat 		       SYSCTL_DESCR("Process " s " limits"),		\
    876       1.74    atatat 		       NULL, 0, NULL, 0,				\
    877       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_LIMIT, n,	\
    878       1.74    atatat 		       CTL_EOL);					\
    879       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,				\
    880       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE, \
    881       1.78    atatat 		       CTLTYPE_QUAD, "soft",				\
    882       1.78    atatat 		       SYSCTL_DESCR("Process soft " s " limit"),	\
    883       1.74    atatat 		       sysctl_proc_plimit, 0, NULL, 0,			\
    884       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_LIMIT, n,	\
    885       1.74    atatat 		       PROC_PID_LIMIT_TYPE_SOFT, CTL_EOL);		\
    886       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,				\
    887       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE, \
    888       1.78    atatat 		       CTLTYPE_QUAD, "hard",				\
    889       1.78    atatat 		       SYSCTL_DESCR("Process hard " s " limit"),	\
    890       1.74    atatat 		       sysctl_proc_plimit, 0, NULL, 0,			\
    891       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_LIMIT, n,	\
    892       1.74    atatat 		       PROC_PID_LIMIT_TYPE_HARD, CTL_EOL);		\
    893       1.74    atatat 	} while (0/*CONSTCOND*/)
    894       1.74    atatat 
    895       1.74    atatat 	create_proc_plimit("cputime",		PROC_PID_LIMIT_CPU);
    896       1.74    atatat 	create_proc_plimit("filesize",		PROC_PID_LIMIT_FSIZE);
    897       1.74    atatat 	create_proc_plimit("datasize",		PROC_PID_LIMIT_DATA);
    898       1.74    atatat 	create_proc_plimit("stacksize",		PROC_PID_LIMIT_STACK);
    899       1.74    atatat 	create_proc_plimit("coredumpsize",	PROC_PID_LIMIT_CORE);
    900       1.74    atatat 	create_proc_plimit("memoryuse",		PROC_PID_LIMIT_RSS);
    901       1.74    atatat 	create_proc_plimit("memorylocked",	PROC_PID_LIMIT_MEMLOCK);
    902       1.74    atatat 	create_proc_plimit("maxproc",		PROC_PID_LIMIT_NPROC);
    903       1.74    atatat 	create_proc_plimit("descriptors",	PROC_PID_LIMIT_NOFILE);
    904       1.79  christos 	create_proc_plimit("sbsize",		PROC_PID_LIMIT_SBSIZE);
    905       1.74    atatat 
    906       1.74    atatat #undef create_proc_plimit
    907       1.74    atatat 
    908       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    909       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE,
    910       1.78    atatat 		       CTLTYPE_INT, "stopfork",
    911       1.78    atatat 		       SYSCTL_DESCR("Stop process at fork(2)"),
    912       1.74    atatat 		       sysctl_proc_stop, 0, NULL, 0,
    913       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_STOPFORK, CTL_EOL);
    914       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    915       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE,
    916       1.78    atatat 		       CTLTYPE_INT, "stopexec",
    917       1.78    atatat 		       SYSCTL_DESCR("Stop process at execve(2)"),
    918       1.74    atatat 		       sysctl_proc_stop, 0, NULL, 0,
    919       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_STOPEXEC, CTL_EOL);
    920       1.76    atatat 	sysctl_createv(clog, 0, NULL, NULL,
    921       1.76    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE|CTLFLAG_ANYWRITE,
    922       1.78    atatat 		       CTLTYPE_INT, "stopexit",
    923       1.78    atatat 		       SYSCTL_DESCR("Stop process before completing exit"),
    924       1.74    atatat 		       sysctl_proc_stop, 0, NULL, 0,
    925       1.74    atatat 		       CTL_PROC, PROC_CURPROC, PROC_PID_STOPEXIT, CTL_EOL);
    926       1.17       cgd }
    927       1.79  christos 
    928       1.88  christos struct uidinfo *
    929       1.88  christos uid_find(uid_t uid)
    930       1.79  christos {
    931       1.79  christos 	struct uidinfo *uip;
    932       1.90  christos 	struct uidinfo *newuip = NULL;
    933       1.79  christos 	struct uihashhead *uipp;
    934       1.79  christos 
    935       1.79  christos 	uipp = UIHASH(uid);
    936       1.79  christos 
    937       1.90  christos again:
    938       1.89  christos 	simple_lock(&uihashtbl_slock);
    939       1.79  christos 	LIST_FOREACH(uip, uipp, ui_hash)
    940       1.88  christos 		if (uip->ui_uid == uid) {
    941       1.88  christos 			simple_unlock(&uihashtbl_slock);
    942       1.90  christos 			if (newuip)
    943       1.90  christos 				free(newuip, M_PROC);
    944       1.79  christos 			return uip;
    945       1.88  christos 		}
    946       1.79  christos 
    947       1.90  christos 	if (newuip == NULL) {
    948       1.90  christos 		simple_unlock(&uihashtbl_slock);
    949       1.90  christos 		newuip = malloc(sizeof(*uip), M_PROC, M_WAITOK | M_ZERO);
    950       1.90  christos 		goto again;
    951       1.90  christos 	}
    952       1.90  christos 	uip = newuip;
    953       1.89  christos 
    954       1.79  christos 	LIST_INSERT_HEAD(uipp, uip, ui_hash);
    955       1.79  christos 	uip->ui_uid = uid;
    956       1.94  christos 	simple_lock_init(&uip->ui_slock);
    957       1.88  christos 	simple_unlock(&uihashtbl_slock);
    958       1.89  christos 
    959       1.79  christos 	return uip;
    960       1.79  christos }
    961       1.79  christos 
    962       1.79  christos /*
    963       1.79  christos  * Change the count associated with number of processes
    964       1.79  christos  * a given user is using.
    965       1.79  christos  */
    966       1.79  christos int
    967       1.79  christos chgproccnt(uid_t uid, int diff)
    968       1.79  christos {
    969       1.79  christos 	struct uidinfo *uip;
    970       1.96  christos 	int s;
    971       1.79  christos 
    972       1.79  christos 	if (diff == 0)
    973       1.79  christos 		return 0;
    974       1.79  christos 
    975       1.88  christos 	uip = uid_find(uid);
    976       1.96  christos 	UILOCK(uip, s);
    977       1.88  christos 	uip->ui_proccnt += diff;
    978       1.88  christos 	KASSERT(uip->ui_proccnt >= 0);
    979       1.96  christos 	UIUNLOCK(uip, s);
    980       1.88  christos 	return uip->ui_proccnt;
    981       1.79  christos }
    982       1.79  christos 
    983       1.79  christos int
    984       1.97  christos chgsbsize(struct uidinfo *uip, u_long *hiwat, u_long to, rlim_t xmax)
    985       1.79  christos {
    986       1.79  christos 	rlim_t nsb;
    987       1.96  christos 	int s;
    988       1.79  christos 
    989       1.96  christos 	UILOCK(uip, s);
    990       1.80      yamt 	nsb = uip->ui_sbsize + to - *hiwat;
    991       1.97  christos 	if (to > *hiwat && nsb > xmax) {
    992       1.96  christos 		UIUNLOCK(uip, s);
    993       1.95  christos 		splx(s);
    994       1.88  christos 		return 0;
    995       1.94  christos 	}
    996       1.79  christos 	*hiwat = to;
    997       1.79  christos 	uip->ui_sbsize = nsb;
    998       1.79  christos 	KASSERT(uip->ui_sbsize >= 0);
    999       1.96  christos 	UIUNLOCK(uip, s);
   1000       1.88  christos 	return 1;
   1001       1.79  christos }
   1002