/*
 * 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) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
 */

#include <sys/ib/ibtl/impl/ibtl.h>
#include <sys/ib/ibtl/impl/ibtl_cm.h>
#include <sys/taskq.h>
#include <sys/disp.h>
#include <sys/callb.h>
#include <sys/proc.h>

/*
 * ibtl_handlers.c
 */

/*
 * What's in this file?
 *
 *   This file started as an implementation of Asynchronous Event/Error
 *   handling and Completion Queue handling.  As the implementation
 *   evolved, code has been added for other ibc_* interfaces (resume,
 *   predetach, etc.) that use the same mechanisms as used for asyncs.
 *
 * Async and CQ handling at interrupt level.
 *
 *   CQ handling is normally done at interrupt level using the CQ callback
 *   handler to call the appropriate IBT Client (owner of the CQ).  For
 *   clients that would prefer a fully flexible non-interrupt context to
 *   do their CQ handling, a CQ can be created so that its handler is
 *   called from a non-interrupt thread.  CQ handling is done frequently
 *   whereas Async handling is expected to occur very infrequently.
 *
 *   Async handling is done by marking (or'ing in of an async_code of) the
 *   pertinent IBTL data structure, and then notifying the async_thread(s)
 *   that the data structure has async work to be done.  The notification
 *   occurs by linking the data structure through its async_link onto a
 *   list of like data structures and waking up an async_thread.  This
 *   list append is not done if there is already async work pending on
 *   this data structure (IBTL_ASYNC_PENDING).
 *
 * Async Mutex and CQ Mutex
 *
 *   The global ibtl_async_mutex is "the" mutex used to control access
 *   to all the data needed by ibc_async_handler.  All the threads that
 *   use this mutex are written so that the mutex is held for very short
 *   periods of time, and never held while making calls to functions
 *   that may block.
 *
 *   The global ibtl_cq_mutex is used similarly by ibc_cq_handler and
 *   the ibtl_cq_thread(s).
 *
 * Mutex hierarchy
 *
 *   The ibtl_clnt_list_mutex is above the ibtl_async_mutex.
 *   ibtl_clnt_list_mutex protects all of the various lists.
 *   The ibtl_async_mutex is below this in the hierarchy.
 *
 *   The ibtl_cq_mutex is independent of the above mutexes.
 *
 * Threads
 *
 *   There are "ibtl_cq_threads" number of threads created for handling
 *   Completion Queues in threads.  If this feature really gets used,
 *   then we will want to do some suitable tuning.  Similarly, we may
 *   want to tune the number of "ibtl_async_thread_init".
 *
 *   The function ibtl_cq_thread is the main loop for handling a CQ in a
 *   thread.  There can be multiple threads executing this same code.
 *   The code sleeps when there is no work to be done (list is empty),
 *   otherwise it pulls the first CQ structure off the list and performs
 *   the CQ handler callback to the client.  After that returns, a check
 *   is made, and if another ibc_cq_handler call was made for this CQ,
 *   the client is called again.
 *
 *   The function ibtl_async_thread is the main loop for handling async
 *   events/errors.  There can be multiple threads executing this same code.
 *   The code sleeps when there is no work to be done (lists are empty),
 *   otherwise it pulls the first structure off one of the lists and
 *   performs the async callback(s) to the client(s).  Note that HCA
 *   async handling is done by calling each of the clients using the HCA.
 *   When the async handling completes, the data structure having the async
 *   event/error is checked for more work before it's considered "done".
 *
 * Taskq
 *
 *   The async_taskq is used here for allowing async handler callbacks to
 *   occur simultaneously to multiple clients of an HCA.  This taskq could
 *   be used for other purposes, e.g., if all the async_threads are in
 *   use, but this is deemed as overkill since asyncs should occur rarely.
 */

/* Globals */
static char ibtf_handlers[] = "ibtl_handlers";

/* priority for IBTL threads (async, cq, and taskq) */
static pri_t ibtl_pri = MAXCLSYSPRI - 1; /* maybe override in /etc/system */

/* taskq used for HCA asyncs */
#define ibtl_async_taskq system_taskq

/* data for async handling by threads */
static kmutex_t ibtl_async_mutex;       /* protects most *_async_* data */
static kcondvar_t ibtl_async_cv;        /* async_threads wait on this */
static kcondvar_t ibtl_clnt_cv;         /* ibt_detach might wait on this */
static void ibtl_dec_clnt_async_cnt(ibtl_clnt_t *clntp);
static void ibtl_inc_clnt_async_cnt(ibtl_clnt_t *clntp);

static kt_did_t *ibtl_async_did;        /* for thread_join() */
int ibtl_async_thread_init = 4; /* total # of async_threads to create */
static int ibtl_async_thread_exit = 0;  /* set if/when thread(s) should exit */

/* async lists for various structures */
static ibtl_hca_devinfo_t *ibtl_async_hca_list_start, *ibtl_async_hca_list_end;
static ibtl_eec_t *ibtl_async_eec_list_start, *ibtl_async_eec_list_end;
static ibtl_qp_t *ibtl_async_qp_list_start, *ibtl_async_qp_list_end;
static ibtl_cq_t *ibtl_async_cq_list_start, *ibtl_async_cq_list_end;
static ibtl_srq_t *ibtl_async_srq_list_start, *ibtl_async_srq_list_end;

/* data for CQ completion handling by threads */
static kmutex_t ibtl_cq_mutex;  /* protects the cv and the list below */
static kcondvar_t ibtl_cq_cv;
static ibtl_cq_t *ibtl_cq_list_start, *ibtl_cq_list_end;

static int ibtl_cq_threads = 0;         /* total # of cq threads */
static int ibtl_cqs_using_threads = 0;  /* total # of cqs using threads */
static int ibtl_cq_thread_exit = 0;     /* set if/when thread(s) should exit */

/* value used to tell IBTL threads to exit */
#define IBTL_THREAD_EXIT 0x1b7fdead     /* IBTF DEAD */
/* Cisco Topspin Vendor ID for Rereg hack */
#define IBT_VENDOR_CISCO 0x05ad

int ibtl_eec_not_supported = 1;

char *ibtl_last_client_name;    /* may help debugging */
typedef ibt_status_t (*ibtl_node_info_cb_t)(ib_guid_t, uint8_t, ib_lid_t,
    ibt_node_info_t *);

ibtl_node_info_cb_t ibtl_node_info_cb;

_NOTE(LOCK_ORDER(ibtl_clnt_list_mutex ibtl_async_mutex))

void
ibtl_cm_set_node_info_cb(ibt_status_t (*node_info_cb)(ib_guid_t, uint8_t,
    ib_lid_t, ibt_node_info_t *))
{
        mutex_enter(&ibtl_clnt_list_mutex);
        ibtl_node_info_cb = node_info_cb;
        mutex_exit(&ibtl_clnt_list_mutex);
}

/*
 * ibc_async_handler()
 *
 * Asynchronous Event/Error Handler.
 *
 *      This is the function called HCA drivers to post various async
 *      event and errors mention in the IB architecture spec.  See
 *      ibtl_types.h for additional details of this.
 *
 *      This function marks the pertinent IBTF object with the async_code,
 *      and queues the object for handling by an ibtl_async_thread.  If
 *      the object is NOT already marked for async processing, it is added
 *      to the associated list for that type of object, and an
 *      ibtl_async_thread is signaled to finish the async work.
 */
