xref: /freebsd/sys/kern/kern_racct.c (revision a8e0740e852f10f94384ddbc8bc37e460b5ab897)
1097055e2SEdward Tomasz Napierala /*-
2097055e2SEdward Tomasz Napierala  * Copyright (c) 2010 The FreeBSD Foundation
3097055e2SEdward Tomasz Napierala  * All rights reserved.
4097055e2SEdward Tomasz Napierala  *
5097055e2SEdward Tomasz Napierala  * This software was developed by Edward Tomasz Napierala under sponsorship
6097055e2SEdward Tomasz Napierala  * from the FreeBSD Foundation.
7097055e2SEdward Tomasz Napierala  *
8097055e2SEdward Tomasz Napierala  * Redistribution and use in source and binary forms, with or without
9097055e2SEdward Tomasz Napierala  * modification, are permitted provided that the following conditions
10097055e2SEdward Tomasz Napierala  * are met:
11097055e2SEdward Tomasz Napierala  * 1. Redistributions of source code must retain the above copyright
12097055e2SEdward Tomasz Napierala  *    notice, this list of conditions and the following disclaimer.
13097055e2SEdward Tomasz Napierala  * 2. Redistributions in binary form must reproduce the above copyright
14097055e2SEdward Tomasz Napierala  *    notice, this list of conditions and the following disclaimer in the
15097055e2SEdward Tomasz Napierala  *    documentation and/or other materials provided with the distribution.
16097055e2SEdward Tomasz Napierala  *
17097055e2SEdward Tomasz Napierala  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18097055e2SEdward Tomasz Napierala  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19097055e2SEdward Tomasz Napierala  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20097055e2SEdward Tomasz Napierala  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
21097055e2SEdward Tomasz Napierala  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22097055e2SEdward Tomasz Napierala  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23097055e2SEdward Tomasz Napierala  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24097055e2SEdward Tomasz Napierala  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25097055e2SEdward Tomasz Napierala  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26097055e2SEdward Tomasz Napierala  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27097055e2SEdward Tomasz Napierala  * SUCH DAMAGE.
28097055e2SEdward Tomasz Napierala  *
29097055e2SEdward Tomasz Napierala  * $FreeBSD$
30097055e2SEdward Tomasz Napierala  */
31097055e2SEdward Tomasz Napierala 
32097055e2SEdward Tomasz Napierala #include <sys/cdefs.h>
33097055e2SEdward Tomasz Napierala __FBSDID("$FreeBSD$");
34097055e2SEdward Tomasz Napierala 
3536af9869SEdward Tomasz Napierala #include "opt_sched.h"
36097055e2SEdward Tomasz Napierala 
37097055e2SEdward Tomasz Napierala #include <sys/param.h>
380e225211SAndriy Gapon #include <sys/systm.h>
39097055e2SEdward Tomasz Napierala #include <sys/eventhandler.h>
40097055e2SEdward Tomasz Napierala #include <sys/jail.h>
41097055e2SEdward Tomasz Napierala #include <sys/kernel.h>
42097055e2SEdward Tomasz Napierala #include <sys/kthread.h>
43097055e2SEdward Tomasz Napierala #include <sys/lock.h>
44097055e2SEdward Tomasz Napierala #include <sys/loginclass.h>
45097055e2SEdward Tomasz Napierala #include <sys/malloc.h>
46097055e2SEdward Tomasz Napierala #include <sys/mutex.h>
47097055e2SEdward Tomasz Napierala #include <sys/proc.h>
48097055e2SEdward Tomasz Napierala #include <sys/racct.h>
49097055e2SEdward Tomasz Napierala #include <sys/resourcevar.h>
50097055e2SEdward Tomasz Napierala #include <sys/sbuf.h>
51097055e2SEdward Tomasz Napierala #include <sys/sched.h>
52097055e2SEdward Tomasz Napierala #include <sys/sdt.h>
5336af9869SEdward Tomasz Napierala #include <sys/smp.h>
54097055e2SEdward Tomasz Napierala #include <sys/sx.h>
5536af9869SEdward Tomasz Napierala #include <sys/sysctl.h>
56097055e2SEdward Tomasz Napierala #include <sys/sysent.h>
57097055e2SEdward Tomasz Napierala #include <sys/sysproto.h>
58097055e2SEdward Tomasz Napierala #include <sys/umtx.h>
5936af9869SEdward Tomasz Napierala #include <machine/smp.h>
60097055e2SEdward Tomasz Napierala 
61097055e2SEdward Tomasz Napierala #ifdef RCTL
62097055e2SEdward Tomasz Napierala #include <sys/rctl.h>
63097055e2SEdward Tomasz Napierala #endif
64097055e2SEdward Tomasz Napierala 
65097055e2SEdward Tomasz Napierala #ifdef RACCT
66097055e2SEdward Tomasz Napierala 
67097055e2SEdward Tomasz Napierala FEATURE(racct, "Resource Accounting");
68097055e2SEdward Tomasz Napierala 
6936af9869SEdward Tomasz Napierala /*
7036af9869SEdward Tomasz Napierala  * Do not block processes that have their %cpu usage <= pcpu_threshold.
7136af9869SEdward Tomasz Napierala  */
7236af9869SEdward Tomasz Napierala static int pcpu_threshold = 1;
73ba8f0eb8SEdward Tomasz Napierala #ifdef RACCT_DEFAULT_TO_DISABLED
744b5c9cf6SEdward Tomasz Napierala int racct_enable = 0;
754b5c9cf6SEdward Tomasz Napierala #else
764b5c9cf6SEdward Tomasz Napierala int racct_enable = 1;
774b5c9cf6SEdward Tomasz Napierala #endif
7836af9869SEdward Tomasz Napierala 
7936af9869SEdward Tomasz Napierala SYSCTL_NODE(_kern, OID_AUTO, racct, CTLFLAG_RW, 0, "Resource Accounting");
804b5c9cf6SEdward Tomasz Napierala SYSCTL_UINT(_kern_racct, OID_AUTO, enable, CTLFLAG_RDTUN, &racct_enable,
814b5c9cf6SEdward Tomasz Napierala     0, "Enable RACCT/RCTL");
8236af9869SEdward Tomasz Napierala SYSCTL_UINT(_kern_racct, OID_AUTO, pcpu_threshold, CTLFLAG_RW, &pcpu_threshold,
8336af9869SEdward Tomasz Napierala     0, "Processes with higher %cpu usage than this value can be throttled.");
8436af9869SEdward Tomasz Napierala 
8536af9869SEdward Tomasz Napierala /*
8636af9869SEdward Tomasz Napierala  * How many seconds it takes to use the scheduler %cpu calculations.  When a
8736af9869SEdward Tomasz Napierala  * process starts, we compute its %cpu usage by dividing its runtime by the
8836af9869SEdward Tomasz Napierala  * process wall clock time.  After RACCT_PCPU_SECS pass, we use the value
8936af9869SEdward Tomasz Napierala  * provided by the scheduler.
9036af9869SEdward Tomasz Napierala  */
9136af9869SEdward Tomasz Napierala #define RACCT_PCPU_SECS		3
9236af9869SEdward Tomasz Napierala 
93097055e2SEdward Tomasz Napierala static struct mtx racct_lock;
94097055e2SEdward Tomasz Napierala MTX_SYSINIT(racct_lock, &racct_lock, "racct lock", MTX_DEF);
95097055e2SEdward Tomasz Napierala 
96097055e2SEdward Tomasz Napierala static uma_zone_t racct_zone;
97097055e2SEdward Tomasz Napierala 
98097055e2SEdward Tomasz Napierala static void racct_sub_racct(struct racct *dest, const struct racct *src);
99097055e2SEdward Tomasz Napierala static void racct_sub_cred_locked(struct ucred *cred, int resource,
100097055e2SEdward Tomasz Napierala 		uint64_t amount);
101097055e2SEdward Tomasz Napierala static void racct_add_cred_locked(struct ucred *cred, int resource,
102097055e2SEdward Tomasz Napierala 		uint64_t amount);
103097055e2SEdward Tomasz Napierala 
104097055e2SEdward Tomasz Napierala SDT_PROVIDER_DEFINE(racct);
105d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, add, "struct proc *", "int",
106097055e2SEdward Tomasz Napierala     "uint64_t");
107d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, add__failure,
108097055e2SEdward Tomasz Napierala     "struct proc *", "int", "uint64_t");
109d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, add__cred, "struct ucred *",
110097055e2SEdward Tomasz Napierala     "int", "uint64_t");
111d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, add__force, "struct proc *",
112097055e2SEdward Tomasz Napierala     "int", "uint64_t");
113d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, set, "struct proc *", "int",
114097055e2SEdward Tomasz Napierala     "uint64_t");
115d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, set__failure,
116097055e2SEdward Tomasz Napierala     "struct proc *", "int", "uint64_t");
117d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, sub, "struct proc *", "int",
118097055e2SEdward Tomasz Napierala     "uint64_t");
119d9fae5abSAndriy Gapon SDT_PROBE_DEFINE3(racct, kernel, rusage, sub__cred, "struct ucred *",
120097055e2SEdward Tomasz Napierala     "int", "uint64_t");
121d9fae5abSAndriy Gapon SDT_PROBE_DEFINE1(racct, kernel, racct, create, "struct racct *");
122d9fae5abSAndriy Gapon SDT_PROBE_DEFINE1(racct, kernel, racct, destroy, "struct racct *");
123d9fae5abSAndriy Gapon SDT_PROBE_DEFINE2(racct, kernel, racct, join, "struct racct *",
124097055e2SEdward Tomasz Napierala     "struct racct *");
125d9fae5abSAndriy Gapon SDT_PROBE_DEFINE2(racct, kernel, racct, join__failure,
126097055e2SEdward Tomasz Napierala     "struct racct *", "struct racct *");
127d9fae5abSAndriy Gapon SDT_PROBE_DEFINE2(racct, kernel, racct, leave, "struct racct *",
128097055e2SEdward Tomasz Napierala     "struct racct *");
129097055e2SEdward Tomasz Napierala 
130097055e2SEdward Tomasz Napierala int racct_types[] = {
131097055e2SEdward Tomasz Napierala 	[RACCT_CPU] =
13285a2f1b4SEdward Tomasz Napierala 		RACCT_IN_MILLIONS,
133097055e2SEdward Tomasz Napierala 	[RACCT_DATA] =
134097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_INHERITABLE | RACCT_DENIABLE,
135097055e2SEdward Tomasz Napierala 	[RACCT_STACK] =
136097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_INHERITABLE | RACCT_DENIABLE,
137097055e2SEdward Tomasz Napierala 	[RACCT_CORE] =
138097055e2SEdward Tomasz Napierala 		RACCT_DENIABLE,
139097055e2SEdward Tomasz Napierala 	[RACCT_RSS] =
140097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE,
141097055e2SEdward Tomasz Napierala 	[RACCT_MEMLOCK] =
142097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE,
143097055e2SEdward Tomasz Napierala 	[RACCT_NPROC] =
144097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE,
145097055e2SEdward Tomasz Napierala 	[RACCT_NOFILE] =
146097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_INHERITABLE | RACCT_DENIABLE,
147097055e2SEdward Tomasz Napierala 	[RACCT_VMEM] =
148097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_INHERITABLE | RACCT_DENIABLE,
149097055e2SEdward Tomasz Napierala 	[RACCT_NPTS] =
150097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
151097055e2SEdward Tomasz Napierala 	[RACCT_SWAP] =
152097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
153097055e2SEdward Tomasz Napierala 	[RACCT_NTHR] =
154097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE,
155097055e2SEdward Tomasz Napierala 	[RACCT_MSGQQUEUED] =
156097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
157097055e2SEdward Tomasz Napierala 	[RACCT_MSGQSIZE] =
158097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
159097055e2SEdward Tomasz Napierala 	[RACCT_NMSGQ] =
160097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
161097055e2SEdward Tomasz Napierala 	[RACCT_NSEM] =
162097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
163097055e2SEdward Tomasz Napierala 	[RACCT_NSEMOP] =
164097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_INHERITABLE | RACCT_DENIABLE,
165097055e2SEdward Tomasz Napierala 	[RACCT_NSHM] =
166097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
167097055e2SEdward Tomasz Napierala 	[RACCT_SHMSIZE] =
168097055e2SEdward Tomasz Napierala 		RACCT_RECLAIMABLE | RACCT_DENIABLE | RACCT_SLOPPY,
169097055e2SEdward Tomasz Napierala 	[RACCT_WALLCLOCK] =
17036af9869SEdward Tomasz Napierala 		RACCT_IN_MILLIONS,
17136af9869SEdward Tomasz Napierala 	[RACCT_PCTCPU] =
17236af9869SEdward Tomasz Napierala 		RACCT_DECAYING | RACCT_DENIABLE | RACCT_IN_MILLIONS };
17336af9869SEdward Tomasz Napierala 
17436af9869SEdward Tomasz Napierala static const fixpt_t RACCT_DECAY_FACTOR = 0.3 * FSCALE;
17536af9869SEdward Tomasz Napierala 
17636af9869SEdward Tomasz Napierala #ifdef SCHED_4BSD
17736af9869SEdward Tomasz Napierala /*
17836af9869SEdward Tomasz Napierala  * Contains intermediate values for %cpu calculations to avoid using floating
17936af9869SEdward Tomasz Napierala  * point in the kernel.
18036af9869SEdward Tomasz Napierala  * ccpu_exp[k] = FSCALE * (ccpu/FSCALE)^k = FSCALE * exp(-k/20)
18136af9869SEdward Tomasz Napierala  * It is needed only for the 4BSD scheduler, because in ULE, the ccpu equals to
18236af9869SEdward Tomasz Napierala  * zero so the calculations are more straightforward.
18336af9869SEdward Tomasz Napierala  */
18436af9869SEdward Tomasz Napierala fixpt_t ccpu_exp[] = {
18536af9869SEdward Tomasz Napierala 	[0] = FSCALE * 1,
18636af9869SEdward Tomasz Napierala 	[1] = FSCALE * 0.95122942450071400909,
18736af9869SEdward Tomasz Napierala 	[2] = FSCALE * 0.90483741803595957316,
18836af9869SEdward Tomasz Napierala 	[3] = FSCALE * 0.86070797642505780722,
18936af9869SEdward Tomasz Napierala 	[4] = FSCALE * 0.81873075307798185866,
19036af9869SEdward Tomasz Napierala 	[5] = FSCALE * 0.77880078307140486824,
19136af9869SEdward Tomasz Napierala 	[6] = FSCALE * 0.74081822068171786606,
19236af9869SEdward Tomasz Napierala 	[7] = FSCALE * 0.70468808971871343435,
19336af9869SEdward Tomasz Napierala 	[8] = FSCALE * 0.67032004603563930074,
19436af9869SEdward Tomasz Napierala 	[9] = FSCALE * 0.63762815162177329314,
19536af9869SEdward Tomasz Napierala 	[10] = FSCALE * 0.60653065971263342360,
19636af9869SEdward Tomasz Napierala 	[11] = FSCALE * 0.57694981038048669531,
19736af9869SEdward Tomasz Napierala 	[12] = FSCALE * 0.54881163609402643262,
19836af9869SEdward Tomasz Napierala 	[13] = FSCALE * 0.52204577676101604789,
19936af9869SEdward Tomasz Napierala 	[14] = FSCALE * 0.49658530379140951470,
20036af9869SEdward Tomasz Napierala 	[15] = FSCALE * 0.47236655274101470713,
20136af9869SEdward Tomasz Napierala 	[16] = FSCALE * 0.44932896411722159143,
20236af9869SEdward Tomasz Napierala 	[17] = FSCALE * 0.42741493194872666992,
20336af9869SEdward Tomasz Napierala 	[18] = FSCALE * 0.40656965974059911188,
20436af9869SEdward Tomasz Napierala 	[19] = FSCALE * 0.38674102345450120691,
20536af9869SEdward Tomasz Napierala 	[20] = FSCALE * 0.36787944117144232159,
20636af9869SEdward Tomasz Napierala 	[21] = FSCALE * 0.34993774911115535467,
20736af9869SEdward Tomasz Napierala 	[22] = FSCALE * 0.33287108369807955328,
20836af9869SEdward Tomasz Napierala 	[23] = FSCALE * 0.31663676937905321821,
20936af9869SEdward Tomasz Napierala 	[24] = FSCALE * 0.30119421191220209664,
21036af9869SEdward Tomasz Napierala 	[25] = FSCALE * 0.28650479686019010032,
21136af9869SEdward Tomasz Napierala 	[26] = FSCALE * 0.27253179303401260312,
21236af9869SEdward Tomasz Napierala 	[27] = FSCALE * 0.25924026064589150757,
21336af9869SEdward Tomasz Napierala 	[28] = FSCALE * 0.24659696394160647693,
21436af9869SEdward Tomasz Napierala 	[29] = FSCALE * 0.23457028809379765313,
21536af9869SEdward Tomasz Napierala 	[30] = FSCALE * 0.22313016014842982893,
21636af9869SEdward Tomasz Napierala 	[31] = FSCALE * 0.21224797382674305771,
21736af9869SEdward Tomasz Napierala 	[32] = FSCALE * 0.20189651799465540848,
21836af9869SEdward Tomasz Napierala 	[33] = FSCALE * 0.19204990862075411423,
21936af9869SEdward Tomasz Napierala 	[34] = FSCALE * 0.18268352405273465022,
22036af9869SEdward Tomasz Napierala 	[35] = FSCALE * 0.17377394345044512668,
22136af9869SEdward Tomasz Napierala 	[36] = FSCALE * 0.16529888822158653829,
22236af9869SEdward Tomasz Napierala 	[37] = FSCALE * 0.15723716631362761621,
22336af9869SEdward Tomasz Napierala 	[38] = FSCALE * 0.14956861922263505264,
22436af9869SEdward Tomasz Napierala 	[39] = FSCALE * 0.14227407158651357185,
22536af9869SEdward Tomasz Napierala 	[40] = FSCALE * 0.13533528323661269189,
22636af9869SEdward Tomasz Napierala 	[41] = FSCALE * 0.12873490358780421886,
22736af9869SEdward Tomasz Napierala 	[42] = FSCALE * 0.12245642825298191021,
22836af9869SEdward Tomasz Napierala 	[43] = FSCALE * 0.11648415777349695786,
22936af9869SEdward Tomasz Napierala 	[44] = FSCALE * 0.11080315836233388333,
23036af9869SEdward Tomasz Napierala 	[45] = FSCALE * 0.10539922456186433678,
23136af9869SEdward Tomasz Napierala 	[46] = FSCALE * 0.10025884372280373372,
23236af9869SEdward Tomasz Napierala 	[47] = FSCALE * 0.09536916221554961888,
23336af9869SEdward Tomasz Napierala 	[48] = FSCALE * 0.09071795328941250337,
23436af9869SEdward Tomasz Napierala 	[49] = FSCALE * 0.08629358649937051097,
23536af9869SEdward Tomasz Napierala 	[50] = FSCALE * 0.08208499862389879516,
23636af9869SEdward Tomasz Napierala 	[51] = FSCALE * 0.07808166600115315231,
23736af9869SEdward Tomasz Napierala 	[52] = FSCALE * 0.07427357821433388042,
23836af9869SEdward Tomasz Napierala 	[53] = FSCALE * 0.07065121306042958674,
23936af9869SEdward Tomasz Napierala 	[54] = FSCALE * 0.06720551273974976512,
24036af9869SEdward Tomasz Napierala 	[55] = FSCALE * 0.06392786120670757270,
24136af9869SEdward Tomasz Napierala 	[56] = FSCALE * 0.06081006262521796499,
24236af9869SEdward Tomasz Napierala 	[57] = FSCALE * 0.05784432087483846296,
24336af9869SEdward Tomasz Napierala 	[58] = FSCALE * 0.05502322005640722902,
24436af9869SEdward Tomasz Napierala 	[59] = FSCALE * 0.05233970594843239308,
24536af9869SEdward Tomasz Napierala 	[60] = FSCALE * 0.04978706836786394297,
24636af9869SEdward Tomasz Napierala 	[61] = FSCALE * 0.04735892439114092119,
24736af9869SEdward Tomasz Napierala 	[62] = FSCALE * 0.04504920239355780606,
24836af9869SEdward Tomasz Napierala 	[63] = FSCALE * 0.04285212686704017991,
24936af9869SEdward Tomasz Napierala 	[64] = FSCALE * 0.04076220397836621516,
25036af9869SEdward Tomasz Napierala 	[65] = FSCALE * 0.03877420783172200988,
25136af9869SEdward Tomasz Napierala 	[66] = FSCALE * 0.03688316740124000544,
25236af9869SEdward Tomasz Napierala 	[67] = FSCALE * 0.03508435410084502588,
25336af9869SEdward Tomasz Napierala 	[68] = FSCALE * 0.03337326996032607948,
25436af9869SEdward Tomasz Napierala 	[69] = FSCALE * 0.03174563637806794323,
25536af9869SEdward Tomasz Napierala 	[70] = FSCALE * 0.03019738342231850073,
25636af9869SEdward Tomasz Napierala 	[71] = FSCALE * 0.02872463965423942912,
25736af9869SEdward Tomasz Napierala 	[72] = FSCALE * 0.02732372244729256080,
25836af9869SEdward Tomasz Napierala 	[73] = FSCALE * 0.02599112877875534358,
25936af9869SEdward Tomasz Napierala 	[74] = FSCALE * 0.02472352647033939120,
26036af9869SEdward Tomasz Napierala 	[75] = FSCALE * 0.02351774585600910823,
26136af9869SEdward Tomasz Napierala 	[76] = FSCALE * 0.02237077185616559577,
26236af9869SEdward Tomasz Napierala 	[77] = FSCALE * 0.02127973643837716938,
26336af9869SEdward Tomasz Napierala 	[78] = FSCALE * 0.02024191144580438847,
26436af9869SEdward Tomasz Napierala 	[79] = FSCALE * 0.01925470177538692429,
26536af9869SEdward Tomasz Napierala 	[80] = FSCALE * 0.01831563888873418029,
26636af9869SEdward Tomasz Napierala 	[81] = FSCALE * 0.01742237463949351138,
26736af9869SEdward Tomasz Napierala 	[82] = FSCALE * 0.01657267540176124754,
26836af9869SEdward Tomasz Napierala 	[83] = FSCALE * 0.01576441648485449082,
26936af9869SEdward Tomasz Napierala 	[84] = FSCALE * 0.01499557682047770621,
27036af9869SEdward Tomasz Napierala 	[85] = FSCALE * 0.01426423390899925527,
27136af9869SEdward Tomasz Napierala 	[86] = FSCALE * 0.01356855901220093175,
27236af9869SEdward Tomasz Napierala 	[87] = FSCALE * 0.01290681258047986886,
27336af9869SEdward Tomasz Napierala 	[88] = FSCALE * 0.01227733990306844117,
27436af9869SEdward Tomasz Napierala 	[89] = FSCALE * 0.01167856697039544521,
27536af9869SEdward Tomasz Napierala 	[90] = FSCALE * 0.01110899653824230649,
27636af9869SEdward Tomasz Napierala 	[91] = FSCALE * 0.01056720438385265337,
27736af9869SEdward Tomasz Napierala 	[92] = FSCALE * 0.01005183574463358164,
27836af9869SEdward Tomasz Napierala 	[93] = FSCALE * 0.00956160193054350793,
27936af9869SEdward Tomasz Napierala 	[94] = FSCALE * 0.00909527710169581709,
28036af9869SEdward Tomasz Napierala 	[95] = FSCALE * 0.00865169520312063417,
28136af9869SEdward Tomasz Napierala 	[96] = FSCALE * 0.00822974704902002884,
28236af9869SEdward Tomasz Napierala 	[97] = FSCALE * 0.00782837754922577143,
28336af9869SEdward Tomasz Napierala 	[98] = FSCALE * 0.00744658307092434051,
28436af9869SEdward Tomasz Napierala 	[99] = FSCALE * 0.00708340892905212004,
28536af9869SEdward Tomasz Napierala 	[100] = FSCALE * 0.00673794699908546709,
28636af9869SEdward Tomasz Napierala 	[101] = FSCALE * 0.00640933344625638184,
28736af9869SEdward Tomasz Napierala 	[102] = FSCALE * 0.00609674656551563610,
28836af9869SEdward Tomasz Napierala 	[103] = FSCALE * 0.00579940472684214321,
28936af9869SEdward Tomasz Napierala 	[104] = FSCALE * 0.00551656442076077241,
29036af9869SEdward Tomasz Napierala 	[105] = FSCALE * 0.00524751839918138427,
29136af9869SEdward Tomasz Napierala 	[106] = FSCALE * 0.00499159390691021621,
29236af9869SEdward Tomasz Napierala 	[107] = FSCALE * 0.00474815099941147558,
29336af9869SEdward Tomasz Napierala 	[108] = FSCALE * 0.00451658094261266798,
29436af9869SEdward Tomasz Napierala 	[109] = FSCALE * 0.00429630469075234057,
29536af9869SEdward Tomasz Napierala 	[110] = FSCALE * 0.00408677143846406699,
29636af9869SEdward Tomasz Napierala };
29736af9869SEdward Tomasz Napierala #endif
29836af9869SEdward Tomasz Napierala 
29936af9869SEdward Tomasz Napierala #define	CCPU_EXP_MAX	110
30036af9869SEdward Tomasz Napierala 
30136af9869SEdward Tomasz Napierala /*
30236af9869SEdward Tomasz Napierala  * This function is analogical to the getpcpu() function in the ps(1) command.
30336af9869SEdward Tomasz Napierala  * They should both calculate in the same way so that the racct %cpu
30436af9869SEdward Tomasz Napierala  * calculations are consistent with the values showed by the ps(1) tool.
30536af9869SEdward Tomasz Napierala  * The calculations are more complex in the 4BSD scheduler because of the value
30636af9869SEdward Tomasz Napierala  * of the ccpu variable.  In ULE it is defined to be zero which saves us some
30736af9869SEdward Tomasz Napierala  * work.
30836af9869SEdward Tomasz Napierala  */
30936af9869SEdward Tomasz Napierala static uint64_t
31036af9869SEdward Tomasz Napierala racct_getpcpu(struct proc *p, u_int pcpu)
31136af9869SEdward Tomasz Napierala {
31236af9869SEdward Tomasz Napierala 	u_int swtime;
31336af9869SEdward Tomasz Napierala #ifdef SCHED_4BSD
31436af9869SEdward Tomasz Napierala 	fixpt_t pctcpu, pctcpu_next;
31536af9869SEdward Tomasz Napierala #endif
31636af9869SEdward Tomasz Napierala #ifdef SMP
31736af9869SEdward Tomasz Napierala 	struct pcpu *pc;
31836af9869SEdward Tomasz Napierala 	int found;
31936af9869SEdward Tomasz Napierala #endif
32036af9869SEdward Tomasz Napierala 	fixpt_t p_pctcpu;
32136af9869SEdward Tomasz Napierala 	struct thread *td;
32236af9869SEdward Tomasz Napierala 
3234b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
3244b5c9cf6SEdward Tomasz Napierala 
32536af9869SEdward Tomasz Napierala 	/*
32636af9869SEdward Tomasz Napierala 	 * If the process is swapped out, we count its %cpu usage as zero.
32736af9869SEdward Tomasz Napierala 	 * This behaviour is consistent with the userland ps(1) tool.
32836af9869SEdward Tomasz Napierala 	 */
32936af9869SEdward Tomasz Napierala 	if ((p->p_flag & P_INMEM) == 0)
33036af9869SEdward Tomasz Napierala 		return (0);
33136af9869SEdward Tomasz Napierala 	swtime = (ticks - p->p_swtick) / hz;
33236af9869SEdward Tomasz Napierala 
33336af9869SEdward Tomasz Napierala 	/*
33436af9869SEdward Tomasz Napierala 	 * For short-lived processes, the sched_pctcpu() returns small
33536af9869SEdward Tomasz Napierala 	 * values even for cpu intensive processes.  Therefore we use
33636af9869SEdward Tomasz Napierala 	 * our own estimate in this case.
33736af9869SEdward Tomasz Napierala 	 */
33836af9869SEdward Tomasz Napierala 	if (swtime < RACCT_PCPU_SECS)
33936af9869SEdward Tomasz Napierala 		return (pcpu);
34036af9869SEdward Tomasz Napierala 
34136af9869SEdward Tomasz Napierala 	p_pctcpu = 0;
34236af9869SEdward Tomasz Napierala 	FOREACH_THREAD_IN_PROC(p, td) {
34336af9869SEdward Tomasz Napierala 		if (td == PCPU_GET(idlethread))
34436af9869SEdward Tomasz Napierala 			continue;
34536af9869SEdward Tomasz Napierala #ifdef SMP
34636af9869SEdward Tomasz Napierala 		found = 0;
34736af9869SEdward Tomasz Napierala 		STAILQ_FOREACH(pc, &cpuhead, pc_allcpu) {
34836af9869SEdward Tomasz Napierala 			if (td == pc->pc_idlethread) {
34936af9869SEdward Tomasz Napierala 				found = 1;
35036af9869SEdward Tomasz Napierala 				break;
35136af9869SEdward Tomasz Napierala 			}
35236af9869SEdward Tomasz Napierala 		}
35336af9869SEdward Tomasz Napierala 		if (found)
35436af9869SEdward Tomasz Napierala 			continue;
35536af9869SEdward Tomasz Napierala #endif
35636af9869SEdward Tomasz Napierala 		thread_lock(td);
35736af9869SEdward Tomasz Napierala #ifdef SCHED_4BSD
35836af9869SEdward Tomasz Napierala 		pctcpu = sched_pctcpu(td);
35936af9869SEdward Tomasz Napierala 		/* Count also the yet unfinished second. */
36036af9869SEdward Tomasz Napierala 		pctcpu_next = (pctcpu * ccpu_exp[1]) >> FSHIFT;
36136af9869SEdward Tomasz Napierala 		pctcpu_next += sched_pctcpu_delta(td);
36236af9869SEdward Tomasz Napierala 		p_pctcpu += max(pctcpu, pctcpu_next);
36336af9869SEdward Tomasz Napierala #else
36436af9869SEdward Tomasz Napierala 		/*
36536af9869SEdward Tomasz Napierala 		 * In ULE the %cpu statistics are updated on every
36636af9869SEdward Tomasz Napierala 		 * sched_pctcpu() call.  So special calculations to
36736af9869SEdward Tomasz Napierala 		 * account for the latest (unfinished) second are
36836af9869SEdward Tomasz Napierala 		 * not needed.
36936af9869SEdward Tomasz Napierala 		 */
37036af9869SEdward Tomasz Napierala 		p_pctcpu += sched_pctcpu(td);
37136af9869SEdward Tomasz Napierala #endif
37236af9869SEdward Tomasz Napierala 		thread_unlock(td);
37336af9869SEdward Tomasz Napierala 	}
37436af9869SEdward Tomasz Napierala 
37536af9869SEdward Tomasz Napierala #ifdef SCHED_4BSD
37636af9869SEdward Tomasz Napierala 	if (swtime <= CCPU_EXP_MAX)
37736af9869SEdward Tomasz Napierala 		return ((100 * (uint64_t)p_pctcpu * 1000000) /
37836af9869SEdward Tomasz Napierala 		    (FSCALE - ccpu_exp[swtime]));
37936af9869SEdward Tomasz Napierala #endif
38036af9869SEdward Tomasz Napierala 
38136af9869SEdward Tomasz Napierala 	return ((100 * (uint64_t)p_pctcpu * 1000000) / FSCALE);
38236af9869SEdward Tomasz Napierala }
383097055e2SEdward Tomasz Napierala 
384097055e2SEdward Tomasz Napierala static void
385097055e2SEdward Tomasz Napierala racct_add_racct(struct racct *dest, const struct racct *src)
386097055e2SEdward Tomasz Napierala {
387097055e2SEdward Tomasz Napierala 	int i;
388097055e2SEdward Tomasz Napierala 
3894b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
390097055e2SEdward Tomasz Napierala 	mtx_assert(&racct_lock, MA_OWNED);
391097055e2SEdward Tomasz Napierala 
392097055e2SEdward Tomasz Napierala 	/*
393097055e2SEdward Tomasz Napierala 	 * Update resource usage in dest.
394097055e2SEdward Tomasz Napierala 	 */
395097055e2SEdward Tomasz Napierala 	for (i = 0; i <= RACCT_MAX; i++) {
396097055e2SEdward Tomasz Napierala 		KASSERT(dest->r_resources[i] >= 0,
397baf85d0aSEdward Tomasz Napierala 		    ("%s: resource %d propagation meltdown: dest < 0",
398baf85d0aSEdward Tomasz Napierala 		    __func__, i));
399097055e2SEdward Tomasz Napierala 		KASSERT(src->r_resources[i] >= 0,
400baf85d0aSEdward Tomasz Napierala 		    ("%s: resource %d propagation meltdown: src < 0",
401baf85d0aSEdward Tomasz Napierala 		    __func__, i));
402097055e2SEdward Tomasz Napierala 		dest->r_resources[i] += src->r_resources[i];
403097055e2SEdward Tomasz Napierala 	}
404097055e2SEdward Tomasz Napierala }
405097055e2SEdward Tomasz Napierala 
406097055e2SEdward Tomasz Napierala static void
407097055e2SEdward Tomasz Napierala racct_sub_racct(struct racct *dest, const struct racct *src)
408097055e2SEdward Tomasz Napierala {
409097055e2SEdward Tomasz Napierala 	int i;
410097055e2SEdward Tomasz Napierala 
4114b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
412097055e2SEdward Tomasz Napierala 	mtx_assert(&racct_lock, MA_OWNED);
413097055e2SEdward Tomasz Napierala 
414097055e2SEdward Tomasz Napierala 	/*
415097055e2SEdward Tomasz Napierala 	 * Update resource usage in dest.
416097055e2SEdward Tomasz Napierala 	 */
417097055e2SEdward Tomasz Napierala 	for (i = 0; i <= RACCT_MAX; i++) {
41884c9193bSEdward Tomasz Napierala 		if (!RACCT_IS_SLOPPY(i) && !RACCT_IS_DECAYING(i)) {
419097055e2SEdward Tomasz Napierala 			KASSERT(dest->r_resources[i] >= 0,
420baf85d0aSEdward Tomasz Napierala 			    ("%s: resource %d propagation meltdown: dest < 0",
421baf85d0aSEdward Tomasz Napierala 			    __func__, i));
422097055e2SEdward Tomasz Napierala 			KASSERT(src->r_resources[i] >= 0,
423baf85d0aSEdward Tomasz Napierala 			    ("%s: resource %d propagation meltdown: src < 0",
424baf85d0aSEdward Tomasz Napierala 			    __func__, i));
425097055e2SEdward Tomasz Napierala 			KASSERT(src->r_resources[i] <= dest->r_resources[i],
426baf85d0aSEdward Tomasz Napierala 			    ("%s: resource %d propagation meltdown: src > dest",
427baf85d0aSEdward Tomasz Napierala 			    __func__, i));
428097055e2SEdward Tomasz Napierala 		}
42936af9869SEdward Tomasz Napierala 		if (RACCT_CAN_DROP(i)) {
430097055e2SEdward Tomasz Napierala 			dest->r_resources[i] -= src->r_resources[i];
431097055e2SEdward Tomasz Napierala 			if (dest->r_resources[i] < 0) {
43284c9193bSEdward Tomasz Napierala 				KASSERT(RACCT_IS_SLOPPY(i) ||
43384c9193bSEdward Tomasz Napierala 				    RACCT_IS_DECAYING(i),
434baf85d0aSEdward Tomasz Napierala 				    ("%s: resource %d usage < 0", __func__, i));
435097055e2SEdward Tomasz Napierala 				dest->r_resources[i] = 0;
436097055e2SEdward Tomasz Napierala 			}
437097055e2SEdward Tomasz Napierala 		}
438097055e2SEdward Tomasz Napierala 	}
439097055e2SEdward Tomasz Napierala }
440097055e2SEdward Tomasz Napierala 
441097055e2SEdward Tomasz Napierala void
442097055e2SEdward Tomasz Napierala racct_create(struct racct **racctp)
443097055e2SEdward Tomasz Napierala {
444097055e2SEdward Tomasz Napierala 
4454b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
4464b5c9cf6SEdward Tomasz Napierala 		return;
4474b5c9cf6SEdward Tomasz Napierala 
4482f2f522bSAndriy Gapon 	SDT_PROBE1(racct, kernel, racct, create, racctp);
449097055e2SEdward Tomasz Napierala 
450097055e2SEdward Tomasz Napierala 	KASSERT(*racctp == NULL, ("racct already allocated"));
451097055e2SEdward Tomasz Napierala 
452097055e2SEdward Tomasz Napierala 	*racctp = uma_zalloc(racct_zone, M_WAITOK | M_ZERO);
453097055e2SEdward Tomasz Napierala }
454097055e2SEdward Tomasz Napierala 
455097055e2SEdward Tomasz Napierala static void
456097055e2SEdward Tomasz Napierala racct_destroy_locked(struct racct **racctp)
457097055e2SEdward Tomasz Napierala {
458097055e2SEdward Tomasz Napierala 	int i;
459097055e2SEdward Tomasz Napierala 	struct racct *racct;
460097055e2SEdward Tomasz Napierala 
4614b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
4624b5c9cf6SEdward Tomasz Napierala 
4632f2f522bSAndriy Gapon 	SDT_PROBE1(racct, kernel, racct, destroy, racctp);
464097055e2SEdward Tomasz Napierala 
465097055e2SEdward Tomasz Napierala 	mtx_assert(&racct_lock, MA_OWNED);
466097055e2SEdward Tomasz Napierala 	KASSERT(racctp != NULL, ("NULL racctp"));
467097055e2SEdward Tomasz Napierala 	KASSERT(*racctp != NULL, ("NULL racct"));
468097055e2SEdward Tomasz Napierala 
469097055e2SEdward Tomasz Napierala 	racct = *racctp;
470097055e2SEdward Tomasz Napierala 
471097055e2SEdward Tomasz Napierala 	for (i = 0; i <= RACCT_MAX; i++) {
4724fe84775SEdward Tomasz Napierala 		if (RACCT_IS_SLOPPY(i))
473097055e2SEdward Tomasz Napierala 			continue;
4744fe84775SEdward Tomasz Napierala 		if (!RACCT_IS_RECLAIMABLE(i))
475097055e2SEdward Tomasz Napierala 			continue;
476097055e2SEdward Tomasz Napierala 		KASSERT(racct->r_resources[i] == 0,
477097055e2SEdward Tomasz Napierala 		    ("destroying non-empty racct: "
478097055e2SEdward Tomasz Napierala 		    "%ju allocated for resource %d\n",
479097055e2SEdward Tomasz Napierala 		    racct->r_resources[i], i));
480097055e2SEdward Tomasz Napierala 	}
481097055e2SEdward Tomasz Napierala 	uma_zfree(racct_zone, racct);
482097055e2SEdward Tomasz Napierala 	*racctp = NULL;
483097055e2SEdward Tomasz Napierala }
484097055e2SEdward Tomasz Napierala 
485097055e2SEdward Tomasz Napierala void
486097055e2SEdward Tomasz Napierala racct_destroy(struct racct **racct)
487097055e2SEdward Tomasz Napierala {
488097055e2SEdward Tomasz Napierala 
4894b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
4904b5c9cf6SEdward Tomasz Napierala 		return;
4914b5c9cf6SEdward Tomasz Napierala 
492097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
493097055e2SEdward Tomasz Napierala 	racct_destroy_locked(racct);
494097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
495097055e2SEdward Tomasz Napierala }
496097055e2SEdward Tomasz Napierala 
497097055e2SEdward Tomasz Napierala /*
498097055e2SEdward Tomasz Napierala  * Increase consumption of 'resource' by 'amount' for 'racct'
499097055e2SEdward Tomasz Napierala  * and all its parents.  Differently from other cases, 'amount' here
500097055e2SEdward Tomasz Napierala  * may be less than zero.
501097055e2SEdward Tomasz Napierala  */
502097055e2SEdward Tomasz Napierala static void
5033768a5dfSJeremie Le Hen racct_adjust_resource(struct racct *racct, int resource,
504*a8e0740eSEdward Tomasz Napierala     int64_t amount)
505097055e2SEdward Tomasz Napierala {
506097055e2SEdward Tomasz Napierala 
5074b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
508097055e2SEdward Tomasz Napierala 	mtx_assert(&racct_lock, MA_OWNED);
509097055e2SEdward Tomasz Napierala 	KASSERT(racct != NULL, ("NULL racct"));
510097055e2SEdward Tomasz Napierala 
511097055e2SEdward Tomasz Napierala 	racct->r_resources[resource] += amount;
512097055e2SEdward Tomasz Napierala 	if (racct->r_resources[resource] < 0) {
51336af9869SEdward Tomasz Napierala 		KASSERT(RACCT_IS_SLOPPY(resource) || RACCT_IS_DECAYING(resource),
514baf85d0aSEdward Tomasz Napierala 		    ("%s: resource %d usage < 0", __func__, resource));
515097055e2SEdward Tomasz Napierala 		racct->r_resources[resource] = 0;
516097055e2SEdward Tomasz Napierala 	}
51736af9869SEdward Tomasz Napierala 
51836af9869SEdward Tomasz Napierala 	/*
51936af9869SEdward Tomasz Napierala 	 * There are some cases where the racct %cpu resource would grow
52009766dd5SJosh Paetzel 	 * beyond 100% per core.  For example in racct_proc_exit() we add
52109766dd5SJosh Paetzel 	 * the process %cpu usage to the ucred racct containers.  If too
52209766dd5SJosh Paetzel 	 * many processes terminated in a short time span, the ucred %cpu
52309766dd5SJosh Paetzel 	 * resource could grow too much.  Also, the 4BSD scheduler sometimes
52409766dd5SJosh Paetzel 	 * returns for a thread more than 100% cpu usage. So we set a sane
52509766dd5SJosh Paetzel 	 * boundary here to 100% * the maxumum number of CPUs.
52636af9869SEdward Tomasz Napierala 	 */
52736af9869SEdward Tomasz Napierala 	if ((resource == RACCT_PCTCPU) &&
52809766dd5SJosh Paetzel 	    (racct->r_resources[RACCT_PCTCPU] > 100 * 1000000 * (int64_t)MAXCPU))
52909766dd5SJosh Paetzel 		racct->r_resources[RACCT_PCTCPU] = 100 * 1000000 * (int64_t)MAXCPU;
530097055e2SEdward Tomasz Napierala }
531097055e2SEdward Tomasz Napierala 
5322d8696d1SEdward Tomasz Napierala static int
5332d8696d1SEdward Tomasz Napierala racct_add_locked(struct proc *p, int resource, uint64_t amount)
534097055e2SEdward Tomasz Napierala {
535097055e2SEdward Tomasz Napierala #ifdef RCTL
536097055e2SEdward Tomasz Napierala 	int error;
537097055e2SEdward Tomasz Napierala #endif
538097055e2SEdward Tomasz Napierala 
5394b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
5404b5c9cf6SEdward Tomasz Napierala 
5412f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, add, p, resource, amount);
542097055e2SEdward Tomasz Napierala 
543097055e2SEdward Tomasz Napierala 	/*
544097055e2SEdward Tomasz Napierala 	 * We need proc lock to dereference p->p_ucred.
545097055e2SEdward Tomasz Napierala 	 */
546097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
547097055e2SEdward Tomasz Napierala 
548097055e2SEdward Tomasz Napierala #ifdef RCTL
549097055e2SEdward Tomasz Napierala 	error = rctl_enforce(p, resource, amount);
5504fe84775SEdward Tomasz Napierala 	if (error && RACCT_IS_DENIABLE(resource)) {
5512f2f522bSAndriy Gapon 		SDT_PROBE3(racct, kernel, rusage, add__failure, p, resource,
5522f2f522bSAndriy Gapon 		    amount);
553097055e2SEdward Tomasz Napierala 		return (error);
554097055e2SEdward Tomasz Napierala 	}
555097055e2SEdward Tomasz Napierala #endif
5563768a5dfSJeremie Le Hen 	racct_adjust_resource(p->p_racct, resource, amount);
557097055e2SEdward Tomasz Napierala 	racct_add_cred_locked(p->p_ucred, resource, amount);
558097055e2SEdward Tomasz Napierala 
559097055e2SEdward Tomasz Napierala 	return (0);
560097055e2SEdward Tomasz Napierala }
561097055e2SEdward Tomasz Napierala 
5622d8696d1SEdward Tomasz Napierala /*
5632d8696d1SEdward Tomasz Napierala  * Increase allocation of 'resource' by 'amount' for process 'p'.
5642d8696d1SEdward Tomasz Napierala  * Return 0 if it's below limits, or errno, if it's not.
5652d8696d1SEdward Tomasz Napierala  */
5662d8696d1SEdward Tomasz Napierala int
5672d8696d1SEdward Tomasz Napierala racct_add(struct proc *p, int resource, uint64_t amount)
5682d8696d1SEdward Tomasz Napierala {
5692d8696d1SEdward Tomasz Napierala 	int error;
5702d8696d1SEdward Tomasz Napierala 
5714b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
5724b5c9cf6SEdward Tomasz Napierala 		return (0);
5734b5c9cf6SEdward Tomasz Napierala 
5742d8696d1SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
5752d8696d1SEdward Tomasz Napierala 	error = racct_add_locked(p, resource, amount);
5762d8696d1SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
5772d8696d1SEdward Tomasz Napierala 	return (error);
5782d8696d1SEdward Tomasz Napierala }
5792d8696d1SEdward Tomasz Napierala 
580097055e2SEdward Tomasz Napierala static void
581097055e2SEdward Tomasz Napierala racct_add_cred_locked(struct ucred *cred, int resource, uint64_t amount)
582097055e2SEdward Tomasz Napierala {
583097055e2SEdward Tomasz Napierala 	struct prison *pr;
584097055e2SEdward Tomasz Napierala 
5854b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
5864b5c9cf6SEdward Tomasz Napierala 
5872f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, add__cred, cred, resource, amount);
588097055e2SEdward Tomasz Napierala 
5893768a5dfSJeremie Le Hen 	racct_adjust_resource(cred->cr_ruidinfo->ui_racct, resource, amount);
590097055e2SEdward Tomasz Napierala 	for (pr = cred->cr_prison; pr != NULL; pr = pr->pr_parent)
5913768a5dfSJeremie Le Hen 		racct_adjust_resource(pr->pr_prison_racct->prr_racct, resource,
592a7ad07bfSEdward Tomasz Napierala 		    amount);
5933768a5dfSJeremie Le Hen 	racct_adjust_resource(cred->cr_loginclass->lc_racct, resource, amount);
594097055e2SEdward Tomasz Napierala }
595097055e2SEdward Tomasz Napierala 
596097055e2SEdward Tomasz Napierala /*
597097055e2SEdward Tomasz Napierala  * Increase allocation of 'resource' by 'amount' for credential 'cred'.
598097055e2SEdward Tomasz Napierala  * Doesn't check for limits and never fails.
599097055e2SEdward Tomasz Napierala  *
600097055e2SEdward Tomasz Napierala  * XXX: Shouldn't this ever return an error?
601097055e2SEdward Tomasz Napierala  */
602097055e2SEdward Tomasz Napierala void
603097055e2SEdward Tomasz Napierala racct_add_cred(struct ucred *cred, int resource, uint64_t amount)
604097055e2SEdward Tomasz Napierala {
605097055e2SEdward Tomasz Napierala 
6064b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
6074b5c9cf6SEdward Tomasz Napierala 		return;
6084b5c9cf6SEdward Tomasz Napierala 
609097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
610097055e2SEdward Tomasz Napierala 	racct_add_cred_locked(cred, resource, amount);
611097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
612097055e2SEdward Tomasz Napierala }
613097055e2SEdward Tomasz Napierala 
614097055e2SEdward Tomasz Napierala /*
615097055e2SEdward Tomasz Napierala  * Increase allocation of 'resource' by 'amount' for process 'p'.
616097055e2SEdward Tomasz Napierala  * Doesn't check for limits and never fails.
617097055e2SEdward Tomasz Napierala  */
618097055e2SEdward Tomasz Napierala void
619097055e2SEdward Tomasz Napierala racct_add_force(struct proc *p, int resource, uint64_t amount)
620097055e2SEdward Tomasz Napierala {
621097055e2SEdward Tomasz Napierala 
6224b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
6234b5c9cf6SEdward Tomasz Napierala 		return;
6244b5c9cf6SEdward Tomasz Napierala 
6252f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, add__force, p, resource, amount);
626097055e2SEdward Tomasz Napierala 
627097055e2SEdward Tomasz Napierala 	/*
628097055e2SEdward Tomasz Napierala 	 * We need proc lock to dereference p->p_ucred.
629097055e2SEdward Tomasz Napierala 	 */
630097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
631097055e2SEdward Tomasz Napierala 
632097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
6333768a5dfSJeremie Le Hen 	racct_adjust_resource(p->p_racct, resource, amount);
63457e2ebdcSEdward Tomasz Napierala 	racct_add_cred_locked(p->p_ucred, resource, amount);
635097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
636097055e2SEdward Tomasz Napierala }
637097055e2SEdward Tomasz Napierala 
638097055e2SEdward Tomasz Napierala static int
639097055e2SEdward Tomasz Napierala racct_set_locked(struct proc *p, int resource, uint64_t amount)
640097055e2SEdward Tomasz Napierala {
64136af9869SEdward Tomasz Napierala 	int64_t old_amount, decayed_amount;
64236af9869SEdward Tomasz Napierala 	int64_t diff_proc, diff_cred;
643097055e2SEdward Tomasz Napierala #ifdef RCTL
644097055e2SEdward Tomasz Napierala 	int error;
645097055e2SEdward Tomasz Napierala #endif
646097055e2SEdward Tomasz Napierala 
6474b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
6484b5c9cf6SEdward Tomasz Napierala 
6492f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, set, p, resource, amount);
650097055e2SEdward Tomasz Napierala 
651097055e2SEdward Tomasz Napierala 	/*
652097055e2SEdward Tomasz Napierala 	 * We need proc lock to dereference p->p_ucred.
653097055e2SEdward Tomasz Napierala 	 */
654097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
655097055e2SEdward Tomasz Napierala 
65636af9869SEdward Tomasz Napierala 	old_amount = p->p_racct->r_resources[resource];
65736af9869SEdward Tomasz Napierala 	/*
65836af9869SEdward Tomasz Napierala 	 * The diffs may be negative.
65936af9869SEdward Tomasz Napierala 	 */
66036af9869SEdward Tomasz Napierala 	diff_proc = amount - old_amount;
66136af9869SEdward Tomasz Napierala 	if (RACCT_IS_DECAYING(resource)) {
66236af9869SEdward Tomasz Napierala 		/*
66336af9869SEdward Tomasz Napierala 		 * Resources in per-credential racct containers may decay.
66436af9869SEdward Tomasz Napierala 		 * If this is the case, we need to calculate the difference
66536af9869SEdward Tomasz Napierala 		 * between the new amount and the proportional value of the
66636af9869SEdward Tomasz Napierala 		 * old amount that has decayed in the ucred racct containers.
66736af9869SEdward Tomasz Napierala 		 */
66836af9869SEdward Tomasz Napierala 		decayed_amount = old_amount * RACCT_DECAY_FACTOR / FSCALE;
66936af9869SEdward Tomasz Napierala 		diff_cred = amount - decayed_amount;
67036af9869SEdward Tomasz Napierala 	} else
67136af9869SEdward Tomasz Napierala 		diff_cred = diff_proc;
672097055e2SEdward Tomasz Napierala #ifdef notyet
67336af9869SEdward Tomasz Napierala 	KASSERT(diff_proc >= 0 || RACCT_CAN_DROP(resource),
674baf85d0aSEdward Tomasz Napierala 	    ("%s: usage of non-droppable resource %d dropping", __func__,
675097055e2SEdward Tomasz Napierala 	     resource));
676097055e2SEdward Tomasz Napierala #endif
677097055e2SEdward Tomasz Napierala #ifdef RCTL
67836af9869SEdward Tomasz Napierala 	if (diff_proc > 0) {
67936af9869SEdward Tomasz Napierala 		error = rctl_enforce(p, resource, diff_proc);
6804fe84775SEdward Tomasz Napierala 		if (error && RACCT_IS_DENIABLE(resource)) {
6812f2f522bSAndriy Gapon 			SDT_PROBE3(racct, kernel, rusage, set__failure, p,
6822f2f522bSAndriy Gapon 			    resource, amount);
683097055e2SEdward Tomasz Napierala 			return (error);
684097055e2SEdward Tomasz Napierala 		}
685097055e2SEdward Tomasz Napierala 	}
686097055e2SEdward Tomasz Napierala #endif
6873768a5dfSJeremie Le Hen 	racct_adjust_resource(p->p_racct, resource, diff_proc);
68836af9869SEdward Tomasz Napierala 	if (diff_cred > 0)
68936af9869SEdward Tomasz Napierala 		racct_add_cred_locked(p->p_ucred, resource, diff_cred);
69036af9869SEdward Tomasz Napierala 	else if (diff_cred < 0)
69136af9869SEdward Tomasz Napierala 		racct_sub_cred_locked(p->p_ucred, resource, -diff_cred);
692097055e2SEdward Tomasz Napierala 
693097055e2SEdward Tomasz Napierala 	return (0);
694097055e2SEdward Tomasz Napierala }
695097055e2SEdward Tomasz Napierala 
696097055e2SEdward Tomasz Napierala /*
697097055e2SEdward Tomasz Napierala  * Set allocation of 'resource' to 'amount' for process 'p'.
698097055e2SEdward Tomasz Napierala  * Return 0 if it's below limits, or errno, if it's not.
699097055e2SEdward Tomasz Napierala  *
700097055e2SEdward Tomasz Napierala  * Note that decreasing the allocation always returns 0,
701097055e2SEdward Tomasz Napierala  * even if it's above the limit.
702097055e2SEdward Tomasz Napierala  */
703097055e2SEdward Tomasz Napierala int
704097055e2SEdward Tomasz Napierala racct_set(struct proc *p, int resource, uint64_t amount)
705097055e2SEdward Tomasz Napierala {
706097055e2SEdward Tomasz Napierala 	int error;
707097055e2SEdward Tomasz Napierala 
7084b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
7094b5c9cf6SEdward Tomasz Napierala 		return (0);
7104b5c9cf6SEdward Tomasz Napierala 
711097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
712097055e2SEdward Tomasz Napierala 	error = racct_set_locked(p, resource, amount);
713097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
714097055e2SEdward Tomasz Napierala 	return (error);
715097055e2SEdward Tomasz Napierala }
716097055e2SEdward Tomasz Napierala 
71736af9869SEdward Tomasz Napierala static void
71836af9869SEdward Tomasz Napierala racct_set_force_locked(struct proc *p, int resource, uint64_t amount)
719097055e2SEdward Tomasz Napierala {
72036af9869SEdward Tomasz Napierala 	int64_t old_amount, decayed_amount;
72136af9869SEdward Tomasz Napierala 	int64_t diff_proc, diff_cred;
722097055e2SEdward Tomasz Napierala 
7234b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
7244b5c9cf6SEdward Tomasz Napierala 
7252f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, set, p, resource, amount);
726097055e2SEdward Tomasz Napierala 
727097055e2SEdward Tomasz Napierala 	/*
728097055e2SEdward Tomasz Napierala 	 * We need proc lock to dereference p->p_ucred.
729097055e2SEdward Tomasz Napierala 	 */
730097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
731097055e2SEdward Tomasz Napierala 
73236af9869SEdward Tomasz Napierala 	old_amount = p->p_racct->r_resources[resource];
73336af9869SEdward Tomasz Napierala 	/*
73436af9869SEdward Tomasz Napierala 	 * The diffs may be negative.
73536af9869SEdward Tomasz Napierala 	 */
73636af9869SEdward Tomasz Napierala 	diff_proc = amount - old_amount;
73736af9869SEdward Tomasz Napierala 	if (RACCT_IS_DECAYING(resource)) {
73836af9869SEdward Tomasz Napierala 		/*
73936af9869SEdward Tomasz Napierala 		 * Resources in per-credential racct containers may decay.
74036af9869SEdward Tomasz Napierala 		 * If this is the case, we need to calculate the difference
74136af9869SEdward Tomasz Napierala 		 * between the new amount and the proportional value of the
74236af9869SEdward Tomasz Napierala 		 * old amount that has decayed in the ucred racct containers.
74336af9869SEdward Tomasz Napierala 		 */
74436af9869SEdward Tomasz Napierala 		decayed_amount = old_amount * RACCT_DECAY_FACTOR / FSCALE;
74536af9869SEdward Tomasz Napierala 		diff_cred = amount - decayed_amount;
74636af9869SEdward Tomasz Napierala 	} else
74736af9869SEdward Tomasz Napierala 		diff_cred = diff_proc;
74836af9869SEdward Tomasz Napierala 
7493768a5dfSJeremie Le Hen 	racct_adjust_resource(p->p_racct, resource, diff_proc);
75036af9869SEdward Tomasz Napierala 	if (diff_cred > 0)
75136af9869SEdward Tomasz Napierala 		racct_add_cred_locked(p->p_ucred, resource, diff_cred);
75236af9869SEdward Tomasz Napierala 	else if (diff_cred < 0)
75336af9869SEdward Tomasz Napierala 		racct_sub_cred_locked(p->p_ucred, resource, -diff_cred);
75436af9869SEdward Tomasz Napierala }
75536af9869SEdward Tomasz Napierala 
75636af9869SEdward Tomasz Napierala void
75736af9869SEdward Tomasz Napierala racct_set_force(struct proc *p, int resource, uint64_t amount)
75836af9869SEdward Tomasz Napierala {
7594b5c9cf6SEdward Tomasz Napierala 
7604b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
7614b5c9cf6SEdward Tomasz Napierala 		return;
7624b5c9cf6SEdward Tomasz Napierala 
763097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
76436af9869SEdward Tomasz Napierala 	racct_set_force_locked(p, resource, amount);
765097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
766097055e2SEdward Tomasz Napierala }
767097055e2SEdward Tomasz Napierala 
768097055e2SEdward Tomasz Napierala /*
769097055e2SEdward Tomasz Napierala  * Returns amount of 'resource' the process 'p' can keep allocated.
770097055e2SEdward Tomasz Napierala  * Allocating more than that would be denied, unless the resource
771097055e2SEdward Tomasz Napierala  * is marked undeniable.  Amount of already allocated resource does
772097055e2SEdward Tomasz Napierala  * not matter.
773097055e2SEdward Tomasz Napierala  */
774097055e2SEdward Tomasz Napierala uint64_t
775097055e2SEdward Tomasz Napierala racct_get_limit(struct proc *p, int resource)
776097055e2SEdward Tomasz Napierala {
777097055e2SEdward Tomasz Napierala 
7784b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
7794b5c9cf6SEdward Tomasz Napierala 		return (UINT64_MAX);
7804b5c9cf6SEdward Tomasz Napierala 
781097055e2SEdward Tomasz Napierala #ifdef RCTL
782097055e2SEdward Tomasz Napierala 	return (rctl_get_limit(p, resource));
783097055e2SEdward Tomasz Napierala #else
784097055e2SEdward Tomasz Napierala 	return (UINT64_MAX);
785097055e2SEdward Tomasz Napierala #endif
786097055e2SEdward Tomasz Napierala }
787097055e2SEdward Tomasz Napierala 
788097055e2SEdward Tomasz Napierala /*
789097055e2SEdward Tomasz Napierala  * Returns amount of 'resource' the process 'p' can keep allocated.
790097055e2SEdward Tomasz Napierala  * Allocating more than that would be denied, unless the resource
791097055e2SEdward Tomasz Napierala  * is marked undeniable.  Amount of already allocated resource does
792097055e2SEdward Tomasz Napierala  * matter.
793097055e2SEdward Tomasz Napierala  */
794097055e2SEdward Tomasz Napierala uint64_t
795097055e2SEdward Tomasz Napierala racct_get_available(struct proc *p, int resource)
796097055e2SEdward Tomasz Napierala {
797097055e2SEdward Tomasz Napierala 
7984b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
7994b5c9cf6SEdward Tomasz Napierala 		return (UINT64_MAX);
8004b5c9cf6SEdward Tomasz Napierala 
801097055e2SEdward Tomasz Napierala #ifdef RCTL
802097055e2SEdward Tomasz Napierala 	return (rctl_get_available(p, resource));
803097055e2SEdward Tomasz Napierala #else
804097055e2SEdward Tomasz Napierala 	return (UINT64_MAX);
805097055e2SEdward Tomasz Napierala #endif
806097055e2SEdward Tomasz Napierala }
807097055e2SEdward Tomasz Napierala 
808097055e2SEdward Tomasz Napierala /*
80936af9869SEdward Tomasz Napierala  * Returns amount of the %cpu resource that process 'p' can add to its %cpu
81036af9869SEdward Tomasz Napierala  * utilization.  Adding more than that would lead to the process being
81136af9869SEdward Tomasz Napierala  * throttled.
81236af9869SEdward Tomasz Napierala  */
81336af9869SEdward Tomasz Napierala static int64_t
81436af9869SEdward Tomasz Napierala racct_pcpu_available(struct proc *p)
81536af9869SEdward Tomasz Napierala {
81636af9869SEdward Tomasz Napierala 
8174b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
8184b5c9cf6SEdward Tomasz Napierala 
81936af9869SEdward Tomasz Napierala #ifdef RCTL
82036af9869SEdward Tomasz Napierala 	return (rctl_pcpu_available(p));
82136af9869SEdward Tomasz Napierala #else
82236af9869SEdward Tomasz Napierala 	return (INT64_MAX);
82336af9869SEdward Tomasz Napierala #endif
82436af9869SEdward Tomasz Napierala }
82536af9869SEdward Tomasz Napierala 
82636af9869SEdward Tomasz Napierala /*
827097055e2SEdward Tomasz Napierala  * Decrease allocation of 'resource' by 'amount' for process 'p'.
828097055e2SEdward Tomasz Napierala  */
829097055e2SEdward Tomasz Napierala void
830097055e2SEdward Tomasz Napierala racct_sub(struct proc *p, int resource, uint64_t amount)
831097055e2SEdward Tomasz Napierala {
832097055e2SEdward Tomasz Napierala 
8334b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
8344b5c9cf6SEdward Tomasz Napierala 		return;
8354b5c9cf6SEdward Tomasz Napierala 
8362f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, sub, p, resource, amount);
837097055e2SEdward Tomasz Napierala 
838097055e2SEdward Tomasz Napierala 	/*
839097055e2SEdward Tomasz Napierala 	 * We need proc lock to dereference p->p_ucred.
840097055e2SEdward Tomasz Napierala 	 */
841097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
84236af9869SEdward Tomasz Napierala 	KASSERT(RACCT_CAN_DROP(resource),
843baf85d0aSEdward Tomasz Napierala 	    ("%s: called for non-droppable resource %d", __func__, resource));
844097055e2SEdward Tomasz Napierala 
845097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
846097055e2SEdward Tomasz Napierala 	KASSERT(amount <= p->p_racct->r_resources[resource],
847baf85d0aSEdward Tomasz Napierala 	    ("%s: freeing %ju of resource %d, which is more "
848baf85d0aSEdward Tomasz Napierala 	     "than allocated %jd for %s (pid %d)", __func__, amount, resource,
849097055e2SEdward Tomasz Napierala 	    (intmax_t)p->p_racct->r_resources[resource], p->p_comm, p->p_pid));
850097055e2SEdward Tomasz Napierala 
8513768a5dfSJeremie Le Hen 	racct_adjust_resource(p->p_racct, resource, -amount);
852097055e2SEdward Tomasz Napierala 	racct_sub_cred_locked(p->p_ucred, resource, amount);
853097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
854097055e2SEdward Tomasz Napierala }
855097055e2SEdward Tomasz Napierala 
856097055e2SEdward Tomasz Napierala static void
857097055e2SEdward Tomasz Napierala racct_sub_cred_locked(struct ucred *cred, int resource, uint64_t amount)
858097055e2SEdward Tomasz Napierala {
859097055e2SEdward Tomasz Napierala 	struct prison *pr;
860097055e2SEdward Tomasz Napierala 
8614b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
8624b5c9cf6SEdward Tomasz Napierala 
8632f2f522bSAndriy Gapon 	SDT_PROBE3(racct, kernel, rusage, sub__cred, cred, resource, amount);
864097055e2SEdward Tomasz Napierala 
865097055e2SEdward Tomasz Napierala #ifdef notyet
86636af9869SEdward Tomasz Napierala 	KASSERT(RACCT_CAN_DROP(resource),
867baf85d0aSEdward Tomasz Napierala 	    ("%s: called for resource %d which can not drop", __func__,
868097055e2SEdward Tomasz Napierala 	     resource));
869097055e2SEdward Tomasz Napierala #endif
870097055e2SEdward Tomasz Napierala 
8713768a5dfSJeremie Le Hen 	racct_adjust_resource(cred->cr_ruidinfo->ui_racct, resource, -amount);
872097055e2SEdward Tomasz Napierala 	for (pr = cred->cr_prison; pr != NULL; pr = pr->pr_parent)
8733768a5dfSJeremie Le Hen 		racct_adjust_resource(pr->pr_prison_racct->prr_racct, resource,
874a7ad07bfSEdward Tomasz Napierala 		    -amount);
8753768a5dfSJeremie Le Hen 	racct_adjust_resource(cred->cr_loginclass->lc_racct, resource, -amount);
876097055e2SEdward Tomasz Napierala }
877097055e2SEdward Tomasz Napierala 
878097055e2SEdward Tomasz Napierala /*
879097055e2SEdward Tomasz Napierala  * Decrease allocation of 'resource' by 'amount' for credential 'cred'.
880097055e2SEdward Tomasz Napierala  */
881097055e2SEdward Tomasz Napierala void
882097055e2SEdward Tomasz Napierala racct_sub_cred(struct ucred *cred, int resource, uint64_t amount)
883097055e2SEdward Tomasz Napierala {
884097055e2SEdward Tomasz Napierala 
8854b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
8864b5c9cf6SEdward Tomasz Napierala 		return;
8874b5c9cf6SEdward Tomasz Napierala 
888097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
889097055e2SEdward Tomasz Napierala 	racct_sub_cred_locked(cred, resource, amount);
890097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
891097055e2SEdward Tomasz Napierala }
892097055e2SEdward Tomasz Napierala 
893097055e2SEdward Tomasz Napierala /*
894097055e2SEdward Tomasz Napierala  * Inherit resource usage information from the parent process.
895097055e2SEdward Tomasz Napierala  */
896097055e2SEdward Tomasz Napierala int
897097055e2SEdward Tomasz Napierala racct_proc_fork(struct proc *parent, struct proc *child)
898097055e2SEdward Tomasz Napierala {
899097055e2SEdward Tomasz Napierala 	int i, error = 0;
900097055e2SEdward Tomasz Napierala 
9014b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
9024b5c9cf6SEdward Tomasz Napierala 		return (0);
9034b5c9cf6SEdward Tomasz Napierala 
904097055e2SEdward Tomasz Napierala 	/*
905097055e2SEdward Tomasz Napierala 	 * Create racct for the child process.
906097055e2SEdward Tomasz Napierala 	 */
907097055e2SEdward Tomasz Napierala 	racct_create(&child->p_racct);
908097055e2SEdward Tomasz Napierala 
909097055e2SEdward Tomasz Napierala 	PROC_LOCK(parent);
910097055e2SEdward Tomasz Napierala 	PROC_LOCK(child);
911097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
912097055e2SEdward Tomasz Napierala 
913c0c09362SEdward Tomasz Napierala #ifdef RCTL
914c0c09362SEdward Tomasz Napierala 	error = rctl_proc_fork(parent, child);
915c0c09362SEdward Tomasz Napierala 	if (error != 0)
916c0c09362SEdward Tomasz Napierala 		goto out;
917c0c09362SEdward Tomasz Napierala #endif
918c0c09362SEdward Tomasz Napierala 
91936af9869SEdward Tomasz Napierala 	/* Init process cpu time. */
92036af9869SEdward Tomasz Napierala 	child->p_prev_runtime = 0;
92136af9869SEdward Tomasz Napierala 	child->p_throttled = 0;
92236af9869SEdward Tomasz Napierala 
923097055e2SEdward Tomasz Napierala 	/*
924097055e2SEdward Tomasz Napierala 	 * Inherit resource usage.
925097055e2SEdward Tomasz Napierala 	 */
926097055e2SEdward Tomasz Napierala 	for (i = 0; i <= RACCT_MAX; i++) {
927097055e2SEdward Tomasz Napierala 		if (parent->p_racct->r_resources[i] == 0 ||
9284fe84775SEdward Tomasz Napierala 		    !RACCT_IS_INHERITABLE(i))
929097055e2SEdward Tomasz Napierala 			continue;
930097055e2SEdward Tomasz Napierala 
931097055e2SEdward Tomasz Napierala 		error = racct_set_locked(child, i,
932097055e2SEdward Tomasz Napierala 		    parent->p_racct->r_resources[i]);
933ac6fafe6SEdward Tomasz Napierala 		if (error != 0)
934097055e2SEdward Tomasz Napierala 			goto out;
935097055e2SEdward Tomasz Napierala 	}
936097055e2SEdward Tomasz Napierala 
9372d8696d1SEdward Tomasz Napierala 	error = racct_add_locked(child, RACCT_NPROC, 1);
9382d8696d1SEdward Tomasz Napierala 	error += racct_add_locked(child, RACCT_NTHR, 1);
9392d8696d1SEdward Tomasz Napierala 
940097055e2SEdward Tomasz Napierala out:
941097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
942097055e2SEdward Tomasz Napierala 	PROC_UNLOCK(child);
943097055e2SEdward Tomasz Napierala 	PROC_UNLOCK(parent);
944097055e2SEdward Tomasz Napierala 
945ab27d5d8SEdward Tomasz Napierala 	if (error != 0)
946ab27d5d8SEdward Tomasz Napierala 		racct_proc_exit(child);
947ab27d5d8SEdward Tomasz Napierala 
948097055e2SEdward Tomasz Napierala 	return (error);
949097055e2SEdward Tomasz Napierala }
950097055e2SEdward Tomasz Napierala 
95172a401d9SEdward Tomasz Napierala /*
95272a401d9SEdward Tomasz Napierala  * Called at the end of fork1(), to handle rules that require the process
95372a401d9SEdward Tomasz Napierala  * to be fully initialized.
95472a401d9SEdward Tomasz Napierala  */
95572a401d9SEdward Tomasz Napierala void
95672a401d9SEdward Tomasz Napierala racct_proc_fork_done(struct proc *child)
95772a401d9SEdward Tomasz Napierala {
95872a401d9SEdward Tomasz Napierala 
95972a401d9SEdward Tomasz Napierala #ifdef RCTL
9604b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
9614b5c9cf6SEdward Tomasz Napierala 		return;
9624b5c9cf6SEdward Tomasz Napierala 
96372a401d9SEdward Tomasz Napierala 	PROC_LOCK(child);
96472a401d9SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
96572a401d9SEdward Tomasz Napierala 	rctl_enforce(child, RACCT_NPROC, 0);
96672a401d9SEdward Tomasz Napierala 	rctl_enforce(child, RACCT_NTHR, 0);
96772a401d9SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
96872a401d9SEdward Tomasz Napierala 	PROC_UNLOCK(child);
96972a401d9SEdward Tomasz Napierala #endif
97072a401d9SEdward Tomasz Napierala }
97172a401d9SEdward Tomasz Napierala 
972097055e2SEdward Tomasz Napierala void
973097055e2SEdward Tomasz Napierala racct_proc_exit(struct proc *p)
974097055e2SEdward Tomasz Napierala {
9752419d7f9SEdward Tomasz Napierala 	int i;
976097055e2SEdward Tomasz Napierala 	uint64_t runtime;
97736af9869SEdward Tomasz Napierala 	struct timeval wallclock;
97836af9869SEdward Tomasz Napierala 	uint64_t pct_estimate, pct;
979097055e2SEdward Tomasz Napierala 
9804b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
9814b5c9cf6SEdward Tomasz Napierala 		return;
9824b5c9cf6SEdward Tomasz Napierala 
983097055e2SEdward Tomasz Napierala 	PROC_LOCK(p);
984097055e2SEdward Tomasz Napierala 	/*
985097055e2SEdward Tomasz Napierala 	 * We don't need to calculate rux, proc_reap() has already done this.
986097055e2SEdward Tomasz Napierala 	 */
987097055e2SEdward Tomasz Napierala 	runtime = cputick2usec(p->p_rux.rux_runtime);
988097055e2SEdward Tomasz Napierala #ifdef notyet
989097055e2SEdward Tomasz Napierala 	KASSERT(runtime >= p->p_prev_runtime, ("runtime < p_prev_runtime"));
990097055e2SEdward Tomasz Napierala #else
991097055e2SEdward Tomasz Napierala 	if (runtime < p->p_prev_runtime)
992097055e2SEdward Tomasz Napierala 		runtime = p->p_prev_runtime;
993097055e2SEdward Tomasz Napierala #endif
99436af9869SEdward Tomasz Napierala 	microuptime(&wallclock);
99536af9869SEdward Tomasz Napierala 	timevalsub(&wallclock, &p->p_stats->p_start);
99684590fd8SEdward Tomasz Napierala 	if (wallclock.tv_sec > 0 || wallclock.tv_usec > 0) {
99736af9869SEdward Tomasz Napierala 		pct_estimate = (1000000 * runtime * 100) /
99836af9869SEdward Tomasz Napierala 		    ((uint64_t)wallclock.tv_sec * 1000000 +
99936af9869SEdward Tomasz Napierala 		    wallclock.tv_usec);
100084590fd8SEdward Tomasz Napierala 	} else
100184590fd8SEdward Tomasz Napierala 		pct_estimate = 0;
100236af9869SEdward Tomasz Napierala 	pct = racct_getpcpu(p, pct_estimate);
100336af9869SEdward Tomasz Napierala 
10042419d7f9SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
10052419d7f9SEdward Tomasz Napierala 	racct_set_locked(p, RACCT_CPU, runtime);
100636af9869SEdward Tomasz Napierala 	racct_add_cred_locked(p->p_ucred, RACCT_PCTCPU, pct);
1007097055e2SEdward Tomasz Napierala 
10082419d7f9SEdward Tomasz Napierala 	for (i = 0; i <= RACCT_MAX; i++) {
10092419d7f9SEdward Tomasz Napierala 		if (p->p_racct->r_resources[i] == 0)
10102419d7f9SEdward Tomasz Napierala 			continue;
10112419d7f9SEdward Tomasz Napierala 	    	if (!RACCT_IS_RECLAIMABLE(i))
10122419d7f9SEdward Tomasz Napierala 			continue;
10132419d7f9SEdward Tomasz Napierala 		racct_set_locked(p, i, 0);
10142419d7f9SEdward Tomasz Napierala 	}
10152419d7f9SEdward Tomasz Napierala 
10162419d7f9SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
1017097055e2SEdward Tomasz Napierala 	PROC_UNLOCK(p);
1018097055e2SEdward Tomasz Napierala 
1019097055e2SEdward Tomasz Napierala #ifdef RCTL
1020097055e2SEdward Tomasz Napierala 	rctl_racct_release(p->p_racct);
1021097055e2SEdward Tomasz Napierala #endif
1022097055e2SEdward Tomasz Napierala 	racct_destroy(&p->p_racct);
1023097055e2SEdward Tomasz Napierala }
1024097055e2SEdward Tomasz Napierala 
1025097055e2SEdward Tomasz Napierala /*
1026097055e2SEdward Tomasz Napierala  * Called after credentials change, to move resource utilisation
1027097055e2SEdward Tomasz Napierala  * between raccts.
1028097055e2SEdward Tomasz Napierala  */
1029097055e2SEdward Tomasz Napierala void
1030097055e2SEdward Tomasz Napierala racct_proc_ucred_changed(struct proc *p, struct ucred *oldcred,
1031097055e2SEdward Tomasz Napierala     struct ucred *newcred)
1032097055e2SEdward Tomasz Napierala {
1033097055e2SEdward Tomasz Napierala 	struct uidinfo *olduip, *newuip;
1034097055e2SEdward Tomasz Napierala 	struct loginclass *oldlc, *newlc;
1035097055e2SEdward Tomasz Napierala 	struct prison *oldpr, *newpr, *pr;
1036097055e2SEdward Tomasz Napierala 
10374b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
10384b5c9cf6SEdward Tomasz Napierala 		return;
10394b5c9cf6SEdward Tomasz Napierala 
1040097055e2SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_NOTOWNED);
1041097055e2SEdward Tomasz Napierala 
1042097055e2SEdward Tomasz Napierala 	newuip = newcred->cr_ruidinfo;
1043097055e2SEdward Tomasz Napierala 	olduip = oldcred->cr_ruidinfo;
1044097055e2SEdward Tomasz Napierala 	newlc = newcred->cr_loginclass;
1045097055e2SEdward Tomasz Napierala 	oldlc = oldcred->cr_loginclass;
1046097055e2SEdward Tomasz Napierala 	newpr = newcred->cr_prison;
1047097055e2SEdward Tomasz Napierala 	oldpr = oldcred->cr_prison;
1048097055e2SEdward Tomasz Napierala 
1049097055e2SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
1050097055e2SEdward Tomasz Napierala 	if (newuip != olduip) {
1051097055e2SEdward Tomasz Napierala 		racct_sub_racct(olduip->ui_racct, p->p_racct);
1052097055e2SEdward Tomasz Napierala 		racct_add_racct(newuip->ui_racct, p->p_racct);
1053097055e2SEdward Tomasz Napierala 	}
1054097055e2SEdward Tomasz Napierala 	if (newlc != oldlc) {
1055097055e2SEdward Tomasz Napierala 		racct_sub_racct(oldlc->lc_racct, p->p_racct);
1056097055e2SEdward Tomasz Napierala 		racct_add_racct(newlc->lc_racct, p->p_racct);
1057097055e2SEdward Tomasz Napierala 	}
1058097055e2SEdward Tomasz Napierala 	if (newpr != oldpr) {
1059097055e2SEdward Tomasz Napierala 		for (pr = oldpr; pr != NULL; pr = pr->pr_parent)
1060a7ad07bfSEdward Tomasz Napierala 			racct_sub_racct(pr->pr_prison_racct->prr_racct,
1061a7ad07bfSEdward Tomasz Napierala 			    p->p_racct);
1062097055e2SEdward Tomasz Napierala 		for (pr = newpr; pr != NULL; pr = pr->pr_parent)
1063a7ad07bfSEdward Tomasz Napierala 			racct_add_racct(pr->pr_prison_racct->prr_racct,
1064a7ad07bfSEdward Tomasz Napierala 			    p->p_racct);
1065097055e2SEdward Tomasz Napierala 	}
1066097055e2SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
1067097055e2SEdward Tomasz Napierala 
1068097055e2SEdward Tomasz Napierala #ifdef RCTL
1069097055e2SEdward Tomasz Napierala 	rctl_proc_ucred_changed(p, newcred);
1070097055e2SEdward Tomasz Napierala #endif
1071097055e2SEdward Tomasz Napierala }
1072097055e2SEdward Tomasz Napierala 
1073c34bbd2aSEdward Tomasz Napierala void
1074c34bbd2aSEdward Tomasz Napierala racct_move(struct racct *dest, struct racct *src)
1075c34bbd2aSEdward Tomasz Napierala {
1076c34bbd2aSEdward Tomasz Napierala 
10774b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
10784b5c9cf6SEdward Tomasz Napierala 
1079c34bbd2aSEdward Tomasz Napierala 	mtx_lock(&racct_lock);
1080c34bbd2aSEdward Tomasz Napierala 
1081c34bbd2aSEdward Tomasz Napierala 	racct_add_racct(dest, src);
1082c34bbd2aSEdward Tomasz Napierala 	racct_sub_racct(src, src);
1083c34bbd2aSEdward Tomasz Napierala 
1084c34bbd2aSEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
1085c34bbd2aSEdward Tomasz Napierala }
1086c34bbd2aSEdward Tomasz Napierala 
1087097055e2SEdward Tomasz Napierala static void
108836af9869SEdward Tomasz Napierala racct_proc_throttle(struct proc *p)
108936af9869SEdward Tomasz Napierala {
109036af9869SEdward Tomasz Napierala 	struct thread *td;
109136af9869SEdward Tomasz Napierala #ifdef SMP
109236af9869SEdward Tomasz Napierala 	int cpuid;
109336af9869SEdward Tomasz Napierala #endif
109436af9869SEdward Tomasz Napierala 
10954b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
109636af9869SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
109736af9869SEdward Tomasz Napierala 
109836af9869SEdward Tomasz Napierala 	/*
109936af9869SEdward Tomasz Napierala 	 * Do not block kernel processes.  Also do not block processes with
110036af9869SEdward Tomasz Napierala 	 * low %cpu utilization to improve interactivity.
110136af9869SEdward Tomasz Napierala 	 */
110236af9869SEdward Tomasz Napierala 	if (((p->p_flag & (P_SYSTEM | P_KTHREAD)) != 0) ||
110336af9869SEdward Tomasz Napierala 	    (p->p_racct->r_resources[RACCT_PCTCPU] <= pcpu_threshold))
110436af9869SEdward Tomasz Napierala 		return;
110536af9869SEdward Tomasz Napierala 	p->p_throttled = 1;
110636af9869SEdward Tomasz Napierala 
110736af9869SEdward Tomasz Napierala 	FOREACH_THREAD_IN_PROC(p, td) {
110816befafdSEdward Tomasz Napierala 		thread_lock(td);
110936af9869SEdward Tomasz Napierala 		switch (td->td_state) {
111036af9869SEdward Tomasz Napierala 		case TDS_RUNQ:
111136af9869SEdward Tomasz Napierala 			/*
111236af9869SEdward Tomasz Napierala 			 * If the thread is on the scheduler run-queue, we can
111336af9869SEdward Tomasz Napierala 			 * not just remove it from there.  So we set the flag
111436af9869SEdward Tomasz Napierala 			 * TDF_NEEDRESCHED for the thread, so that once it is
111536af9869SEdward Tomasz Napierala 			 * running, it is taken off the cpu as soon as possible.
111636af9869SEdward Tomasz Napierala 			 */
111736af9869SEdward Tomasz Napierala 			td->td_flags |= TDF_NEEDRESCHED;
111836af9869SEdward Tomasz Napierala 			break;
111936af9869SEdward Tomasz Napierala 		case TDS_RUNNING:
112036af9869SEdward Tomasz Napierala 			/*
112136af9869SEdward Tomasz Napierala 			 * If the thread is running, we request a context
112236af9869SEdward Tomasz Napierala 			 * switch for it by setting the TDF_NEEDRESCHED flag.
112336af9869SEdward Tomasz Napierala 			 */
112436af9869SEdward Tomasz Napierala 			td->td_flags |= TDF_NEEDRESCHED;
112536af9869SEdward Tomasz Napierala #ifdef SMP
112636af9869SEdward Tomasz Napierala 			cpuid = td->td_oncpu;
112736af9869SEdward Tomasz Napierala 			if ((cpuid != NOCPU) && (td != curthread))
112836af9869SEdward Tomasz Napierala 				ipi_cpu(cpuid, IPI_AST);
112936af9869SEdward Tomasz Napierala #endif
113036af9869SEdward Tomasz Napierala 			break;
113136af9869SEdward Tomasz Napierala 		default:
113236af9869SEdward Tomasz Napierala 			break;
113336af9869SEdward Tomasz Napierala 		}
113416befafdSEdward Tomasz Napierala 		thread_unlock(td);
113536af9869SEdward Tomasz Napierala 	}
113636af9869SEdward Tomasz Napierala }
113736af9869SEdward Tomasz Napierala 
113836af9869SEdward Tomasz Napierala static void
113936af9869SEdward Tomasz Napierala racct_proc_wakeup(struct proc *p)
114036af9869SEdward Tomasz Napierala {
11414b5c9cf6SEdward Tomasz Napierala 
11424b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
11434b5c9cf6SEdward Tomasz Napierala 
114436af9869SEdward Tomasz Napierala 	PROC_LOCK_ASSERT(p, MA_OWNED);
114536af9869SEdward Tomasz Napierala 
114636af9869SEdward Tomasz Napierala 	if (p->p_throttled) {
114736af9869SEdward Tomasz Napierala 		p->p_throttled = 0;
114836af9869SEdward Tomasz Napierala 		wakeup(p->p_racct);
114936af9869SEdward Tomasz Napierala 	}
115036af9869SEdward Tomasz Napierala }
115136af9869SEdward Tomasz Napierala 
115236af9869SEdward Tomasz Napierala static void
115336af9869SEdward Tomasz Napierala racct_decay_resource(struct racct *racct, void * res, void* dummy)
115436af9869SEdward Tomasz Napierala {
115536af9869SEdward Tomasz Napierala 	int resource;
115636af9869SEdward Tomasz Napierala 	int64_t r_old, r_new;
115736af9869SEdward Tomasz Napierala 
11584b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
115915db3c07SEdward Tomasz Napierala 	mtx_assert(&racct_lock, MA_OWNED);
11604b5c9cf6SEdward Tomasz Napierala 
116136af9869SEdward Tomasz Napierala 	resource = *(int *)res;
116236af9869SEdward Tomasz Napierala 	r_old = racct->r_resources[resource];
116336af9869SEdward Tomasz Napierala 
116436af9869SEdward Tomasz Napierala 	/* If there is nothing to decay, just exit. */
116536af9869SEdward Tomasz Napierala 	if (r_old <= 0)
116636af9869SEdward Tomasz Napierala 		return;
116736af9869SEdward Tomasz Napierala 
116836af9869SEdward Tomasz Napierala 	r_new = r_old * RACCT_DECAY_FACTOR / FSCALE;
116936af9869SEdward Tomasz Napierala 	racct->r_resources[resource] = r_new;
117015db3c07SEdward Tomasz Napierala }
117115db3c07SEdward Tomasz Napierala 
117215db3c07SEdward Tomasz Napierala static void
117315db3c07SEdward Tomasz Napierala racct_decay_pre(void)
117415db3c07SEdward Tomasz Napierala {
117515db3c07SEdward Tomasz Napierala 
117615db3c07SEdward Tomasz Napierala 	mtx_lock(&racct_lock);
117715db3c07SEdward Tomasz Napierala }
117815db3c07SEdward Tomasz Napierala 
117915db3c07SEdward Tomasz Napierala static void
118015db3c07SEdward Tomasz Napierala racct_decay_post(void)
118115db3c07SEdward Tomasz Napierala {
118215db3c07SEdward Tomasz Napierala 
118336af9869SEdward Tomasz Napierala 	mtx_unlock(&racct_lock);
118436af9869SEdward Tomasz Napierala }
118536af9869SEdward Tomasz Napierala 
118636af9869SEdward Tomasz Napierala static void
118736af9869SEdward Tomasz Napierala racct_decay(int resource)
118836af9869SEdward Tomasz Napierala {
11894b5c9cf6SEdward Tomasz Napierala 
11904b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
11914b5c9cf6SEdward Tomasz Napierala 
119215db3c07SEdward Tomasz Napierala 	ui_racct_foreach(racct_decay_resource, racct_decay_pre,
119315db3c07SEdward Tomasz Napierala 	    racct_decay_post, &resource, NULL);
119415db3c07SEdward Tomasz Napierala 	loginclass_racct_foreach(racct_decay_resource, racct_decay_pre,
119515db3c07SEdward Tomasz Napierala 	    racct_decay_post, &resource, NULL);
119615db3c07SEdward Tomasz Napierala 	prison_racct_foreach(racct_decay_resource, racct_decay_pre,
119715db3c07SEdward Tomasz Napierala 	    racct_decay_post, &resource, NULL);
119836af9869SEdward Tomasz Napierala }
119936af9869SEdward Tomasz Napierala 
120036af9869SEdward Tomasz Napierala static void
1201097055e2SEdward Tomasz Napierala racctd(void)
1202097055e2SEdward Tomasz Napierala {
1203097055e2SEdward Tomasz Napierala 	struct thread *td;
1204097055e2SEdward Tomasz Napierala 	struct proc *p;
1205097055e2SEdward Tomasz Napierala 	struct timeval wallclock;
1206097055e2SEdward Tomasz Napierala 	uint64_t runtime;
120736af9869SEdward Tomasz Napierala 	uint64_t pct, pct_estimate;
1208097055e2SEdward Tomasz Napierala 
12094b5c9cf6SEdward Tomasz Napierala 	ASSERT_RACCT_ENABLED();
12104b5c9cf6SEdward Tomasz Napierala 
1211097055e2SEdward Tomasz Napierala 	for (;;) {
121236af9869SEdward Tomasz Napierala 		racct_decay(RACCT_PCTCPU);
121336af9869SEdward Tomasz Napierala 
1214097055e2SEdward Tomasz Napierala 		sx_slock(&allproc_lock);
1215097055e2SEdward Tomasz Napierala 
121636af9869SEdward Tomasz Napierala 		LIST_FOREACH(p, &zombproc, p_list) {
121736af9869SEdward Tomasz Napierala 			PROC_LOCK(p);
121836af9869SEdward Tomasz Napierala 			racct_set(p, RACCT_PCTCPU, 0);
121936af9869SEdward Tomasz Napierala 			PROC_UNLOCK(p);
122036af9869SEdward Tomasz Napierala 		}
122136af9869SEdward Tomasz Napierala 
1222097055e2SEdward Tomasz Napierala 		FOREACH_PROC_IN_SYSTEM(p) {
122336af9869SEdward Tomasz Napierala 			PROC_LOCK(p);
122436af9869SEdward Tomasz Napierala 			if (p->p_state != PRS_NORMAL) {
122536af9869SEdward Tomasz Napierala 				PROC_UNLOCK(p);
1226097055e2SEdward Tomasz Napierala 				continue;
122736af9869SEdward Tomasz Napierala 			}
1228097055e2SEdward Tomasz Napierala 
1229097055e2SEdward Tomasz Napierala 			microuptime(&wallclock);
1230097055e2SEdward Tomasz Napierala 			timevalsub(&wallclock, &p->p_stats->p_start);
12315c7bebf9SKonstantin Belousov 			PROC_STATLOCK(p);
12320a53cd57SEdward Tomasz Napierala 			FOREACH_THREAD_IN_PROC(p, td)
1233097055e2SEdward Tomasz Napierala 				ruxagg(p, td);
1234097055e2SEdward Tomasz Napierala 			runtime = cputick2usec(p->p_rux.rux_runtime);
12355c7bebf9SKonstantin Belousov 			PROC_STATUNLOCK(p);
1236097055e2SEdward Tomasz Napierala #ifdef notyet
1237097055e2SEdward Tomasz Napierala 			KASSERT(runtime >= p->p_prev_runtime,
1238097055e2SEdward Tomasz Napierala 			    ("runtime < p_prev_runtime"));
1239097055e2SEdward Tomasz Napierala #else
1240097055e2SEdward Tomasz Napierala 			if (runtime < p->p_prev_runtime)
1241097055e2SEdward Tomasz Napierala 				runtime = p->p_prev_runtime;
1242097055e2SEdward Tomasz Napierala #endif
1243097055e2SEdward Tomasz Napierala 			p->p_prev_runtime = runtime;
124484590fd8SEdward Tomasz Napierala 			if (wallclock.tv_sec > 0 || wallclock.tv_usec > 0) {
124536af9869SEdward Tomasz Napierala 				pct_estimate = (1000000 * runtime * 100) /
124636af9869SEdward Tomasz Napierala 				    ((uint64_t)wallclock.tv_sec * 1000000 +
124736af9869SEdward Tomasz Napierala 				    wallclock.tv_usec);
124884590fd8SEdward Tomasz Napierala 			} else
124984590fd8SEdward Tomasz Napierala 				pct_estimate = 0;
125036af9869SEdward Tomasz Napierala 			pct = racct_getpcpu(p, pct_estimate);
1251097055e2SEdward Tomasz Napierala 			mtx_lock(&racct_lock);
125236af9869SEdward Tomasz Napierala 			racct_set_force_locked(p, RACCT_PCTCPU, pct);
1253097055e2SEdward Tomasz Napierala 			racct_set_locked(p, RACCT_CPU, runtime);
1254097055e2SEdward Tomasz Napierala 			racct_set_locked(p, RACCT_WALLCLOCK,
125559f513cdSJaakko Heinonen 			    (uint64_t)wallclock.tv_sec * 1000000 +
125659f513cdSJaakko Heinonen 			    wallclock.tv_usec);
1257097055e2SEdward Tomasz Napierala 			mtx_unlock(&racct_lock);
1258097055e2SEdward Tomasz Napierala 			PROC_UNLOCK(p);
1259097055e2SEdward Tomasz Napierala 		}
126036af9869SEdward Tomasz Napierala 
126136af9869SEdward Tomasz Napierala 		/*
126236af9869SEdward Tomasz Napierala 		 * To ensure that processes are throttled in a fair way, we need
126336af9869SEdward Tomasz Napierala 		 * to iterate over all processes again and check the limits
126436af9869SEdward Tomasz Napierala 		 * for %cpu resource only after ucred racct containers have been
126536af9869SEdward Tomasz Napierala 		 * properly filled.
126636af9869SEdward Tomasz Napierala 		 */
126736af9869SEdward Tomasz Napierala 		FOREACH_PROC_IN_SYSTEM(p) {
126836af9869SEdward Tomasz Napierala 			PROC_LOCK(p);
126936af9869SEdward Tomasz Napierala 			if (p->p_state != PRS_NORMAL) {
127036af9869SEdward Tomasz Napierala 				PROC_UNLOCK(p);
127136af9869SEdward Tomasz Napierala 				continue;
127236af9869SEdward Tomasz Napierala 			}
127336af9869SEdward Tomasz Napierala 
127436af9869SEdward Tomasz Napierala 			if (racct_pcpu_available(p) <= 0)
127536af9869SEdward Tomasz Napierala 				racct_proc_throttle(p);
127636af9869SEdward Tomasz Napierala 			else if (p->p_throttled)
127736af9869SEdward Tomasz Napierala 				racct_proc_wakeup(p);
127836af9869SEdward Tomasz Napierala 			PROC_UNLOCK(p);
127936af9869SEdward Tomasz Napierala 		}
1280097055e2SEdward Tomasz Napierala 		sx_sunlock(&allproc_lock);
1281097055e2SEdward Tomasz Napierala 		pause("-", hz);
1282097055e2SEdward Tomasz Napierala 	}
1283097055e2SEdward Tomasz Napierala }
1284097055e2SEdward Tomasz Napierala 
1285097055e2SEdward Tomasz Napierala static struct kproc_desc racctd_kp = {
1286097055e2SEdward Tomasz Napierala 	"racctd",
1287097055e2SEdward Tomasz Napierala 	racctd,
1288097055e2SEdward Tomasz Napierala 	NULL
1289097055e2SEdward Tomasz Napierala };
12904b5c9cf6SEdward Tomasz Napierala 
12914b5c9cf6SEdward Tomasz Napierala static void
12924b5c9cf6SEdward Tomasz Napierala racctd_init(void)
12934b5c9cf6SEdward Tomasz Napierala {
12944b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
12954b5c9cf6SEdward Tomasz Napierala 		return;
12964b5c9cf6SEdward Tomasz Napierala 
12974b5c9cf6SEdward Tomasz Napierala 	kproc_start(&racctd_kp);
12984b5c9cf6SEdward Tomasz Napierala }
12994b5c9cf6SEdward Tomasz Napierala SYSINIT(racctd, SI_SUB_RACCTD, SI_ORDER_FIRST, racctd_init, NULL);
1300097055e2SEdward Tomasz Napierala 
1301097055e2SEdward Tomasz Napierala static void
1302097055e2SEdward Tomasz Napierala racct_init(void)
1303097055e2SEdward Tomasz Napierala {
13044b5c9cf6SEdward Tomasz Napierala 	if (!racct_enable)
13054b5c9cf6SEdward Tomasz Napierala 		return;
1306097055e2SEdward Tomasz Napierala 
1307097055e2SEdward Tomasz Napierala 	racct_zone = uma_zcreate("racct", sizeof(struct racct),
1308097055e2SEdward Tomasz Napierala 	    NULL, NULL, NULL, NULL, UMA_ALIGN_PTR, UMA_ZONE_NOFREE);
1309097055e2SEdward Tomasz Napierala 	/*
1310097055e2SEdward Tomasz Napierala 	 * XXX: Move this somewhere.
1311097055e2SEdward Tomasz Napierala 	 */
1312a7ad07bfSEdward Tomasz Napierala 	prison0.pr_prison_racct = prison_racct_find("0");
1313097055e2SEdward Tomasz Napierala }
1314097055e2SEdward Tomasz Napierala SYSINIT(racct, SI_SUB_RACCT, SI_ORDER_FIRST, racct_init, NULL);
1315097055e2SEdward Tomasz Napierala 
1316097055e2SEdward Tomasz Napierala #endif /* !RACCT */
1317