Skip to content
Permalink
Browse files

10573 define TASKQID_INVALID as (taskq_id)0

Reviewed by: Andy Stormont <astormont@racktopsystems.com>
Reviewed by: Gergő Doma <domag02@gmail.com>
Approved by: Dan McDonald <danmcd@joyent.com>
  • Loading branch information...
tsoome committed Mar 20, 2019
1 parent bcb78a4 commit fc8ae2ec4282de7ec96f48e11078345f3dc0ac3d
Showing with 185 additions and 152 deletions.
  1. +1 −1 usr/src/lib/libfakekernel/common/taskq.c
  2. +2 −1 usr/src/uts/common/crypto/api/kcf_random.c
  3. +3 −3 usr/src/uts/common/crypto/core/kcf_sched.c
  4. +1 −1 usr/src/uts/common/crypto/io/dprov.c
  5. +1 −1 usr/src/uts/common/fs/dnlc.c
  6. +1 −1 usr/src/uts/common/fs/smbsrv/smb_server.c
  7. +1 −1 usr/src/uts/common/fs/vnode.c
  8. +2 −2 usr/src/uts/common/fs/zfs/dmu_traverse.c
  9. +1 −1 usr/src/uts/common/fs/zfs/metaslab.c
  10. +1 −1 usr/src/uts/common/fs/zfs/vdev.c
  11. +1 −1 usr/src/uts/common/fs/zfs/vdev_file.c
  12. +2 −1 usr/src/uts/common/fs/zfs/zil.c
  13. +3 −2 usr/src/uts/common/inet/ip/ip_if.c
  14. +1 −1 usr/src/uts/common/inet/ip/ip_ndp.c
  15. +2 −2 usr/src/uts/common/inet/ip/ipsecah.c
  16. +3 −3 usr/src/uts/common/inet/ip/ipsecesp.c
  17. +1 −1 usr/src/uts/common/inet/kssl/ksslfilter.c
  18. +1 −1 usr/src/uts/common/inet/sadb.h
  19. +2 −2 usr/src/uts/common/inet/sctp/sctp.c
  20. +2 −1 usr/src/uts/common/io/comstar/port/iscsit/iscsit_login.c
  21. +1 −1 usr/src/uts/common/io/comstar/port/iscsit/iscsit_tgt.c
  22. +1 −1 usr/src/uts/common/io/comstar/port/pppt/pppt_tgt.c
  23. +2 −2 usr/src/uts/common/io/dld/dld_str.c
  24. +3 −3 usr/src/uts/common/io/emul64.c
  25. +1 −1 usr/src/uts/common/io/fibre-channel/impl/fp.c
  26. +3 −3 usr/src/uts/common/io/fibre-channel/ulp/fcip.c
  27. +1 −1 usr/src/uts/common/io/fibre-channel/ulp/fcp.c
  28. +1 −1 usr/src/uts/common/io/ib/clients/daplt/daplt.c
  29. +1 −1 usr/src/uts/common/io/ib/clients/of/sol_ofs/sol_cma.c
  30. +1 −1 usr/src/uts/common/io/ib/ibnex/ibnex.c
  31. +2 −2 usr/src/uts/common/io/ib/mgt/ibcm/ibcm_path.c
  32. +5 −3 usr/src/uts/common/io/ib/mgt/ibcm/ibcm_sm.c
  33. +2 −2 usr/src/uts/common/io/ib/mgt/ibcm/ibcm_ti.c
  34. +4 −4 usr/src/uts/common/io/ib/mgt/ibdm/ibdm.c
  35. +2 −2 usr/src/uts/common/io/ib/mgt/ibmf/ibmf_recv.c
  36. +1 −1 usr/src/uts/common/io/ib/mgt/ibmf/ibmf_saa_events.c
  37. +1 −1 usr/src/uts/common/io/ib/mgt/ibmf/ibmf_send.c
  38. +6 −4 usr/src/uts/common/io/idm/idm.c
  39. +2 −2 usr/src/uts/common/io/pciex/hotplug/pciehpc.c
  40. +53 −37 usr/src/uts/common/io/sata/impl/sata.c
  41. +2 −2 usr/src/uts/common/io/scsi/adapters/scsi_vhci/scsi_vhci.c
  42. +4 −4 usr/src/uts/common/io/scsi/targets/sd.c
  43. +2 −1 usr/src/uts/common/io/scsi/targets/sd_xbuf.c
  44. +3 −2 usr/src/uts/common/io/softmac/softmac_fp.c
  45. +1 −1 usr/src/uts/common/io/usb/usba/hcdi.c
  46. +3 −3 usr/src/uts/common/io/usb/usba/usbai_util.c
  47. +1 −1 usr/src/uts/common/os/console.c
  48. +2 −2 usr/src/uts/common/os/damap.c
  49. +2 −2 usr/src/uts/common/os/ddi_hp_ndi.c
  50. +10 −7 usr/src/uts/common/os/kmem.c
  51. +2 −2 usr/src/uts/common/os/serializer.c
  52. +1 −1 usr/src/uts/common/os/strsubr.c
  53. +1 −1 usr/src/uts/common/os/sunddi.c
  54. +2 −1 usr/src/uts/common/os/sunpm.c
  55. +1 −1 usr/src/uts/common/os/task.c
  56. +3 −3 usr/src/uts/common/os/taskq.c
  57. +1 −1 usr/src/uts/common/rpc/clnt_clts.c
  58. +2 −0 usr/src/uts/common/sys/taskq.h
  59. +1 −1 usr/src/uts/i86pc/vm/vm_machdep.c
  60. +1 −1 usr/src/uts/intel/io/ipmi/ipmi_kcs.c
  61. +2 −2 usr/src/uts/sun4u/cpu/us3_common.c
  62. +1 −1 usr/src/uts/sun4u/os/plat_ecc_unum.c
  63. +1 −1 usr/src/uts/sun4u/serengeti/io/sgsbbc_mailbox.c
  64. +3 −3 usr/src/uts/sun4u/starcat/io/drmach.c
  65. +1 −1 usr/src/uts/sun4u/starcat/io/schpc.c
  66. +2 −1 usr/src/uts/sun4u/starcat/io/sckmdrv.c
  67. +1 −1 usr/src/uts/sun4u/starcat/io/scosmb.c
  68. +2 −2 usr/src/uts/sun4v/io/ds_drv.c
  69. +2 −2 usr/src/uts/sun4v/io/vdc.c