void
ibc_async_handler(ibc_clnt_hdl_t hca_devp, ibt_async_code_t code,
    ibc_async_event_t *event_p)
{
        ibtl_qp_t       *ibtl_qp;
        ibtl_cq_t       *ibtl_cq;
        ibtl_srq_t      *ibtl_srq;
        ibtl_eec_t      *ibtl_eec;
        uint8_t         port_minus1;

        ibtl_async_port_event_t *portp;

        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler(%p, 0x%x, %p)",
            hca_devp, code, event_p);

        mutex_enter(&ibtl_async_mutex);

        switch (code) {
        case IBT_EVENT_PATH_MIGRATED_QP:
        case IBT_EVENT_SQD:
        case IBT_ERROR_CATASTROPHIC_QP:
        case IBT_ERROR_PATH_MIGRATE_REQ_QP:
        case IBT_EVENT_COM_EST_QP:
        case IBT_ERROR_INVALID_REQUEST_QP:
        case IBT_ERROR_ACCESS_VIOLATION_QP:
        case IBT_EVENT_EMPTY_QP:
        case IBT_FEXCH_ERROR:
                ibtl_qp = event_p->ev_qp_hdl;
                if (ibtl_qp == NULL) {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler: "
                            "bad qp handle");
                        break;
                }
                switch (code) {
                case IBT_ERROR_CATASTROPHIC_QP:
                        ibtl_qp->qp_cat_fma_ena = event_p->ev_fma_ena; break;
                case IBT_ERROR_PATH_MIGRATE_REQ_QP:
                        ibtl_qp->qp_pth_fma_ena = event_p->ev_fma_ena; break;
                case IBT_ERROR_INVALID_REQUEST_QP:
                        ibtl_qp->qp_inv_fma_ena = event_p->ev_fma_ena; break;
                case IBT_ERROR_ACCESS_VIOLATION_QP:
                        ibtl_qp->qp_acc_fma_ena = event_p->ev_fma_ena; break;
                }

                ibtl_qp->qp_async_codes |= code;
                if ((ibtl_qp->qp_async_flags & IBTL_ASYNC_PENDING) == 0) {
                        ibtl_qp->qp_async_flags |= IBTL_ASYNC_PENDING;
                        ibtl_qp->qp_async_link = NULL;
                        if (ibtl_async_qp_list_end == NULL)
                                ibtl_async_qp_list_start = ibtl_qp;
                        else
                                ibtl_async_qp_list_end->qp_async_link = ibtl_qp;
                        ibtl_async_qp_list_end = ibtl_qp;
                        cv_signal(&ibtl_async_cv);
                }
                break;

        case IBT_ERROR_CQ:
                ibtl_cq = event_p->ev_cq_hdl;
                if (ibtl_cq == NULL) {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler: "
                            "bad cq handle");
                        break;
                }
                ibtl_cq->cq_async_codes |= code;
                ibtl_cq->cq_fma_ena = event_p->ev_fma_ena;
                if ((ibtl_cq->cq_async_flags & IBTL_ASYNC_PENDING) == 0) {
                        ibtl_cq->cq_async_flags |= IBTL_ASYNC_PENDING;
                        ibtl_cq->cq_async_link = NULL;
                        if (ibtl_async_cq_list_end == NULL)
                                ibtl_async_cq_list_start = ibtl_cq;
                        else
                                ibtl_async_cq_list_end->cq_async_link = ibtl_cq;
                        ibtl_async_cq_list_end = ibtl_cq;
                        cv_signal(&ibtl_async_cv);
                }
                break;

        case IBT_ERROR_CATASTROPHIC_SRQ:
        case IBT_EVENT_LIMIT_REACHED_SRQ:
                ibtl_srq = event_p->ev_srq_hdl;
                if (ibtl_srq == NULL) {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler: "
                            "bad srq handle");
                        break;
                }
                ibtl_srq->srq_async_codes |= code;
                ibtl_srq->srq_fma_ena = event_p->ev_fma_ena;
                if ((ibtl_srq->srq_async_flags & IBTL_ASYNC_PENDING) == 0) {
                        ibtl_srq->srq_async_flags |= IBTL_ASYNC_PENDING;
                        ibtl_srq->srq_async_link = NULL;
                        if (ibtl_async_srq_list_end == NULL)
                                ibtl_async_srq_list_start = ibtl_srq;
                        else
                                ibtl_async_srq_list_end->srq_async_link =
                                    ibtl_srq;
                        ibtl_async_srq_list_end = ibtl_srq;
                        cv_signal(&ibtl_async_cv);
                }
                break;

        case IBT_EVENT_PATH_MIGRATED_EEC:
        case IBT_ERROR_PATH_MIGRATE_REQ_EEC:
        case IBT_ERROR_CATASTROPHIC_EEC:
        case IBT_EVENT_COM_EST_EEC:
                if (ibtl_eec_not_supported) {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler: "
                            "EEC events are disabled.");
                        break;
                }
                ibtl_eec = event_p->ev_eec_hdl;
                if (ibtl_eec == NULL) {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibc_async_handler: "
                            "bad eec handle");
                        break;
                }
                switch (code) {
                case IBT_ERROR_PATH_MIGRATE_REQ_EEC:
                        ibtl_eec->eec_pth_fma_ena = event_p->ev_fma_ena; break;
                case IBT_ERROR_CATASTROPHIC_EEC:
                        ibtl_eec->eec_cat_fma_ena = event_p->ev_fma_ena; break;
                }
                ibtl_eec->eec_async_codes |= code;
                if ((ibtl_eec->eec_async_flags & IBTL_ASYNC_PENDING) == 0) {
                        ibtl_eec->eec_async_flags |= IBTL_ASYNC_PENDING;
                        ibtl_eec->eec_async_link = NULL;
                        if (ibtl_async_eec_list_end == NULL)
                                ibtl_async_eec_list_start = ibtl_eec;
                        else
                                ibtl_async_eec_list_end->eec_async_link =
                                    ibtl_eec;
                        ibtl_async_eec_list_end = ibtl_eec;
                        cv_signal(&ibtl_async_cv);
                }
                break;

        case IBT_ERROR_LOCAL_CATASTROPHIC:
                hca_devp->hd_async_codes |= code;
                hca_devp->hd_fma_ena = event_p->ev_fma_ena;
                /* FALLTHROUGH */

        case IBT_EVENT_PORT_UP:
        case IBT_PORT_CHANGE_EVENT:
        case IBT_CLNT_REREG_EVENT:
        case IBT_ERROR_PORT_DOWN:
                if ((code & IBT_PORT_EVENTS) != 0) {
                        if ((port_minus1 = event_p->ev_port - 1) >=
                            hca_devp->hd_hca_attr->hca_nports) {
                                IBTF_DPRINTF_L2(ibtf_handlers,
                                    "ibc_async_handler: bad port #: %d",
                                    event_p->ev_port);
                                break;
                        }
                        portp = &hca_devp->hd_async_port[port_minus1];
                        if (code == IBT_EVENT_PORT_UP) {
                                /*
                                 * The port is just coming UP we can't have any
                                 * valid older events.
                                 */
                                portp->status = IBTL_HCA_PORT_UP;
                        } else if (code == IBT_ERROR_PORT_DOWN) {
                                /*
                                 * The port is going DOWN older events don't
                                 * count.
                                 */
                                portp->status = IBTL_HCA_PORT_DOWN;
                        } else if (code == IBT_PORT_CHANGE_EVENT) {
                                /*
                                 * For port UP and DOWN events only the latest
                                 * event counts. If we get a UP after DOWN it
                                 * is sufficient to send just UP and vice versa.
                                 * In the case of port CHANGE event it is valid
                                 * only when the port is UP already but if we
                                 * receive it after UP but before UP is
                                 * delivered we still need to deliver CHANGE
                                 * after we deliver UP event.
                                 *
                                 * We will not get a CHANGE event when the port
                                 * is down or DOWN event is pending.
                                 */
                                portp->flags |= event_p->ev_port_flags;
                                portp->status |= IBTL_HCA_PORT_CHG;
                        } else if (code == IBT_CLNT_REREG_EVENT) {
                                /*
                                 * SM has requested a re-register of
                                 * subscription to SM events notification.
                                 */
                                portp->status |= IBTL_HCA_PORT_ASYNC_CLNT_REREG;
                        }

                        hca_devp->hd_async_codes |= code;
                }

                if ((hca_devp->hd_async_flags & IBTL_ASYNC_PENDING) == 0) {
                        hca_devp->hd_async_flags |= IBTL_ASYNC_PENDING;
                        hca_devp->hd_async_link = NULL;
                        if (ibtl_async_hca_list_end == NULL)
                                ibtl_async_hca_list_start = hca_devp;
                        else
                                ibtl_async_hca_list_end->hd_async_link =
                                    hca_devp;
                        ibtl_async_hca_list_end = hca_devp;
                        cv_signal(&ibtl_async_cv);
                }

                break;

        default:
                IBTF_DPRINTF_L1(ibtf_handlers, "ibc_async_handler: "
                    "invalid code (0x%x)", code);
        }

        mutex_exit(&ibtl_async_mutex);
}


/* Finally, make the async call to the client. */

static void
ibtl_async_client_call(ibtl_hca_t *ibt_hca, ibt_async_code_t code,
    ibt_async_event_t *event_p)
{
        ibtl_clnt_t             *clntp;
        void                    *client_private;
        ibt_async_handler_t     async_handler;
        char                    *client_name;

        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_async_client_call(%p, 0x%x, %p)",
            ibt_hca, code, event_p);

        clntp = ibt_hca->ha_clnt_devp;

        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_last_client_name))
        /* Record who is being called (just a debugging aid) */
        ibtl_last_client_name = client_name = clntp->clnt_name;
        _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_last_client_name))

        client_private = clntp->clnt_private;
        async_handler = clntp->clnt_modinfop->mi_async_handler;

        if (code & (IBT_EVENT_COM_EST_QP | IBT_EVENT_COM_EST_EEC)) {
                mutex_enter(&ibtl_clnt_list_mutex);
                async_handler = ibtl_cm_async_handler;
                client_private = ibtl_cm_clnt_private;
                mutex_exit(&ibtl_clnt_list_mutex);
                ibt_hca = NULL;
                IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_async_client_call: "
                    "calling CM for COM_EST");
        } else {
                IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_async_client_call: "
                    "calling client '%s'", client_name);
        }
        if (async_handler != NULL)
                async_handler(client_private, ibt_hca, code, event_p);
        else
                IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_async_client_call: "
                    "client '%s' has no async handler", client_name);
}

/*
 * Inform CM or DM about HCA events.
 *
 *      We use taskqs to allow simultaneous notification, with sleeping.
 *      Since taskqs only allow one argument, we define a structure
 *      because we need to pass in more than one argument.
 */

struct ibtl_mgr_s {
        ibtl_hca_devinfo_t      *mgr_hca_devp;
        ibt_async_handler_t     mgr_async_handler;
        void                    *mgr_clnt_private;
};

/*
 * Asyncs of HCA level events for CM and DM.  Call CM or DM and tell them
 * about the HCA for the event recorded in the ibtl_hca_devinfo_t.
 */
static void
ibtl_do_mgr_async_task(void *arg)
{
        struct ibtl_mgr_s       *mgrp = (struct ibtl_mgr_s *)arg;
        ibtl_hca_devinfo_t      *hca_devp = mgrp->mgr_hca_devp;

        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_do_mgr_async_task(0x%x)",
            hca_devp->hd_async_code);

        mgrp->mgr_async_handler(mgrp->mgr_clnt_private, NULL,
            hca_devp->hd_async_code, &hca_devp->hd_async_event);
        kmem_free(mgrp, sizeof (*mgrp));

        mutex_enter(&ibtl_clnt_list_mutex);
        if (--hca_devp->hd_async_task_cnt == 0)
                cv_signal(&hca_devp->hd_async_task_cv);
        mutex_exit(&ibtl_clnt_list_mutex);
}

static void
ibt_cisco_embedded_sm_rereg_fix(void *arg)
{
        struct ibtl_mgr_s *mgrp = arg;
        ibtl_hca_devinfo_t *hca_devp;
        ibt_node_info_t node_info;
        ibt_status_t ibt_status;
        ibtl_async_port_event_t *portp;
        ib_lid_t sm_lid;
        ib_guid_t hca_guid;
        ibt_async_event_t *event_p;
        ibt_hca_portinfo_t *pinfop;
        uint8_t port;

        hca_devp = mgrp->mgr_hca_devp;

        mutex_enter(&ibtl_clnt_list_mutex);
        event_p = &hca_devp->hd_async_event;
        port = event_p->ev_port;
        portp = &hca_devp->hd_async_port[port - 1];
        pinfop = &hca_devp->hd_portinfop[port - 1];
        sm_lid = pinfop->p_sm_lid;
        hca_guid = hca_devp->hd_hca_attr->hca_node_guid;
        mutex_exit(&ibtl_clnt_list_mutex);

        ibt_status = ((ibtl_node_info_cb_t)(uintptr_t)
            mgrp->mgr_async_handler)(hca_guid, port, sm_lid, &node_info);
        if (ibt_status == IBT_SUCCESS) {
                if ((node_info.n_vendor_id == IBT_VENDOR_CISCO) &&
                    (node_info.n_node_type == IBT_NODE_TYPE_SWITCH)) {
                        mutex_enter(&ibtl_async_mutex);
                        portp->status |= IBTL_HCA_PORT_ASYNC_CLNT_REREG;
                        hca_devp->hd_async_codes |= IBT_CLNT_REREG_EVENT;
                        mutex_exit(&ibtl_async_mutex);
                }
        }
        kmem_free(mgrp, sizeof (*mgrp));

        mutex_enter(&ibtl_clnt_list_mutex);
        if (--hca_devp->hd_async_task_cnt == 0)
                cv_signal(&hca_devp->hd_async_task_cv);
        mutex_exit(&ibtl_clnt_list_mutex);
}

