1 /*-
2  * Copyright (c) 1986, 1989, 1991, 1993
3  *	The Regents of the University of California.  All rights reserved.
4  * (c) UNIX System Laboratories, Inc.
5  * All or some portions of this file are derived from material licensed
6  * to the University of California by American Telephone and Telegraph
7  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
8  * the permission of UNIX System Laboratories, Inc.
9  *
10  * Redistribution and use in source and binary forms, with or without
11  * modification, are permitted provided that the following conditions
12  * are met:
13  * 1. Redistributions of source code must retain the above copyright
14  *    notice, this list of conditions and the following disclaimer.
15  * 2. Redistributions in binary form must reproduce the above copyright
16  *    notice, this list of conditions and the following disclaimer in the
17  *    documentation and/or other materials provided with the distribution.
18  * 4. Neither the name of the University nor the names of its contributors
19  *    may be used to endorse or promote products derived from this software
20  *    without specific prior written permission.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32  * SUCH DAMAGE.
33  *
34  *	@(#)proc.h	8.15 (Berkeley) 5/19/95
35  * $FreeBSD: stable/10/sys/sys/proc.h 318743 2017-05-23 12:40:50Z badger $
36  */
37 
38 #ifndef _SYS_PROC_H_
39 #define	_SYS_PROC_H_
40 
41 #include <sys/callout.h>		/* For struct callout. */
42 #include <sys/event.h>			/* For struct klist. */
43 #include <sys/condvar.h>
44 #ifndef _KERNEL
45 #include <sys/filedesc.h>
46 #endif
47 #include <sys/queue.h>
48 #include <sys/_lock.h>
49 #include <sys/lock_profile.h>
50 #include <sys/_mutex.h>
51 #include <sys/osd.h>
52 #include <sys/priority.h>
53 #include <sys/rtprio.h>			/* XXX. */
54 #include <sys/runq.h>
55 #include <sys/resource.h>
56 #include <sys/sigio.h>
57 #include <sys/signal.h>
58 #include <sys/signalvar.h>
59 #ifndef _KERNEL
60 #include <sys/time.h>			/* For structs itimerval, timeval. */
61 #else
62 #include <sys/pcpu.h>
63 #endif
64 #include <sys/ucontext.h>
65 #include <sys/ucred.h>
66 #include <machine/proc.h>		/* Machine-dependent proc substruct. */
67 
68 /*
69  * One structure allocated per session.
70  *
71  * List of locks
72  * (m)		locked by s_mtx mtx
73  * (e)		locked by proctree_lock sx
74  * (c)		const until freeing
75  */
76 struct session {
77 	u_int		s_count;	/* Ref cnt; pgrps in session - atomic. */
78 	struct proc	*s_leader;	/* (m + e) Session leader. */
79 	struct vnode	*s_ttyvp;	/* (m) Vnode of controlling tty. */
80 	struct cdev_priv *s_ttydp;	/* (m) Device of controlling tty.  */
81 	struct tty	*s_ttyp;	/* (e) Controlling tty. */
82 	pid_t		s_sid;		/* (c) Session ID. */
83 					/* (m) Setlogin() name: */
84 	char		s_login[roundup(MAXLOGNAME, sizeof(long))];
85 	struct mtx	s_mtx;		/* Mutex to protect members. */
86 };
87 
88 /*
89  * One structure allocated per process group.
90  *
91  * List of locks
92  * (m)		locked by pg_mtx mtx
93  * (e)		locked by proctree_lock sx
94  * (c)		const until freeing
95  */
96 struct pgrp {
97 	LIST_ENTRY(pgrp) pg_hash;	/* (e) Hash chain. */
98 	LIST_HEAD(, proc) pg_members;	/* (m + e) Pointer to pgrp members. */
99 	struct session	*pg_session;	/* (c) Pointer to session. */
100 	struct sigiolst	pg_sigiolst;	/* (m) List of sigio sources. */
101 	pid_t		pg_id;		/* (c) Process group id. */
102 	int		pg_jobc;	/* (m) Job control process count. */
103 	struct mtx	pg_mtx;		/* Mutex to protect members */
104 };
105 
106 /*
107  * pargs, used to hold a copy of the command line, if it had a sane length.
108  */
109 struct pargs {
110 	u_int	ar_ref;		/* Reference count. */
111 	u_int	ar_length;	/* Length. */
112 	u_char	ar_args[1];	/* Arguments. */
113 };
114 
115 /*-
116  * Description of a process.
117  *
118  * This structure contains the information needed to manage a thread of
119  * control, known in UN*X as a process; it has references to substructures
120  * containing descriptions of things that the process uses, but may share
121  * with related processes.  The process structure and the substructures
122  * are always addressable except for those marked "(CPU)" below,
123  * which might be addressable only on a processor on which the process
124  * is running.
125  *
126  * Below is a key of locks used to protect each member of struct proc.  The
127  * lock is indicated by a reference to a specific character in parens in the
128  * associated comment.
129  *      * - not yet protected
130  *      a - only touched by curproc or parent during fork/wait
131  *      b - created at fork, never changes
132  *		(exception aiods switch vmspaces, but they are also
133  *		marked 'P_SYSTEM' so hopefully it will be left alone)
134  *      c - locked by proc mtx
135  *      d - locked by allproc_lock lock
136  *      e - locked by proctree_lock lock
137  *      f - session mtx
138  *      g - process group mtx
139  *      h - callout_lock mtx
140  *      i - by curproc or the master session mtx
141  *      j - locked by proc slock
142  *      k - only accessed by curthread
143  *	k*- only accessed by curthread and from an interrupt
144  *      l - the attaching proc or attaching proc parent
145  *      m - Giant
146  *      n - not locked, lazy
147  *      o - ktrace lock
148  *      q - td_contested lock
149  *      r - p_peers lock
150  *      t - thread lock
151  *      x - created at fork, only changes during single threading in exec
152  *      y - created at first aio, doesn't change until exit or exec at which
153  *          point we are single-threaded and only curthread changes it
154  *      z - zombie threads lock
155  *
156  * If the locking key specifies two identifiers (for example, p_pptr) then
157  * either lock is sufficient for read access, but both locks must be held
158  * for write access.
159  */
160 struct cpuset;
161 struct filemon;
162 struct kaioinfo;
163 struct kaudit_record;
164 struct kdtrace_proc;
165 struct kdtrace_thread;
166 struct mqueue_notifier;
167 struct nlminfo;
168 struct p_sched;
169 struct proc;
170 struct procdesc;
171 struct racct;
172 struct sbuf;
173 struct sleepqueue;
174 struct syscall_args;
175 struct td_sched;
176 struct thread;
177 struct trapframe;
178 struct turnstile;
179 
180 /*
181  * XXX: Does this belong in resource.h or resourcevar.h instead?
182  * Resource usage extension.  The times in rusage structs in the kernel are
183  * never up to date.  The actual times are kept as runtimes and tick counts
184  * (with control info in the "previous" times), and are converted when
185  * userland asks for rusage info.  Backwards compatibility prevents putting
186  * this directly in the user-visible rusage struct.
187  *
188  * Locking for p_rux: (cj) means (j) for p_rux and (c) for p_crux.
189  * Locking for td_rux: (t) for all fields.
190  */
191 struct rusage_ext {
192 	uint64_t	rux_runtime;    /* (cj) Real time. */
193 	uint64_t	rux_uticks;     /* (cj) Statclock hits in user mode. */
194 	uint64_t	rux_sticks;     /* (cj) Statclock hits in sys mode. */
195 	uint64_t	rux_iticks;     /* (cj) Statclock hits in intr mode. */
196 	uint64_t	rux_uu;         /* (c) Previous user time in usec. */
197 	uint64_t	rux_su;         /* (c) Previous sys time in usec. */
198 	uint64_t	rux_tu;         /* (c) Previous total time in usec. */
199 };
200 
201 /*
202  * Kernel runnable context (thread).
203  * This is what is put to sleep and reactivated.
204  * Thread context.  Processes may have multiple threads.
205  */
206 struct thread {
207 	struct mtx	*volatile td_lock; /* replaces sched lock */
208 	struct proc	*td_proc;	/* (*) Associated process. */
209 	TAILQ_ENTRY(thread) td_plist;	/* (*) All threads in this proc. */
210 	TAILQ_ENTRY(thread) td_runq;	/* (t) Run queue. */
211 	TAILQ_ENTRY(thread) td_slpq;	/* (t) Sleep queue. */
212 	TAILQ_ENTRY(thread) td_lockq;	/* (t) Lock queue. */
213 	LIST_ENTRY(thread) td_hash;	/* (d) Hash chain. */
214 	struct cpuset	*td_cpuset;	/* (t) CPU affinity mask. */
215 	struct seltd	*td_sel;	/* Select queue/channel. */
216 	struct sleepqueue *td_sleepqueue; /* (k) Associated sleep queue. */
217 	struct turnstile *td_turnstile;	/* (k) Associated turnstile. */
218 	struct rl_q_entry *td_rlqe;	/* (k) Associated range lock entry. */
219 	struct umtx_q   *td_umtxq;	/* (c?) Link for when we're blocked. */
220 	lwpid_t		td_tid;		/* (b) Thread ID. */
221 	uint64_t	padding1[4];
222 	void		*padding2[4];
223 	u_char		td_lend_user_pri; /* (t) Lend user pri. */
224 
225 /* Cleared during fork1() */
226 #define	td_startzero td_flags
227 	int		td_flags;	/* (t) TDF_* flags. */
228 	int		td_inhibitors;	/* (t) Why can not run. */
229 	int		td_pflags;	/* (k) Private thread (TDP_*) flags. */
230 	int		td_dupfd;	/* (k) Ret value from fdopen. XXX */
231 	int		td_sqqueue;	/* (t) Sleepqueue queue blocked on. */
232 	void		*td_wchan;	/* (t) Sleep address. */
233 	const char	*td_wmesg;	/* (t) Reason for sleep. */
234 	u_char		td_lastcpu;	/* (t) Last cpu we were on. */
235 	u_char		td_oncpu;	/* (t) Which cpu we are on. */
236 	volatile u_char td_owepreempt;  /* (k*) Preempt on last critical_exit */
237 	u_char		td_tsqueue;	/* (t) Turnstile queue blocked on. */
238 	short		td_locks;	/* (k) Count of non-spin locks. */
239 	short		td_rw_rlocks;	/* (k) Count of rwlock read locks. */
240 	short		td_lk_slocks;	/* (k) Count of lockmgr shared locks. */
241 	short		td_stopsched;	/* (k) Scheduler stopped. */
242 	struct turnstile *td_blocked;	/* (t) Lock thread is blocked on. */
243 	const char	*td_lockname;	/* (t) Name of lock blocked on. */
244 	LIST_HEAD(, turnstile) td_contested;	/* (q) Contested locks. */
245 	struct lock_list_entry *td_sleeplocks; /* (k) Held sleep locks. */
246 	int		td_intr_nesting_level; /* (k) Interrupt recursion. */
247 	int		td_pinned;	/* (k) Temporary cpu pin count. */
248 	struct ucred	*td_ucred;	/* (k) Reference to credentials. */
249 	u_int		td_estcpu;	/* (t) estimated cpu utilization */
250 	int		td_slptick;	/* (t) Time at sleep. */
251 	int		td_blktick;	/* (t) Time spent blocked. */
252 	int		td_swvoltick;	/* (t) Time at last SW_VOL switch. */
253 	u_int		td_cow;		/* (*) Number of copy-on-write faults */
254 	struct rusage	td_ru;		/* (t) rusage information. */
255 	struct rusage_ext td_rux;	/* (t) Internal rusage information. */
256 	uint64_t	td_incruntime;	/* (t) Cpu ticks to transfer to proc. */
257 	uint64_t	td_runtime;	/* (t) How many cpu ticks we've run. */
258 	u_int 		td_pticks;	/* (t) Statclock hits for profiling */
259 	u_int		td_sticks;	/* (t) Statclock hits in system mode. */
260 	u_int		td_iticks;	/* (t) Statclock hits in intr mode. */
261 	u_int		td_uticks;	/* (t) Statclock hits in user mode. */
262 	int		td_intrval;	/* (t) Return value for sleepq. */
263 	sigset_t	td_oldsigmask;	/* (k) Saved mask from pre sigpause. */
264 	volatile u_int	td_generation;	/* (k) For detection of preemption */
265 	stack_t		td_sigstk;	/* (k) Stack ptr and on-stack flag. */
266 	int		td_xsig;	/* (c) Signal for ptrace */
267 	u_long		td_profil_addr;	/* (k) Temporary addr until AST. */
268 	u_int		td_profil_ticks; /* (k) Temporary ticks until AST. */
269 	char		td_name[MAXCOMLEN + 1];	/* (*) Thread name. */
270 	struct file	*td_fpop;	/* (k) file referencing cdev under op */
271 	int		td_dbgflags;	/* (c) Userland debugger flags */
272 	struct ksiginfo td_dbgksi;	/* (c) ksi reflected to debugger. */
273 	int		td_ng_outbound;	/* (k) Thread entered ng from above. */
274 	struct osd	td_osd;		/* (k) Object specific data. */
275 	struct vm_map_entry *td_map_def_user; /* (k) Deferred entries. */
276 	pid_t		td_dbg_forked;	/* (c) Child pid for debugger. */
277 	u_int		td_vp_reserv;	/* (k) Count of reserved vnodes. */
278 	int		td_no_sleeping;	/* (k) Sleeping disabled count. */
279 	int		td_dom_rr_idx;	/* (k) RR Numa domain selection. */
280 #define	td_endzero td_sigmask
281 
282 /* Copied during fork1() or create_thread(). */
283 #define	td_startcopy td_endzero
284 	sigset_t	td_sigmask;	/* (c) Current signal mask. */
285 	u_char		td_rqindex;	/* (t) Run queue index. */
286 	u_char		td_base_pri;	/* (t) Thread base kernel priority. */
287 	u_char		td_priority;	/* (t) Thread active priority. */
288 	u_char		td_pri_class;	/* (t) Scheduling class. */
289 	u_char		td_user_pri;	/* (t) User pri from estcpu and nice. */
290 	u_char		td_base_user_pri; /* (t) Base user pri */
291 #define	td_endcopy td_pcb
292 
293 /*
294  * Fields that must be manually set in fork1() or create_thread()
295  * or already have been set in the allocator, constructor, etc.
296  */
297 	struct pcb	*td_pcb;	/* (k) Kernel VA of pcb and kstack. */
298 	enum {
299 		TDS_INACTIVE = 0x0,
300 		TDS_INHIBITED,
301 		TDS_CAN_RUN,
302 		TDS_RUNQ,
303 		TDS_RUNNING
304 	} td_state;			/* (t) thread state */
305 	register_t	td_retval[2];	/* (k) Syscall aux returns. */
306 	struct callout	td_slpcallout;	/* (h) Callout for sleep. */
307 	struct trapframe *td_frame;	/* (k) */
308 	struct vm_object *td_kstack_obj;/* (a) Kstack object. */
309 	vm_offset_t	td_kstack;	/* (a) Kernel VA of kstack. */
310 	int		td_kstack_pages; /* (a) Size of the kstack. */
311 	volatile u_int	td_critnest;	/* (k*) Critical section nest level. */
312 	struct mdthread td_md;		/* (k) Any machine-dependent fields. */
313 	struct td_sched	*td_sched;	/* (*) Scheduler-specific data. */
314 	struct kaudit_record	*td_ar;	/* (k) Active audit record, if any. */
315 	struct lpohead	td_lprof[2];	/* (a) lock profiling objects. */
316 	struct kdtrace_thread	*td_dtrace; /* (*) DTrace-specific data. */
317 	int		td_errno;	/* Error returned by last syscall. */
318 	struct vnet	*td_vnet;	/* (k) Effective vnet. */
319 	const char	*td_vnet_lpush;	/* (k) Debugging vnet push / pop. */
320 	struct trapframe *td_intr_frame;/* (k) Frame of the current irq */
321 	struct proc	*td_rfppwait_p;	/* (k) The vforked child */
322 	struct vm_page	**td_ma;	/* (k) uio pages held */
323 	int		td_ma_cnt;	/* (k) size of *td_ma */
324 	void		*td_su;		/* (k) FFS SU private */
325 	u_int		td_dbg_sc_code;	/* (c) Syscall code to debugger. */
326 	u_int		td_dbg_sc_narg;	/* (c) Syscall arg count to debugger.*/
327 	void		*td_emuldata;	/* Emulator state data */
328 	sbintime_t	td_sleeptimo;	/* (t) Sleep timeout. */
329 	sigqueue_t	td_sigqueue;	/* (c) Sigs arrived, not delivered. */
330 #define	td_siglist	td_sigqueue.sq_signals
331 };
332 
333 struct mtx *thread_lock_block(struct thread *);
334 void thread_lock_unblock(struct thread *, struct mtx *);
335 void thread_lock_set(struct thread *, struct mtx *);
336 #define	THREAD_LOCK_ASSERT(td, type)					\
337 do {									\
338 	struct mtx *__m = (td)->td_lock;				\
339 	if (__m != &blocked_lock)					\
340 		mtx_assert(__m, (type));				\
341 } while (0)
342 
343 #ifdef INVARIANTS
344 #define	THREAD_LOCKPTR_ASSERT(td, lock)					\
345 do {									\
346 	struct mtx *__m = (td)->td_lock;				\
347 	KASSERT((__m == &blocked_lock || __m == (lock)),		\
348 	    ("Thread %p lock %p does not match %p", td, __m, (lock)));	\
349 } while (0)
350 #else
351 #define	THREAD_LOCKPTR_ASSERT(td, lock)
352 #endif
353 
354 /*
355  * Flags kept in td_flags:
356  * To change these you MUST have the scheduler lock.
357  */
358 #define	TDF_BORROWING	0x00000001 /* Thread is borrowing pri from another. */
359 #define	TDF_INPANIC	0x00000002 /* Caused a panic, let it drive crashdump. */
360 #define	TDF_INMEM	0x00000004 /* Thread's stack is in memory. */
361 #define	TDF_SINTR	0x00000008 /* Sleep is interruptible. */
362 #define	TDF_TIMEOUT	0x00000010 /* Timing out during sleep. */
363 #define	TDF_IDLETD	0x00000020 /* This is a per-CPU idle thread. */
364 #define	TDF_CANSWAP	0x00000040 /* Thread can be swapped. */
365 #define	TDF_SLEEPABORT	0x00000080 /* sleepq_abort was called. */
366 #define	TDF_KTH_SUSP	0x00000100 /* kthread is suspended */
367 #define	TDF_ALLPROCSUSP	0x00000200 /* suspended by SINGLE_ALLPROC */
368 #define	TDF_BOUNDARY	0x00000400 /* Thread suspended at user boundary */
369 #define	TDF_ASTPENDING	0x00000800 /* Thread has some asynchronous events. */
370 #define	TDF_UNUSED12	0x00001000 /* --available-- */
371 #define	TDF_SBDRY	0x00002000 /* Stop only on usermode boundary. */
372 #define	TDF_UPIBLOCKED	0x00004000 /* Thread blocked on user PI mutex. */
373 #define	TDF_NEEDSUSPCHK	0x00008000 /* Thread may need to suspend. */
374 #define	TDF_NEEDRESCHED	0x00010000 /* Thread needs to yield. */
375 #define	TDF_NEEDSIGCHK	0x00020000 /* Thread may need signal delivery. */
376 #define	TDF_NOLOAD	0x00040000 /* Ignore during load avg calculations. */
377 #define	TDF_UNUSED19	0x00080000 /* --available-- */
378 #define	TDF_THRWAKEUP	0x00100000 /* Libthr thread must not suspend itself. */
379 #define	TDF_UNUSED21	0x00200000 /* --available-- */
380 #define	TDF_SWAPINREQ	0x00400000 /* Swapin request due to wakeup. */
381 #define	TDF_UNUSED23	0x00800000 /* --available-- */
382 #define	TDF_SCHED0	0x01000000 /* Reserved for scheduler private use */
383 #define	TDF_SCHED1	0x02000000 /* Reserved for scheduler private use */
384 #define	TDF_SCHED2	0x04000000 /* Reserved for scheduler private use */
385 #define	TDF_SCHED3	0x08000000 /* Reserved for scheduler private use */
386 #define	TDF_ALRMPEND	0x10000000 /* Pending SIGVTALRM needs to be posted. */
387 #define	TDF_PROFPEND	0x20000000 /* Pending SIGPROF needs to be posted. */
388 #define	TDF_MACPEND	0x40000000 /* AST-based MAC event pending. */
389 
390 /* Userland debug flags */
391 #define	TDB_SUSPEND	0x00000001 /* Thread is suspended by debugger */
392 #define	TDB_XSIG	0x00000002 /* Thread is exchanging signal under trace */
393 #define	TDB_USERWR	0x00000004 /* Debugger modified memory or registers */
394 #define	TDB_SCE		0x00000008 /* Thread performs syscall enter */
395 #define	TDB_SCX		0x00000010 /* Thread performs syscall exit */
396 #define	TDB_EXEC	0x00000020 /* TDB_SCX from exec(2) family */
397 #define	TDB_FORK	0x00000040 /* TDB_SCX from fork(2) that created new
398 				      process */
399 #define	TDB_STOPATFORK	0x00000080 /* Stop at the return from fork (child
400 				      only) */
401 #define	TDB_CHILD	0x00000100 /* New child indicator for ptrace() */
402 #define	TDB_BORN	0x00000200 /* New LWP indicator for ptrace() */
403 #define	TDB_EXIT	0x00000400 /* Exiting LWP indicator for ptrace() */
404 #define	TDB_VFORK	0x00000800 /* vfork indicator for ptrace() */
405 #define	TDB_FSTP	0x00001000 /* The thread is PT_ATTACH leader */
406 
407 /*
408  * "Private" flags kept in td_pflags:
409  * These are only written by curthread and thus need no locking.
410  */
411 #define	TDP_OLDMASK	0x00000001 /* Need to restore mask after suspend. */
412 #define	TDP_INKTR	0x00000002 /* Thread is currently in KTR code. */
413 #define	TDP_INKTRACE	0x00000004 /* Thread is currently in KTRACE code. */
414 #define	TDP_BUFNEED	0x00000008 /* Do not recurse into the buf flush */
415 #define	TDP_COWINPROGRESS 0x00000010 /* Snapshot copy-on-write in progress. */
416 #define	TDP_ALTSTACK	0x00000020 /* Have alternate signal stack. */
417 #define	TDP_DEADLKTREAT	0x00000040 /* Lock acquisition - deadlock treatment. */
418 #define	TDP_NOFAULTING	0x00000080 /* Do not handle page faults. */
419 #define	TDP_UNUSED9	0x00000100 /* --available-- */
420 #define	TDP_OWEUPC	0x00000200 /* Call addupc() at next AST. */
421 #define	TDP_ITHREAD	0x00000400 /* Thread is an interrupt thread. */
422 #define	TDP_SYNCIO	0x00000800 /* Local override, disable async i/o. */
423 #define	TDP_SCHED1	0x00001000 /* Reserved for scheduler private use */
424 #define	TDP_SCHED2	0x00002000 /* Reserved for scheduler private use */
425 #define	TDP_SCHED3	0x00004000 /* Reserved for scheduler private use */
426 #define	TDP_SCHED4	0x00008000 /* Reserved for scheduler private use */
427 #define	TDP_GEOM	0x00010000 /* Settle GEOM before finishing syscall */
428 #define	TDP_SOFTDEP	0x00020000 /* Stuck processing softdep worklist */
429 #define	TDP_NORUNNINGBUF 0x00040000 /* Ignore runningbufspace check */
430 #define	TDP_WAKEUP	0x00080000 /* Don't sleep in umtx cond_wait */
431 #define	TDP_INBDFLUSH	0x00100000 /* Already in BO_BDFLUSH, do not recurse */
432 #define	TDP_KTHREAD	0x00200000 /* This is an official kernel thread */
433 #define	TDP_CALLCHAIN	0x00400000 /* Capture thread's callchain */
434 #define	TDP_IGNSUSP	0x00800000 /* Permission to ignore the MNTK_SUSPEND* */
435 #define	TDP_AUDITREC	0x01000000 /* Audit record pending on thread */
436 #define	TDP_RFPPWAIT	0x02000000 /* Handle RFPPWAIT on syscall exit */
437 #define	TDP_RESETSPUR	0x04000000 /* Reset spurious page fault history. */
438 #define	TDP_NERRNO	0x08000000 /* Last errno is already in td_errno */
439 #define	TDP_UIOHELD	0x10000000 /* Current uio has pages held in td_ma */
440 #define	TDP_UNUSED29	0x20000000 /* --available-- */
441 #define	TDP_EXECVMSPC	0x40000000 /* Execve destroyed old vmspace */
442 
443 /*
444  * Reasons that the current thread can not be run yet.
445  * More than one may apply.
446  */
447 #define	TDI_SUSPENDED	0x0001	/* On suspension queue. */
448 #define	TDI_SLEEPING	0x0002	/* Actually asleep! (tricky). */
449 #define	TDI_SWAPPED	0x0004	/* Stack not in mem.  Bad juju if run. */
450 #define	TDI_LOCK	0x0008	/* Stopped on a lock. */
451 #define	TDI_IWAIT	0x0010	/* Awaiting interrupt. */
452 
453 #define	TD_IS_SLEEPING(td)	((td)->td_inhibitors & TDI_SLEEPING)
454 #define	TD_ON_SLEEPQ(td)	((td)->td_wchan != NULL)
455 #define	TD_IS_SUSPENDED(td)	((td)->td_inhibitors & TDI_SUSPENDED)
456 #define	TD_IS_SWAPPED(td)	((td)->td_inhibitors & TDI_SWAPPED)
457 #define	TD_ON_LOCK(td)		((td)->td_inhibitors & TDI_LOCK)
458 #define	TD_AWAITING_INTR(td)	((td)->td_inhibitors & TDI_IWAIT)
459 #define	TD_IS_RUNNING(td)	((td)->td_state == TDS_RUNNING)
460 #define	TD_ON_RUNQ(td)		((td)->td_state == TDS_RUNQ)
461 #define	TD_CAN_RUN(td)		((td)->td_state == TDS_CAN_RUN)
462 #define	TD_IS_INHIBITED(td)	((td)->td_state == TDS_INHIBITED)
463 #define	TD_ON_UPILOCK(td)	((td)->td_flags & TDF_UPIBLOCKED)
464 #define TD_IS_IDLETHREAD(td)	((td)->td_flags & TDF_IDLETD)
465 
466 #define	KTDSTATE(td)							\
467 	(((td)->td_inhibitors & TDI_SLEEPING) != 0 ? "sleep"  :		\
468 	((td)->td_inhibitors & TDI_SUSPENDED) != 0 ? "suspended" :	\
469 	((td)->td_inhibitors & TDI_SWAPPED) != 0 ? "swapped" :		\
470 	((td)->td_inhibitors & TDI_LOCK) != 0 ? "blocked" :		\
471 	((td)->td_inhibitors & TDI_IWAIT) != 0 ? "iwait" : "yielding")
472 
473 #define	TD_SET_INHIB(td, inhib) do {			\
474 	(td)->td_state = TDS_INHIBITED;			\
475 	(td)->td_inhibitors |= (inhib);			\
476 } while (0)
477 
478 #define	TD_CLR_INHIB(td, inhib) do {			\
479 	if (((td)->td_inhibitors & (inhib)) &&		\
480 	    (((td)->td_inhibitors &= ~(inhib)) == 0))	\
481 		(td)->td_state = TDS_CAN_RUN;		\
482 } while (0)
483 
484 #define	TD_SET_SLEEPING(td)	TD_SET_INHIB((td), TDI_SLEEPING)
485 #define	TD_SET_SWAPPED(td)	TD_SET_INHIB((td), TDI_SWAPPED)
486 #define	TD_SET_LOCK(td)		TD_SET_INHIB((td), TDI_LOCK)
487 #define	TD_SET_SUSPENDED(td)	TD_SET_INHIB((td), TDI_SUSPENDED)
488 #define	TD_SET_IWAIT(td)	TD_SET_INHIB((td), TDI_IWAIT)
489 #define	TD_SET_EXITING(td)	TD_SET_INHIB((td), TDI_EXITING)
490 
491 #define	TD_CLR_SLEEPING(td)	TD_CLR_INHIB((td), TDI_SLEEPING)
492 #define	TD_CLR_SWAPPED(td)	TD_CLR_INHIB((td), TDI_SWAPPED)
493 #define	TD_CLR_LOCK(td)		TD_CLR_INHIB((td), TDI_LOCK)
494 #define	TD_CLR_SUSPENDED(td)	TD_CLR_INHIB((td), TDI_SUSPENDED)
495 #define	TD_CLR_IWAIT(td)	TD_CLR_INHIB((td), TDI_IWAIT)
496 
497 #define	TD_SET_RUNNING(td)	(td)->td_state = TDS_RUNNING
498 #define	TD_SET_RUNQ(td)		(td)->td_state = TDS_RUNQ
499 #define	TD_SET_CAN_RUN(td)	(td)->td_state = TDS_CAN_RUN
500 
501 /*
502  * Process structure.
503  */
504 struct proc {
505 	LIST_ENTRY(proc) p_list;	/* (d) List of all processes. */
506 	TAILQ_HEAD(, thread) p_threads;	/* (c) all threads. */
507 	struct mtx	p_slock;	/* process spin lock */
508 	struct ucred	*p_ucred;	/* (c) Process owner's identity. */
509 	struct filedesc	*p_fd;		/* (b) Open files. */
510 	struct filedesc_to_leader *p_fdtol; /* (b) Tracking node */
511 	struct pstats	*p_stats;	/* (b) Accounting/statistics (CPU). */
512 	struct plimit	*p_limit;	/* (c) Process limits. */
513 	struct callout	p_limco;	/* (c) Limit callout handle */
514 	struct sigacts	*p_sigacts;	/* (x) Signal actions, state (CPU). */
515 
516 	int		p_flag;		/* (c) P_* flags. */
517 	int		p_flag2;	/* (c) P2_* flags. */
518 	enum {
519 		PRS_NEW = 0,		/* In creation */
520 		PRS_NORMAL,		/* threads can be run. */
521 		PRS_ZOMBIE
522 	} p_state;			/* (j/c) Process status. */
523 	pid_t		p_pid;		/* (b) Process identifier. */
524 	LIST_ENTRY(proc) p_hash;	/* (d) Hash chain. */
525 	LIST_ENTRY(proc) p_pglist;	/* (g + e) List of processes in pgrp. */
526 	struct proc	*p_pptr;	/* (c + e) Pointer to parent process. */
527 	LIST_ENTRY(proc) p_sibling;	/* (e) List of sibling processes. */
528 	LIST_HEAD(, proc) p_children;	/* (e) Pointer to list of children. */
529 	struct mtx	p_mtx;		/* (n) Lock for this struct. */
530 	struct ksiginfo *p_ksi;	/* Locked by parent proc lock */
531 	uint64_t	padding1[4];
532 	void		*padding2[4];
533 
534 /* The following fields are all zeroed upon creation in fork. */
535 #define	p_startzero	p_oppid
536 	pid_t		p_oppid;	/* (c + e) Save ppid in ptrace. XXX */
537 	struct vmspace	*p_vmspace;	/* (b) Address space. */
538 	u_int		p_swtick;	/* (c) Tick when swapped in or out. */
539 	struct itimerval p_realtimer;	/* (c) Alarm timer. */
540 	struct rusage	p_ru;		/* (a) Exit information. */
541 	struct rusage_ext p_rux;	/* (cj) Internal resource usage. */
542 	struct rusage_ext p_crux;	/* (c) Internal child resource usage. */
543 	int		p_profthreads;	/* (c) Num threads in addupc_task. */
544 	volatile int	p_exitthreads;	/* (j) Number of threads exiting */
545 	int		p_traceflag;	/* (o) Kernel trace points. */
546 	struct vnode	*p_tracevp;	/* (c + o) Trace to vnode. */
547 	struct ucred	*p_tracecred;	/* (o) Credentials to trace with. */
548 	struct vnode	*p_textvp;	/* (b) Vnode of executable. */
549 	u_int		p_lock;		/* (c) Proclock (prevent swap) count. */
550 	struct sigiolst	p_sigiolst;	/* (c) List of sigio sources. */
551 	int		p_sigparent;	/* (c) Signal to parent on exit. */
552 	int		p_sig;		/* (n) For core dump/debugger XXX. */
553 	u_long		p_code;		/* (n) For core dump/debugger XXX. */
554 	u_int		p_stops;	/* (c) Stop event bitmask. */
555 	u_int		p_stype;	/* (c) Stop event type. */
556 	char		p_step;		/* (c) Process is stopped. */
557 	u_char		p_pfsflags;	/* (c) Procfs flags. */
558 	struct nlminfo	*p_nlminfo;	/* (?) Only used by/for lockd. */
559 	struct kaioinfo	*p_aioinfo;	/* (y) ASYNC I/O info. */
560 	struct thread	*p_singlethread;/* (c + j) If single threading this is it */
561 	int		p_suspcount;	/* (j) Num threads in suspended mode. */
562 	struct thread	*p_xthread;	/* (c) Trap thread */
563 	int		p_boundary_count;/* (j) Num threads at user boundary */
564 	int		p_pendingcnt;	/* how many signals are pending */
565 	struct itimers	*p_itimers;	/* (c) POSIX interval timers. */
566 	struct procdesc	*p_procdesc;	/* (e) Process descriptor, if any. */
567 	int		p_pendingexits; /* (c) Count of pending thread exits. */
568 /* End area that is zeroed on creation. */
569 #define	p_endzero	p_magic
570 
571 /* The following fields are all copied upon creation in fork. */
572 #define	p_startcopy	p_endzero
573 	u_int		p_magic;	/* (b) Magic number. */
574 	int		p_osrel;	/* (x) osreldate for the
575 					       binary (from ELF note, if any) */
576 	char		p_comm[MAXCOMLEN + 1];	/* (x) Process name. */
577 	void		*p_pad0;
578 	struct sysentvec *p_sysent;	/* (b) Syscall dispatch info. */
579 	struct pargs	*p_args;	/* (c) Process arguments. */
580 	rlim_t		p_cpulimit;	/* (c) Current CPU limit in seconds. */
581 	signed char	p_nice;		/* (c) Process "nice" value. */
582 	int		p_fibnum;	/* in this routing domain XXX MRT */
583 
584 /* End area that is copied on creation. */
585 #define	p_endcopy	p_xstat
586 
587 	u_short		p_xstat;	/* (c) Exit status; also stop sig. */
588 	struct knlist	p_klist;	/* (c) Knotes attached to this proc. */
589 	int		p_numthreads;	/* (c) Number of threads. */
590 	struct mdproc	p_md;		/* Any machine-dependent fields. */
591 	struct callout	p_itcallout;	/* (h + c) Interval timer callout. */
592 	u_short		p_acflag;	/* (c) Accounting flags. */
593 	struct proc	*p_peers;	/* (r) */
594 	struct proc	*p_leader;	/* (b) */
595 	void		*p_emuldata;	/* (c) Emulator state data. */
596 	struct label	*p_label;	/* (*) Proc (not subject) MAC label. */
597 	struct p_sched	*p_sched;	/* (*) Scheduler-specific data. */
598 	STAILQ_HEAD(, ktr_request)	p_ktr;	/* (o) KTR event queue. */
599 	LIST_HEAD(, mqueue_notifier)	p_mqnotifier; /* (c) mqueue notifiers.*/
600 	struct kdtrace_proc	*p_dtrace; /* (*) DTrace-specific data. */
601 	struct cv	p_pwait;	/* (*) wait cv for exit/exec. */
602 	struct cv	p_dbgwait;	/* (*) wait cv for debugger attach
603 					   after fork. */
604 	uint64_t	p_prev_runtime;	/* (c) Resource usage accounting. */
605 	struct racct	*p_racct;	/* (b) Resource accounting. */
606 	u_char		p_throttled;	/* (c) Flag for racct pcpu throttling */
607 	/*
608 	 * An orphan is the child that has beed re-parented to the
609 	 * debugger as a result of attaching to it.  Need to keep
610 	 * track of them for parent to be able to collect the exit
611 	 * status of what used to be children.
612 	 */
613 	LIST_ENTRY(proc) p_orphan;	/* (e) List of orphan processes. */
614 	LIST_HEAD(, proc) p_orphans;	/* (e) Pointer to list of orphans. */
615 	u_int		p_treeflag;	/* (e) P_TREE flags */
616 	struct proc	*p_reaper;	/* (e) My reaper. */
617 	LIST_HEAD(, proc) p_reaplist;	/* (e) List of my descendants
618 					       (if I am reaper). */
619 	LIST_ENTRY(proc) p_reapsibling;	/* (e) List of siblings - descendants of
620 					       the same reaper. */
621 	pid_t		p_reapsubtree;	/* (e) Pid of the direct child of the
622 					       reaper which spawned
623 					       our subtree. */
624 	struct pgrp	*p_pgrp;	/* (c + e) Pointer to process group. */
625 	struct filemon	*p_filemon;	/* (c) filemon-specific data. */
626 	u_int		p_ptevents;	/* (c) ptrace() event mask. */
627 	uint16_t	p_elf_machine;	/* (x) ELF machine type */
628 	uint64_t	p_elf_flags;	/* (x) ELF flags */
629 	sigqueue_t	p_sigqueue;	/* (c) Sigs not delivered to a td. */
630 #define p_siglist	p_sigqueue.sq_signals
631 };
632 
633 #define	p_session	p_pgrp->pg_session
634 #define	p_pgid		p_pgrp->pg_id
635 
636 #define	NOCPU	0xff		/* For when we aren't on a CPU. */
637 
638 #define	PROC_SLOCK(p)	mtx_lock_spin(&(p)->p_slock)
639 #define	PROC_SUNLOCK(p)	mtx_unlock_spin(&(p)->p_slock)
640 #define	PROC_SLOCK_ASSERT(p, type)	mtx_assert(&(p)->p_slock, (type))
641 
642 #define	PROC_STATLOCK(p)	mtx_lock_spin(&(p)->p_slock)
643 #define	PROC_STATUNLOCK(p)	mtx_unlock_spin(&(p)->p_slock)
644 #define	PROC_STATLOCK_ASSERT(p, type)	mtx_assert(&(p)->p_slock, (type))
645 
646 #define	PROC_ITIMLOCK(p)	mtx_lock_spin(&(p)->p_slock)
647 #define	PROC_ITIMUNLOCK(p)	mtx_unlock_spin(&(p)->p_slock)
648 #define	PROC_ITIMLOCK_ASSERT(p, type)	mtx_assert(&(p)->p_slock, (type))
649 
650 #define	PROC_PROFLOCK(p)	mtx_lock_spin(&(p)->p_slock)
651 #define	PROC_PROFUNLOCK(p)	mtx_unlock_spin(&(p)->p_slock)
652 #define	PROC_PROFLOCK_ASSERT(p, type)	mtx_assert(&(p)->p_slock, (type))
653 
654 /* These flags are kept in p_flag. */
655 #define	P_ADVLOCK	0x00001	/* Process may hold a POSIX advisory lock. */
656 #define	P_CONTROLT	0x00002	/* Has a controlling terminal. */
657 #define	P_KTHREAD	0x00004	/* Kernel thread (*). */
658 #define	P_UNUSED3	0x00008	/* --available-- */
659 #define	P_PPWAIT	0x00010	/* Parent is waiting for child to exec/exit. */
660 #define	P_PROFIL	0x00020	/* Has started profiling. */
661 #define	P_STOPPROF	0x00040	/* Has thread requesting to stop profiling. */
662 #define	P_HADTHREADS	0x00080	/* Has had threads (no cleanup shortcuts) */
663 #define	P_SUGID		0x00100	/* Had set id privileges since last exec. */
664 #define	P_SYSTEM	0x00200	/* System proc: no sigs, stats or swapping. */
665 #define	P_SINGLE_EXIT	0x00400	/* Threads suspending should exit, not wait. */
666 #define	P_TRACED	0x00800	/* Debugged process being traced. */
667 #define	P_WAITED	0x01000	/* Someone is waiting for us. */
668 #define	P_WEXIT		0x02000	/* Working on exiting. */
669 #define	P_EXEC		0x04000	/* Process called exec. */
670 #define	P_WKILLED	0x08000	/* Killed, go to kernel/user boundary ASAP. */
671 #define	P_CONTINUED	0x10000	/* Proc has continued from a stopped state. */
672 #define	P_STOPPED_SIG	0x20000	/* Stopped due to SIGSTOP/SIGTSTP. */
673 #define	P_STOPPED_TRACE	0x40000	/* Stopped because of tracing. */
674 #define	P_STOPPED_SINGLE 0x80000 /* Only 1 thread can continue (not to user). */
675 #define	P_PROTECTED	0x100000 /* Do not kill on memory overcommit. */
676 #define	P_SIGEVENT	0x200000 /* Process pending signals changed. */
677 #define	P_SINGLE_BOUNDARY 0x400000 /* Threads should suspend at user boundary. */
678 #define	P_HWPMC		0x800000 /* Process is using HWPMCs */
679 #define	P_JAILED	0x1000000 /* Process is in jail. */
680 #define	P_TOTAL_STOP	0x2000000 /* Stopped in proc_stop_total. */
681 #define	P_INEXEC	0x4000000 /* Process is in execve(). */
682 #define	P_STATCHILD	0x8000000 /* Child process stopped or exited. */
683 #define	P_INMEM		0x10000000 /* Loaded into memory. */
684 #define	P_SWAPPINGOUT	0x20000000 /* Process is being swapped out. */
685 #define	P_SWAPPINGIN	0x40000000 /* Process is being swapped in. */
686 #define	P_PPTRACE	0x80000000 /* PT_TRACEME by vforked child. */
687 
688 #define	P_STOPPED	(P_STOPPED_SIG|P_STOPPED_SINGLE|P_STOPPED_TRACE)
689 #define	P_SHOULDSTOP(p)	((p)->p_flag & P_STOPPED)
690 #define	P_KILLED(p)	((p)->p_flag & P_WKILLED)
691 
692 /* These flags are kept in p_flag2. */
693 #define	P2_INHERIT_PROTECTED 0x00000001 /* New children get P_PROTECTED. */
694 #define	P2_NOTRACE	0x00000002	/* No ptrace(2) attach or coredumps. */
695 #define	P2_NOTRACE_EXEC 0x00000004	/* Keep P2_NOPTRACE on exec(2). */
696 #define	P2_AST_SU	0x00000008	/* Handles SU ast for kthreads. */
697 #define	P2_PTRACE_FSTP	0x00000010 /* SIGSTOP from PT_ATTACH not yet handled. */
698 
699 /* Flags protected by proctree_lock, kept in p_treeflags. */
700 #define	P_TREE_ORPHANED		0x00000001	/* Reparented, on orphan list */
701 #define	P_TREE_FIRST_ORPHAN	0x00000002	/* First element of orphan
702 						   list */
703 #define	P_TREE_REAPER		0x00000004	/* Reaper of subtree */
704 
705 /*
706  * These were process status values (p_stat), now they are only used in
707  * legacy conversion code.
708  */
709 #define	SIDL	1		/* Process being created by fork. */
710 #define	SRUN	2		/* Currently runnable. */
711 #define	SSLEEP	3		/* Sleeping on an address. */
712 #define	SSTOP	4		/* Process debugging or suspension. */
713 #define	SZOMB	5		/* Awaiting collection by parent. */
714 #define	SWAIT	6		/* Waiting for interrupt. */
715 #define	SLOCK	7		/* Blocked on a lock. */
716 
717 #define	P_MAGIC		0xbeefface
718 
719 #ifdef _KERNEL
720 
721 /* Types and flags for mi_switch(). */
722 #define	SW_TYPE_MASK		0xff	/* First 8 bits are switch type */
723 #define	SWT_NONE		0	/* Unspecified switch. */
724 #define	SWT_PREEMPT		1	/* Switching due to preemption. */
725 #define	SWT_OWEPREEMPT		2	/* Switching due to owepreempt. */
726 #define	SWT_TURNSTILE		3	/* Turnstile contention. */
727 #define	SWT_SLEEPQ		4	/* Sleepq wait. */
728 #define	SWT_SLEEPQTIMO		5	/* Sleepq timeout wait. */
729 #define	SWT_RELINQUISH		6	/* yield call. */
730 #define	SWT_NEEDRESCHED		7	/* NEEDRESCHED was set. */
731 #define	SWT_IDLE		8	/* Switching from the idle thread. */
732 #define	SWT_IWAIT		9	/* Waiting for interrupts. */
733 #define	SWT_SUSPEND		10	/* Thread suspended. */
734 #define	SWT_REMOTEPREEMPT	11	/* Remote processor preempted. */
735 #define	SWT_REMOTEWAKEIDLE	12	/* Remote processor preempted idle. */
736 #define	SWT_COUNT		13	/* Number of switch types. */
737 /* Flags */
738 #define	SW_VOL		0x0100		/* Voluntary switch. */
739 #define	SW_INVOL	0x0200		/* Involuntary switch. */
740 #define SW_PREEMPT	0x0400		/* The invol switch is a preemption */
741 
742 /* How values for thread_single(). */
743 #define	SINGLE_NO_EXIT	0
744 #define	SINGLE_EXIT	1
745 #define	SINGLE_BOUNDARY	2
746 #define	SINGLE_ALLPROC	3
747 
748 #ifdef MALLOC_DECLARE
749 MALLOC_DECLARE(M_PARGS);
750 MALLOC_DECLARE(M_PGRP);
751 MALLOC_DECLARE(M_SESSION);
752 MALLOC_DECLARE(M_SUBPROC);
753 #endif
754 
755 #define	FOREACH_PROC_IN_SYSTEM(p)					\
756 	LIST_FOREACH((p), &allproc, p_list)
757 #define	FOREACH_THREAD_IN_PROC(p, td)					\
758 	TAILQ_FOREACH((td), &(p)->p_threads, td_plist)
759 
760 #define	FIRST_THREAD_IN_PROC(p)	TAILQ_FIRST(&(p)->p_threads)
761 
762 /*
763  * We use process IDs <= pid_max <= PID_MAX; PID_MAX + 1 must also fit
764  * in a pid_t, as it is used to represent "no process group".
765  */
766 #define	PID_MAX		99999
767 #define	NO_PID		100000
768 extern pid_t pid_max;
769 
770 #define	SESS_LEADER(p)	((p)->p_session->s_leader == (p))
771 
772 
773 #define	STOPEVENT(p, e, v) do {						\
774 	if ((p)->p_stops & (e))	{					\
775 		PROC_LOCK(p);						\
776 		stopevent((p), (e), (v));				\
777 		PROC_UNLOCK(p);						\
778 	}								\
779 } while (0)
780 #define	_STOPEVENT(p, e, v) do {					\
781 	PROC_LOCK_ASSERT(p, MA_OWNED);					\
782 	WITNESS_WARN(WARN_GIANTOK | WARN_SLEEPOK, &p->p_mtx.lock_object, \
783  	    "checking stopevent %d", (e));				\
784 	if ((p)->p_stops & (e))						\
785 		stopevent((p), (e), (v));				\
786 } while (0)
787 
788 /* Lock and unlock a process. */
789 #define	PROC_LOCK(p)	mtx_lock(&(p)->p_mtx)
790 #define	PROC_TRYLOCK(p)	mtx_trylock(&(p)->p_mtx)
791 #define	PROC_UNLOCK(p)	mtx_unlock(&(p)->p_mtx)
792 #define	PROC_LOCKED(p)	mtx_owned(&(p)->p_mtx)
793 #define	PROC_LOCK_ASSERT(p, type)	mtx_assert(&(p)->p_mtx, (type))
794 
795 /* Lock and unlock a process group. */
796 #define	PGRP_LOCK(pg)	mtx_lock(&(pg)->pg_mtx)
797 #define	PGRP_UNLOCK(pg)	mtx_unlock(&(pg)->pg_mtx)
798 #define	PGRP_LOCKED(pg)	mtx_owned(&(pg)->pg_mtx)
799 #define	PGRP_LOCK_ASSERT(pg, type)	mtx_assert(&(pg)->pg_mtx, (type))
800 
801 #define	PGRP_LOCK_PGSIGNAL(pg) do {					\
802 	if ((pg) != NULL)						\
803 		PGRP_LOCK(pg);						\
804 } while (0)
805 #define	PGRP_UNLOCK_PGSIGNAL(pg) do {					\
806 	if ((pg) != NULL)						\
807 		PGRP_UNLOCK(pg);					\
808 } while (0)
809 
810 /* Lock and unlock a session. */
811 #define	SESS_LOCK(s)	mtx_lock(&(s)->s_mtx)
812 #define	SESS_UNLOCK(s)	mtx_unlock(&(s)->s_mtx)
813 #define	SESS_LOCKED(s)	mtx_owned(&(s)->s_mtx)
814 #define	SESS_LOCK_ASSERT(s, type)	mtx_assert(&(s)->s_mtx, (type))
815 
816 /* Hold process U-area in memory, normally for ptrace/procfs work. */
817 #define	PHOLD(p) do {							\
818 	PROC_LOCK(p);							\
819 	_PHOLD(p);							\
820 	PROC_UNLOCK(p);							\
821 } while (0)
822 #define	_PHOLD(p) do {							\
823 	PROC_LOCK_ASSERT((p), MA_OWNED);				\
824 	KASSERT(!((p)->p_flag & P_WEXIT) || (p) == curproc,		\
825 	    ("PHOLD of exiting process"));				\
826 	(p)->p_lock++;							\
827 	if (((p)->p_flag & P_INMEM) == 0)				\
828 		faultin((p));						\
829 } while (0)
830 #define PROC_ASSERT_HELD(p) do {					\
831 	KASSERT((p)->p_lock > 0, ("process not held"));			\
832 } while (0)
833 
834 #define	PRELE(p) do {							\
835 	PROC_LOCK((p));							\
836 	_PRELE((p));							\
837 	PROC_UNLOCK((p));						\
838 } while (0)
839 #define	_PRELE(p) do {							\
840 	PROC_LOCK_ASSERT((p), MA_OWNED);				\
841 	PROC_ASSERT_HELD(p);						\
842 	(--(p)->p_lock);						\
843 	if (((p)->p_flag & P_WEXIT) && (p)->p_lock == 0)		\
844 		wakeup(&(p)->p_lock);					\
845 } while (0)
846 #define PROC_ASSERT_NOT_HELD(p) do {					\
847 	KASSERT((p)->p_lock == 0, ("process held"));			\
848 } while (0)
849 
850 /* Check whether a thread is safe to be swapped out. */
851 #define	thread_safetoswapout(td)	((td)->td_flags & TDF_CANSWAP)
852 
853 /* Control whether or not it is safe for curthread to sleep. */
854 #define	THREAD_NO_SLEEPING()		((curthread)->td_no_sleeping++)
855 
856 #define	THREAD_SLEEPING_OK()		((curthread)->td_no_sleeping--)
857 
858 #define	THREAD_CAN_SLEEP()		((curthread)->td_no_sleeping == 0)
859 
860 #define	PIDHASH(pid)	(&pidhashtbl[(pid) & pidhash])
861 extern LIST_HEAD(pidhashhead, proc) *pidhashtbl;
862 extern u_long pidhash;
863 #define	TIDHASH(tid)	(&tidhashtbl[(tid) & tidhash])
864 extern LIST_HEAD(tidhashhead, thread) *tidhashtbl;
865 extern u_long tidhash;
866 extern struct rwlock tidhash_lock;
867 
868 #define	PGRPHASH(pgid)	(&pgrphashtbl[(pgid) & pgrphash])
869 extern LIST_HEAD(pgrphashhead, pgrp) *pgrphashtbl;
870 extern u_long pgrphash;
871 
872 extern struct sx allproc_lock;
873 extern int allproc_gen;
874 extern struct sx proctree_lock;
875 extern struct mtx ppeers_lock;
876 extern struct proc proc0;		/* Process slot for swapper. */
877 extern struct thread thread0;		/* Primary thread in proc0. */
878 extern struct vmspace vmspace0;		/* VM space for proc0. */
879 extern int hogticks;			/* Limit on kernel cpu hogs. */
880 extern int lastpid;
881 extern int nprocs, maxproc;		/* Current and max number of procs. */
882 extern int maxprocperuid;		/* Max procs per uid. */
883 extern u_long ps_arg_cache_limit;
884 
885 LIST_HEAD(proclist, proc);
886 TAILQ_HEAD(procqueue, proc);
887 TAILQ_HEAD(threadqueue, thread);
888 extern struct proclist allproc;		/* List of all processes. */
889 extern struct proclist zombproc;	/* List of zombie processes. */
890 extern struct proc *initproc, *pageproc; /* Process slots for init, pager. */
891 
892 extern struct uma_zone *proc_zone;
893 
894 struct	proc *pfind(pid_t);		/* Find process by id. */
895 struct	proc *pfind_locked(pid_t pid);
896 struct	pgrp *pgfind(pid_t);		/* Find process group by id. */
897 struct	proc *zpfind(pid_t);		/* Find zombie process by id. */
898 
899 /*
900  * pget() flags.
901  */
902 #define	PGET_HOLD	0x00001	/* Hold the process. */
903 #define	PGET_CANSEE	0x00002	/* Check against p_cansee(). */
904 #define	PGET_CANDEBUG	0x00004	/* Check against p_candebug(). */
905 #define	PGET_ISCURRENT	0x00008	/* Check that the found process is current. */
906 #define	PGET_NOTWEXIT	0x00010	/* Check that the process is not in P_WEXIT. */
907 #define	PGET_NOTINEXEC	0x00020	/* Check that the process is not in P_INEXEC. */
908 #define	PGET_NOTID	0x00040	/* Do not assume tid if pid > PID_MAX. */
909 
910 #define	PGET_WANTREAD	(PGET_HOLD | PGET_CANDEBUG | PGET_NOTWEXIT)
911 
912 int	pget(pid_t pid, int flags, struct proc **pp);
913 
914 void	ast(struct trapframe *framep);
915 struct	thread *choosethread(void);
916 int	cr_cansignal(struct ucred *cred, struct proc *proc, int signum);
917 int	enterpgrp(struct proc *p, pid_t pgid, struct pgrp *pgrp,
918 	    struct session *sess);
919 int	enterthispgrp(struct proc *p, struct pgrp *pgrp);
920 void	faultin(struct proc *p);
921 void	fixjobc(struct proc *p, struct pgrp *pgrp, int entering);
922 int	fork1(struct thread *, int, int, struct proc **, int *, int);
923 void	fork_exit(void (*)(void *, struct trapframe *), void *,
924 	    struct trapframe *);
925 void	fork_return(struct thread *, struct trapframe *);
926 int	inferior(struct proc *p);
927 void	kern_yield(int);
928 void 	kick_proc0(void);
929 int	leavepgrp(struct proc *p);
930 int	maybe_preempt(struct thread *td);
931 void	maybe_yield(void);
932 void	mi_switch(int flags, struct thread *newtd);
933 int	p_candebug(struct thread *td, struct proc *p);
934 int	p_cansee(struct thread *td, struct proc *p);
935 int	p_cansched(struct thread *td, struct proc *p);
936 int	p_cansignal(struct thread *td, struct proc *p, int signum);
937 int	p_canwait(struct thread *td, struct proc *p);
938 struct	pargs *pargs_alloc(int len);
939 void	pargs_drop(struct pargs *pa);
940 void	pargs_hold(struct pargs *pa);
941 int	proc_getargv(struct thread *td, struct proc *p, struct sbuf *sb);
942 int	proc_getauxv(struct thread *td, struct proc *p, struct sbuf *sb);
943 int	proc_getenvv(struct thread *td, struct proc *p, struct sbuf *sb);
944 void	procinit(void);
945 void	proc_linkup0(struct proc *p, struct thread *td);
946 void	proc_linkup(struct proc *p, struct thread *td);
947 struct proc *proc_realparent(struct proc *child);
948 void	proc_reap(struct thread *td, struct proc *p, int *status, int options);
949 void	proc_reparent(struct proc *child, struct proc *newparent);
950 void	proc_set_traced(struct proc *p, bool stop);
951 struct	pstats *pstats_alloc(void);
952 void	pstats_fork(struct pstats *src, struct pstats *dst);
953 void	pstats_free(struct pstats *ps);
954 void	reaper_abandon_children(struct proc *p, bool exiting);
955 int	securelevel_ge(struct ucred *cr, int level);
956 int	securelevel_gt(struct ucred *cr, int level);
957 void	sess_hold(struct session *);
958 void	sess_release(struct session *);
959 int	setrunnable(struct thread *);
960 void	setsugid(struct proc *p);
961 int	should_yield(void);
962 int	sigonstack(size_t sp);
963 void	stopevent(struct proc *, u_int, u_int);
964 struct	thread *tdfind(lwpid_t, pid_t);
965 void	threadinit(void);
966 void	tidhash_add(struct thread *);
967 void	tidhash_remove(struct thread *);
968 void	cpu_idle(int);
969 int	cpu_idle_wakeup(int);
970 extern	void (*cpu_idle_hook)(sbintime_t);	/* Hook to machdep CPU idler. */
971 void	cpu_switch(struct thread *, struct thread *, struct mtx *);
972 void	cpu_throw(struct thread *, struct thread *) __dead2;
973 void	unsleep(struct thread *);
974 void	userret(struct thread *, struct trapframe *);
975 
976 void	cpu_exit(struct thread *);
977 void	exit1(struct thread *, int) __dead2;
978 int	cpu_fetch_syscall_args(struct thread *td, struct syscall_args *sa);
979 void	cpu_fork(struct thread *, struct proc *, struct thread *, int);
980 void	cpu_set_fork_handler(struct thread *, void (*)(void *), void *);
981 void	cpu_set_syscall_retval(struct thread *, int);
982 void	cpu_set_upcall(struct thread *td, struct thread *td0);
983 void	cpu_set_upcall_kse(struct thread *, void (*)(void *), void *,
984 	    stack_t *);
985 int	cpu_set_user_tls(struct thread *, void *tls_base);
986 void	cpu_thread_alloc(struct thread *);
987 void	cpu_thread_clean(struct thread *);
988 void	cpu_thread_exit(struct thread *);
989 void	cpu_thread_free(struct thread *);
990 void	cpu_thread_swapin(struct thread *);
991 void	cpu_thread_swapout(struct thread *);
992 struct	thread *thread_alloc(int pages);
993 int	thread_alloc_stack(struct thread *, int pages);
994 int	thread_create(struct thread *td, struct rtprio *rtp,
995 	    int (*initialize_thread)(struct thread *, void *), void *thunk);
996 void	thread_exit(void) __dead2;
997 void	thread_free(struct thread *td);
998 void	thread_link(struct thread *td, struct proc *p);
999 void	thread_reap(void);
1000 int	thread_single(struct proc *p, int how);
1001 void	thread_single_end(struct proc *p, int how);
1002 void	thread_stash(struct thread *td);
1003 void	thread_stopped(struct proc *p);
1004 void	childproc_stopped(struct proc *child, int reason);
1005 void	childproc_continued(struct proc *child);
1006 void	childproc_exited(struct proc *child);
1007 int	thread_suspend_check(int how);
1008 bool	thread_suspend_check_needed(void);
1009 void	thread_suspend_switch(struct thread *, struct proc *p);
1010 void	thread_suspend_one(struct thread *td);
1011 void	thread_unlink(struct thread *td);
1012 void	thread_unsuspend(struct proc *p);
1013 void	thread_wait(struct proc *p);
1014 struct thread	*thread_find(struct proc *p, lwpid_t tid);
1015 
1016 void	stop_all_proc(void);
1017 void	resume_all_proc(void);
1018 
1019 static __inline int
curthread_pflags_set(int flags)1020 curthread_pflags_set(int flags)
1021 {
1022 	struct thread *td;
1023 	int save;
1024 
1025 	td = curthread;
1026 	save = ~flags | (td->td_pflags & flags);
1027 	td->td_pflags |= flags;
1028 	return (save);
1029 }
1030 
1031 static __inline void
curthread_pflags_restore(int save)1032 curthread_pflags_restore(int save)
1033 {
1034 
1035 	curthread->td_pflags &= save;
1036 }
1037 
1038 #endif	/* _KERNEL */
1039 
1040 #endif	/* !_SYS_PROC_H_ */
1041