@@ -162,7 +162,7 @@ taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags)
ASSERT(tq->tq_flags & TASKQ_ACTIVE);
if ((t = task_alloc(tq, tqflags)) == NULL) {
mutex_exit(&tq->tq_lock);
return (0);
return (TASKQID_INVALID);
}
if (tqflags & TQ_FRONT) {
t->tqent_next = tq->tq_task.tqent_next;
@@ -964,7 +964,8 @@ rnd_handler(void *arg)
* cache becomes empty.
*/
if (taskq_dispatch(system_taskq, rngprov_task,
(void *)(uintptr_t)len, TQ_NOSLEEP | TQ_NOQUEUE) == 0) {
(void *)(uintptr_t)len, TQ_NOSLEEP | TQ_NOQUEUE) ==
TASKQID_INVALID) {
rngprov_task_idle = B_TRUE;
}
}
@@ -563,7 +563,7 @@ kcf_resubmit_request(kcf_areq_node_t *areq)
taskq_t *taskq = new_pd->pd_taskq;

if (taskq_dispatch(taskq, process_req_hwp, areq, TQ_NOSLEEP) ==
(taskqid_t)0) {
TASKQID_INVALID) {
error = CRYPTO_HOST_MEMORY;
} else {
error = CRYPTO_QUEUED;
@@ -782,7 +782,7 @@ kcf_submit_request(kcf_provider_desc_t *pd, crypto_ctx_t *ctx,

if (taskq_dispatch(taskq,
process_req_hwp, areq, TQ_NOSLEEP) ==
(taskqid_t)0) {
TASKQID_INVALID) {
error = CRYPTO_HOST_MEMORY;
if (!(crq->cr_flag & CRYPTO_SKIP_REQID))
kcf_reqid_delete(areq);
@@ -1882,7 +1882,7 @@ kcf_next_req(void *next_req_arg, int status)
* here as we may be in interrupt context.
*/
if (taskq_dispatch(taskq, process_req_hwp, areq,
TQ_NOSLEEP) == (taskqid_t)0) {
TQ_NOSLEEP) == TASKQID_INVALID) {
error = CRYPTO_HOST_MEMORY;
} else {
error = CRYPTO_QUEUED;
@@ -5040,7 +5040,7 @@ dprov_taskq_dispatch(dprov_state_t *softc, dprov_req_t *taskq_req,
task_func_t *func, int kmflag)
{
if (taskq_dispatch(softc->ds_taskq, func, taskq_req,
kmflag == KM_NOSLEEP ? TQ_NOSLEEP : TQ_SLEEP) == (taskqid_t)0) {
kmflag == KM_NOSLEEP ? TQ_NOSLEEP : TQ_SLEEP) == TASKQID_INVALID) {
kmem_free(taskq_req, sizeof (dprov_req_t));
return (CRYPTO_HOST_MEMORY);
} else
@@ -954,7 +954,7 @@ dnlc_reduce_cache(void *reduce_percent)
if (dnlc_reduce_idle && (dnlc_nentries >= ncsize || reduce_percent)) {
dnlc_reduce_idle = 0;
if ((taskq_dispatch(system_taskq, do_dnlc_reduce_cache,
reduce_percent, TQ_NOSLEEP)) == (uintptr_t)NULL)
reduce_percent, TQ_NOSLEEP)) == TASKQID_INVALID)
dnlc_reduce_idle = 1;
}
}
@@ -2351,7 +2351,7 @@ smb_server_create_session(smb_listener_daemon_t *ld, ksocket_t s_so)
*/
tqid = taskq_dispatch(ld->ld_sv->sv_receiver_pool,
smb_server_receiver, rarg, TQ_NOQUEUE | TQ_SLEEP);
if (tqid == 0) {
if (tqid == TASKQID_INVALID) {
smb_mem_free(rarg);
smb_session_disconnect(session);
smb_server_destroy_session(ld, session);
@@ -915,7 +915,7 @@ vn_rele_async(vnode_t *vp, taskq_t *taskq)
if (vp->v_count == 1) {
mutex_exit(&vp->v_lock);
VERIFY(taskq_dispatch(taskq, (task_func_t *)vn_rele_inactive,
vp, TQ_SLEEP) != (uintptr_t)NULL);
vp, TQ_SLEEP) != TASKQID_INVALID);
return;
}
VN_RELE_LOCKED(vp);
@@ -598,8 +598,8 @@ traverse_impl(spa_t *spa, dsl_dataset_t *ds, uint64_t objset, blkptr_t *rootbp,
}

