Home
last modified time | relevance | path

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

/titanic_50/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.c121 ibmf_alt_qp_t *qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_issue_pkt() local
122 mutex_enter(&qpp->isq_mutex); in ibmf_i_issue_pkt()
123 qpp->isq_sends_active++; in ibmf_i_issue_pkt()
124 mutex_exit(&qpp->isq_mutex); in ibmf_i_issue_pkt()
261 ibmf_alt_qp_t *qpp; in ibmf_i_handle_send_completion() local
314 qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_handle_send_completion()
324 mutex_enter(&qpp->isq_mutex); in ibmf_i_handle_send_completion()
325 qpp->isq_sends_active--; in ibmf_i_handle_send_completion()
326 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.c59 ibmf_alt_qp_t *qpp = (ibmf_alt_qp_t *)ibmf_qp_handle; in ibmf_i_is_rmpp() local
70 (qpp->isq_supports_rmpp == B_FALSE)) { in ibmf_i_is_rmpp()
/titanic_50/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); \
/titanic_50/usr/src/cmd/fm/modules/common/disk-monitor/
H A Dutil.c265 queue_free(qu_t **qpp) in queue_free() argument
267 qu_t *qp = *qpp; in queue_free()
282 *qpp = NULL; in queue_free()
/titanic_50/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);
/titanic_50/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 …]
/titanic_50/usr/src/uts/common/os/
H A Dstrsubr.c502 queue_t **qpp = &sq->sq_tail; \
505 while (*qpp != NULL && qp->q_spri > (*qpp)->q_spri) { \
506 qnext = *qpp; \
507 qpp = &(*qpp)->q_sqprev; \
510 qp->q_sqprev = *qpp; \
511 if (*qpp != NULL) { \
512 (*qpp)->q_sqnext = qp; \
517 *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()