static void
ibtl_cm_get_node_info(ibtl_hca_devinfo_t *hca_devp,
    ibt_async_handler_t async_handler)
{
        struct ibtl_mgr_s *mgrp;

        if (async_handler == NULL)
                return;

        _NOTE(NO_COMPETING_THREADS_NOW)
        mgrp = kmem_alloc(sizeof (*mgrp), KM_SLEEP);
        mgrp->mgr_hca_devp = hca_devp;
        mgrp->mgr_async_handler = async_handler;
        mgrp->mgr_clnt_private = NULL;
        hca_devp->hd_async_task_cnt++;

        (void) taskq_dispatch(ibtl_async_taskq,
            ibt_cisco_embedded_sm_rereg_fix, mgrp, TQ_SLEEP);
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif
}

static void
ibtl_tell_mgr(ibtl_hca_devinfo_t *hca_devp, ibt_async_handler_t async_handler,
    void *clnt_private)
{
        struct ibtl_mgr_s *mgrp;

        if (async_handler == NULL)
                return;

        _NOTE(NO_COMPETING_THREADS_NOW)
        mgrp = kmem_alloc(sizeof (*mgrp), KM_SLEEP);
        mgrp->mgr_hca_devp = hca_devp;
        mgrp->mgr_async_handler = async_handler;
        mgrp->mgr_clnt_private = clnt_private;
        hca_devp->hd_async_task_cnt++;

        (void) taskq_dispatch(ibtl_async_taskq, ibtl_do_mgr_async_task, mgrp,
            TQ_SLEEP);
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif
}

/*
 * Per client-device asyncs for HCA level events.  Call each client that is
 * using the HCA for the event recorded in the ibtl_hca_devinfo_t.
 */
static void
ibtl_hca_client_async_task(void *arg)
{
        ibtl_hca_t              *ibt_hca = (ibtl_hca_t *)arg;
        ibtl_hca_devinfo_t      *hca_devp = ibt_hca->ha_hca_devp;
        ibtl_clnt_t             *clntp = ibt_hca->ha_clnt_devp;
        ibt_async_event_t       async_event;

        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_hca_client_async_task(%p, 0x%x)",
            ibt_hca, hca_devp->hd_async_code);

        bcopy(&hca_devp->hd_async_event, &async_event, sizeof (async_event));
        ibtl_async_client_call(ibt_hca, hca_devp->hd_async_code, &async_event);

        mutex_enter(&ibtl_async_mutex);
        if (--ibt_hca->ha_async_cnt == 0 &&
            (ibt_hca->ha_async_flags & IBTL_ASYNC_FREE_OBJECT)) {
                mutex_exit(&ibtl_async_mutex);
                kmem_free(ibt_hca, sizeof (ibtl_hca_t));
        } else
                mutex_exit(&ibtl_async_mutex);

        mutex_enter(&ibtl_clnt_list_mutex);
        if (--hca_devp->hd_async_task_cnt == 0)
                cv_signal(&hca_devp->hd_async_task_cv);
        if (--clntp->clnt_async_cnt == 0)
                cv_broadcast(&ibtl_clnt_cv);

        mutex_exit(&ibtl_clnt_list_mutex);
}

/*
 * Asyncs for HCA level events.
 *
 * The function continues to run until there are no more async
 * events/errors for this HCA.  An event is chosen for dispatch
 * to all clients of this HCA.  This thread dispatches them via
 * the ibtl_async_taskq, then sleeps until all tasks are done.
 *
 * This thread records the async_code and async_event in the
 * ibtl_hca_devinfo_t for all client taskq threads to reference.
 *
 * This is called from an async or taskq thread with ibtl_async_mutex held.
 */
static void
ibtl_do_hca_asyncs(ibtl_hca_devinfo_t *hca_devp)
{
        ibtl_hca_t                      *ibt_hca;
        ibt_async_event_t               *eventp;
        ibt_async_code_t                code;
        ibtl_async_port_status_t        temp;
        uint8_t                         nports;
        uint8_t                         port_minus1;
        ibtl_async_port_event_t         *portp;

        mutex_exit(&ibtl_async_mutex);

        mutex_enter(&ibtl_clnt_list_mutex);
        while (hca_devp->hd_async_busy)
                cv_wait(&hca_devp->hd_async_busy_cv, &ibtl_clnt_list_mutex);
        hca_devp->hd_async_busy = 1;
        mutex_enter(&ibtl_async_mutex);

        bzero(&hca_devp->hd_async_event, sizeof (hca_devp->hd_async_event));
        for (;;) {

                hca_devp->hd_async_event.ev_fma_ena = 0;

                code = hca_devp->hd_async_codes;
                if (code & IBT_ERROR_LOCAL_CATASTROPHIC) {
                        code = IBT_ERROR_LOCAL_CATASTROPHIC;
                        hca_devp->hd_async_event.ev_fma_ena =
                            hca_devp->hd_fma_ena;
                } else if (code & IBT_ERROR_PORT_DOWN) {
                        code = IBT_ERROR_PORT_DOWN;
                        temp = IBTL_HCA_PORT_DOWN;
                } else if (code & IBT_EVENT_PORT_UP) {
                        code = IBT_EVENT_PORT_UP;
                        temp = IBTL_HCA_PORT_UP;
                } else if (code & IBT_PORT_CHANGE_EVENT) {
                        code = IBT_PORT_CHANGE_EVENT;
                        temp = IBTL_HCA_PORT_CHG;
                } else if (code & IBT_CLNT_REREG_EVENT) {
                        code = IBT_CLNT_REREG_EVENT;
                        temp = IBTL_HCA_PORT_ASYNC_CLNT_REREG;
                } else {
                        hca_devp->hd_async_codes = 0;
                        code = 0;
                }

                if (code == 0) {
                        hca_devp->hd_async_flags &= ~IBTL_ASYNC_PENDING;
                        break;
                }
                hca_devp->hd_async_codes &= ~code;

                /* PORT_UP, PORT_CHANGE, PORT_DOWN or ASYNC_REREG */
                if ((code & IBT_PORT_EVENTS) != 0) {
                        portp = hca_devp->hd_async_port;
                        nports = hca_devp->hd_hca_attr->hca_nports;
                        for (port_minus1 = 0; port_minus1 < nports;
                            port_minus1++) {
                                /*
                                 * Matching event in this port, let's go handle
                                 * it.
                                 */
                                if ((portp[port_minus1].status & temp) != 0)
                                        break;
                        }
                        if (port_minus1 >= nports) {
                                /* we checked again, but found nothing */
                                continue;
                        }
                        IBTF_DPRINTF_L4(ibtf_handlers, "ibtl_do_hca_asyncs: "
                            "async: port# %x code %x", port_minus1 + 1, code);
                        /* mark it to check for other ports after we're done */
                        hca_devp->hd_async_codes |= code;

                        /*
                         * Copy the event information into hca_devp and clear
                         * event information from the per port data.
                         */
                        hca_devp->hd_async_event.ev_port = port_minus1 + 1;
                        if (temp == IBTL_HCA_PORT_CHG) {
                                hca_devp->hd_async_event.ev_port_flags =
                                    hca_devp->hd_async_port[port_minus1].flags;
                                hca_devp->hd_async_port[port_minus1].flags = 0;
                        }
                        hca_devp->hd_async_port[port_minus1].status &= ~temp;

                        mutex_exit(&ibtl_async_mutex);
                        ibtl_reinit_hca_portinfo(hca_devp, port_minus1 + 1);
                        mutex_enter(&ibtl_async_mutex);
                        eventp = &hca_devp->hd_async_event;
                        eventp->ev_hca_guid =
                            hca_devp->hd_hca_attr->hca_node_guid;
                }

                hca_devp->hd_async_code = code;
                hca_devp->hd_async_event.ev_hca_guid =
                    hca_devp->hd_hca_attr->hca_node_guid;
                mutex_exit(&ibtl_async_mutex);

                /*
                 * Make sure to inform CM, DM, and IBMA if we know of them.
                 * Also, make sure not to inform them a second time, which
                 * would occur if they have the HCA open.
                 */

                if (ibtl_ibma_async_handler)
                        ibtl_tell_mgr(hca_devp, ibtl_ibma_async_handler,
                            ibtl_ibma_clnt_private);
                /* wait for all tasks to complete */
                while (hca_devp->hd_async_task_cnt != 0)
                        cv_wait(&hca_devp->hd_async_task_cv,
                            &ibtl_clnt_list_mutex);

                /*
                 * Hack Alert:
                 * The ibmf handler would have updated the Master SM LID if it
                 * was SM LID change event. Now lets check if the new Master SM
                 * is a Embedded Cisco Topspin SM.
                 */
                if ((code == IBT_PORT_CHANGE_EVENT) &&
                    eventp->ev_port_flags & IBT_PORT_CHANGE_SM_LID)
                        ibtl_cm_get_node_info(hca_devp,
                            (ibt_async_handler_t)(uintptr_t)ibtl_node_info_cb);
                /* wait for node info task to complete */
                while (hca_devp->hd_async_task_cnt != 0)
                        cv_wait(&hca_devp->hd_async_task_cv,
                            &ibtl_clnt_list_mutex);

                if (ibtl_dm_async_handler)
                        ibtl_tell_mgr(hca_devp, ibtl_dm_async_handler,
                            ibtl_dm_clnt_private);
                if (ibtl_cm_async_handler)
                        ibtl_tell_mgr(hca_devp, ibtl_cm_async_handler,
                            ibtl_cm_clnt_private);
                /* wait for all tasks to complete */
                while (hca_devp->hd_async_task_cnt != 0)
                        cv_wait(&hca_devp->hd_async_task_cv,
                            &ibtl_clnt_list_mutex);

                for (ibt_hca = hca_devp->hd_clnt_list;
                    ibt_hca != NULL;
                    ibt_hca = ibt_hca->ha_clnt_link) {

                        /* Managers are handled above */
                        if (IBTL_HCA2MODI_P(ibt_hca)->mi_async_handler ==
                            ibtl_cm_async_handler)
                                continue;
                        if (IBTL_HCA2MODI_P(ibt_hca)->mi_async_handler ==
                            ibtl_dm_async_handler)
                                continue;
                        if (IBTL_HCA2MODI_P(ibt_hca)->mi_async_handler ==
                            ibtl_ibma_async_handler)
                                continue;
                        ++ibt_hca->ha_clnt_devp->clnt_async_cnt;

                        mutex_enter(&ibtl_async_mutex);
                        ibt_hca->ha_async_cnt++;
                        mutex_exit(&ibtl_async_mutex);
                        hca_devp->hd_async_task_cnt++;
                        (void) taskq_dispatch(ibtl_async_taskq,
                            ibtl_hca_client_async_task, ibt_hca, TQ_SLEEP);
                }

                /* wait for all tasks to complete */
                while (hca_devp->hd_async_task_cnt != 0)
                        cv_wait(&hca_devp->hd_async_task_cv,
                            &ibtl_clnt_list_mutex);

                mutex_enter(&ibtl_async_mutex);
        }
        hca_devp->hd_async_code = 0;
        hca_devp->hd_async_busy = 0;
        cv_broadcast(&hca_devp->hd_async_busy_cv);
        mutex_exit(&ibtl_clnt_list_mutex);
}

