b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/*
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * This file and its contents are supplied under the terms of the
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * Common Development and Distribution License ("CDDL"), version 1.0.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * You may only use this file in accordance with the terms of version
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * 1.0 of the CDDL.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross *
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * A full copy of the text of the CDDL should have accompanied this
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * source. A copy of the CDDL is also available via the Internet at
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * http://www.illumos.org/license/CDDL.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/*
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * Copyright 2013 Nexenta Systems, Inc. All rights reserved.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross#include <sys/cmn_err.h>
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross#include <sys/thread.h>
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross#include <sys/zone.h>
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross#define _SYNCH_H /* keep out <synch.h> */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross#include <thread.h>
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/*
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * Get the current kthread_t pointer.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosskthread_t *
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross_curthread(void)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thread_t tid;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross tid = thr_self();
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross return ((kthread_t *)(uintptr_t)tid);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/*
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * Create a thread.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross *
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross * thread_create() blocks for memory if necessary. It never fails.
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/* ARGSUSED */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosskthread_t *
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossthread_create(
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross caddr_t stk,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross size_t stksize,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross void (*func)(),
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross void *arg,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross size_t len,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross struct proc *pp,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross int state,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross pri_t pri)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross void * (*thr_func)(void *);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thread_t newtid;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross int thr_flags = 0;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross int rc;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thr_flags = THR_BOUND;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross switch (state) {
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross case TS_RUN:
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross case TS_ONPROC:
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross break;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross case TS_STOPPED:
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thr_flags |= THR_SUSPENDED;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross break;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross default:
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross cmn_err(CE_PANIC, "thread_create: invalid state");
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross break;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross }
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thr_func = (void *(*)(void *))func;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross rc = thr_create(NULL, 0, thr_func, arg, thr_flags, &newtid);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross if (rc != 0)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross cmn_err(CE_PANIC, "thread_create failed, rc=%d", rc);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross return ((void *)(uintptr_t)newtid);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossvoid
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossthread_exit(void)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thr_exit(NULL);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossvoid
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossthread_join(kt_did_t id)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thread_t thr_id;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thr_id = (thread_t)id;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross (void) thr_join(thr_id, NULL, NULL);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossvoid
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosstsignal(kthread_t *kt, int sig)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thread_t tid = (thread_t)(uintptr_t)kt;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross (void) thr_kill(tid, sig);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross/*ARGSUSED*/
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosskthread_t *
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosszthread_create(
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross caddr_t stk,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross size_t stksize,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross void (*func)(),
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross void *arg,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross size_t len,
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross pri_t pri)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross kthread_t *t;
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross t = thread_create(stk, stksize, func, arg, len, NULL, TS_RUN, pri);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross return (t);
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rossvoid
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Rosszthread_exit(void)
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross{
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross thread_exit();
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross /* NOTREACHED */
b819cea2f73f98c5662230cc9affc8cc84f77fcfGordon Ross}