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