/*
 * Asyncs for QP objects.
 *
 * The function continues to run until there are no more async
 * events/errors for this object.
 */
static void
ibtl_do_qp_asyncs(ibtl_qp_t *ibtl_qp)
{
        ibt_async_code_t        code;
        ibt_async_event_t       async_event;

        ASSERT(MUTEX_HELD(&ibtl_async_mutex));
        bzero(&async_event, sizeof (async_event));
        async_event.ev_chan_hdl = IBTL_QP2CHAN(ibtl_qp);

        while ((code = ibtl_qp->qp_async_codes) != 0) {
                async_event.ev_fma_ena = 0;
                if (ibtl_qp->qp_async_flags & IBTL_ASYNC_FREE_OBJECT)
                        code = 0;       /* fallthrough to "kmem_free" */
                else if (code & IBT_ERROR_CATASTROPHIC_QP) {
                        code = IBT_ERROR_CATASTROPHIC_QP;
                        async_event.ev_fma_ena = ibtl_qp->qp_cat_fma_ena;
                } else if (code & IBT_ERROR_INVALID_REQUEST_QP) {
                        code = IBT_ERROR_INVALID_REQUEST_QP;
                        async_event.ev_fma_ena = ibtl_qp->qp_inv_fma_ena;
                } else if (code & IBT_ERROR_ACCESS_VIOLATION_QP) {
                        code = IBT_ERROR_ACCESS_VIOLATION_QP;
                        async_event.ev_fma_ena = ibtl_qp->qp_acc_fma_ena;
                } else if (code & IBT_ERROR_PATH_MIGRATE_REQ_QP) {
                        code = IBT_ERROR_PATH_MIGRATE_REQ_QP;
                        async_event.ev_fma_ena = ibtl_qp->qp_pth_fma_ena;
                } else if (code & IBT_EVENT_PATH_MIGRATED_QP)
                        code = IBT_EVENT_PATH_MIGRATED_QP;
                else if (code & IBT_EVENT_SQD)
                        code = IBT_EVENT_SQD;
                else if (code & IBT_EVENT_COM_EST_QP)
                        code = IBT_EVENT_COM_EST_QP;
                else if (code & IBT_EVENT_EMPTY_QP)
                        code = IBT_EVENT_EMPTY_QP;
                else {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_do_qp_asyncs: "
                            "async: unexpected QP async code 0x%x", code);
                        ibtl_qp->qp_async_codes = 0;
                        code = 0;
                }
                ibtl_qp->qp_async_codes &= ~code;

                if (code) {
                        mutex_exit(&ibtl_async_mutex);
                        ibtl_async_client_call(ibtl_qp->qp_hca,
                            code, &async_event);
                        mutex_enter(&ibtl_async_mutex);
                }

                if (ibtl_qp->qp_async_flags & IBTL_ASYNC_FREE_OBJECT) {
                        mutex_exit(&ibtl_async_mutex);
                        cv_destroy(&(IBTL_QP2CHAN(ibtl_qp))->ch_cm_cv);
                        mutex_destroy(&(IBTL_QP2CHAN(ibtl_qp))->ch_cm_mutex);
                        kmem_free(IBTL_QP2CHAN(ibtl_qp),
                            sizeof (ibtl_channel_t));
                        mutex_enter(&ibtl_async_mutex);
                        return;
                }
        }
        ibtl_qp->qp_async_flags &= ~IBTL_ASYNC_PENDING;
}

/*
 * Asyncs for SRQ objects.
 *
 * The function continues to run until there are no more async
 * events/errors for this object.
 */
static void
ibtl_do_srq_asyncs(ibtl_srq_t *ibtl_srq)
{
        ibt_async_code_t        code;
        ibt_async_event_t       async_event;

        ASSERT(MUTEX_HELD(&ibtl_async_mutex));
        bzero(&async_event, sizeof (async_event));
        async_event.ev_srq_hdl = ibtl_srq;
        async_event.ev_fma_ena = ibtl_srq->srq_fma_ena;

        while ((code = ibtl_srq->srq_async_codes) != 0) {
                if (ibtl_srq->srq_async_flags & IBTL_ASYNC_FREE_OBJECT)
                        code = 0;       /* fallthrough to "kmem_free" */
                else if (code & IBT_ERROR_CATASTROPHIC_SRQ)
                        code = IBT_ERROR_CATASTROPHIC_SRQ;
                else if (code & IBT_EVENT_LIMIT_REACHED_SRQ)
                        code = IBT_EVENT_LIMIT_REACHED_SRQ;
                else {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_do_srq_asyncs: "
                            "async: unexpected SRQ async code 0x%x", code);
                        ibtl_srq->srq_async_codes = 0;
                        code = 0;
                }
                ibtl_srq->srq_async_codes &= ~code;

                if (code) {
                        mutex_exit(&ibtl_async_mutex);
                        ibtl_async_client_call(ibtl_srq->srq_hca,
                            code, &async_event);
                        mutex_enter(&ibtl_async_mutex);
                }

                if (ibtl_srq->srq_async_flags & IBTL_ASYNC_FREE_OBJECT) {
                        mutex_exit(&ibtl_async_mutex);
                        kmem_free(ibtl_srq, sizeof (struct ibtl_srq_s));
                        mutex_enter(&ibtl_async_mutex);
                        return;
                }
        }
        ibtl_srq->srq_async_flags &= ~IBTL_ASYNC_PENDING;
}

/*
 * Asyncs for CQ objects.
 *
 * The function continues to run until there are no more async
 * events/errors for this object.
 */
static void
ibtl_do_cq_asyncs(ibtl_cq_t *ibtl_cq)
{
        ibt_async_code_t        code;
        ibt_async_event_t       async_event;

        ASSERT(MUTEX_HELD(&ibtl_async_mutex));
        bzero(&async_event, sizeof (async_event));
        async_event.ev_cq_hdl = ibtl_cq;
        async_event.ev_fma_ena = ibtl_cq->cq_fma_ena;

        while ((code = ibtl_cq->cq_async_codes) != 0) {
                if (ibtl_cq->cq_async_flags & IBTL_ASYNC_FREE_OBJECT)
                        code = 0;       /* fallthrough to "kmem_free" */
                else if (code & IBT_ERROR_CQ)
                        code = IBT_ERROR_CQ;
                else {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_do_cq_asyncs: "
                            "async: unexpected CQ async code 0x%x", code);
                        ibtl_cq->cq_async_codes = 0;
                        code = 0;
                }
                ibtl_cq->cq_async_codes &= ~code;

                if (code) {
                        mutex_exit(&ibtl_async_mutex);
                        ibtl_async_client_call(ibtl_cq->cq_hca,
                            code, &async_event);
                        mutex_enter(&ibtl_async_mutex);
                }

                if (ibtl_cq->cq_async_flags & IBTL_ASYNC_FREE_OBJECT) {
                        mutex_exit(&ibtl_async_mutex);
                        mutex_destroy(&ibtl_cq->cq_mutex);
                        kmem_free(ibtl_cq, sizeof (struct ibtl_cq_s));
                        mutex_enter(&ibtl_async_mutex);
                        return;
                }
        }
        ibtl_cq->cq_async_flags &= ~IBTL_ASYNC_PENDING;
}

/*
 * Asyncs for EEC objects.
 *
 * The function continues to run until there are no more async
 * events/errors for this object.
 */
static void
ibtl_do_eec_asyncs(ibtl_eec_t *ibtl_eec)
{
        ibt_async_code_t        code;
        ibt_async_event_t       async_event;

        ASSERT(MUTEX_HELD(&ibtl_async_mutex));
        bzero(&async_event, sizeof (async_event));
        async_event.ev_chan_hdl = ibtl_eec->eec_channel;

        while ((code = ibtl_eec->eec_async_codes) != 0) {
                async_event.ev_fma_ena = 0;
                if (ibtl_eec->eec_async_flags & IBTL_ASYNC_FREE_OBJECT)
                        code = 0;       /* fallthrough to "kmem_free" */
                else if (code & IBT_ERROR_CATASTROPHIC_EEC) {
                        code = IBT_ERROR_CATASTROPHIC_CHAN;
                        async_event.ev_fma_ena = ibtl_eec->eec_cat_fma_ena;
                } else if (code & IBT_ERROR_PATH_MIGRATE_REQ_EEC) {
                        code = IBT_ERROR_PATH_MIGRATE_REQ;
                        async_event.ev_fma_ena = ibtl_eec->eec_pth_fma_ena;
                } else if (code & IBT_EVENT_PATH_MIGRATED_EEC)
                        code = IBT_EVENT_PATH_MIGRATED;
                else if (code & IBT_EVENT_COM_EST_EEC)
                        code = IBT_EVENT_COM_EST;
                else {
                        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_do_eec_asyncs: "
                            "async: unexpected code 0x%x", code);
                        ibtl_eec->eec_async_codes = 0;
                        code = 0;
                }
                ibtl_eec->eec_async_codes &= ~code;

                if (code) {
                        mutex_exit(&ibtl_async_mutex);
                        ibtl_async_client_call(ibtl_eec->eec_hca,
                            code, &async_event);
                        mutex_enter(&ibtl_async_mutex);
                }

                if (ibtl_eec->eec_async_flags & IBTL_ASYNC_FREE_OBJECT) {
                        mutex_exit(&ibtl_async_mutex);
                        kmem_free(ibtl_eec, sizeof (struct ibtl_eec_s));
                        mutex_enter(&ibtl_async_mutex);
                        return;
                }
        }
        ibtl_eec->eec_async_flags &= ~IBTL_ASYNC_PENDING;
}

