/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License (the "License").
* You may not use this file except in compliance with the License.
*
* You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
* or http://www.opensolaris.org/os/licensing.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at usr/src/OPENSOLARIS.LICENSE.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information: Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*/
/*
* Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved.
*/
#include <signal.h>
#include <fmd_alloc.h>
#include <fmd_thread.h>
#include <fmd_module.h>
#include <fmd_error.h>
#include <fmd_subr.h>
#include <fmd.h>
fmd_thread_t *
fmd_thread_xcreate(fmd_module_t *mp, pthread_t tid)
{
fmd_thread_t *tp = fmd_alloc(sizeof (fmd_thread_t), FMD_SLEEP);
tp->thr_mod = mp;
tp->thr_tid = tid;
tp->thr_func = NULL;
tp->thr_arg = NULL;
tp->thr_trdata = fmd_trace_create();
tp->thr_trfunc = (fmd_tracebuf_f *)fmd.d_thr_trace;
tp->thr_errdepth = 0;
tp->thr_isdoor = 0;
(void) pthread_mutex_lock(&fmd.d_thr_lock);
fmd_list_append(&fmd.d_thr_list, tp);
(void) pthread_mutex_unlock(&fmd.d_thr_lock);
return (tp);
}
static void *
fmd_thread_start(void *arg)
{
fmd_thread_t *tp = arg;
if (pthread_setspecific(fmd.d_key, tp) != 0)
fmd_panic("failed to initialize thread key to %p", arg);
if (!tp->thr_isdoor) {
(void) pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
(void) pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
}
tp->thr_func(tp->thr_arg);
return (NULL);
}
static fmd_thread_t *
fmd_thread_create_cmn(fmd_module_t *mp, fmd_thread_f *func, void *arg,
int isdoor)
{
fmd_thread_t *tp = fmd_alloc(sizeof (fmd_thread_t), FMD_SLEEP);
sigset_t oset, nset;
int err;
tp->thr_mod = mp;
tp->thr_func = func;
tp->thr_arg = arg;
tp->thr_trdata = fmd_trace_create();
tp->thr_trfunc = (fmd_tracebuf_f *)fmd.d_thr_trace;
tp->thr_errdepth = 0;
tp->thr_isdoor = isdoor;
(void) sigfillset(&nset);
(void) sigdelset(&nset, SIGABRT); /* always unblocked for fmd_panic() */
if (!isdoor)
(void) sigdelset(&nset, fmd.d_thr_sig); /* fmd_thr_signal() */
(void) pthread_sigmask(SIG_SETMASK, &nset, &oset);
err = pthread_create(&tp->thr_tid, NULL, fmd_thread_start, tp);
(void) pthread_sigmask(SIG_SETMASK, &oset, NULL);
if (err != 0) {
fmd_free(tp, sizeof (fmd_thread_t));
return (NULL);
}
(void) pthread_mutex_lock(&fmd.d_thr_lock);
fmd_list_append(&fmd.d_thr_list, tp);
(void) pthread_mutex_unlock(&fmd.d_thr_lock);
return (tp);
}
fmd_thread_t *
fmd_thread_create(fmd_module_t *mp, fmd_thread_f *func, void *arg)
{
return (fmd_thread_create_cmn(mp, func, arg, 0));
}
fmd_thread_t *
fmd_doorthread_create(fmd_module_t *mp, fmd_thread_f *func, void *arg)
{
return (fmd_thread_create_cmn(mp, func, arg, 1));
}
void
fmd_thread_destroy(fmd_thread_t *tp, int flag)
{
if (flag == FMD_THREAD_JOIN && tp->thr_tid != pthread_self() &&
pthread_join(tp->thr_tid, NULL) != 0) {
fmd_error(EFMD_MOD_JOIN, "failed to join thread for module "
"%s (tid %u)\n", tp->thr_mod->mod_name, tp->thr_tid);
}
(void) pthread_mutex_lock(&fmd.d_thr_lock);
fmd_list_delete(&fmd.d_thr_list, tp);
(void) pthread_mutex_unlock(&fmd.d_thr_lock);
fmd_trace_destroy(tp->thr_trdata);
fmd_free(tp, sizeof (fmd_thread_t));
}