Home
last modified time | relevance | path

Searched refs:wq (Results 1 – 25 of 135) sorted by relevance

123456

/illumos-gate/usr/src/uts/common/os/
H A Dwaitq.c44 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 Doce_tx.c117 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 Doce_queue.c474 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 Doce_gld.c103 (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 Drdsv3_impl.c558 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 Dbufmod.c345 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 Dtl.c2748 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 Dsundlpi.c43 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 Dpfmod.c207 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 Dstrsun.c43 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 Dmlxcx_ring.c408 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 Dmlxcx_gld.c474 (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 Dsvc_gen.c110 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 Drpcmod.c2013 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 Dhxge_hw.c478 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 Ddapl_tavor_wr.c62 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 Dsoftmac_dev.c402 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 Dsoftmac_pkt.c33 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 Dhermon_wr.c108 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 Daudio_sun.c645 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 Ddm2s.c116 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 Dfcip.c3704 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 Dnxge_hw.c592 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 Dtavor_wr.c2522 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 Doce_buf.h126 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);

123456