#ifdef __lock_lint
kmutex_t cpr_mutex;
#endif

/*
 * Loop forever, calling async_handlers until all of the async lists
 * are empty.
 */

static void
ibtl_async_thread(void)
{
#ifndef __lock_lint
        kmutex_t cpr_mutex;
#endif
        callb_cpr_t     cprinfo;

        _NOTE(MUTEX_PROTECTS_DATA(cpr_mutex, cprinfo))
        _NOTE(NO_COMPETING_THREADS_NOW)
        mutex_init(&cpr_mutex, NULL, MUTEX_DRIVER, NULL);
        CALLB_CPR_INIT(&cprinfo, &cpr_mutex, callb_generic_cpr,
            "ibtl_async_thread");
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif

        mutex_enter(&ibtl_async_mutex);

        for (;;) {
                if (ibtl_async_hca_list_start) {
                        ibtl_hca_devinfo_t *hca_devp;

                        /* remove first entry from list */
                        hca_devp = ibtl_async_hca_list_start;
                        ibtl_async_hca_list_start = hca_devp->hd_async_link;
                        hca_devp->hd_async_link = NULL;
                        if (ibtl_async_hca_list_start == NULL)
                                ibtl_async_hca_list_end = NULL;

                        ibtl_do_hca_asyncs(hca_devp);

                } else if (ibtl_async_qp_list_start) {
                        ibtl_qp_t *ibtl_qp;

                        /* remove from list */
                        ibtl_qp = ibtl_async_qp_list_start;
                        ibtl_async_qp_list_start = ibtl_qp->qp_async_link;
                        ibtl_qp->qp_async_link = NULL;
                        if (ibtl_async_qp_list_start == NULL)
                                ibtl_async_qp_list_end = NULL;

                        ibtl_do_qp_asyncs(ibtl_qp);

                } else if (ibtl_async_srq_list_start) {
                        ibtl_srq_t *ibtl_srq;

                        /* remove from list */
                        ibtl_srq = ibtl_async_srq_list_start;
                        ibtl_async_srq_list_start = ibtl_srq->srq_async_link;
                        ibtl_srq->srq_async_link = NULL;
                        if (ibtl_async_srq_list_start == NULL)
                                ibtl_async_srq_list_end = NULL;

                        ibtl_do_srq_asyncs(ibtl_srq);

                } else if (ibtl_async_eec_list_start) {
                        ibtl_eec_t *ibtl_eec;

                        /* remove from list */
                        ibtl_eec = ibtl_async_eec_list_start;
                        ibtl_async_eec_list_start = ibtl_eec->eec_async_link;
                        ibtl_eec->eec_async_link = NULL;
                        if (ibtl_async_eec_list_start == NULL)
                                ibtl_async_eec_list_end = NULL;

                        ibtl_do_eec_asyncs(ibtl_eec);

                } else if (ibtl_async_cq_list_start) {
                        ibtl_cq_t *ibtl_cq;

                        /* remove from list */
                        ibtl_cq = ibtl_async_cq_list_start;
                        ibtl_async_cq_list_start = ibtl_cq->cq_async_link;
                        ibtl_cq->cq_async_link = NULL;
                        if (ibtl_async_cq_list_start == NULL)
                                ibtl_async_cq_list_end = NULL;

                        ibtl_do_cq_asyncs(ibtl_cq);

                } else {
                        if (ibtl_async_thread_exit == IBTL_THREAD_EXIT)
                                break;
                        mutex_enter(&cpr_mutex);
                        CALLB_CPR_SAFE_BEGIN(&cprinfo);
                        mutex_exit(&cpr_mutex);

                        cv_wait(&ibtl_async_cv, &ibtl_async_mutex);

                        mutex_exit(&ibtl_async_mutex);
                        mutex_enter(&cpr_mutex);
                        CALLB_CPR_SAFE_END(&cprinfo, &cpr_mutex);
                        mutex_exit(&cpr_mutex);
                        mutex_enter(&ibtl_async_mutex);
                }
        }

        mutex_exit(&ibtl_async_mutex);

#ifndef __lock_lint
        mutex_enter(&cpr_mutex);
        CALLB_CPR_EXIT(&cprinfo);
#endif
        mutex_destroy(&cpr_mutex);
}


void
ibtl_free_qp_async_check(ibtl_qp_t *ibtl_qp)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_qp_async_check(%p)", ibtl_qp);

        mutex_enter(&ibtl_async_mutex);

        /*
         * If there is an active async, mark this object to be freed
         * by the async_thread when it's done.
         */
        if (ibtl_qp->qp_async_flags & IBTL_ASYNC_PENDING) {
                ibtl_qp->qp_async_flags |= IBTL_ASYNC_FREE_OBJECT;
                mutex_exit(&ibtl_async_mutex);
        } else {        /* free the object now */
                mutex_exit(&ibtl_async_mutex);
                cv_destroy(&(IBTL_QP2CHAN(ibtl_qp))->ch_cm_cv);
                mutex_destroy(&(IBTL_QP2CHAN(ibtl_qp))->ch_cm_mutex);
                kmem_free(IBTL_QP2CHAN(ibtl_qp), sizeof (ibtl_channel_t));
        }
}

void
ibtl_free_cq_async_check(ibtl_cq_t *ibtl_cq)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_cq_async_check(%p)", ibtl_cq);

        mutex_enter(&ibtl_async_mutex);

        /* if there is an active async, mark this object to be freed */
        if (ibtl_cq->cq_async_flags & IBTL_ASYNC_PENDING) {
                ibtl_cq->cq_async_flags |= IBTL_ASYNC_FREE_OBJECT;
                mutex_exit(&ibtl_async_mutex);
        } else {        /* free the object now */
                mutex_exit(&ibtl_async_mutex);
                mutex_destroy(&ibtl_cq->cq_mutex);
                kmem_free(ibtl_cq, sizeof (struct ibtl_cq_s));
        }
}

void
ibtl_free_srq_async_check(ibtl_srq_t *ibtl_srq)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_srq_async_check(%p)",
            ibtl_srq);

        mutex_enter(&ibtl_async_mutex);

        /* if there is an active async, mark this object to be freed */
        if (ibtl_srq->srq_async_flags & IBTL_ASYNC_PENDING) {
                ibtl_srq->srq_async_flags |= IBTL_ASYNC_FREE_OBJECT;
                mutex_exit(&ibtl_async_mutex);
        } else {        /* free the object now */
                mutex_exit(&ibtl_async_mutex);
                kmem_free(ibtl_srq, sizeof (struct ibtl_srq_s));
        }
}

void
ibtl_free_eec_async_check(ibtl_eec_t *ibtl_eec)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_eec_async_check(%p)",
            ibtl_eec);

        mutex_enter(&ibtl_async_mutex);

        /* if there is an active async, mark this object to be freed */
        if (ibtl_eec->eec_async_flags & IBTL_ASYNC_PENDING) {
                ibtl_eec->eec_async_flags |= IBTL_ASYNC_FREE_OBJECT;
                mutex_exit(&ibtl_async_mutex);
        } else {        /* free the object now */
                mutex_exit(&ibtl_async_mutex);
                kmem_free(ibtl_eec, sizeof (struct ibtl_eec_s));
        }
}

/*
 * This function differs from above in that we assume this is called
 * from non-interrupt context, and never called from the async_thread.
 */

void
ibtl_free_hca_async_check(ibtl_hca_t *ibt_hca)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_hca_async_check(%p)",
            ibt_hca);

        mutex_enter(&ibtl_async_mutex);

        /* if there is an active async, mark this object to be freed */
        if (ibt_hca->ha_async_cnt > 0) {
                ibt_hca->ha_async_flags |= IBTL_ASYNC_FREE_OBJECT;
                mutex_exit(&ibtl_async_mutex);
        } else {        /* free the object now */
                mutex_exit(&ibtl_async_mutex);
                kmem_free(ibt_hca, sizeof (ibtl_hca_t));
        }
}

/*
 * Completion Queue Handling.
 *
 *      A completion queue can be handled through a simple callback
 *      at interrupt level, or it may be queued for an ibtl_cq_thread
 *      to handle.  The latter is chosen during ibt_alloc_cq when the
 *      IBTF_CQ_HANDLER_IN_THREAD is specified.
 */

static void
ibtl_cq_handler_call(ibtl_cq_t *ibtl_cq)
{
        ibt_cq_handler_t        cq_handler;
        void                    *arg;

        IBTF_DPRINTF_L4(ibtf_handlers, "ibtl_cq_handler_call(%p)", ibtl_cq);

        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*ibtl_cq))
        cq_handler = ibtl_cq->cq_comp_handler;
        arg = ibtl_cq->cq_arg;
        if (cq_handler != NULL)
                cq_handler(ibtl_cq, arg);
        else
                IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_cq_handler_call: "
                    "no cq_handler for cq %p", ibtl_cq);
}

/*
 * Before ibt_free_cq can continue, we need to ensure no more cq_handler
 * callbacks can occur.  When we get the mutex, we know there are no
 * outstanding cq_handler callbacks.  We set the cq_handler to NULL to
 * prohibit future callbacks.
 */
void
ibtl_free_cq_check(ibtl_cq_t *ibtl_cq)
{
        mutex_enter(&ibtl_cq->cq_mutex);
        ibtl_cq->cq_comp_handler = NULL;
        mutex_exit(&ibtl_cq->cq_mutex);
        if (ibtl_cq->cq_in_thread) {
                mutex_enter(&ibtl_cq_mutex);
                --ibtl_cqs_using_threads;
                while (ibtl_cq->cq_impl_flags & IBTL_CQ_PENDING) {
                        ibtl_cq->cq_impl_flags &= ~IBTL_CQ_CALL_CLIENT;
                        ibtl_cq->cq_impl_flags |= IBTL_CQ_FREE;
                        cv_wait(&ibtl_cq_cv, &ibtl_cq_mutex);
                }
                mutex_exit(&ibtl_cq_mutex);
        }
}

/*
 * Loop forever, calling cq_handlers until the cq list
 * is empty.
 */

