| 1 | /*- |
| 2 | * SPDX-License-Identifier: BSD-3-Clause |
| 3 | * |
| 4 | * Copyright (c) 1991, 1993 |
| 5 | *	The Regents of the University of California. All rights reserved. |
| 6 | * |
| 7 | * Redistribution and use in source and binary forms, with or without |
| 8 | * modification, are permitted provided that the following conditions |
| 9 | * are met: |
| 10 | * 1. Redistributions of source code must retain the above copyright |
| 11 | * notice, this list of conditions and the following disclaimer. |
| 12 | * 2. Redistributions in binary form must reproduce the above copyright |
| 13 | * notice, this list of conditions and the following disclaimer in the |
| 14 | * documentation and/or other materials provided with the distribution. |
| 15 | * 3. Neither the name of the University nor the names of its contributors |
| 16 | * may be used to endorse or promote products derived from this software |
| 17 | * without specific prior written permission. |
| 18 | * |
| 19 | * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND |
| 20 | * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
| 21 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
| 22 | * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE |
| 23 | * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL |
| 24 | * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS |
| 25 | * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) |
| 26 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT |
| 27 | * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY |
| 28 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF |
| 29 | * SUCH DAMAGE. |
| 30 | */ |
| 31 | |
| 32 | #ifndef	_SYS_RESOURCEVAR_H_ |
| 33 | #define	_SYS_RESOURCEVAR_H_ |
| 34 | |
| 35 | #include <sys/resource.h> |
| 36 | #include <sys/queue.h> |
| 37 | #ifdef _KERNEL |
| 38 | #include <sys/_lock.h> |
| 39 | #include <sys/_mutex.h> |
| 40 | #endif |
| 41 | |
| 42 | /* |
| 43 | * Kernel per-process accounting / statistics |
| 44 | * (not necessarily resident except when running). |
| 45 | * |
| 46 | * Locking key: |
| 47 | * b - created at fork, never changes |
| 48 | * c - locked by proc mtx |
| 49 | * k - only accessed by curthread |
| 50 | * w - locked by proc itim lock |
| 51 | *	w2 - locked by proc prof lock |
| 52 | */ |
| 53 | struct pstats { |
| 54 | #define	pstat_startzero	p_cru |
| 55 | 	struct	rusage p_cru;		/* Stats for reaped children. */ |
| 56 | 	struct	itimerval p_timer[3];	/* (w) Virtual-time timers. */ |
| 57 | #define	pstat_endzero	pstat_startcopy |
| 58 | |
| 59 | #define	pstat_startcopy	p_prof |
| 60 | 	struct uprof {			/* Profile arguments. */ |
| 61 | 		caddr_t	pr_base;	/* (c + w2) Buffer base. */ |
| 62 | 		u_long	pr_size;	/* (c + w2) Buffer size. */ |
| 63 | 		u_long	pr_off;		/* (c + w2) PC offset. */ |
| 64 | 		u_long	pr_scale;	/* (c + w2) PC scaling. */ |
| 65 | 	} p_prof; |
| 66 | #define	pstat_endcopy	p_start |
| 67 | 	struct	timeval p_start;	/* (b) Starting time. */ |
| 68 | }; |
| 69 | |
| 70 | #ifdef _KERNEL |
| 71 | |
| 72 | /* |
| 73 | * Kernel shareable process resource limits. Because this structure |
| 74 | * is moderately large but changes infrequently, it is normally |
| 75 | * shared copy-on-write after forks. |
| 76 | */ |
| 77 | struct plimit { |
| 78 | 	struct	rlimit pl_rlimit[RLIM_NLIMITS]; |
| 79 | 	int	pl_refcnt;		/* number of references */ |
| 80 | }; |
| 81 | |
| 82 | struct limbatch { |
| 83 | 	struct plimit *limp; |
| 84 | 	int count; |
| 85 | }; |
| 86 | |
| 87 | static inline void |
| 88 | limbatch_prep(struct limbatch *lb) |
| 89 | { |
| 90 | lb->limp = NULL; |
| 91 | lb->count = 0; |
| 92 | } |
| 93 | |
| 94 | void limbatch_add(struct limbatch *lb, struct thread *td); |
| 95 | |
| 96 | static inline void |
| 97 | limbatch_process(struct limbatch *lb __unused) |
| 98 | { |
| 99 | |
| 100 | } |
| 101 | |
| 102 | void limbatch_final(struct limbatch *lb); |
| 103 | |
| 104 | struct racct; |
| 105 | |
| 106 | /*- |
| 107 | * Per uid resource consumption. This structure is used to track |
| 108 | * the total resource consumption (process count, socket buffer size, |
| 109 | * etc) for the uid and impose limits. |
| 110 | * |
| 111 | * Locking guide: |
| 112 | * (a) Constant from inception |
| 113 | * (b) Lockless, updated using atomics |
| 114 | * (c) Locked by global uihashtbl_lock |
| 115 | */ |
| 116 | struct uidinfo { |
| 117 | 	LIST_ENTRY(uidinfo) ui_hash;	/* (c) hash chain of uidinfos */ |
| 118 | 	u_long ui_vmsize;	/* (b) pages of swap reservation by uid */ |
| 119 | 	long	ui_sbsize;		/* (b) socket buffer space consumed */ |
| 120 | 	long	ui_proccnt;		/* (b) number of processes */ |
| 121 | 	long	ui_ptscnt;		/* (b) number of pseudo-terminals */ |
| 122 | 	long	ui_kqcnt;		/* (b) number of kqueues */ |
| 123 | 	long	ui_umtxcnt;		/* (b) number of shared umtxs */ |
| 124 | 	long	ui_pipecnt;		/* (b) consumption of pipe buffers */ |
| 125 | 	long	ui_inotifycnt;		/* (b) number of inotify descriptors */ |
| 126 | 	long	ui_inotifywatchcnt;	/* (b) number of inotify watches */ |
| 127 | 	uid_t	ui_uid;			/* (a) uid */ |
| 128 | 	u_int	ui_ref;			/* (b) reference count */ |
| 129 | #ifdef	RACCT |
| 130 | 	struct racct *ui_racct;		/* (a) resource accounting */ |
| 131 | #endif |
| 132 | }; |
| 133 | |
| 134 | struct proc; |
| 135 | struct rusage_ext; |
| 136 | struct thread; |
| 137 | |
| 138 | void	 addupc_intr(struct thread *td, uintfptr_t pc, u_int ticks); |
| 139 | void	 addupc_task(struct thread *td, uintfptr_t pc, u_int ticks); |
| 140 | void	 calccru(struct proc *p, struct timeval *up, struct timeval *sp); |
| 141 | void	 calcru(struct proc *p, struct timeval *up, struct timeval *sp); |
| 142 | int	 chgkqcnt(struct uidinfo *uip, int diff, rlim_t max); |
| 143 | int	 chgproccnt(struct uidinfo *uip, int diff, rlim_t maxval); |
| 144 | int	 chgsbsize(struct uidinfo *uip, u_int *hiwat, u_int to, |
| 145 | 	 rlim_t maxval); |
| 146 | int	 chgptscnt(struct uidinfo *uip, int diff, rlim_t maxval); |
| 147 | int	 chgumtxcnt(struct uidinfo *uip, int diff, rlim_t maxval); |
| 148 | int	 chgpipecnt(struct uidinfo *uip, int diff, rlim_t max); |
| 149 | int	 chginotifycnt(struct uidinfo *uip, int diff, rlim_t maxval); |
| 150 | int	 chginotifywatchcnt(struct uidinfo *uip, int diff, rlim_t maxval); |
| 151 | int	 kern_proc_setrlimit(struct thread *td, struct proc *p, u_int which, |
| 152 | 	 struct rlimit *limp); |
| 153 | struct plimit |
| 154 | 	*lim_alloc(void); |
| 155 | void	 lim_copy(struct plimit *dst, struct plimit *src); |
| 156 | rlim_t	 lim_cur(struct thread *td, int which); |
| 157 | #define lim_cur(td, which)	({					\ |
| 158 | 	rlim_t _rlim;							\ |
| 159 | 	struct thread *_td = (td);					\ |
| 160 | 	int _which = (which);						\ |
| 161 | 	if (__builtin_constant_p(which) && which != RLIMIT_DATA &&	\ |
| 162 | 	 which != RLIMIT_STACK && which != RLIMIT_VMEM) {		\ |
| 163 | 		_rlim = _td->td_limit->pl_rlimit[_which].rlim_cur;	\ |
| 164 | 	} else {							\ |
| 165 | 		_rlim = lim_cur(_td, _which);				\ |
| 166 | 	}								\ |
| 167 | 	_rlim;								\ |
| 168 | }) |
| 169 | |
| 170 | rlim_t	 lim_cur_proc(struct proc *p, int which); |
| 171 | void	 lim_fork(struct proc *p1, struct proc *p2); |
| 172 | void	 lim_free(struct plimit *limp); |
| 173 | void	 lim_freen(struct plimit *limp, int n); |
| 174 | struct plimit |
| 175 | 	*lim_hold(struct plimit *limp); |
| 176 | struct plimit |
| 177 | 	*lim_cowsync(void); |
| 178 | rlim_t	 lim_max(struct thread *td, int which); |
| 179 | rlim_t	 lim_max_proc(struct proc *p, int which); |
| 180 | void	 lim_rlimit(struct thread *td, int which, struct rlimit *rlp); |
| 181 | void	 lim_rlimit_proc(struct proc *p, int which, struct rlimit *rlp); |
| 182 | void	 ruadd(struct rusage *ru, struct rusage_ext *rux, struct rusage *ru2, |
| 183 | 	 struct rusage_ext *rux2); |
| 184 | void	 rucollect(struct rusage *ru, struct rusage *ru2); |
| 185 | void	 rufetch(struct proc *p, struct rusage *ru); |
| 186 | void	 rufetchcalc(struct proc *p, struct rusage *ru, struct timeval *up, |
| 187 | 	 struct timeval *sp); |
| 188 | void	 rufetchtd(struct thread *td, struct rusage *ru); |
| 189 | void	 ruxagg(struct proc *p, struct thread *td); |
| 190 | void	 ruxagg_locked(struct proc *p, struct thread *td); |
| 191 | struct uidinfo |
| 192 | 	*uifind(uid_t uid); |
| 193 | void	 uifree(struct uidinfo *uip); |
| 194 | void	 uihashinit(void); |
| 195 | void	 uihold(struct uidinfo *uip); |
| 196 | #ifdef	RACCT |
| 197 | void	 ui_racct_foreach(void (*callback)(struct racct *racct, |
| 198 | 	 void *arg2, void *arg3), void (*pre)(void), void (*post)(void), |
| 199 | 	 void *arg2, void *arg3); |
| 200 | #endif |
| 201 | |
| 202 | #endif /* _KERNEL */ |
| 203 | #endif /* !_SYS_RESOURCEVAR_H_ */ |