Home
last modified time | relevance | path

Searched refs:qpp (Results 1 – 15 of 15) sorted by relevance

/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_trans.c178 ibmf_alt_qp_t *qpp = in ibmf_i_notify_client() local
180 mutex_enter(&qpp->isq_mutex); in ibmf_i_notify_client()
181 IBMF_ALT_RECV_CB_CLEANUP(qpp); in ibmf_i_notify_client()
182 mutex_exit(&qpp->isq_mutex); in ibmf_i_notify_client()
247 ibmf_alt_qp_t *qpp = in ibmf_i_notify_client() local
250 mutex_enter(&qpp->isq_mutex); in ibmf_i_notify_client()
252 if ((qpp->isq_recv_cb == NULL) || in ibmf_i_notify_client()
253 (qpp->isq_flags & IBMF_CLIENT_TEAR_DOWN_CB)) { in ibmf_i_notify_client()
254 IBMF_ALT_RECV_CB_CLEANUP(qpp); in ibmf_i_notify_client()
255 mutex_exit(&qpp->isq_mutex); in ibmf_i_notify_client()
[all …]
H A Dibmf_impl.c144 static int ibmf_i_init_qp(ibmf_ci_t *ibmf_cip, ibmf_qp_t *qpp);
145 static void ibmf_i_uninit_qp(ibmf_ci_t *ibmf_cip, ibmf_qp_t *qpp);
1074 ibmf_qp_t *qpp; in ibmf_i_fini_qplist() local
1087 qpp = ibmf_cip->ci_qp_list; in ibmf_i_fini_qplist()
1088 while (qpp != NULL) { in ibmf_i_fini_qplist()
1090 ibmf_cip->ci_qp_list = qpp->iq_next; in ibmf_i_fini_qplist()
1092 ASSERT(qpp->iq_qp_ref == 0); in ibmf_i_fini_qplist()
1093 ASSERT(qpp->iq_flags == IBMF_QP_FLAGS_INVALID); in ibmf_i_fini_qplist()
1095 if (qpp->iq_qp_handle != NULL) { in ibmf_i_fini_qplist()
1097 status = ibt_flush_qp(qpp->iq_qp_handle); in ibmf_i_fini_qplist()
[all …]
H A Dibmf_recv.c183 ibmf_qp_t *qpp = recv_wqep->recv_qpp; in ibmf_i_handle_recv_completion() local
185 mutex_enter(&qpp->iq_mutex); in ibmf_i_handle_recv_completion()
186 qpp->iq_rwqes_posted--; in ibmf_i_handle_recv_completion()
187 if (qpp->iq_rwqes_posted <= (ibmf_recv_wqes_per_port >> 1)) { in ibmf_i_handle_recv_completion()
188 mutex_exit(&qpp->iq_mutex); in ibmf_i_handle_recv_completion()
195 tnf_int, qpnum, qpp->iq_qp_num); in ibmf_i_handle_recv_completion()
198 ret = ibmf_i_post_recv_buffer(cip, qpp, in ibmf_i_handle_recv_completion()
209 mutex_enter(&qpp->iq_mutex); in ibmf_i_handle_recv_completion()
211 mutex_exit(&qpp->iq_mutex); in ibmf_i_handle_recv_completion()
440 ibmf_alt_qp_t *qpp; in ibmf_i_do_recv_cb() local
[all …]
H A Dibmf.c543 ibmf_alt_qp_t *qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_tear_down_async_cb() local
545 mutex_enter(&qpp->isq_mutex); in ibmf_tear_down_async_cb()
548 if (qpp->isq_recv_cb == NULL) { in ibmf_tear_down_async_cb()
549 mutex_exit(&qpp->isq_mutex); in ibmf_tear_down_async_cb()
560 while (qpp->isq_flags & IBMF_CLIENT_RECV_CB_ACTIVE) { in ibmf_tear_down_async_cb()
561 qpp->isq_flags |= IBMF_CLIENT_TEAR_DOWN_CB; in ibmf_tear_down_async_cb()
562 cv_wait(&qpp->isq_recv_cb_teardown_cv, in ibmf_tear_down_async_cb()
563 &qpp->isq_mutex); in ibmf_tear_down_async_cb()
564 qpp->isq_flags &= ~IBMF_CLIENT_TEAR_DOWN_CB; in ibmf_tear_down_async_cb()
571 qpp->isq_recv_cb = NULL; in ibmf_tear_down_async_cb()
[all …]
H A Dibmf_send.c119 ibmf_alt_qp_t *qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_issue_pkt() local
120 mutex_enter(&qpp->isq_mutex); in ibmf_i_issue_pkt()
121 qpp->isq_sends_active++; in ibmf_i_issue_pkt()
122 mutex_exit(&qpp->isq_mutex); in ibmf_i_issue_pkt()
259 ibmf_alt_qp_t *qpp; in ibmf_i_handle_send_completion() local
312 qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_handle_send_completion()
322 mutex_enter(&qpp->isq_mutex); in ibmf_i_handle_send_completion()
323 qpp->isq_sends_active--; in ibmf_i_handle_send_completion()
324 mutex_exit(&qpp->isq_mutex); in ibmf_i_handle_send_completion()
H A Dibmf_dr.c387 ibmf_alt_qp_t *qpp; in ibmf_i_dr_loopback_filter() local
389 qpp = (ibmf_alt_qp_t *)rmsgimplp->im_qp_hdl; in ibmf_i_dr_loopback_filter()
390 mutex_enter(&qpp->isq_mutex); in ibmf_i_dr_loopback_filter()
391 IBMF_ALT_RECV_CB_SETUP(qpp); in ibmf_i_dr_loopback_filter()
392 mutex_exit(&qpp->isq_mutex); in ibmf_i_dr_loopback_filter()
H A Dibmf_wqe.c1020 ibmf_i_init_recv_wqe(ibmf_qp_t *qpp, ibt_wr_ds_t *sglp, in ibmf_i_init_recv_wqe() argument
1029 tnf_opaque, qpp, qpp, tnf_opaque, sglp, sglp, tnf_opaque, in ibmf_i_init_recv_wqe()
1050 wqep->recv_port_num = qpp->iq_port_num; in ibmf_i_init_recv_wqe()
1055 wqep->recv_qpp = qpp; in ibmf_i_init_recv_wqe()
H A Dibmf_rmpp.c57 ibmf_alt_qp_t *qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_is_rmpp() local
68 (qpp->isq_supports_rmpp == B_FALSE)) { in ibmf_i_is_rmpp()
/illumos-gate/usr/src/uts/common/sys/ib/clients/of/sol_ofs/
H A Dsol_kverb_impl.h40 #define FIRE_QP_EVENT(clnt, hdl, ib_event, qpp, type) \ argument
42 if (qpp && qpp->event_handler && \
43 qpp->device->reg_state == IB_DEV_OPEN) { \
44 ib_event.device = qpp->device; \
46 ib_event.element.qp = qpp; \
47 qpp->event_handler(&ib_event, qpp->qp_context); \
/illumos-gate/usr/src/cmd/fm/modules/common/disk-monitor/
H A Dutil.c263 queue_free(qu_t **qpp) in queue_free() argument
265 qu_t *qp = *qpp; in queue_free()
280 *qpp = NULL; in queue_free()
/illumos-gate/usr/src/uts/common/sys/ib/mgt/ibmf/
H A Dibmf_impl.h624 void ibmf_i_release_qp(ibmf_ci_t *ibmf_cip, ibmf_qp_t **qpp);
654 int ibmf_i_post_recv_buffer(ibmf_ci_t *cip, ibmf_qp_t *qpp, boolean_t block,
675 void ibmf_i_init_recv_wqe(ibmf_qp_t *qpp, ibt_wr_ds_t *sglp,
757 void ibmf_i_alt_recv_cb_setup(ibmf_alt_qp_t *qpp);
758 void ibmf_i_alt_recv_cb_cleanup(ibmf_alt_qp_t *qpp);
/illumos-gate/usr/src/uts/common/io/ib/clients/of/sol_ofs/
H A Dsol_kverbs.c146 struct ib_qp *qpp; in ofs_async_handler() local
153 qpp = event->ev_chan_hdl ? in ofs_async_handler()
160 clntp, hdl, code, qpp, cqp, event->ev_srq_hdl, in ofs_async_handler()
166 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
170 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
174 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
178 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
182 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
186 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
190 FIRE_QP_EVENT(ofs_client, hdl, ib_event, qpp, in ofs_async_handler()
[all …]
/illumos-gate/usr/src/uts/common/os/
H A Dstrsubr.c505 queue_t **qpp = &sq->sq_tail; \
508 while (*qpp != NULL && qp->q_spri > (*qpp)->q_spri) { \
509 qnext = *qpp; \
510 qpp = &(*qpp)->q_sqprev; \
513 qp->q_sqprev = *qpp; \
514 if (*qpp != NULL) { \
515 (*qpp)->q_sqnext = qp; \
520 *qpp = qp; \
H A Dsig.c1918 sigdeq(proc_t *p, kthread_t *t, int sig, sigqueue_t **qpp) in sigdeq() argument
1924 *qpp = NULL; in sigdeq()
1944 *qpp = sqp; in sigdeq()
/illumos-gate/usr/src/uts/common/io/cxgbe/common/
H A Dt4_hw.c10268 u32 hps, qpp; in t4_init_sge_params() local
10282 qpp = t4_read_reg(adapter, A_SGE_EGRESS_QUEUES_PER_PAGE_PF); in t4_init_sge_params()
10283 sge_params->eq_qpp = ((qpp >> s_qpp) & M_QUEUESPERPAGEPF0); in t4_init_sge_params()
10284 qpp = t4_read_reg(adapter, A_SGE_INGRESS_QUEUES_PER_PAGE_PF); in t4_init_sge_params()
10285 sge_params->iq_qpp = ((qpp >> s_qpp) & M_QUEUESPERPAGEPF0); in t4_init_sge_params()