static void
ibtl_cq_thread(void)
{
#ifndef __lock_lint
        kmutex_t cpr_mutex;
#endif
        callb_cpr_t     cprinfo;

        _NOTE(MUTEX_PROTECTS_DATA(cpr_mutex, cprinfo))
        _NOTE(NO_COMPETING_THREADS_NOW)
        mutex_init(&cpr_mutex, NULL, MUTEX_DRIVER, NULL);
        CALLB_CPR_INIT(&cprinfo, &cpr_mutex, callb_generic_cpr,
            "ibtl_cq_thread");
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif

        mutex_enter(&ibtl_cq_mutex);

        for (;;) {
                if (ibtl_cq_list_start) {
                        ibtl_cq_t *ibtl_cq;

                        ibtl_cq = ibtl_cq_list_start;
                        ibtl_cq_list_start = ibtl_cq->cq_link;
                        ibtl_cq->cq_link = NULL;
                        if (ibtl_cq == ibtl_cq_list_end)
                                ibtl_cq_list_end = NULL;

                        while (ibtl_cq->cq_impl_flags & IBTL_CQ_CALL_CLIENT) {
                                ibtl_cq->cq_impl_flags &= ~IBTL_CQ_CALL_CLIENT;
                                mutex_exit(&ibtl_cq_mutex);
                                ibtl_cq_handler_call(ibtl_cq);
                                mutex_enter(&ibtl_cq_mutex);
                        }
                        ibtl_cq->cq_impl_flags &= ~IBTL_CQ_PENDING;
                        if (ibtl_cq->cq_impl_flags & IBTL_CQ_FREE)
                                cv_broadcast(&ibtl_cq_cv);
                } else {
                        if (ibtl_cq_thread_exit == IBTL_THREAD_EXIT)
                                break;
                        mutex_enter(&cpr_mutex);
                        CALLB_CPR_SAFE_BEGIN(&cprinfo);
                        mutex_exit(&cpr_mutex);

                        cv_wait(&ibtl_cq_cv, &ibtl_cq_mutex);

                        mutex_exit(&ibtl_cq_mutex);
                        mutex_enter(&cpr_mutex);
                        CALLB_CPR_SAFE_END(&cprinfo, &cpr_mutex);
                        mutex_exit(&cpr_mutex);
                        mutex_enter(&ibtl_cq_mutex);
                }
        }

        mutex_exit(&ibtl_cq_mutex);
#ifndef __lock_lint
        mutex_enter(&cpr_mutex);
        CALLB_CPR_EXIT(&cprinfo);
#endif
        mutex_destroy(&cpr_mutex);
}


/*
 * ibc_cq_handler()
 *
 *    Completion Queue Notification Handler.
 *
 */
/*ARGSUSED*/
void
ibc_cq_handler(ibc_clnt_hdl_t ibc_hdl, ibt_cq_hdl_t ibtl_cq)
{
        IBTF_DPRINTF_L4(ibtf_handlers, "ibc_cq_handler(%p, %p)",
            ibc_hdl, ibtl_cq);

        if (ibtl_cq->cq_in_thread) {
                mutex_enter(&ibtl_cq_mutex);
                ibtl_cq->cq_impl_flags |= IBTL_CQ_CALL_CLIENT;
                if ((ibtl_cq->cq_impl_flags & IBTL_CQ_PENDING) == 0) {
                        ibtl_cq->cq_impl_flags |= IBTL_CQ_PENDING;
                        ibtl_cq->cq_link = NULL;
                        if (ibtl_cq_list_end == NULL)
                                ibtl_cq_list_start = ibtl_cq;
                        else
                                ibtl_cq_list_end->cq_link = ibtl_cq;
                        ibtl_cq_list_end = ibtl_cq;
                        cv_signal(&ibtl_cq_cv);
                }
                mutex_exit(&ibtl_cq_mutex);
                return;
        } else
                ibtl_cq_handler_call(ibtl_cq);
}


/*
 * ibt_enable_cq_notify()
 *      Enable Notification requests on the specified CQ.
 *
 *      ibt_cq          The CQ handle.
 *
 *      notify_type     Enable notifications for all (IBT_NEXT_COMPLETION)
 *                      completions, or the next Solicited completion
 *                      (IBT_NEXT_SOLICITED) only.
 *
 *      Completion notifications are disabled by setting the completion
 *      handler to NULL by calling ibt_set_cq_handler().
 */
ibt_status_t
ibt_enable_cq_notify(ibt_cq_hdl_t ibtl_cq, ibt_cq_notify_flags_t notify_type)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibt_enable_cq_notify(%p, %d)",
            ibtl_cq, notify_type);

        return (IBTL_CQ2CIHCAOPS_P(ibtl_cq)->ibc_notify_cq(
            IBTL_CQ2CIHCA(ibtl_cq), ibtl_cq->cq_ibc_cq_hdl, notify_type));
}


/*
 * ibt_set_cq_handler()
 *      Register a work request completion handler with the IBTF.
 *
 *      ibt_cq                  The CQ handle.
 *
 *      completion_handler      The completion handler.
 *
 *      arg                     The IBTF client private argument to be passed
 *                              back to the client when calling the CQ
 *                              completion handler.
 *
 *      Completion notifications are disabled by setting the completion
 *      handler to NULL.  When setting the handler to NULL, no additional
 *      calls to the previous CQ handler will be initiated, but there may
 *      be one in progress.
 *
 *      This function does not otherwise change the state of previous
 *      calls to ibt_enable_cq_notify().
 */
void
ibt_set_cq_handler(ibt_cq_hdl_t ibtl_cq, ibt_cq_handler_t completion_handler,
    void *arg)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibt_set_cq_handler(%p, %p, %p)",
            ibtl_cq, completion_handler, arg);

        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*ibtl_cq))
        ibtl_cq->cq_comp_handler = completion_handler;
        ibtl_cq->cq_arg = arg;
}


/*
 * Inform IBT clients about New HCAs.
 *
 *      We use taskqs to allow simultaneous notification, with sleeping.
 *      Since taskqs only allow one argument, we define a structure
 *      because we need to pass in two arguments.
 */

struct ibtl_new_hca_s {
        ibtl_clnt_t             *nh_clntp;
        ibtl_hca_devinfo_t      *nh_hca_devp;
        ibt_async_code_t        nh_code;
};

static void
ibtl_tell_client_about_new_hca(void *arg)
{
        struct ibtl_new_hca_s   *new_hcap = (struct ibtl_new_hca_s *)arg;
        ibtl_clnt_t             *clntp = new_hcap->nh_clntp;
        ibt_async_event_t       async_event;
        ibtl_hca_devinfo_t      *hca_devp = new_hcap->nh_hca_devp;

        bzero(&async_event, sizeof (async_event));
        async_event.ev_hca_guid = hca_devp->hd_hca_attr->hca_node_guid;
        clntp->clnt_modinfop->mi_async_handler(
            clntp->clnt_private, NULL, new_hcap->nh_code, &async_event);
        kmem_free(new_hcap, sizeof (*new_hcap));
#ifdef __lock_lint
        {
                ibt_hca_hdl_t hca_hdl;
                (void) ibt_open_hca(clntp, 0ULL, &hca_hdl);
        }
#endif
        mutex_enter(&ibtl_clnt_list_mutex);
        if (--hca_devp->hd_async_task_cnt == 0)
                cv_signal(&hca_devp->hd_async_task_cv);
        if (--clntp->clnt_async_cnt == 0)
                cv_broadcast(&ibtl_clnt_cv);
        mutex_exit(&ibtl_clnt_list_mutex);
}

/*
 * ibtl_announce_new_hca:
 *
 *      o First attach these clients in the given order
 *              IBMA
 *              IBCM
 *
 *      o Next attach all other clients in parallel.
 *
 * NOTE: Use the taskq to simultaneously notify all clients of the new HCA.
 * Retval from clients is ignored.
 */
