fmd/common/fmd_thread.c

	fmd_thread.c revision f6e214c7418f43af38bd8c3a557e3d0a1d311cfa
/*
 * 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));
}