1/*
2 * Copyright (c) 2007 Pawel Jakub Dawidek <pjd@FreeBSD.org>
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 * 1. Redistributions of source code must retain the above copyright
9 *    notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 *    notice, this list of conditions and the following disclaimer in the
12 *    documentation and/or other materials provided with the distribution.
13 *
14 * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
15 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
16 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
17 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
18 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
19 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
20 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
21 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
22 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
23 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
24 * SUCH DAMAGE.
25 *
26 * $FreeBSD$
27 */
28
29#ifndef _OPENSOLARIS_SYS_PROC_H_
30#define	_OPENSOLARIS_SYS_PROC_H_
31
32#include <sys/param.h>
33#include <sys/kthread.h>
34#include_next <sys/proc.h>
35#include <sys/stdint.h>
36#include <sys/smp.h>
37#include <sys/sched.h>
38#include <sys/lock.h>
39#include <sys/mutex.h>
40#include <sys/unistd.h>
41#include <sys/kmem.h>
42#include <sys/malloc.h>
43
44#ifdef _KERNEL
45#define	CPU		curcpu
46#define	minclsyspri	PRIBIO
47#define	defclsyspri minclsyspri
48#define	maxclsyspri	PVM
49#define	max_ncpus	(mp_maxid + 1)
50#define	boot_max_ncpus	(mp_maxid + 1)
51
52#define	TS_RUN	0
53
54#define	p0	proc0
55
56#define	t_tid	td_tid
57
58typedef	short		pri_t;
59typedef	struct thread	_kthread;
60typedef	struct thread	kthread_t;
61typedef struct thread	*kthread_id_t;
62typedef struct proc	proc_t;
63
64extern proc_t *system_proc;
65
66static __inline kthread_t *
67do_thread_create(caddr_t stk, size_t stksize, void (*proc)(void *), void *arg,
68    size_t len, proc_t *pp, int state, pri_t pri, const char *name)
69{
70	kthread_t *td = NULL;
71	proc_t **ppp;
72	int error;
73
74	/*
75	 * Be sure there are no surprises.
76	 */
77	ASSERT(stk == NULL);
78	ASSERT(len == 0);
79	ASSERT(state == TS_RUN);
80
81	if (pp == &p0)
82		ppp = &system_proc;
83	else
84		ppp = &pp;
85	error = kproc_kthread_add(proc, arg, ppp, &td, RFSTOPPED,
86	    stksize / PAGE_SIZE, "zfskern", "%s", name);
87	if (error == 0) {
88		thread_lock(td);
89		sched_prio(td, pri);
90		sched_add(td, SRQ_BORING);
91#if __FreeBSD_version < 1300068
92		thread_unlock(td);
93#endif
94	}
95	return (td);
96}
97
98#define	thread_create_named(name, stk, stksize, proc, arg, len,	\
99    pp, state, pri) \
100	do_thread_create(stk, stksize, proc, arg, len, pp, state, pri, name)
101#define	thread_create(stk, stksize, proc, arg, len, pp, state, pri) \
102	do_thread_create(stk, stksize, proc, arg, len, pp, state, pri, #proc)
103#define	thread_exit()	kthread_exit()
104
105int	uread(proc_t *, void *, size_t, uintptr_t);
106int	uwrite(proc_t *, void *, size_t, uintptr_t);
107
108static inline boolean_t
109zfs_proc_is_caller(proc_t *p)
110{
111	return (p == curproc);
112}
113
114#endif	/* _KERNEL */
115#endif	/* _OPENSOLARIS_SYS_PROC_H_ */
116