void
ibtl_announce_new_hca(ibtl_hca_devinfo_t *hca_devp)
{
        ibtl_clnt_t             *clntp;
        struct ibtl_new_hca_s   *new_hcap;

        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_announce_new_hca(%p, %llX)",
            hca_devp, hca_devp->hd_hca_attr->hca_node_guid);

        mutex_enter(&ibtl_clnt_list_mutex);

        clntp = ibtl_clnt_list;
        while (clntp != NULL) {
                if (clntp->clnt_modinfop->mi_clnt_class == IBT_IBMA) {
                        IBTF_DPRINTF_L4(ibtf_handlers,
                            "ibtl_announce_new_hca: calling IBMF");
                        if (clntp->clnt_modinfop->mi_async_handler) {
                                _NOTE(NO_COMPETING_THREADS_NOW)
                                new_hcap = kmem_alloc(sizeof (*new_hcap),
                                    KM_SLEEP);
                                new_hcap->nh_clntp = clntp;
                                new_hcap->nh_hca_devp = hca_devp;
                                new_hcap->nh_code = IBT_HCA_ATTACH_EVENT;
#ifndef lint
                                _NOTE(COMPETING_THREADS_NOW)
#endif
                                clntp->clnt_async_cnt++;
                                hca_devp->hd_async_task_cnt++;

                                (void) taskq_dispatch(ibtl_async_taskq,
                                    ibtl_tell_client_about_new_hca, new_hcap,
                                    TQ_SLEEP);
                        }
                        break;
                }
                clntp = clntp->clnt_list_link;
        }
        if (clntp != NULL)
                while (clntp->clnt_async_cnt > 0)
                        cv_wait(&ibtl_clnt_cv, &ibtl_clnt_list_mutex);
        clntp = ibtl_clnt_list;
        while (clntp != NULL) {
                if (clntp->clnt_modinfop->mi_clnt_class == IBT_DM) {
                        IBTF_DPRINTF_L4(ibtf_handlers, "ibtl_announce_new_hca: "
                            "calling  %s", clntp->clnt_modinfop->mi_clnt_name);
                        if (clntp->clnt_modinfop->mi_async_handler) {
                                _NOTE(NO_COMPETING_THREADS_NOW)
                                new_hcap = kmem_alloc(sizeof (*new_hcap),
                                    KM_SLEEP);
                                new_hcap->nh_clntp = clntp;
                                new_hcap->nh_hca_devp = hca_devp;
                                new_hcap->nh_code = IBT_HCA_ATTACH_EVENT;
#ifndef lint
                                _NOTE(COMPETING_THREADS_NOW)
#endif
                                clntp->clnt_async_cnt++;
                                hca_devp->hd_async_task_cnt++;

                                mutex_exit(&ibtl_clnt_list_mutex);
                                (void) ibtl_tell_client_about_new_hca(
                                    new_hcap);
                                mutex_enter(&ibtl_clnt_list_mutex);
                        }
                        break;
                }
                clntp = clntp->clnt_list_link;
        }

        clntp = ibtl_clnt_list;
        while (clntp != NULL) {
                if (clntp->clnt_modinfop->mi_clnt_class == IBT_CM) {
                        IBTF_DPRINTF_L4(ibtf_handlers, "ibtl_announce_new_hca: "
                            "calling  %s", clntp->clnt_modinfop->mi_clnt_name);
                        if (clntp->clnt_modinfop->mi_async_handler) {
                                _NOTE(NO_COMPETING_THREADS_NOW)
                                new_hcap = kmem_alloc(sizeof (*new_hcap),
                                    KM_SLEEP);
                                new_hcap->nh_clntp = clntp;
                                new_hcap->nh_hca_devp = hca_devp;
                                new_hcap->nh_code = IBT_HCA_ATTACH_EVENT;
#ifndef lint
                                _NOTE(COMPETING_THREADS_NOW)
#endif
                                clntp->clnt_async_cnt++;
                                hca_devp->hd_async_task_cnt++;

                                (void) taskq_dispatch(ibtl_async_taskq,
                                    ibtl_tell_client_about_new_hca, new_hcap,
                                    TQ_SLEEP);
                        }
                        break;
                }
                clntp = clntp->clnt_list_link;
        }
        if (clntp != NULL)
                while (clntp->clnt_async_cnt > 0)
                        cv_wait(&ibtl_clnt_cv, &ibtl_clnt_list_mutex);
        clntp = ibtl_clnt_list;
        while (clntp != NULL) {
                if ((clntp->clnt_modinfop->mi_clnt_class != IBT_DM) &&
                    (clntp->clnt_modinfop->mi_clnt_class != IBT_CM) &&
                    (clntp->clnt_modinfop->mi_clnt_class != IBT_IBMA)) {
                        IBTF_DPRINTF_L4(ibtf_handlers,
                            "ibtl_announce_new_hca: Calling %s ",
                            clntp->clnt_modinfop->mi_clnt_name);
                        if (clntp->clnt_modinfop->mi_async_handler) {
                                _NOTE(NO_COMPETING_THREADS_NOW)
                                new_hcap = kmem_alloc(sizeof (*new_hcap),
                                    KM_SLEEP);
                                new_hcap->nh_clntp = clntp;
                                new_hcap->nh_hca_devp = hca_devp;
                                new_hcap->nh_code = IBT_HCA_ATTACH_EVENT;
#ifndef lint
                                _NOTE(COMPETING_THREADS_NOW)
#endif
                                clntp->clnt_async_cnt++;
                                hca_devp->hd_async_task_cnt++;

                                (void) taskq_dispatch(ibtl_async_taskq,
                                    ibtl_tell_client_about_new_hca, new_hcap,
                                    TQ_SLEEP);
                        }
                }
                clntp = clntp->clnt_list_link;
        }

        /* wait for all tasks to complete */
        while (hca_devp->hd_async_task_cnt != 0)
                cv_wait(&hca_devp->hd_async_task_cv, &ibtl_clnt_list_mutex);

        /* wakeup thread that may be waiting to send an HCA async */
        ASSERT(hca_devp->hd_async_busy == 1);
        hca_devp->hd_async_busy = 0;
        cv_broadcast(&hca_devp->hd_async_busy_cv);
        mutex_exit(&ibtl_clnt_list_mutex);
}

/*
 * ibtl_detach_all_clients:
 *
 *      Return value - 0 for Success, 1 for Failure
 *
 *      o First detach general clients.
 *
 *      o Next detach these clients
 *              IBCM
 *              IBDM
 *
 *      o Finally, detach this client
 *              IBMA
 */
int
ibtl_detach_all_clients(ibtl_hca_devinfo_t *hca_devp)
{
        ib_guid_t               hcaguid = hca_devp->hd_hca_attr->hca_node_guid;
        ibtl_hca_t              *ibt_hca;
        ibtl_clnt_t             *clntp;
        int                     retval;

        IBTF_DPRINTF_L2(ibtf_handlers, "ibtl_detach_all_clients(%llX)",
            hcaguid);

        ASSERT(MUTEX_HELD(&ibtl_clnt_list_mutex));

        while (hca_devp->hd_async_busy)
                cv_wait(&hca_devp->hd_async_busy_cv, &ibtl_clnt_list_mutex);
        hca_devp->hd_async_busy = 1;

        /* First inform general clients asynchronously */
        hca_devp->hd_async_event.ev_hca_guid = hcaguid;
        hca_devp->hd_async_event.ev_fma_ena = 0;
        hca_devp->hd_async_event.ev_chan_hdl = NULL;
        hca_devp->hd_async_event.ev_cq_hdl = NULL;
        hca_devp->hd_async_code = IBT_HCA_DETACH_EVENT;

        ibt_hca = hca_devp->hd_clnt_list;
        while (ibt_hca != NULL) {
                clntp = ibt_hca->ha_clnt_devp;
                if (IBTL_GENERIC_CLIENT(clntp)) {
                        ++ibt_hca->ha_clnt_devp->clnt_async_cnt;
                        mutex_enter(&ibtl_async_mutex);
                        ibt_hca->ha_async_cnt++;
                        mutex_exit(&ibtl_async_mutex);
                        hca_devp->hd_async_task_cnt++;

                        (void) taskq_dispatch(ibtl_async_taskq,
                            ibtl_hca_client_async_task, ibt_hca, TQ_SLEEP);
                }
                ibt_hca = ibt_hca->ha_clnt_link;
        }

        /* wait for all clients to complete */
        while (hca_devp->hd_async_task_cnt != 0) {
                cv_wait(&hca_devp->hd_async_task_cv, &ibtl_clnt_list_mutex);
        }
        /* Go thru the clients and check if any have not closed this HCA. */
        retval = 0;
        ibt_hca = hca_devp->hd_clnt_list;
        while (ibt_hca != NULL) {
                clntp = ibt_hca->ha_clnt_devp;
                if (IBTL_GENERIC_CLIENT(clntp)) {
                        IBTF_DPRINTF_L2(ibtf_handlers,
                            "ibtl_detach_all_clients: "
                            "client '%s' failed to close the HCA.",
                            ibt_hca->ha_clnt_devp->clnt_modinfop->mi_clnt_name);
                        retval = 1;
                }
                ibt_hca = ibt_hca->ha_clnt_link;
        }
        if (retval == 1)
                goto bailout;

        /* Next inform IBDM asynchronously */
        ibt_hca = hca_devp->hd_clnt_list;
        while (ibt_hca != NULL) {
                clntp = ibt_hca->ha_clnt_devp;
                if (clntp->clnt_modinfop->mi_clnt_class == IBT_DM) {
                        ++ibt_hca->ha_clnt_devp->clnt_async_cnt;
                        mutex_enter(&ibtl_async_mutex);
                        ibt_hca->ha_async_cnt++;
                        mutex_exit(&ibtl_async_mutex);
                        hca_devp->hd_async_task_cnt++;

                        mutex_exit(&ibtl_clnt_list_mutex);
                        ibtl_hca_client_async_task(ibt_hca);
                        mutex_enter(&ibtl_clnt_list_mutex);
                        break;
                }
                ibt_hca = ibt_hca->ha_clnt_link;
        }

        /*
         * Next inform IBCM.
         * As IBCM doesn't perform ibt_open_hca(), IBCM will not be
         * accessible via hca_devp->hd_clnt_list.
         * ibtl_cm_async_handler will NOT be NULL, if IBCM is registered.
         */
        if (ibtl_cm_async_handler) {
                ibtl_tell_mgr(hca_devp, ibtl_cm_async_handler,
                    ibtl_cm_clnt_private);

                /* wait for all tasks to complete */
                while (hca_devp->hd_async_task_cnt != 0)
                        cv_wait(&hca_devp->hd_async_task_cv,
                            &ibtl_clnt_list_mutex);
        }

        /* Go thru the clients and check if any have not closed this HCA. */
        retval = 0;
        ibt_hca = hca_devp->hd_clnt_list;
        while (ibt_hca != NULL) {
                clntp = ibt_hca->ha_clnt_devp;
                if (clntp->clnt_modinfop->mi_clnt_class != IBT_IBMA) {
                        IBTF_DPRINTF_L2(ibtf_handlers,
                            "ibtl_detach_all_clients: "
                            "client '%s' failed to close the HCA.",
                            ibt_hca->ha_clnt_devp->clnt_modinfop->mi_clnt_name);
                        retval = 1;
                }
                ibt_hca = ibt_hca->ha_clnt_link;
        }
        if (retval == 1)
                goto bailout;

        /* Finally, inform IBMA */
        ibt_hca = hca_devp->hd_clnt_list;
        while (ibt_hca != NULL) {
                clntp = ibt_hca->ha_clnt_devp;
                if (clntp->clnt_modinfop->mi_clnt_class == IBT_IBMA) {
                        ++ibt_hca->ha_clnt_devp->clnt_async_cnt;
                        mutex_enter(&ibtl_async_mutex);
                        ibt_hca->ha_async_cnt++;
                        mutex_exit(&ibtl_async_mutex);
                        hca_devp->hd_async_task_cnt++;

                        (void) taskq_dispatch(ibtl_async_taskq,
                            ibtl_hca_client_async_task, ibt_hca, TQ_SLEEP);
                } else
                        IBTF_DPRINTF_L2(ibtf_handlers,
                            "ibtl_detach_all_clients: "
                            "client '%s' is unexpectedly on the client list",
                            ibt_hca->ha_clnt_devp->clnt_modinfop->mi_clnt_name);
                ibt_hca = ibt_hca->ha_clnt_link;
        }

        /* wait for IBMA to complete */
        while (hca_devp->hd_async_task_cnt != 0) {
                cv_wait(&hca_devp->hd_async_task_cv, &ibtl_clnt_list_mutex);
        }

        /* Check if this HCA's client list is empty. */
        ibt_hca = hca_devp->hd_clnt_list;
        if (ibt_hca != NULL) {
                IBTF_DPRINTF_L2(ibtf_handlers,
                    "ibtl_detach_all_clients: "
                    "client '%s' failed to close the HCA.",
                    ibt_hca->ha_clnt_devp->clnt_modinfop->mi_clnt_name);
                retval = 1;
        } else
                retval = 0;

bailout:
        if (retval) {
                hca_devp->hd_state = IBTL_HCA_DEV_ATTACHED; /* fix hd_state */
                mutex_exit(&ibtl_clnt_list_mutex);
                ibtl_announce_new_hca(hca_devp);
                mutex_enter(&ibtl_clnt_list_mutex);
        } else {
                hca_devp->hd_async_busy = 0;
                cv_broadcast(&hca_devp->hd_async_busy_cv);
        }

        return (retval);
}