if (!(flags & TRAVERSE_PREFETCH_DATA) ||
0 == taskq_dispatch(system_taskq, traverse_prefetch_thread,
&td, TQ_NOQUEUE))
taskq_dispatch(system_taskq, traverse_prefetch_thread,
&td, TQ_NOQUEUE) == TASKQID_INVALID)
pd.pd_exited = B_TRUE;

SET_BOOKMARK(&czb, td.td_objset,
@@ -2247,7 +2247,7 @@ metaslab_group_preload(metaslab_group_t *mg)
}

VERIFY(taskq_dispatch(mg->mg_taskq, metaslab_preload,
msp, TQ_SLEEP) != NULL);
msp, TQ_SLEEP) != TASKQID_INVALID);
}
mutex_exit(&mg->mg_lock);
}
@@ -1352,7 +1352,7 @@ vdev_open_children(vdev_t *vd)

for (int c = 0; c < children; c++)
VERIFY(taskq_dispatch(tq, vdev_open_child, vd->vdev_child[c],
TQ_SLEEP) != NULL);
TQ_SLEEP) != TASKQID_INVALID);

taskq_destroy(tq);
}
@@ -245,7 +245,7 @@ vdev_file_io_start(zio_t *zio)
bp->b_iodone = vdev_file_io_intr;

