Home
last modified time | relevance | path

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

123456

/titanic_51/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 in hermon_qp_alloc()
770 hermon_qphdl_t qp; hermon_special_qp_alloc() local
1230 hermon_qphdl_t qp; hermon_qp_alloc_range() local
1870 hermon_qphdl_t qp; hermon_qp_free() local
2103 hermon_qp_query(hermon_state_t * state,hermon_qphdl_t qp,ibt_qp_query_attr_t * attr_p) hermon_qp_query() argument
2404 hermon_qp_create_qpn(hermon_state_t * state,hermon_qphdl_t qp,hermon_rsrc_t * qpc) hermon_qp_create_qpn() argument
[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);
84 hermon_qp_modify(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p,ibt_queue_sizes_t * actual_sz) hermon_qp_modify() argument
834 hermon_qp_reset2init(hermon_state_t * state,hermon_qphdl_t qp,ibt_qp_info_t * info_p) hermon_qp_reset2init() argument
1111 hermon_qp_init2init(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_init2init() argument
1317 hermon_qp_init2rtr(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_init2rtr() argument
1691 hermon_qp_rtr2rts(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_rtr2rts() argument
1960 hermon_qp_rts2rts(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_rts2rts() argument
2192 hermon_qp_rts2sqd(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags) hermon_qp_rts2sqd() argument
2249 hermon_qp_sqd2rts(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_sqd2rts() argument
2550 hermon_qp_sqd2sqd(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_sqd2sqd() argument
3001 hermon_qp_sqerr2rts(hermon_state_t * state,hermon_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) hermon_qp_sqerr2rts() argument
3088 hermon_qp_to_error(hermon_state_t * state,hermon_qphdl_t qp) hermon_qp_to_error() argument
3122 hermon_qp_to_reset(hermon_state_t * state,hermon_qphdl_t qp) hermon_qp_to_reset() argument
3168 hermon_qp_reset2err(hermon_state_t * state,hermon_qphdl_t qp) hermon_qp_reset2err() argument
[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 in hermon_post_send_ud()
426 hermon_post_send_rc(hermon_state_t * state,hermon_qphdl_t qp,ibt_send_wr_t * wr,uint_t num_wr,uint_t * num_posted) hermon_post_send_rc() argument
779 hermon_post_send(hermon_state_t * state,hermon_qphdl_t qp,ibt_send_wr_t * wr,uint_t num_wr,uint_t * num_posted) hermon_post_send() argument
1112 hermon_post_recv(hermon_state_t * state,hermon_qphdl_t qp,ibt_recv_wr_t * wr,uint_t num_wr,uint_t * num_posted) hermon_post_recv() argument
1301 hermon_wqe_send_build(hermon_state_t * state,hermon_qphdl_t qp,ibt_send_wr_t * wr,uint64_t * desc,uint_t * size) hermon_wqe_send_build() argument
1680 hermon_wqe_mlx_build(hermon_state_t * state,hermon_qphdl_t qp,ibt_send_wr_t * wr,uint64_t * desc,uint_t * size) hermon_wqe_mlx_build() argument
1909 hermon_wqe_recv_build(hermon_state_t * state,hermon_qphdl_t qp,ibt_recv_wr_t * wr,uint64_t * desc) hermon_wqe_recv_build() argument
2070 hermon_wqe_headroom(uint_t from,hermon_qphdl_t qp) hermon_wqe_headroom() argument
2216 hermon_wrid_from_reset_handling(hermon_state_t * state,hermon_qphdl_t qp) hermon_wrid_from_reset_handling() argument
2293 hermon_wrid_to_reset_handling(hermon_state_t * state,hermon_qphdl_t qp) hermon_wrid_to_reset_handling() argument
[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 in hermon_local_wq_cat_err_handler()
1295 hermon_qphdl_t qp; hermon_invreq_local_wq_err_handler() local
1345 hermon_qphdl_t qp; hermon_local_acc_vio_wq_err_handler() local
1395 hermon_qphdl_t qp; hermon_sendq_drained_handler() local
1461 hermon_qphdl_t qp; hermon_path_mig_handler() local
1511 hermon_qphdl_t qp; hermon_path_mig_err_handler() local
1561 hermon_qphdl_t qp; hermon_catastrophic_handler() local
1621 hermon_qphdl_t qp; hermon_srq_last_wqe_reached_handler() local
1666 hermon_qphdl_t qp; hermon_fexch_error_handler() local
[all...]
/titanic_51/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 in msg_dtor()
394 msgunlink(kmsqid_t * qp,struct msg * mp) msgunlink() argument
408 kmsqid_t *qp = (kmsqid_t *)perm; msg_rmid() local
439 kmsqid_t *qp; /* ptr to associated q */ msgctl() local
595 kmsqid_t *qp; msgget() local
669 kmsqid_t *qp; /* ptr to associated q */ msgrcv() local
790 msgq_check_err(kmsqid_t * qp,int cvres) msgq_check_err() argument
804 msg_copyout(kmsqid_t * qp,long msgtyp,kmutex_t ** lock,size_t * xtsz_ret,size_t msgsz,struct msg * smp,struct ipcmsgbuf * msgp,int msgflg) msg_copyout() argument
880 msgrcv_lookup(kmsqid_t * qp,long msgtyp) msgrcv_lookup() argument
971 kmsqid_t *qp; /* ptr to associated q */ msgsnap() local
1096 kmsqid_t *qp; msgsnd() local
1260 msg_wakeup_rdr(kmsqid_t * qp,msg_select_t ** flist,long type) msg_wakeup_rdr() argument
1314 msg_fnd_any_snd(kmsqid_t * qp,int msg_hash,long type) msg_fnd_any_snd() argument
1327 msg_fnd_any_rdr(kmsqid_t * qp,int msg_hash,long type) msg_fnd_any_rdr() argument
1338 msg_fnd_spc_snd(kmsqid_t * qp,int msg_hash,long type) msg_fnd_spc_snd() argument
1353 msg_fnd_neg_snd(kmsqid_t * qp,int msg_hash,long type) msg_fnd_neg_snd() argument
1405 msg_rcvq_sleep(list_t * queue,msgq_wakeup_t * entry,kmutex_t ** lock,kmsqid_t * qp) msg_rcvq_sleep() argument
1483 msg_wakeup_senders(kmsqid_t * qp) msg_wakeup_senders() argument
[all...]
H A Dputnext.c101 * purpose: call the put routine of the queue linked to qp
144 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 in putnext()
426 put(queue_t * qp,mblk_t * mp) put() argument
[all...]
/titanic_51/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, b in vuidmice_send_wheel_event()
186 sendButtonEvent(queue_t * const qp) sendButtonEvent() argument
202 put1(queue_t * const qp,int c) put1() argument
213 vuidmice_start_wdc_or_setres(queue_t * qp) vuidmice_start_wdc_or_setres() argument
237 VUID_OPEN(queue_t * const qp) VUID_OPEN() argument
264 VUID_CLOSE(queue_t * const qp) VUID_CLOSE() argument
273 queue_t *qp = q; VUID_INIT_TIMEOUT() local
336 VUID_QUEUE(queue_t * const qp,mblk_t * mp) VUID_QUEUE() argument
[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 in vuidmice_open()
226 vuidmice_close(queue_t * const qp,const int flag,const cred_t * const crp) vuidmice_close() argument
250 vuidmice_rput(queue_t * const qp,mblk_t * mp) vuidmice_rput() argument
273 vuidmice_rsrv(queue_t * const qp) vuidmice_rsrv() argument
309 vuidmice_wput(queue_t * const qp,mblk_t * mp) vuidmice_wput() argument
481 VUID_PUTNEXT(queue_t * const qp,uchar_t event_id,uchar_t event_pair_type,uchar_t event_pair,int event_value) VUID_PUTNEXT() argument
520 vuidmice_miocdata(queue_t * qp,mblk_t * mp) vuidmice_miocdata() argument
660 vuidmice_handle_wheel_resolution_ioctl(queue_t * qp,mblk_t * mp,int cmd) vuidmice_handle_wheel_resolution_ioctl() argument
795 vuidmice_service_wheel_state(register queue_t * qp,register mblk_t * datap,register uint_t cmd) vuidmice_service_wheel_state() 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_51/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 in tavor_qp_alloc()
651 tavor_qphdl_t qp; tavor_special_qp_alloc() local
1062 tavor_qphdl_t qp; tavor_qp_free() local
1280 tavor_qp_query(tavor_state_t * state,tavor_qphdl_t qp,ibt_qp_query_attr_t * attr_p) tavor_qp_query() argument
1537 tavor_qp_create_qpn(tavor_state_t * state,tavor_qphdl_t qp,tavor_rsrc_t * qpc) tavor_qp_create_qpn() argument
[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);
82 tavor_qp_modify(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p,ibt_queue_sizes_t * actual_sz) tavor_qp_modify() argument
850 tavor_qp_reset2init(tavor_state_t * state,tavor_qphdl_t qp,ibt_qp_info_t * info_p) tavor_qp_reset2init() argument
1034 tavor_qp_init2init(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_init2init() argument
1259 tavor_qp_init2rtr(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_init2rtr() argument
1682 tavor_qp_rtr2rts(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_rtr2rts() argument
2008 tavor_qp_rts2rts(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_rts2rts() argument
2271 tavor_qp_rts2sqd(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags) tavor_qp_rts2sqd() argument
2332 tavor_qp_sqd2rts(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_sqd2rts() argument
2595 tavor_qp_sqd2sqd(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_sqd2sqd() argument
3072 tavor_qp_sqerr2rts(tavor_state_t * state,tavor_qphdl_t qp,ibt_cep_modify_flags_t flags,ibt_qp_info_t * info_p) tavor_qp_sqerr2rts() argument
3168 tavor_qp_to_error(tavor_state_t * state,tavor_qphdl_t qp) tavor_qp_to_error() argument
3205 tavor_qp_to_reset(tavor_state_t * state,tavor_qphdl_t qp) tavor_qp_to_reset() argument
3248 tavor_qp_reset2err(tavor_state_t * state,tavor_qphdl_t qp) tavor_qp_reset2err() argument
[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 in tavor_post_send()
396 tavor_post_recv(tavor_state_t * state,tavor_qphdl_t qp,ibt_recv_wr_t * wr,uint_t num_wr,uint_t * num_posted) tavor_post_recv() argument
943 tavor_wqe_send_build(tavor_state_t * state,tavor_qphdl_t qp,ibt_send_wr_t * wr,uint64_t * desc,uint_t * size) tavor_wqe_send_build() argument
1306 tavor_wqe_send_linknext(ibt_send_wr_t * curr_wr,ibt_send_wr_t * prev_wr,uint64_t * curr_desc,uint_t curr_descsz,uint64_t * prev_desc,tavor_sw_wqe_dbinfo_t * dbinfo,tavor_qphdl_t qp) tavor_wqe_send_linknext() argument
1433 tavor_wqe_mlx_build(tavor_state_t * state,tavor_qphdl_t qp,ibt_send_wr_t * wr,uint64_t * desc,uint_t * size) tavor_wqe_mlx_build() argument
1675 tavor_wqe_mlx_linknext(ibt_send_wr_t * prev_wr,uint64_t * curr_desc,uint_t curr_descsz,uint64_t * prev_desc,tavor_sw_wqe_dbinfo_t * dbinfo,tavor_qphdl_t qp) tavor_wqe_mlx_linknext() argument
1805 tavor_wqe_recv_build(tavor_state_t * state,tavor_qphdl_t qp,ibt_recv_wr_t * wr,uint64_t * desc,uint_t * size) tavor_wqe_recv_build() argument
1875 tavor_wqe_recv_linknext(uint64_t * curr_desc,uint_t curr_descsz,uint64_t * prev_desc,tavor_qphdl_t qp) tavor_wqe_recv_linknext() argument
2080 tavor_qphdl_t qp; tavor_wqe_sync() local
2328 tavor_wrid_from_reset_handling(tavor_state_t * state,tavor_qphdl_t qp) tavor_wrid_from_reset_handling() argument
2613 tavor_wrid_to_reset_handling(tavor_state_t * state,tavor_qphdl_t qp) tavor_wrid_to_reset_handling() argument
3583 tavor_wrid_wqhdr_lock_both(tavor_qphdl_t qp) tavor_wrid_wqhdr_lock_both() argument
3619 tavor_wrid_wqhdr_unlock_both(tavor_qphdl_t qp) tavor_wrid_wqhdr_unlock_both() argument
[all...]
/titanic_51/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) in zc_side()
693 handle_mflush(queue_t * qp,mblk_t * mp) handle_mflush() argument
744 zc_wput(queue_t * qp,mblk_t * mp) zc_wput() argument
948 zc_rsrv(queue_t * qp) zc_rsrv() argument
974 zc_wsrv(queue_t * qp) zc_wsrv() argument
[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 in sadclose()
281 sadwput(queue_t * qp,mblk_t * mp) sadwput() argument
348 apush_ioctl(queue_t * qp,mblk_t * mp) apush_ioctl() argument
398 apush_iocdata(queue_t * qp,mblk_t * mp) apush_iocdata() argument
621 vml_ioctl(queue_t * qp,mblk_t * mp) vml_ioctl() argument
644 vml_iocdata(queue_t * qp,mblk_t * mp) vml_iocdata() argument
[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, m in ptmwput()
615 ptmrsrv(queue_t * qp) ptmrsrv() argument
639 ptmwsrv(queue_t * qp) ptmwsrv() argument
[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()
591 DBG(("qreply(qp) turning FLUSHR around\n")); in ptswput()
592 qreply(qp, mp); in ptswput()
638 qreply(qp, m in ptswput()
663 ptsrsrv(queue_t * qp) ptsrsrv() argument
689 ptswsrv(queue_t * qp) ptswsrv() argument
[all...]
/titanic_51/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 in queue_add()
221 queue_remove(qu_t * qp) queue_remove() argument
267 qu_t *qp = *qpp; queue_free() local
[all...]
/titanic_51/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
140 * Takes the specified next descriptor information, qp number, opcode and
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 in dapli_arbel_wqe_send_build()
431 dapli_arbel_wqe_recv_build(ib_qp_handle_t qp,ibt_recv_wr_t * wr,uint64_t * addr,uint_t * size) dapli_arbel_wqe_recv_build() argument
1046 ib_qp_handle_t qp; dapli_arbel_post_send() local
1176 ib_qp_handle_t qp; dapli_arbel_post_recv() local
1384 dapli_arbel_cq_srq_entries_flush(ib_qp_handle_t qp) dapli_arbel_cq_srq_entries_flush() argument
1571 dapli_arbel_qp_init(ib_qp_handle_t qp) dapli_arbel_qp_init() argument
[all...]
H A Ddapl_hermon_hw.c139 * Takes the specified qp number and rings the send doorbell.
175 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_ argument
1041 dapli_hermon_wqe_headroom(ib_qp_handle_t qp,uint32_t start) dapli_hermon_wqe_headroom() argument
1084 ib_qp_handle_t qp; dapli_hermon_post_send() local
1234 ib_qp_handle_t qp; dapli_hermon_post_recv() local
1439 dapli_hermon_cq_srq_entries_flush(ib_qp_handle_t qp) dapli_hermon_cq_srq_entries_flush() argument
1616 dapli_hermon_qp_init(ib_qp_handle_t qp) dapli_hermon_qp_init() argument
[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 in dapls_tavor_wrid_init()
879 dapls_tavor_wrid_cleanup(DAPL_EP * ep,ib_qp_handle_t qp) dapls_tavor_wrid_cleanup() argument
1041 dapli_tavor_wrid_wqhdr_lock_both(ib_qp_handle_t qp) dapli_tavor_wrid_wqhdr_lock_both() argument
1068 dapli_tavor_wrid_wqhdr_unlock_both(ib_qp_handle_t qp) dapli_tavor_wrid_wqhdr_unlock_both() argument
[all...]
H A Ddapl_tavor_hw.c132 * Takes the specified next descriptor information, qp number, opcode and
184 * Takes the specified next descriptor information, qp number and
292 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 in dapli_tavor_wqe_send_build()
562 dapli_tavor_wqe_recv_build(ib_qp_handle_t qp,ibt_recv_wr_t * wr,uint64_t * addr,uint_t * size) dapli_tavor_wqe_recv_build() argument
1306 ib_qp_handle_t qp; dapli_tavor_post_send() local
1431 ib_qp_handle_t qp; dapli_tavor_post_recv() local
1717 dapli_tavor_cq_srq_entries_flush(ib_qp_handle_t qp) dapli_tavor_cq_srq_entries_flush() argument
1873 dapli_tavor_qp_init(ib_qp_handle_t qp) dapli_tavor_qp_init() argument
[all...]
/titanic_51/usr/src/uts/common/io/ib/clients/of/sol_ofs/
H A Dsol_kverbs.c137 * which dispatches each event to corresponding qp/cq handlers registered
158 "event->qp: 0x%p, event->cq: 0x%p, event->srq: 0x%p " in ofs_async_handler()
1034 * there is a possibility that this qp is used even after in ib_destroy_cq()
1073 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 in ib_create_qp()
1226 ib_destroy_qp(struct ib_qp * qp) ib_destroy_qp() argument
1639 ib_modify_qp(struct ib_qp * qp,struct ib_qp_attr * attr,int attr_mask) ib_modify_qp() argument
[all...]
/titanic_51/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);
837 * A qp is allowed to access a memory region in rpcib_open_hcas()
862 * If number of qp's gets too large, then several in rpcib_open_hcas()
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()
1102 rib_qp_t *qp; rib_svc_scq_handler() local
1180 rib_qp_t *qp; rib_clnt_rcq_handler() local
1318 rib_qp_t *qp; rib_svc_rcq_handler() local
1565 rib_clnt_create_chan(rib_hca_t * hca,struct netbuf * raddr,rib_qp_t ** qp) rib_clnt_create_chan() argument
1614 rib_svc_create_chan(rib_hca_t * hca,caddr_t q,uint8_t port,rib_qp_t ** qp) rib_svc_create_chan() argument
1719 rib_qp_t *qp; rib_clnt_cm_handler() local
1794 rib_conn_to_srv(rib_hca_t * hca,rib_qp_t * qp,rpcib_ping_t * rptp) rib_conn_to_srv() argument
2023 rib_qp_t *qp = ctoqp(conn); rib_disconnect_channel() local
2145 rib_send_hold(rib_qp_t * qp) rib_send_hold() argument
2153 rib_send_rele(rib_qp_t * qp) rib_send_rele() argument
2163 rib_recv_rele(rib_qp_t * qp) rib_recv_rele() argument
2178 rib_sendwait(rib_qp_t * qp,struct send_wid * wd) rib_sendwait() argument
2261 rib_init_sendwait(uint32_t xid,int cv_sig,rib_qp_t * qp) rib_init_sendwait() argument
2287 rib_rem_rep(rib_qp_t * qp,struct reply * rep) rib_rem_rep() argument
2316 rib_qp_t *qp; rib_send_and_wait() local
2426 rib_qp_t *qp = ctoqp(conn); rib_send_resp() local
2456 rib_create_wid(rib_qp_t * qp,ibt_wr_ds_t * sgl,uint32_t msgid) rib_create_wid() argument
2477 rib_qp_t *qp = ctoqp(conn); rib_clnt_post() local
2563 rib_qp_t *qp = ctoqp(conn); rib_svc_post() local
2627 rib_qp_t *qp = ctoqp(conn); rib_post_resp_remove() local
2650 rib_qp_t *qp = ctoqp(conn); rib_post_recv() local
2671 rib_qp_t *qp = ctoqp(conn); rib_recv() local
2757 rib_qp_t *qp = ctoqp(conn); rib_write() local
2849 rib_qp_t *qp = ctoqp(conn); rib_read() local
2936 rib_qp_t *qp; rib_srv_cm_handler() local
3136 rib_qp_t *qp; rib_srv_cm_handler() local
3564 rib_init_svc_recv(rib_qp_t * qp,ibt_wr_ds_t * sgl) rib_init_svc_recv() argument
3584 rib_addreplylist(rib_qp_t * qp,uint32_t msgid) rib_addreplylist() argument
3618 rib_rem_replylist(rib_qp_t * qp) rib_rem_replylist() argument
3633 rib_remreply(rib_qp_t * qp,struct reply * rep) rib_remreply() argument
4061 rib_qp_t *qp = ctoqp(conn); rib_rbuf_alloc() local
4133 rib_qp_t *qp = ctoqp(conn); rib_rbuf_free() local
4340 rib_qp_t *qp; rib_connect() local
4475 rib_qp_t *qp = ctoqp(conn); rib_conn_close() local
4605 rdma_done_add(rib_qp_t * qp,uint32_t xid) rdma_done_add() argument
4625 rdma_done_rm(rib_qp_t * qp,struct rdma_done_list * rd) rdma_done_rm() argument
4648 rdma_done_rem_list(rib_qp_t * qp) rdma_done_rem_list() argument
4661 rdma_done_notify(rib_qp_t * qp,uint32_t xid) rdma_done_notify() argument
4686 rib_qp_t *qp; rib_close_a_channel() local
[all...]
/titanic_51/usr/src/lib/libc/port/threads/
H A Dsynch.c471 queue_head_t *qp; in queue_alloc() local
484 udp->queue_head = qp = (queue_head_t *)data; in queue_alloc()
485 for (i = 0; i < 2 * QHASHSIZE; qp++, i++) { in queue_alloc()
486 qp->qh_type = (i < QHASHSIZE)? MX : CV; in queue_alloc()
487 qp->qh_lock.mutex_flag = LOCK_INITED; in queue_alloc()
488 qp->qh_lock.mutex_magic = MUTEX_MAGIC; in queue_alloc()
489 qp->qh_hlist = &qp->qh_def_root; in queue_alloc()
491 qp->qh_hlen = 1; in queue_alloc()
492 qp in queue_alloc()
503 QVERIFY(queue_head_t * qp) QVERIFY() argument
549 QVERIFY(qp) global() argument
560 queue_head_t *qp; queue_lock() local
597 queue_unlock(queue_head_t * qp) queue_unlock() argument
611 enqueue(queue_head_t * qp,ulwp_t * ulwp,int force_fifo) enqueue() argument
780 queue_slot(queue_head_t * qp,ulwp_t ** prevp,int * more) queue_slot() argument
825 queue_unlink(queue_head_t * qp,ulwp_t ** ulwpp,ulwp_t * prev) queue_unlink() argument
882 dequeue(queue_head_t * qp,int * more) dequeue() argument
901 queue_waiter(queue_head_t * qp) queue_waiter() argument
913 dequeue_self(queue_head_t * qp) dequeue_self() argument
954 queue_head_t *qp; unsleep_self() local
1618 queue_head_t *qp; mutex_wakeup() local
1641 queue_head_t *qp; mutex_wakeup_all() local
1786 queue_head_t *qp; mutex_lock_queue() local
3181 queue_head_t *qp; cond_sleep_queue() local
3703 queue_head_t *qp; cond_signal() local
3832 queue_head_t *qp; cond_broadcast() local
3968 queue_head_t *qp; dump_queue_statistics() local
[all...]
/titanic_51/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);
[all...]

123456