Home
last modified time | relevance | path

Searched refs:qp (Results 1 – 25 of 126) sorted by relevance

123456

/titanic_44/usr/src/uts/common/io/ib/adapters/hermon/
H A Dhermon_qp.c45 static int hermon_qp_create_qpn(hermon_state_t *state, hermon_qphdl_t qp,
67 hermon_qphdl_t qp; in hermon_qp_alloc() local
273 qp = (hermon_qphdl_t)rsrc->hr_addr; in hermon_qp_alloc()
274 bzero(qp, sizeof (struct hermon_sw_qp_s)); in hermon_qp_alloc()
275 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*qp)) in hermon_qp_alloc()
277 qp->qp_alloc_flags = alloc_flags; in hermon_qp_alloc()
285 qp->qp_qpnum = qpc->hr_indx; in hermon_qp_alloc()
286 qp->qp_ring = qp->qp_qpnum << 8; in hermon_qp_alloc()
287 qp->qp_qpn_hdl = NULL; in hermon_qp_alloc()
289 status = hermon_qp_create_qpn(state, qp, qpc); in hermon_qp_alloc()
[all …]
H A Dhermon_qpmod.c47 static int hermon_qp_reset2init(hermon_state_t *state, hermon_qphdl_t qp,
49 static int hermon_qp_init2init(hermon_state_t *state, hermon_qphdl_t qp,
51 static int hermon_qp_init2rtr(hermon_state_t *state, hermon_qphdl_t qp,
53 static int hermon_qp_rtr2rts(hermon_state_t *state, hermon_qphdl_t qp,
55 static int hermon_qp_rts2rts(hermon_state_t *state, hermon_qphdl_t qp,
58 static int hermon_qp_rts2sqd(hermon_state_t *state, hermon_qphdl_t qp,
61 static int hermon_qp_sqd2rts(hermon_state_t *state, hermon_qphdl_t qp,
63 static int hermon_qp_sqd2sqd(hermon_state_t *state, hermon_qphdl_t qp,
65 static int hermon_qp_sqerr2rts(hermon_state_t *state, hermon_qphdl_t qp,
67 static int hermon_qp_to_error(hermon_state_t *state, hermon_qphdl_t qp);
[all …]
H A Dhermon_wr.c46 static int hermon_wqe_send_build(hermon_state_t *state, hermon_qphdl_t qp,
48 static int hermon_wqe_mlx_build(hermon_state_t *state, hermon_qphdl_t qp,
50 static void hermon_wqe_headroom(uint_t from, hermon_qphdl_t qp);
51 static int hermon_wqe_recv_build(hermon_state_t *state, hermon_qphdl_t qp,
73 hermon_post_send_ud(hermon_state_t *state, hermon_qphdl_t qp, in hermon_post_send_ud() argument
101 ASSERT(MUTEX_HELD(&qp->qp_sq_lock)); in hermon_post_send_ud()
102 _NOTE(LOCK_RELEASED_AS_SIDE_EFFECT(&qp->qp_sq_lock)) in hermon_post_send_ud()
108 wq = qp->qp_sq_wqhdr; in hermon_post_send_ud()
110 hdrmwqes = qp->qp_sq_hdrmwqes; /* in WQEs */ in hermon_post_send_ud()
111 sectperwqe = 1 << (qp->qp_sq_log_wqesz - 2); in hermon_post_send_ud()
[all …]
H A Dhermon_event.c1195 hermon_qphdl_t qp; in hermon_comm_estbl_handler() local
1202 qp = hermon_qphdl_from_qpnum(state, qpnum); in hermon_comm_estbl_handler()
1224 if ((qp != NULL) && (qp->qp_qpnum == qpnum) && in hermon_comm_estbl_handler()
1226 event.ev_qp_hdl = (ibtl_qp_hdl_t)qp->qp_hdlrarg; in hermon_comm_estbl_handler()
1245 hermon_qphdl_t qp; in hermon_local_wq_cat_err_handler() local
1252 qp = hermon_qphdl_from_qpnum(state, qpnum); in hermon_local_wq_cat_err_handler()
1274 if ((qp != NULL) && (qp->qp_qpnum == qpnum) && in hermon_local_wq_cat_err_handler()
1276 event.ev_qp_hdl = (ibtl_qp_hdl_t)qp->qp_hdlrarg; in hermon_local_wq_cat_err_handler()
1295 hermon_qphdl_t qp; in hermon_invreq_local_wq_err_handler() local
1302 qp = hermon_qphdl_from_qpnum(state, qpnum); in hermon_invreq_local_wq_err_handler()
[all …]
/titanic_44/usr/src/uts/common/os/
H A Dmsg.c283 static int msgq_check_err(kmsqid_t *qp, int cvres);
351 kmsqid_t *qp = (kmsqid_t *)perm; in msg_dtor() local
355 ASSERT(list_is_empty(&qp->msg_wait_snd[ii])); in msg_dtor()
356 ASSERT(list_is_empty(&qp->msg_wait_snd_ngt[ii])); in msg_dtor()
357 list_destroy(&qp->msg_wait_snd[ii]); in msg_dtor()
358 list_destroy(&qp->msg_wait_snd_ngt[ii]); in msg_dtor()
360 ASSERT(list_is_empty(&qp->msg_cpy_block)); in msg_dtor()
361 ASSERT(list_is_empty(&qp->msg_wait_rcv)); in msg_dtor()
362 list_destroy(&qp->msg_cpy_block); in msg_dtor()
363 ASSERT(qp->msg_snd_cnt == 0); in msg_dtor()
[all …]
H A Dputnext.c144 putnext(queue_t *qp, mblk_t *mp) in putnext() argument
146 queue_t *fqp = qp; /* For strft tracing */ in putnext()
160 "putnext_start:(%p, %p)", qp, mp); in putnext()
164 stp = STREAM(qp); in putnext()
173 qp = qp->q_next; in putnext()
174 sq = qp->q_syncq; in putnext()
177 qi = qp->q_qinfo; in putnext()
195 queued = qp->q_sqflags & Q_SQQUEUED; in putnext()
223 qp, mp, sq); in putnext()
232 qfill_syncq(sq, qp, mp); in putnext()
[all …]
/titanic_44/usr/src/uts/common/io/vuidmice/
H A Dvuidps2.c137 vuid_set_timeout(queue_t *const qp, clock_t time) in vuid_set_timeout() argument
140 (void) quntimeout(qp, STATEP->init_tid); in vuid_set_timeout()
141 STATEP->init_tid = qtimeout(qp, VUID_INIT_TIMEOUT, in vuid_set_timeout()
142 qp, drv_usectohz(time)); in vuid_set_timeout()
146 vuid_cancel_timeout(queue_t *const qp) in vuid_cancel_timeout() argument
148 (void) quntimeout(qp, STATEP->init_tid); in vuid_cancel_timeout()
157 vuidmice_send_wheel_event(queue_t *const qp, uchar_t event_id, in vuidmice_send_wheel_event() argument
177 if (canput(qp->q_next)) { in vuidmice_send_wheel_event()
178 putnext(qp, bp); in vuidmice_send_wheel_event()
180 (void) putbq(qp, bp); /* read side is blocked */ in vuidmice_send_wheel_event()
[all …]
H A Dvuidmice.c180 vuidmice_open(queue_t *const qp, const dev_t *const devp, in vuidmice_open() argument
183 if (qp->q_ptr != NULL) in vuidmice_open()
200 qp->q_ptr = kmem_zalloc(sizeof (struct MouseStateInfo), KM_SLEEP); in vuidmice_open()
201 WR(qp)->q_ptr = qp->q_ptr; in vuidmice_open()
206 qprocson(qp); in vuidmice_open()
209 if (VUID_OPEN(qp) != 0) { in vuidmice_open()
210 qprocsoff(qp); in vuidmice_open()
215 kmem_free(qp->q_ptr, sizeof (struct MouseStateInfo)); in vuidmice_open()
216 qp->q_ptr = NULL; in vuidmice_open()
226 vuidmice_close(queue_t *const qp, const int flag, const cred_t *const crp) in vuidmice_close() argument
[all …]
H A Dvuidm3p.c55 VUID_OPEN(queue_t *const qp) in VUID_OPEN() argument
63 vuidm3p_sendButtonEvent(queue_t *const qp) in vuidm3p_sendButtonEvent() argument
72 vuidm3p_putnext(qp, (uchar_t)MS_MIDDLE, FE_PAIR_NONE, 0, 1); in vuidm3p_sendButtonEvent()
79 vuidm3p_putnext(qp, (uchar_t)MS_MIDDLE, FE_PAIR_NONE, 0, 0); in vuidm3p_sendButtonEvent()
90 VUID_PUTNEXT(qp, VUID_BUT(b), FE_PAIR_NONE, 0, in vuidm3p_sendButtonEvent()
96 vuidm3p(queue_t *const qp, mblk_t *mp) in vuidm3p() argument
131 vuidm3p_sendButtonEvent(qp); in vuidm3p()
187 VUID_PUTNEXT(qp, (uchar_t)LOC_X_DELTA, in vuidm3p()
192 VUID_PUTNEXT(qp, (uchar_t)LOC_Y_DELTA, in vuidm3p()
/titanic_44/usr/src/uts/common/io/ib/adapters/tavor/
H A Dtavor_qp.c46 static int tavor_qp_create_qpn(tavor_state_t *state, tavor_qphdl_t qp,
67 tavor_qphdl_t qp; in tavor_qp_alloc() local
252 qp = (tavor_qphdl_t)rsrc->tr_addr; in tavor_qp_alloc()
253 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*qp)) in tavor_qp_alloc()
260 status = tavor_qp_create_qpn(state, qp, qpc); in tavor_qp_alloc()
275 umapdb = tavor_umap_db_alloc(state->ts_instance, qp->qp_qpnum, in tavor_qp_alloc()
304 qp->qp_rdbrsrcp = rdb; in tavor_qp_alloc()
307 qp->qp_rdb_ddraddr = (uintptr_t)rsrc_pool->rsrc_ddr_offset + in tavor_qp_alloc()
363 qp->qp_rq_log_wqesz = 0; in tavor_qp_alloc()
364 qp->qp_rq_sgl = 0; in tavor_qp_alloc()
[all …]
H A Dtavor_qpmod.c47 static int tavor_qp_reset2init(tavor_state_t *state, tavor_qphdl_t qp,
49 static int tavor_qp_init2init(tavor_state_t *state, tavor_qphdl_t qp,
51 static int tavor_qp_init2rtr(tavor_state_t *state, tavor_qphdl_t qp,
53 static int tavor_qp_rtr2rts(tavor_state_t *state, tavor_qphdl_t qp,
55 static int tavor_qp_rts2rts(tavor_state_t *state, tavor_qphdl_t qp,
57 static int tavor_qp_rts2sqd(tavor_state_t *state, tavor_qphdl_t qp,
59 static int tavor_qp_sqd2rts(tavor_state_t *state, tavor_qphdl_t qp,
61 static int tavor_qp_sqd2sqd(tavor_state_t *state, tavor_qphdl_t qp,
63 static int tavor_qp_sqerr2rts(tavor_state_t *state, tavor_qphdl_t qp,
65 static int tavor_qp_to_error(tavor_state_t *state, tavor_qphdl_t qp);
[all …]
H A Dtavor_wr.c53 static int tavor_wqe_send_build(tavor_state_t *state, tavor_qphdl_t qp,
57 uint64_t *prev_desc, tavor_sw_wqe_dbinfo_t *dbinfo, tavor_qphdl_t qp);
58 static int tavor_wqe_mlx_build(tavor_state_t *state, tavor_qphdl_t qp,
62 tavor_qphdl_t qp);
63 static int tavor_wqe_recv_build(tavor_state_t *state, tavor_qphdl_t qp,
66 uint64_t *prev, tavor_qphdl_t qp);
86 static void tavor_wrid_wqhdr_lock_both(tavor_qphdl_t qp);
87 static void tavor_wrid_wqhdr_unlock_both(tavor_qphdl_t qp);
96 tavor_post_send(tavor_state_t *state, tavor_qphdl_t qp, in tavor_post_send() argument
119 if (qp->qp_is_umap) { in tavor_post_send()
[all …]
/titanic_44/usr/src/uts/common/io/
H A Dzcons.c416 zc_switch(queue_t *qp) in zc_switch() argument
418 zc_state_t *zcs = qp->q_ptr; in zc_switch()
421 if (qp == zcs->zc_master_rdq) in zc_switch()
423 else if (OTHERQ(qp) == zcs->zc_master_rdq && zcs->zc_slave_rdq != NULL) in zc_switch()
425 else if (qp == zcs->zc_slave_rdq) in zc_switch()
427 else if (OTHERQ(qp) == zcs->zc_slave_rdq && zcs->zc_master_rdq != NULL) in zc_switch()
438 zc_side(queue_t *qp) in zc_side() argument
440 zc_state_t *zcs = qp->q_ptr; in zc_side()
443 if (qp == zcs->zc_master_rdq || in zc_side()
444 OTHERQ(qp) == zcs->zc_master_rdq) { in zc_side()
[all …]
H A Dsad.c60 static int sadwput(queue_t *qp, mblk_t *mp);
183 queue_t *qp, /* pointer to read queue */ in sadopen() argument
235 ss->ss_saddev[i].sa_qp = qp; in sadopen()
237 qp->q_ptr = (caddr_t)&ss->ss_saddev[i]; in sadopen()
238 WR(qp)->q_ptr = (caddr_t)&ss->ss_saddev[i]; in sadopen()
247 qprocson(qp); in sadopen()
258 queue_t *qp, /* pointer to read queue */ in sadclose() argument
264 qprocsoff(qp); in sadclose()
265 sadp = (struct saddev *)qp->q_ptr; in sadclose()
270 qp->q_ptr = NULL; in sadclose()
[all …]
H A Dptm.c454 ptmwput(queue_t *qp, mblk_t *mp) in ptmwput() argument
460 ASSERT(qp->q_ptr); in ptmwput()
462 ptmp = (struct pt_ttys *)qp->q_ptr; in ptmwput()
482 flushband(qp, *(mp->b_rptr + 1), in ptmwput()
485 flushq(qp, FLUSHDATA); in ptmwput()
509 miocnak(qp, mp, 0, EINVAL); in ptmwput()
513 (void) putq(qp, mp); in ptmwput()
522 miocack(qp, mp, 0, 0); in ptmwput()
530 miocnak(qp, mp, 0, error); in ptmwput()
534 miocnak(qp, mp, 0, error); in ptmwput()
[all …]
H A Dpts.c508 ptswput(queue_t *qp, mblk_t *mp) in ptswput() argument
515 ASSERT(qp->q_ptr); in ptswput()
517 ptsp = (struct pt_ttys *)qp->q_ptr; in ptswput()
529 qreply(qp, mp); in ptswput()
553 flushband(qp, *(mp->b_rptr + 1), FLUSHDATA); in ptswput()
555 flushq(qp, FLUSHDATA); in ptswput()
590 ASSERT(RD(qp)->q_first == NULL); in ptswput()
592 qreply(qp, mp); in ptswput()
638 qreply(qp, mp); in ptswput()
648 (void) putq(qp, mp); in ptswput()
[all …]
/titanic_44/usr/src/cmd/fm/modules/common/disk-monitor/
H A Dutil.c193 queue_add(qu_t *qp, void *data) in queue_add() argument
196 (struct q_node *)qp->nalloc(sizeof (struct q_node)); in queue_add()
201 dm_assert(pthread_mutex_lock(&qp->mutex) == 0); in queue_add()
203 if (qp->nodep == NULL) in queue_add()
204 qp->nodep = qnp; in queue_add()
206 nodep = qp->nodep; in queue_add()
215 if (qp->boe && qp->nodep == qnp) in queue_add()
216 dm_assert(pthread_cond_broadcast(&qp->cvar) == 0); in queue_add()
217 dm_assert(pthread_mutex_unlock(&qp->mutex) == 0); in queue_add()
221 queue_remove(qu_t *qp) in queue_remove() argument
[all …]
/titanic_44/usr/src/lib/udapl/udapl_tavor/tavor/
H A Ddapl_arbel_hw.c47 #define ARBEL_WQE_SETCTRL(qp, desc, ctrl) \ argument
49 #define ARBEL_WQE_SETNEXT(qp, desc, nda_op, ee_nds) \ argument
144 dapli_arbel_sq_dbrec(ib_qp_handle_t qp, uint16_t wqe_counter) in dapli_arbel_sq_dbrec() argument
146 qp->qp_sq_dbp[0] = HTOBE_32((wqe_counter + 1) & 0xffff); in dapli_arbel_sq_dbrec()
188 dapli_arbel_wqe_send_build(ib_qp_handle_t qp, ibt_send_wr_t *wr, in dapli_arbel_wqe_send_build() argument
225 if (qp->qp_sq_inline != 0) in dapli_arbel_wqe_send_build()
227 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_SEND; in dapli_arbel_wqe_send_build()
230 if (qp->qp_sq_inline != 0) in dapli_arbel_wqe_send_build()
232 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_RDMAW; in dapli_arbel_wqe_send_build()
235 if (qp->qp_sq_inline < 0 && wr->wr_opcode == IBT_WRC_RDMAR) in dapli_arbel_wqe_send_build()
[all …]
H A Ddapl_hermon_hw.c175 dapli_hermon_wqe_send_build(ib_qp_handle_t qp, ibt_send_wr_t *wr, in dapli_hermon_wqe_send_build() argument
214 if (qp->qp_sq_inline != 0) in dapli_hermon_wqe_send_build()
216 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_SEND; in dapli_hermon_wqe_send_build()
220 if (qp->qp_sq_inline != 0) in dapli_hermon_wqe_send_build()
222 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_RDMAW; in dapli_hermon_wqe_send_build()
227 if (qp->qp_sq_inline < 0) in dapli_hermon_wqe_send_build()
228 qp->qp_sq_inline = 0; in dapli_hermon_wqe_send_build()
299 if (nds > qp->qp_sq_sgl) { in dapli_hermon_wqe_send_build()
409 dapli_hermon_wqe_recv_build(ib_qp_handle_t qp, ibt_recv_wr_t *wr, in dapli_hermon_wqe_recv_build() argument
421 if (wr->wr_nds > qp->qp_rq_sgl) { in dapli_hermon_wqe_recv_build()
[all …]
H A Ddapl_tavor_wr.c725 dapls_tavor_wrid_init(ib_qp_handle_t qp) in dapls_tavor_wrid_init() argument
740 dapli_tavor_wrid_wqhdr_lock_both(qp); in dapls_tavor_wrid_init()
741 swq = dapli_tavor_wrid_wqhdr_find(qp->qp_sq_cqhdl, qp->qp_num, in dapls_tavor_wrid_init()
746 swq = dapli_tavor_wrid_wqhdr_create(qp->qp_sq_cqhdl, in dapls_tavor_wrid_init()
747 qp->qp_num, TAVOR_WR_SEND, 1); in dapls_tavor_wrid_init()
753 dapli_tavor_wrid_wqhdr_unlock_both(qp); in dapls_tavor_wrid_init()
757 qp->qp_sq_wqhdr = swq; in dapls_tavor_wrid_init()
758 swq->wq_size = qp->qp_sq_numwqe; in dapls_tavor_wrid_init()
775 dapli_tavor_cq_wqhdr_remove(qp->qp_sq_cqhdl, swq); in dapls_tavor_wrid_init()
778 dapli_tavor_wrid_wqhdr_unlock_both(qp); in dapls_tavor_wrid_init()
[all …]
H A Ddapl_tavor_hw.c292 dapli_tavor_wqe_send_build(ib_qp_handle_t qp, ibt_send_wr_t *wr, in dapli_tavor_wqe_send_build() argument
324 if (qp->qp_sq_inline != 0) in dapli_tavor_wqe_send_build()
326 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_SEND; in dapli_tavor_wqe_send_build()
329 if (qp->qp_sq_inline != 0) in dapli_tavor_wqe_send_build()
331 qp->qp_sq_wqesz - TAVOR_INLINE_HEADER_SIZE_RDMAW; in dapli_tavor_wqe_send_build()
334 if (qp->qp_sq_inline < 0 && wr->wr_opcode == IBT_WRC_RDMAR) in dapli_tavor_wqe_send_build()
335 qp->qp_sq_inline = 0; in dapli_tavor_wqe_send_build()
361 tavor_num_mpt_mask = (uint32_t)(1 << qp->qp_num_mpt_shift) - 1; in dapli_tavor_wqe_send_build()
362 new_rkey = (old_rkey >> qp->qp_num_mpt_shift); in dapli_tavor_wqe_send_build()
364 new_rkey = ((new_rkey << qp->qp_num_mpt_shift) | in dapli_tavor_wqe_send_build()
[all …]
/titanic_44/usr/src/uts/common/io/ib/clients/of/sol_ofs/
H A Dsol_kverbs.c1073 struct ib_qp *qp; in ib_create_qp() local
1095 if ((qp = kmem_alloc(sizeof (struct ib_qp), KM_NOSLEEP)) == NULL) { in ib_create_qp()
1105 kmem_free(qp, sizeof (struct ib_qp)); in ib_create_qp()
1168 kmem_free(qp, sizeof (struct ib_qp)); in ib_create_qp()
1182 qp->device = pd->device; in ib_create_qp()
1183 qp->pd = pd; in ib_create_qp()
1184 qp->send_cq = qp_init_attr->send_cq; in ib_create_qp()
1185 qp->recv_cq = qp_init_attr->recv_cq; in ib_create_qp()
1186 qp->srq = qp_init_attr->srq; in ib_create_qp()
1187 qp->event_handler = qp_init_attr->event_handler; in ib_create_qp()
[all …]
/titanic_44/usr/src/uts/common/rpc/
H A Drpcib.c384 static struct rdma_done_list *rdma_done_add(rib_qp_t *qp, uint32_t xid);
385 static void rdma_done_rm(rib_qp_t *qp, struct rdma_done_list *rd);
387 static void rdma_done_notify(rib_qp_t *qp, uint32_t xid);
1010 rib_qp_t *qp; in rib_clnt_scq_handler() local
1031 qp = wd->qp; in rib_clnt_scq_handler()
1032 conn = qptoc(qp); in rib_clnt_scq_handler()
1080 rib_rbuf_free(qptoc(wd->qp), in rib_clnt_scq_handler()
1086 rib_send_rele(qp); in rib_clnt_scq_handler()
1102 rib_qp_t *qp; in rib_svc_scq_handler() local
1124 qp = wd->qp; in rib_svc_scq_handler()
[all …]
/titanic_44/usr/src/lib/libc/port/threads/
H A Dsynch.c470 queue_head_t *qp; in queue_alloc() local
483 udp->queue_head = qp = (queue_head_t *)data; in queue_alloc()
484 for (i = 0; i < 2 * QHASHSIZE; qp++, i++) { in queue_alloc()
485 qp->qh_type = (i < QHASHSIZE)? MX : CV; in queue_alloc()
486 qp->qh_lock.mutex_flag = LOCK_INITED; in queue_alloc()
487 qp->qh_lock.mutex_magic = MUTEX_MAGIC; in queue_alloc()
488 qp->qh_hlist = &qp->qh_def_root; in queue_alloc()
490 qp->qh_hlen = 1; in queue_alloc()
491 qp->qh_hmax = 1; in queue_alloc()
502 QVERIFY(queue_head_t *qp) in QVERIFY() argument
[all …]
/titanic_44/usr/src/uts/common/sys/ib/adapters/hermon/
H A Dhermon_wr.h63 #define HERMON_SET_SEND_WQE_OWNER(qp, desc, opcode) \ argument
71 #define HERMON_QP_SQ_ENTRY(qp, tail) \ argument
72 ((uint64_t *)((uintptr_t)((qp)->qp_sq_buf) + \
73 ((tail) << (qp)->qp_sq_log_wqesz)))
74 #define HERMON_QP_RQ_ENTRY(qp, tail) \ argument
75 ((uint64_t *)((uintptr_t)((qp)->qp_rq_buf) + \
76 ((tail) << (qp)->qp_rq_log_wqesz)))
184 int hermon_wrid_from_reset_handling(hermon_state_t *state, hermon_qphdl_t qp);
185 int hermon_wrid_to_reset_handling(hermon_state_t *state, hermon_qphdl_t qp);
191 void hermon_check_qp_debug(hermon_state_t *state, hermon_qphdl_t qp);

123456