VERIFY3U(taskq_dispatch(system_taskq, vdev_file_io_strategy, bp,
TQ_SLEEP), !=, 0);
TQ_SLEEP), !=, TASKQID_INVALID);
}

/* ARGSUSED */
@@ -1907,7 +1907,8 @@ zil_clean(zilog_t *zilog, uint64_t synced_txg)
ASSERT3P(zilog->zl_dmu_pool, !=, NULL);
ASSERT3P(zilog->zl_dmu_pool->dp_zil_clean_taskq, !=, NULL);
if (taskq_dispatch(zilog->zl_dmu_pool->dp_zil_clean_taskq,
(void (*)(void *))zil_itxg_clean, clean_me, TQ_NOSLEEP) == NULL)
(void (*)(void *))zil_itxg_clean, clean_me, TQ_NOSLEEP) ==
TASKQID_INVALID)
zil_itxg_clean(clean_me);
}

@@ -2246,7 +2246,8 @@ ill_taskq_dispatch(ip_stack_t *ipst)
mp->b_next = NULL;

VERIFY(taskq_dispatch(system_taskq,
ill_capability_ack_thr, mp, TQ_SLEEP) != 0);
ill_capability_ack_thr, mp, TQ_SLEEP) !=
TASKQID_INVALID);
mutex_enter(&ipst->ips_capab_taskq_lock);
mp = ipst->ips_capab_taskq_head;
}
@@ -2353,7 +2354,7 @@ ill_capability_ack(ill_t *ill, mblk_t *mp)
ASSERT(mp->b_next == NULL);

if (taskq_dispatch(system_taskq, ill_capability_ack_thr, mp,
TQ_NOSLEEP) != 0)
TQ_NOSLEEP) != TASKQID_INVALID)
return;

