1168404Spjd/*- 2168404Spjd * Copyright (c) 2007 Pawel Jakub Dawidek <pjd@FreeBSD.org> 3168404Spjd * All rights reserved. 4168404Spjd * 5168404Spjd * Redistribution and use in source and binary forms, with or without 6168404Spjd * modification, are permitted provided that the following conditions 7168404Spjd * are met: 8168404Spjd * 1. Redistributions of source code must retain the above copyright 9168404Spjd * notice, this list of conditions and the following disclaimer. 10168404Spjd * 2. Redistributions in binary form must reproduce the above copyright 11168404Spjd * notice, this list of conditions and the following disclaimer in the 12168404Spjd * documentation and/or other materials provided with the distribution. 13168404Spjd * 14168404Spjd * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND 15168404Spjd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 16168404Spjd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 17168404Spjd * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE 18168404Spjd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 19168404Spjd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 20168404Spjd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 21168404Spjd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 22168404Spjd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 23168404Spjd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 24168404Spjd * SUCH DAMAGE. 25168404Spjd * 26168404Spjd * $FreeBSD$ 27168404Spjd */ 28168404Spjd 29168404Spjd#ifndef _OPENSOLARIS_SYS_PROC_H_ 30168404Spjd#define _OPENSOLARIS_SYS_PROC_H_ 31168404Spjd 32168404Spjd#include <sys/param.h> 33168404Spjd#include <sys/kthread.h> 34168404Spjd#include_next <sys/proc.h> 35168404Spjd#include <sys/stdint.h> 36168404Spjd#include <sys/smp.h> 37196456Spjd#include <sys/sched.h> 38196456Spjd#include <sys/lock.h> 39196456Spjd#include <sys/mutex.h> 40196947Spjd#include <sys/unistd.h> 41168404Spjd#include <sys/debug.h> 42168404Spjd 43168404Spjd#ifdef _KERNEL 44168404Spjd 45168404Spjd#define CPU curcpu 46196456Spjd#define minclsyspri PRIBIO 47196456Spjd#define maxclsyspri PVM 48168404Spjd#define max_ncpus mp_ncpus 49168404Spjd#define boot_max_ncpus mp_ncpus 50168404Spjd 51168404Spjd#define TS_RUN 0 52168404Spjd 53168404Spjd#define p0 proc0 54168404Spjd 55219089Spjd#define t_tid td_tid 56219089Spjd 57168404Spjdtypedef short pri_t; 58168404Spjdtypedef struct thread _kthread; 59168404Spjdtypedef struct thread kthread_t; 60168404Spjdtypedef struct thread *kthread_id_t; 61168404Spjdtypedef struct proc proc_t; 62168404Spjd 63196458Spjdextern struct proc *zfsproc; 64196458Spjd 65168404Spjdstatic __inline kthread_t * 66286843Seddo_thread_create(caddr_t stk, size_t stksize, void (*proc)(void *), void *arg, 67168404Spjd size_t len, proc_t *pp, int state, pri_t pri) 68168404Spjd{ 69196458Spjd kthread_t *td = NULL; 70168404Spjd int error; 71168404Spjd 72168404Spjd /* 73168404Spjd * Be sure there are no surprises. 74168404Spjd */ 75168404Spjd ASSERT(stk == NULL); 76168404Spjd ASSERT(len == 0); 77168404Spjd ASSERT(state == TS_RUN); 78196458Spjd ASSERT(pp == &p0); 79168404Spjd 80196947Spjd error = kproc_kthread_add(proc, arg, &zfsproc, &td, RFSTOPPED, 81196458Spjd stksize / PAGE_SIZE, "zfskern", "solthread %p", proc); 82196458Spjd if (error == 0) { 83196456Spjd thread_lock(td); 84196456Spjd sched_prio(td, pri); 85196947Spjd sched_add(td, SRQ_BORING); 86196456Spjd thread_unlock(td); 87196456Spjd } 88196456Spjd return (td); 89168404Spjd} 90168404Spjd 91286843Sed#define thread_create(stk, stksize, proc, arg, len, pp, state, pri) \ 92286843Sed do_thread_create(stk, stksize, proc, arg, len, pp, state, pri) 93196458Spjd#define thread_exit() kthread_exit() 94168404Spjd 95168404Spjd#endif /* _KERNEL */ 96168404Spjd 97168404Spjd#endif /* _OPENSOLARIS_SYS_PROC_H_ */ 98