/illumos-gate/usr/src/uts/common/os/ |
H A D | waitq.c | 44 waitq_init(waitq_t *wq) in waitq_init() argument 47 wq->wq_first = NULL; in waitq_init() 48 wq->wq_count = 0; in waitq_init() 149 wq->wq_count++; in waitq_link() 150 t->t_waitq = wq; in waitq_link() 191 wq->wq_count--; in waitq_unlink() 232 waitq_link(wq, t); in waitq_enqueue() 253 waitq_link(wq, t); in waitq_change_pri() 296 if (wq == NULL) in waitq_setrun() 315 waitq_dequeue(wq, wq->wq_first); in waitq_takeone() [all …]
|
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/oce/ |
H A D | oce_tx.c | 117 dev = wq->parent; in oce_wqm_ctor() 150 ret = oce_wqm_ctor(&wq->wq_mdesc_array[cnt], wq); in oce_wqm_cache_create() 260 dev = wq->parent; in oce_wqb_ctor() 401 struct oce_wq *wq; in oce_get_wq() local 410 wq = dev->wq[qidx]; in oce_get_wq() 412 return (wq); in oce_get_wq() 565 cq = wq->cq; in oce_process_tx_compl() 566 dev = wq->parent; in oce_process_tx_compl() 617 dev = wq->parent; in oce_drain_wq_cq() 701 dev = wq->parent; in oce_send_packet() [all …]
|
H A D | oce_queue.c | 474 if (wq == NULL) { in oce_wq_init() 484 wq->cfg.nbufs = 2 * wq->cfg.q_len; in oce_wq_init() 485 wq->cfg.nhdl = 2 * wq->cfg.q_len; in oce_wq_init() 492 ret = oce_wqb_cache_create(wq, wq->cfg.buf_size); in oce_wq_init() 535 return (wq); in oce_wq_init() 569 wq->ring = NULL; in oce_wq_fini() 639 wq->cq = cq; in oce_wq_create() 642 wq->cq->cb_arg = (void *)wq; in oce_wq_create() 644 wq->wq_free = wq->cfg.q_len; in oce_wq_create() 649 wq->wq_id); in oce_wq_create() [all …]
|
H A D | oce_gld.c | 103 (void) oce_start_wq(dev->wq[qidx]); in oce_start() 145 mutex_enter(&dev->wq[qidx]->tx_lock); in oce_stop() 150 oce_clean_wq(dev->wq[qidx]); in oce_stop() 154 mutex_exit(&dev->wq[qidx]->tx_lock); in oce_stop() 287 struct oce_wq *wq; in oce_m_send() local 299 wq = oce_get_wq(dev, mp); in oce_m_send() 306 rmp = oce_send_packet(wq, mp); in oce_m_send() 309 wq->resched = B_TRUE; in oce_m_send() 587 miocnak(wq, mp, 0, EINVAL); in oce_m_ioctl() 608 miocnak(wq, mp, 0, ENOTSUP); in oce_m_ioctl() [all …]
|
/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/ |
H A D | rdsv3_impl.c | 558 switch (wq->wq_state) { in rdsv3_flush_workqueue() 650 dwp->wq->wq_pending--; in rdsv3_work_timeout_handler() 682 wq->wq_pending++; in rdsv3_queue_delayed_work() 687 dwp->wq = wq; in rdsv3_queue_delayed_work() 696 wq->wq_pending--; in rdsv3_queue_delayed_work() 723 dwp->wq->wq_pending--; in rdsv3_cancel_delayed_work() 735 ASSERT(wq); in rdsv3_destroy_task_workqueue() 756 wq = NULL; in rdsv3_destroy_task_workqueue() 787 if (wq == NULL) { in rdsv3_create_task_workqueue() 797 wq->wq_pending = 0; in rdsv3_create_task_workqueue() [all …]
|
/illumos-gate/usr/src/uts/common/io/ |
H A D | bufmod.c | 345 qreply(wq, mop); in sbioc() 415 sbioctl(wq, mp); in sbwput() 437 sbioc(wq, mp); in sbwput() 447 putnext(wq, mp); in sbwput() 593 qreply(wq, mp); in sbioctl() 722 qreply(wq, mp); in sbioctl() 782 qreply(wq, mp); in sbioctl() 790 qreply(wq, mp); in sbioctl() 862 qreply(wq, mp); in sbioctl() 873 qreply(wq, mp); in sbioctl() [all …]
|
H A D | tl.c | 2748 queue_t *wq; in tl_unbind() local 3135 queue_t *wq; in tl_conn_req_ser() local 3386 noenable(wq); in tl_conn_req_ser() 3415 queue_t *wq; in tl_conn_res() local 6298 enableok(wq); in tl_timer() 6303 qenable(wq); in tl_timer() 6317 enableok(wq); in tl_buffer() 6322 qenable(wq); in tl_buffer() 6336 noenable(wq); in tl_memrecover() 6338 (void) insq(wq, wq->q_first, mp); in tl_memrecover() [all …]
|
H A D | sundlpi.c | 43 queue_t *wq, in dlbindack() argument 66 qreply(wq, mp); in dlbindack() 71 queue_t *wq, in dlokack() argument 82 qreply(wq, mp); in dlokack() 87 queue_t *wq, in dlerrorack() argument 102 qreply(wq, mp); in dlerrorack() 107 queue_t *wq, in dluderrorind() argument 128 qreply(wq, mp); in dluderrorind() 133 queue_t *wq, in dlphysaddrack() argument 149 qreply(wq, mp); in dlphysaddrack() [all …]
|
H A D | pfmod.c | 207 pfwput(queue_t *wq, mblk_t *mp) in pfwput() argument 211 pfioctl(wq, mp); in pfwput() 215 putnext(wq, mp); in pfwput() 335 pfioctl(queue_t *wq, mblk_t *mp) in pfioctl() argument 360 miocnak(wq, mp, 0, error); in pfioctl() 365 miocnak(wq, mp, 0, EINVAL); in pfioctl() 376 miocnak(wq, mp, 0, error); in pfioctl() 382 miocnak(wq, mp, 0, EINVAL); in pfioctl() 395 miocnak(wq, mp, 0, EINVAL); in pfioctl() 443 miocack(wq, mp, 0, 0); in pfioctl() [all …]
|
H A D | strsun.c | 43 merror(queue_t *wq, mblk_t *mp, int error) in merror() argument 45 if ((mp = mexchange(wq, mp, 1, M_ERROR, -1)) == NULL) in merror() 49 qreply(wq, mp); in merror() 70 miocack(queue_t *wq, mblk_t *mp, int count, int rval) in miocack() argument 78 qreply(wq, mp); in miocack() 82 miocnak(queue_t *wq, mblk_t *mp, int count, int error) in miocnak() argument 89 qreply(wq, mp); in miocnak() 93 mexchange(queue_t *wq, mblk_t *mp, size_t size, uchar_t type, int32_t primtype) in mexchange() argument 98 if (wq != NULL) { in mexchange() 100 merror(wq, mp, ENOSR); in mexchange()
|
/illumos-gate/usr/src/uts/common/io/mlxcx/ |
H A D | mlxcx_ring.c | 408 wq->mlwq_cq = cq; in mlxcx_rq_setup() 424 wq->mlwq_bufhwm = wq->mlwq_nents - MLXCX_WQ_HWM_GAP; in mlxcx_rq_setup() 425 wq->mlwq_buflwm = wq->mlwq_nents - MLXCX_WQ_LWM_GAP; in mlxcx_rq_setup() 432 cq->mlcq_wq = wq; in mlxcx_rq_setup() 452 wq->mlwq_cq = cq; in mlxcx_sq_setup() 455 wq->mlwq_tis = tis; in mlxcx_sq_setup() 473 wq->mlwq_bufhwm = wq->mlwq_nents - MLXCX_WQ_HWM_GAP; in mlxcx_sq_setup() 474 wq->mlwq_buflwm = wq->mlwq_nents - MLXCX_WQ_LWM_GAP; in mlxcx_sq_setup() 481 cq->mlcq_wq = wq; in mlxcx_sq_setup() 504 cq = wq->mlwq_cq; in mlxcx_quiesce_rx_cqs() [all …]
|
H A D | mlxcx_gld.c | 474 (void) wq; in mlxcx_mac_ring_stat() 862 mutex_enter(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 867 mutex_exit(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 873 mutex_exit(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 904 mutex_exit(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 913 s = wq->mlwq_bufs; in mlxcx_mac_ring_stop() 922 s = wq->mlwq_foreign_bufs; in mlxcx_mac_ring_stop() 935 mutex_exit(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 937 mutex_exit(&wq->mlwq_mtx); in mlxcx_mac_ring_stop() 966 mlxcx_work_queue_t *wq; in mlxcx_mac_fill_tx_ring() local [all …]
|
/illumos-gate/usr/src/uts/common/rpc/ |
H A D | svc_gen.c | 110 queue_t *wq; in svc_tli_kcreate() local 130 wq = fp->f_vnode->v_stream->sd_wrq; in svc_tli_kcreate() 131 while ((wq = wq->q_next) != NULL) { in svc_tli_kcreate() 132 if (strcmp(wq->q_qinfo->qi_minfo->mi_idname, "rpcmod") == 0) in svc_tli_kcreate() 135 if (!wq) { in svc_tli_kcreate() 191 xprt->xp_wq = wq; in svc_tli_kcreate() 225 vp = (void **)wq->q_ptr; in svc_tli_kcreate() 235 create_putlocks(wq, 1); in svc_tli_kcreate()
|
H A D | rpcmod.c | 2013 qenable(RD(wq)); in mir_svc_start_close() 2019 qenable(wq); in mir_svc_start_close() 2023 mir_svc_hold(queue_t *wq) in mir_svc_hold() argument 2047 qenable(RD(wq)); in mir_svc_release() 2062 (void *)RD(wq)); in mir_svc_release() 2066 putnext(RD(wq), cmp); in mir_svc_release() 2079 mir_svc_idle_start(wq, mir); in mir_svc_release() 2100 mir_svc_start(queue_t *wq) in mir_svc_start() argument 2111 qenable(RD(wq)); in mir_svc_start() 2152 mir_clnt_idle_stop(wq, mir); in mir_clnt_idle_do_stop() [all …]
|
/illumos-gate/usr/src/uts/common/io/hxge/ |
H A D | hxge_hw.c | 478 miocnak(wq, mp, 0, EINVAL); in hxge_hw_ioctl() 487 miocnak(wq, mp, 0, EINVAL); in hxge_hw_ioctl() 492 miocack(wq, mp, 0, 0); in hxge_hw_ioctl() 497 miocack(wq, mp, 0, 0); in hxge_hw_ioctl() 518 miocnak(wq, mp, 0, EINVAL); in hxge_loopback_ioctl() 529 miocnak(wq, mp, 0, EINVAL); in hxge_loopback_ioctl() 535 miocack(wq, mp, 0, 0); in hxge_loopback_ioctl() 539 miocack(wq, mp, 0, 0); in hxge_loopback_ioctl() 541 miocnak(wq, mp, 0, EPROTO); in hxge_loopback_ioctl() 571 miocack(wq, mp, size, 0); in hxge_loopback_ioctl() [all …]
|
/illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/ |
H A D | dapl_tavor_wr.c | 62 dapls_tavor_workq_hdr_t *wq; in dapls_tavor_wrid_get_entry() local 74 dapl_os_assert(wq != NULL); in dapls_tavor_wrid_get_entry() 86 dapl_os_lock(&wq->wq_wrid_lock->wrl_lock); in dapls_tavor_wrid_get_entry() 113 dapl_os_unlock(&wq->wq_wrid_lock->wrl_lock); in dapls_tavor_wrid_get_entry() 148 container = wq->wq_wrid_poll; in dapli_tavor_wrid_find_match() 211 wq->wq_wrid_poll = container->wl_next; in dapli_tavor_wrid_find_match() 241 wq->wq_head = wq->wq_wrid_post->wl_head; in dapli_tavor_wrid_find_match() 242 wq->wq_full = wq->wq_wrid_post->wl_full; in dapli_tavor_wrid_find_match() 582 if (wq->wq_wrid_poll->wl_head == wq->wq_wrid_poll->wl_tail) { in dapli_tavor_wrid_get_wqeaddrsz() 592 head = wq->wq_wrid_poll->wl_head; in dapli_tavor_wrid_get_wqeaddrsz() [all …]
|
/illumos-gate/usr/src/uts/common/io/softmac/ |
H A D | softmac_dev.c | 402 ASSERT(wq->q_next != NULL); in softmac_mod_wput() 410 softmac_lower_t *slp = wq->q_ptr; in softmac_mod_wput() 414 miocnak(wq, mp, 0, EINVAL); in softmac_mod_wput() 429 miocnak(wq, mp, 0, EINVAL); in softmac_mod_wput() 442 softmac_mod_wsrv(queue_t *wq) in softmac_mod_wsrv() argument 444 softmac_lower_t *slp = wq->q_ptr; in softmac_mod_wsrv() 449 ASSERT(wq->q_next != NULL); in softmac_mod_wsrv() 625 ASSERT(wq->q_next == NULL); in softmac_drv_wput() 655 softmac_drv_wsrv(queue_t *wq) in softmac_drv_wsrv() argument 659 ASSERT(wq->q_next == NULL); in softmac_drv_wsrv() [all …]
|
H A D | softmac_pkt.c | 33 queue_t *wq = ((softmac_t *)arg)->smac_lower->sl_wq; in softmac_m_tx() local 39 if (!SOFTMAC_CANPUTNEXT(wq)) in softmac_m_tx() 43 putnext(wq, mp); in softmac_m_tx() 50 if (!SOFTMAC_CANPUTNEXT(wq)) in softmac_m_tx() 54 putnext(wq, mp); in softmac_m_tx()
|
/illumos-gate/usr/src/uts/common/io/ib/adapters/hermon/ |
H A D | hermon_wr.c | 108 wq = qp->qp_sq_wqhdr; in hermon_post_send_ud() 113 tail = wq->wq_tail; in hermon_post_send_ud() 114 head = wq->wq_head; in hermon_post_send_ud() 131 wq->wq_full = 1; in hermon_post_send_ud() 368 wq->wq_tail = tail; in hermon_post_send_ud() 488 wq->wq_full = 1; in hermon_post_send_rc() 711 wq->wq_tail = tail; in hermon_post_send_rc() 1182 wq->wq_full = 1; in hermon_post_recv() 2375 wq = wqa->wqa_wq; in hermon_wrid_get_entry() 2401 wq->wq_head = (indx + 1) & wq->wq_mask; in hermon_wrid_get_entry() [all …]
|
/illumos-gate/usr/src/uts/common/io/audio/impl/ |
H A D | audio_sun.c | 645 qreply(wq, mp); in devaudio_ioc_getinfo() 681 qreply(wq, mp); in devaudio_ioc_setinfo() 934 qreply(wq, mp); in devaudio_ioc_setinfo() 939 miocnak(wq, mp, 0, rv); in devaudio_ioc_setinfo() 964 qreply(wq, mp); in devaudio_ioc_getdev() 1130 queue_t *wq; in devaudio_miocdata() local 1133 wq = auclnt_get_wq(c); in devaudio_miocdata() 1243 qreply(wq, mp); in devaudioctl_wput() 1269 (void) putq(wq, mp); in devaudio_wput() 1298 qreply(wq, mp); in devaudio_wput() [all …]
|
/illumos-gate/usr/src/uts/sun4u/opl/io/ |
H A D | dm2s.c | 116 int dm2s_wsrv(queue_t *wq); 533 dm2s_wsrv(queue_t *wq) in dm2s_wsrv() argument 546 dm2s_start(wq, dm2sp); in dm2s_wsrv() 587 (void) putq(wq, mp); in dm2s_wput() 588 qenable(wq); in dm2s_wput() 597 qreply(wq, mp); in dm2s_wput() 628 flushq(wq, FLUSHDATA); in dm2s_wput() 635 qreply(wq, mp); in dm2s_wput() 937 flushq(wq, FLUSHDATA); in dm2s_start() 1086 (void) putbq(wq, mp); in dm2s_transmit() [all …]
|
/illumos-gate/usr/src/uts/common/io/fibre-channel/ulp/ |
H A D | fcip.c | 3704 if (wq->q_first) { in fcip_wput() 3707 qenable(wq); in fcip_wput() 3714 qenable(wq); in fcip_wput() 3740 qenable(wq); in fcip_wput() 3744 fcip_ioctl(wq, mp); in fcip_wput() 3760 qreply(wq, mp); in fcip_wput() 3803 fcip_areq(wq, mp); in fcip_proto() 3808 fcip_dreq(wq, mp); in fcip_proto() 3813 fcip_breq(wq, mp); in fcip_proto() 3823 fcip_ireq(wq, mp); in fcip_proto() [all …]
|
/illumos-gate/usr/src/uts/common/io/nxge/ |
H A D | nxge_hw.c | 592 miocnak(wq, mp, 0, EINVAL); in nxge_hw_ioctl() 600 miocnak(wq, mp, 0, EINVAL); in nxge_hw_ioctl() 610 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 620 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 625 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 630 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 635 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 639 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 644 miocack(wq, mp, 0, 0); in nxge_hw_ioctl() 679 miocack(wq, mp, 0, 0); in nxge_loopback_ioctl() [all …]
|
/illumos-gate/usr/src/uts/common/io/ib/adapters/tavor/ |
H A D | tavor_wr.c | 2522 head = wq->wq_wrid_post->wl_head; in tavor_wrid_add_entry() 2523 tail = wq->wq_wrid_post->wl_tail; in tavor_wrid_add_entry() 2524 size = wq->wq_wrid_post->wl_size; in tavor_wrid_add_entry() 2542 wq->wq_wrid_post->wl_tail = tail; in tavor_wrid_add_entry() 2551 wq->wq_wrid_post->wl_full = 1; in tavor_wrid_add_entry() 2602 tavor_workq_hdr_t *wq; in tavor_wrid_get_entry() local 2628 ASSERT(wq != NULL); in tavor_wrid_get_entry() 2702 container = wq->wq_wrid_poll; in tavor_wrid_find_match() 2796 wq->wq_head = wq->wq_wrid_post->wl_head; in tavor_wrid_find_match() 2797 wq->wq_full = wq->wq_wrid_post->wl_full; in tavor_wrid_find_match() [all …]
|
/illumos-gate/usr/src/uts/common/sys/fibre-channel/fca/oce/ |
H A D | oce_buf.h | 126 struct oce_wq *wq; member 181 int oce_wqb_cache_create(struct oce_wq *wq, size_t buf_size); 182 void oce_wqb_cache_destroy(struct oce_wq *wq); 184 void oce_wqm_cache_destroy(struct oce_wq *wq); 185 int oce_wqm_cache_create(struct oce_wq *wq);
|