/*
@@ -1219,7 +1219,7 @@ nce_graveyard_free(list_t *graveyard)
}
mutex_exit(&ill->ill_lock);
if (!doit || taskq_dispatch(system_taskq, ncec_mcast_reap,
ill, TQ_NOSLEEP) == (taskqid_t)NULL) {
ill, TQ_NOSLEEP) == TASKQID_INVALID) {
mutex_enter(&ill->ill_lock);
if (doit) {
IP_STAT(ill->ill_ipst, ip_nce_mcast_reclaim_tqfail);
@@ -929,8 +929,8 @@ ah_add_sa_finish(mblk_t *mp, sadb_msg_t *samsg, keysock_in_t *ksi,
if (rc == 0) {
lpkt = sadb_clear_lpkt(larval);
if (lpkt != NULL) {
rc = !taskq_dispatch(ah_taskq, inbound_task,
lpkt, TQ_NOSLEEP);
rc = taskq_dispatch(ah_taskq, inbound_task,
lpkt, TQ_NOSLEEP) == TASKQID_INVALID;
}
}
IPSA_REFRELE(larval);
@@ -2130,7 +2130,7 @@ ipsecesp_send_keepalive(ipsa_t *assoc)
mp->b_prev = (mblk_t *)(uintptr_t)ns->netstack_stackid;

if (taskq_dispatch(esp_taskq, actually_send_keepalive, mp,
TQ_NOSLEEP) == 0) {
TQ_NOSLEEP) == TASKQID_INVALID) {
/* Assume no memory if taskq_dispatch() fails. */
mp->b_prev = NULL;
ip_drop_packet(mp, B_FALSE, NULL,
@@ -3221,8 +3221,8 @@ esp_add_sa_finish(mblk_t *mp, sadb_msg_t *samsg, keysock_in_t *ksi,
if (rc == 0) {
lpkt = sadb_clear_lpkt(larval);
if (lpkt != NULL) {
rc = !taskq_dispatch(esp_taskq, inbound_task,
lpkt, TQ_NOSLEEP);
rc = taskq_dispatch(esp_taskq, inbound_task,
lpkt, TQ_NOSLEEP) == TASKQID_INVALID;
}
}
IPSA_REFRELE(larval);
@@ -563,7 +563,7 @@ kssl_input_callback(void *arg, mblk_t *mp, kssl_cmd_t kssl_cmd)
* block when handling client_finish messages.
*/
if (taskq_dispatch(system_taskq, kssl_input_asynch, handle,
TQ_NOSLEEP) == NULL) {
TQ_NOSLEEP) == TASKQID_INVALID) {
DTRACE_PROBE(kssl_err__taskq_dispatch_failed);
kssl_async_done(kssl->ksslf_ctx);
}
@@ -794,7 +794,7 @@ void sadb_clear_buf_pkt(void *ipkt);
{ \
if (buf_pkt != NULL) { \
if (taskq_dispatch(taskq, sadb_clear_buf_pkt, \
(void *) buf_pkt, TQ_NOSLEEP) == 0) { \
(void *) buf_pkt, TQ_NOSLEEP) == TASKQID_INVALID) { \
/* Dispatch was unsuccessful drop the packets. */ \
mblk_t *tmp; \
while (buf_pkt != NULL) { \
@@ -1788,7 +1788,7 @@ sctp_find_next_tq(sctp_t *sctp)
for (try = 0; try < sctps->sctps_recvq_tq_list_cur_sz; try++) {
tq = sctps->sctps_recvq_tq_list[next_tq];
if (taskq_dispatch(tq, sctp_process_recvq, sctp,
TQ_NOSLEEP) != (uintptr_t)NULL) {
TQ_NOSLEEP) != TASKQID_INVALID) {
sctp->sctp_recvq_tq = tq;
return (B_TRUE);
}
@@ -1804,7 +1804,7 @@ sctp_find_next_tq(sctp_t *sctp)
sctp_inc_taskq(sctps);
tq = sctps->sctps_recvq_tq_list[sctps->sctps_recvq_tq_list_cur_sz - 1];
if (taskq_dispatch(tq, sctp_process_recvq, sctp, TQ_NOSLEEP) !=
(uintptr_t)NULL) {
TASKQID_INVALID) {
sctp->sctp_recvq_tq = tq;
return (B_TRUE);
}
@@ -382,7 +382,8 @@ iscsit_login_sm_event_locked(iscsit_conn_t *ict, iscsit_login_event_t event,
if (lsm->icl_login_complete) {
lsm->icl_busy = B_TRUE;
if (taskq_dispatch(iscsit_global.global_dispatch_taskq,
login_sm_complete, ict, DDI_SLEEP) == NULL) {
login_sm_complete, ict, DDI_SLEEP) ==
TASKQID_INVALID) {
cmn_err(CE_WARN, "iscsit_login_sm_event_locked:"
" Failed to dispatch task");
}
@@ -650,7 +650,7 @@ iscsit_tgt_dereg_retry(void *arg)
* If it fails we'll setup another timeout and try again later.
*/
if (taskq_dispatch(iscsit_global.global_dispatch_taskq,
iscsit_tgt_dereg_task, tgt, DDI_NOSLEEP) == NULL) {
iscsit_tgt_dereg_task, tgt, DDI_NOSLEEP) == TASKQID_INVALID) {
/* Dispatch failed, try again later */
(void) timeout(iscsit_tgt_dereg_retry, tgt,
drv_usectohz(TGT_DEREG_RETRY_SECONDS * 1000000));
@@ -802,7 +802,7 @@ pppt_tgt_dereg_retry(void *arg)
* If it fails we'll setup another timeout and try again later.
*/
if (taskq_dispatch(pppt_global.global_dispatch_taskq,
pppt_tgt_dereg_task, tgt, KM_NOSLEEP) == NULL) {
pppt_tgt_dereg_task, tgt, KM_NOSLEEP) == TASKQID_INVALID) {
/* Dispatch failed, try again later */
(void) timeout(pppt_tgt_dereg_retry, tgt,
drv_usectohz(TGT_DEREG_RETRY_SECONDS * 1000000));
@@ -1957,7 +1957,7 @@ dld_taskq_dispatch(void)
list_remove(&dld_taskq_list, dsp);
mutex_exit(&dld_taskq_lock);
VERIFY(taskq_dispatch(dld_taskq, dld_wput_nondata_task,
dsp, TQ_SLEEP) != 0);
dsp, TQ_SLEEP) != TASKQID_INVALID);
mutex_enter(&dld_taskq_lock);
dsp = list_head(&dld_taskq_list);
}
@@ -2024,7 +2024,7 @@ dld_wput_nondata(dld_str_t *dsp, mblk_t *mp)
mutex_exit(&dsp->ds_lock);

if (taskq_dispatch(dld_taskq, dld_wput_nondata_task, dsp,
TQ_NOSLEEP) != 0)
TQ_NOSLEEP) != TASKQID_INVALID)
return;