void
ibtl_free_clnt_async_check(ibtl_clnt_t *clntp)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_free_clnt_async_check(%p)", clntp);

        ASSERT(MUTEX_HELD(&ibtl_clnt_list_mutex));

        /* wait for all asyncs based on "ibtl_clnt_list" to complete */
        while (clntp->clnt_async_cnt != 0) {
                cv_wait(&ibtl_clnt_cv, &ibtl_clnt_list_mutex);
        }
}

static void
ibtl_dec_clnt_async_cnt(ibtl_clnt_t *clntp)
{
        mutex_enter(&ibtl_clnt_list_mutex);
        if (--clntp->clnt_async_cnt == 0) {
                cv_broadcast(&ibtl_clnt_cv);
        }
        mutex_exit(&ibtl_clnt_list_mutex);
}

static void
ibtl_inc_clnt_async_cnt(ibtl_clnt_t *clntp)
{
        mutex_enter(&ibtl_clnt_list_mutex);
        ++clntp->clnt_async_cnt;
        mutex_exit(&ibtl_clnt_list_mutex);
}


/*
 * Functions and data structures to inform clients that a notification
 * has occurred about Multicast Groups that might interest them.
 */
struct ibtl_sm_notice {
        ibt_clnt_hdl_t          np_ibt_hdl;
        ib_gid_t                np_sgid;
        ibt_subnet_event_code_t np_code;
        ibt_subnet_event_t      np_event;
};

static void
ibtl_sm_notice_task(void *arg)
{
        struct ibtl_sm_notice *noticep = (struct ibtl_sm_notice *)arg;
        ibt_clnt_hdl_t ibt_hdl = noticep->np_ibt_hdl;
        ibt_sm_notice_handler_t sm_notice_handler;

        sm_notice_handler = ibt_hdl->clnt_sm_trap_handler;
        if (sm_notice_handler != NULL)
                sm_notice_handler(ibt_hdl->clnt_sm_trap_handler_arg,
                    noticep->np_sgid, noticep->np_code, &noticep->np_event);
        kmem_free(noticep, sizeof (*noticep));
        ibtl_dec_clnt_async_cnt(ibt_hdl);
}

/*
 * Inform the client that MCG notices are not working at this time.
 */
void
ibtl_cm_sm_notice_init_failure(ibtl_cm_sm_init_fail_t *ifail)
{
        ibt_clnt_hdl_t ibt_hdl = ifail->smf_ibt_hdl;
        struct ibtl_sm_notice *noticep;
        ib_gid_t *sgidp = &ifail->smf_sgid[0];
        int i;

        for (i = 0; i < ifail->smf_num_sgids; i++) {
                _NOTE(NO_COMPETING_THREADS_NOW)
                noticep = kmem_zalloc(sizeof (*noticep), KM_SLEEP);
                noticep->np_ibt_hdl = ibt_hdl;
                noticep->np_sgid = *sgidp++;
                noticep->np_code = IBT_SM_EVENT_UNAVAILABLE;
#ifndef lint
                _NOTE(COMPETING_THREADS_NOW)
#endif
                ibtl_inc_clnt_async_cnt(ibt_hdl);
                (void) taskq_dispatch(ibtl_async_taskq,
                    ibtl_sm_notice_task, noticep, TQ_SLEEP);
        }
}

/*
 * Inform all clients of the event.
 */
void
ibtl_cm_sm_notice_handler(ib_gid_t sgid, ibt_subnet_event_code_t code,
    ibt_subnet_event_t *event)
{
        _NOTE(NO_COMPETING_THREADS_NOW)
        struct ibtl_sm_notice   *noticep;
        ibtl_clnt_t             *clntp;

        mutex_enter(&ibtl_clnt_list_mutex);
        clntp = ibtl_clnt_list;
        while (clntp != NULL) {
                if (clntp->clnt_sm_trap_handler) {
                        noticep = kmem_zalloc(sizeof (*noticep), KM_SLEEP);
                        noticep->np_ibt_hdl = clntp;
                        noticep->np_sgid = sgid;
                        noticep->np_code = code;
                        noticep->np_event = *event;
                        ++clntp->clnt_async_cnt;
                        (void) taskq_dispatch(ibtl_async_taskq,
                            ibtl_sm_notice_task, noticep, TQ_SLEEP);
                }
                clntp = clntp->clnt_list_link;
        }
        mutex_exit(&ibtl_clnt_list_mutex);
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif
}

/*
 * Record the handler for this client.
 */
void
ibtl_cm_set_sm_notice_handler(ibt_clnt_hdl_t ibt_hdl,
    ibt_sm_notice_handler_t sm_notice_handler, void *private)
{
        _NOTE(NO_COMPETING_THREADS_NOW)
        ibt_hdl->clnt_sm_trap_handler = sm_notice_handler;
        ibt_hdl->clnt_sm_trap_handler_arg = private;
#ifndef lint
        _NOTE(COMPETING_THREADS_NOW)
#endif
}


/*
 * ibtl_another_cq_handler_in_thread()
 *
 * Conditionally increase the number of cq_threads.
 * The number of threads grows, based on the number of cqs using threads.
 *
 * The table below controls the number of threads as follows:
 *
 *      Number of CQs   Number of cq_threads
 *              0               0
 *              1               1
 *              2-3             2
 *              4-5             3
 *              6-9             4
 *              10-15           5
 *              16-23           6
 *              24-31           7
 *              32+             8
 */

#define IBTL_CQ_MAXTHREADS 8
static uint8_t ibtl_cq_scaling[IBTL_CQ_MAXTHREADS] = {
        1, 2, 4, 6, 10, 16, 24, 32
};

static kt_did_t ibtl_cq_did[IBTL_CQ_MAXTHREADS];

void
ibtl_another_cq_handler_in_thread(void)
{
        kthread_t *t;
        int my_idx;

        mutex_enter(&ibtl_cq_mutex);
        if ((ibtl_cq_threads == IBTL_CQ_MAXTHREADS) ||
            (++ibtl_cqs_using_threads < ibtl_cq_scaling[ibtl_cq_threads])) {
                mutex_exit(&ibtl_cq_mutex);
                return;
        }
        my_idx = ibtl_cq_threads++;
        mutex_exit(&ibtl_cq_mutex);
        t = thread_create(NULL, 0, ibtl_cq_thread, NULL, 0, &p0, TS_RUN,
            ibtl_pri - 1);
        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_cq_did))
        ibtl_cq_did[my_idx] = t->t_did; /* save for thread_join() */
        _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_cq_did))
}

void
ibtl_thread_init(void)
{
        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_thread_init()");

        mutex_init(&ibtl_async_mutex, NULL, MUTEX_DEFAULT, NULL);
        cv_init(&ibtl_async_cv, NULL, CV_DEFAULT, NULL);
        cv_init(&ibtl_clnt_cv, NULL, CV_DEFAULT, NULL);

        mutex_init(&ibtl_cq_mutex, NULL, MUTEX_DEFAULT, NULL);
        cv_init(&ibtl_cq_cv, NULL, CV_DEFAULT, NULL);
}

void
ibtl_thread_init2(void)
{
        int i;
        static int initted = 0;
        kthread_t *t;

        mutex_enter(&ibtl_async_mutex);
        if (initted == 1) {
                mutex_exit(&ibtl_async_mutex);
                return;
        }
        initted = 1;
        mutex_exit(&ibtl_async_mutex);
        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_async_did))
        ibtl_async_did = kmem_zalloc(ibtl_async_thread_init * sizeof (kt_did_t),
            KM_SLEEP);

        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_thread_init2()");

        for (i = 0; i < ibtl_async_thread_init; i++) {
                t = thread_create(NULL, 0, ibtl_async_thread, NULL, 0, &p0,
                    TS_RUN, ibtl_pri - 1);
                ibtl_async_did[i] = t->t_did; /* thread_join() */
        }
        _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_async_did))
        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_cq_threads))
        for (i = 0; i < ibtl_cq_threads; i++) {
                t = thread_create(NULL, 0, ibtl_cq_thread, NULL, 0, &p0,
                    TS_RUN, ibtl_pri - 1);
                _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_cq_did))
                ibtl_cq_did[i] = t->t_did; /* save for thread_join() */
                _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_cq_did))
        }
        _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_cq_threads))
}

void
ibtl_thread_fini(void)
{
        int i;

        IBTF_DPRINTF_L3(ibtf_handlers, "ibtl_thread_fini()");

        /* undo the work done by ibtl_thread_init() */

        mutex_enter(&ibtl_cq_mutex);
        ibtl_cq_thread_exit = IBTL_THREAD_EXIT;
        cv_broadcast(&ibtl_cq_cv);
        mutex_exit(&ibtl_cq_mutex);

        mutex_enter(&ibtl_async_mutex);
        ibtl_async_thread_exit = IBTL_THREAD_EXIT;
        cv_broadcast(&ibtl_async_cv);
        mutex_exit(&ibtl_async_mutex);

        _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(ibtl_cq_threads))
        for (i = 0; i < ibtl_cq_threads; i++)
                thread_join(ibtl_cq_did[i]);
        _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(ibtl_cq_threads))

        if (ibtl_async_did) {
                for (i = 0; i < ibtl_async_thread_init; i++)
                        thread_join(ibtl_async_did[i]);

                kmem_free(ibtl_async_did,
                    ibtl_async_thread_init * sizeof (kt_did_t));
        }
        mutex_destroy(&ibtl_cq_mutex);
        cv_destroy(&ibtl_cq_cv);

        mutex_destroy(&ibtl_async_mutex);
        cv_destroy(&ibtl_async_cv);
        cv_destroy(&ibtl_clnt_cv);
}

/* ARGSUSED */
ibt_status_t ibtl_dummy_node_info_cb(ib_guid_t hca_guid, uint8_t port,
    ib_lid_t lid, ibt_node_info_t *node_info)
{
        return (IBT_SUCCESS);
}