mutex_enter(&dld_taskq_lock);
@@ -1029,7 +1029,7 @@ emul64_scsi_start(struct scsi_address *ap, struct scsi_pkt *pkt)
if ((emul64_usetaskq == 0) || (pkt->pkt_flags & FLAG_NOINTR) != 0) {
emul64_pkt_comp((caddr_t)pkt);
} else {
dispatched = NULL;
dispatched = TASKQID_INVALID;
if (emul64_collect_stats) {
/*
* If we are collecting statistics, call
@@ -1042,14 +1042,14 @@ emul64_scsi_start(struct scsi_address *ap, struct scsi_pkt *pkt)
*/
dispatched = taskq_dispatch(emul64->emul64_taskq,
emul64_pkt_comp, (void *)pkt, TQ_NOSLEEP);
if (dispatched == NULL) {
if (dispatched == TASKQID_INVALID) {
/* Queue was full. dispatch failed. */
mutex_enter(&emul64_stats_mutex);
emul64_taskq_max++;
mutex_exit(&emul64_stats_mutex);
}
}
if (dispatched == NULL) {
if (dispatched == TASKQID_INVALID) {
(void) taskq_dispatch(emul64->emul64_taskq,
emul64_pkt_comp, (void *)pkt, TQ_SLEEP);
}
@@ -4839,7 +4839,7 @@ fp_ulp_devc_cb(fc_local_port_t *port, fc_portmap_t *changelist,
}

ret = taskq_dispatch(port->fp_taskq, fctl_ulp_statec_cb, clist, sleep);
if (sync && ret) {
if (sync && ret != TASKQID_INVALID) {
mutex_enter(&clist->clist_mutex);
while (clist->clist_wait) {
cv_wait(&clist->clist_cv, &clist->clist_mutex);
@@ -4583,7 +4583,7 @@ fcip_handle_topology(struct fcip *fptr)
if (!(fptr->fcip_flags & FCIP_REG_INPROGRESS)) {
fptr->fcip_flags |= FCIP_REG_INPROGRESS;
if (taskq_dispatch(fptr->fcip_tq, fcip_port_ns,
fptr, KM_NOSLEEP) == 0) {
fptr, KM_NOSLEEP) == TASKQID_INVALID) {
fptr->fcip_flags &= ~FCIP_REG_INPROGRESS;
}
}
@@ -7258,7 +7258,7 @@ fcip_timeout(void *arg)

if (taskq_dispatch(fptr->fcip_tq,
fcip_rte_remove_deferred, fptr,
KM_NOSLEEP) == 0) {
KM_NOSLEEP) == TASKQID_INVALID) {
/*
* failed - so mark the entry
* as invalid again.
@@ -7302,7 +7302,7 @@ fcip_timeout(void *arg)
mutex_exit(&fdestp->fcipd_mutex);
if (taskq_dispatch(fptr->fcip_tq,
fcip_pkt_timeout, fcip_pkt,
KM_NOSLEEP) == 0) {
KM_NOSLEEP) == TASKQID_INVALID) {
/*
* timeout immediately
*/
@@ -14458,7 +14458,7 @@ fcp_pass_to_hp(struct fcp_port *pptr, struct fcp_lun *plun,
}
mutex_exit(&plun->lun_mutex);
if (taskq_dispatch(DEVI(pdip)->devi_taskq, fcp_hp_task,
(void *)elem, KM_NOSLEEP) == NULL) {
(void *)elem, KM_NOSLEEP) == TASKQID_INVALID) {
mutex_enter(&plun->lun_mutex);
if (elem->what == FCP_ONLINE || elem->what == FCP_OFFLINE) {
plun->lun_event_count--;
@@ -1893,7 +1893,7 @@ daplka_timer_dispatch(void *arg)
* taskq_dispatch succeeds.
*/
if (taskq_dispatch(daplka_taskq,
daplka_timer_thread, arg, TQ_NOSLEEP) == 0) {
daplka_timer_thread, arg, TQ_NOSLEEP) == TASKQID_INVALID) {
DERR("timer_dispatch: taskq_dispatch failed, retrying...\n");
(void) timeout(daplka_timer_dispatch, arg, 10);
}
@@ -1686,7 +1686,7 @@ cma_generate_event(struct rdma_cm_id *idp, enum rdma_cm_event_type event,
}

if (taskq_dispatch(system_taskq, cma_generate_event_thr,
(void *)event_arg, TQ_SLEEP) == 0) {
(void *)event_arg, TQ_SLEEP) == TASKQID_INVALID) {
SOL_OFS_DPRINTF_L2(sol_rdmacm_dbg_str,
"generate_event_async: taskq_dispatch() failed!!");
mutex_enter(&chanp->chan_mutex);
@@ -867,7 +867,7 @@ ibnex_ibtl_callback(ibtl_ibnex_cb_args_t *cb_args)
* from interrupt context.
*/
if (taskq_dispatch(system_taskq, ibnex_handle_reprobe_dev,
clnt_dip, TQ_SLEEP) == 0) {
clnt_dip, TQ_SLEEP) == TASKQID_INVALID) {
IBTF_DPRINTF_L2("ibnex",
"ibnex_ibtl_callback: taskq_dispatch failed");
mutex_enter(&ibnex.ibnex_mutex);
@@ -482,7 +482,7 @@ ibcm_handle_get_path(ibt_path_attr_t *attrp, ibt_path_flags_t flags,
if (func != NULL) { /* Non-Blocking */
IBTF_DPRINTF_L3(cmlog, "ibcm_handle_get_path: Non Blocking");
if (taskq_dispatch(ibcm_taskq, ibcm_process_async_get_paths,
path_tq, TQ_NOSLEEP) == 0) {
path_tq, TQ_NOSLEEP) == TASKQID_INVALID) {
IBTF_DPRINTF_L2(cmlog, "ibcm_handle_get_path: "
"Failed to dispatch the TaskQ");
kmem_free(path_tq, len);
@@ -4169,7 +4169,7 @@ ibcm_get_ip_path(ibt_clnt_hdl_t ibt_hdl, ibt_path_flags_t flags,
sleep_flag = ((func == NULL) ? TQ_SLEEP : TQ_NOSLEEP);
ret = taskq_dispatch(ibcm_taskq, ibcm_process_get_ip_paths, path_tq,
sleep_flag);
if (ret == 0) {
if (ret == TASKQID_INVALID) {
IBTF_DPRINTF_L2(cmlog, "ibcm_get_ip_path: Failed to dispatch "
"the TaskQ");
if (func == NULL) { /* Blocking */

0 comments on commit fc8ae2e

Please sign in to comment.
You can’t perform that action at this time.