| /NextBSD/contrib/ofed/libcxgb4/src/ |
| HD | verbs.c | 310 struct c4iw_qp *qhp; in create_qp_v0() local
316 qhp = calloc(1, sizeof *qhp); in create_qp_v0()
317 if (!qhp) in create_qp_v0()
320 ret = ibv_cmd_create_qp(pd, &qhp->ibv_qp, attr, &cmd, in create_qp_v0()
332 qhp->wq.qid_mask = resp.qid_mask; in create_qp_v0()
333 qhp->rhp = dev; in create_qp_v0()
334 qhp->wq.sq.qid = resp.sqid; in create_qp_v0()
335 qhp->wq.sq.size = resp.sq_size; in create_qp_v0()
336 qhp->wq.sq.memsize = resp.sq_memsize; in create_qp_v0()
337 qhp->wq.sq.flags = 0; in create_qp_v0()
[all …]
|
| HD | qp.c | 258 static int build_rdma_recv(struct c4iw_qp *qhp, union t4_recv_wr *wqe, in build_rdma_recv() argument
285 static void ring_kernel_db(struct c4iw_qp *qhp, u32 qid, u16 idx) in ring_kernel_db() argument
293 if (qid == qhp->wq.sq.qid) { in ring_kernel_db()
300 ret = ibv_cmd_modify_qp(&qhp->ibv_qp, &attr, mask, &cmd, sizeof cmd); in ring_kernel_db()
311 struct c4iw_qp *qhp; in c4iw_post_send() local
317 qhp = to_c4iw_qp(ibqp); in c4iw_post_send()
318 pthread_spin_lock(&qhp->lock); in c4iw_post_send()
319 if (t4_wq_in_error(&qhp->wq)) { in c4iw_post_send()
320 pthread_spin_unlock(&qhp->lock); in c4iw_post_send()
323 num_wrs = t4_sq_avail(&qhp->wq); in c4iw_post_send()
[all …]
|
| HD | dev.c | 253 static void dump_qp(struct c4iw_qp *qhp) in dump_qp() argument
266 qhp, in dump_qp()
267 qhp->wq.sq.qid, in dump_qp()
268 qhp->wq.error, in dump_qp()
269 qhp->wq.flushed, in dump_qp()
270 qhp->wq.qid_mask, in dump_qp()
271 qhp->wq.sq.qid, in dump_qp()
272 qhp->wq.sq.queue, in dump_qp()
273 qhp->wq.sq.sw_sq, in dump_qp()
274 qhp->wq.sq.cidx, in dump_qp()
[all …]
|
| HD | cq.c | 98 void c4iw_flush_sq(struct c4iw_qp *qhp) in c4iw_flush_sq() argument
101 struct t4_wq *wq = &qhp->wq; in c4iw_flush_sq()
102 struct c4iw_cq *chp = to_c4iw_cq(qhp->ibv_qp.send_cq); in c4iw_flush_sq()
204 struct c4iw_qp *qhp; in c4iw_flush_hw_cq() local
217 qhp = get_qhp(chp->rhp, CQE_QPID(hw_cqe)); in c4iw_flush_hw_cq()
222 if (qhp == NULL) in c4iw_flush_hw_cq()
250 if (!qhp->wq.sq.oldest_read->signaled) { in c4iw_flush_hw_cq()
251 advance_oldest_read(&qhp->wq); in c4iw_flush_hw_cq()
259 create_read_req_cqe(&qhp->wq, hw_cqe, &read_cqe); in c4iw_flush_hw_cq()
261 advance_oldest_read(&qhp->wq); in c4iw_flush_hw_cq()
[all …]
|
| HD | libcxgb4.h | 205 void c4iw_flush_qp(struct c4iw_qp *qhp);
221 void c4iw_flush_sq(struct c4iw_qp *qhp);
|
| /NextBSD/sys/dev/cxgb/ulp/iw_cxgb/ |
| HD | iw_cxgb_qp.c | 246 static int build_rdma_recv(struct iwch_qp *qhp, union t3_wr *wqe, in build_rdma_recv() argument
257 err = iwch_sgl2pbl_map(qhp->rhp, wr->sg_list, wr->num_sge, pbl_addr, in build_rdma_recv()
282 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr, in build_rdma_recv()
283 qhp->wq.rq_size_log2)].wr_id = wr->wr_id; in build_rdma_recv()
284 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr, in build_rdma_recv()
285 qhp->wq.rq_size_log2)].pbl_addr = 0; in build_rdma_recv()
290 static int build_zero_stag_recv(struct iwch_qp *qhp, union t3_wr *wqe, in build_zero_stag_recv() argument
304 pbl_addr = cxio_hal_pblpool_alloc(&qhp->rhp->rdev, T3_STAG0_PBL_SIZE); in build_zero_stag_recv()
311 pbl_offset = (pbl_addr - qhp->rhp->rdev.rnic_info.pbl_base) >> 3; in build_zero_stag_recv()
346 qhp->wq.rq[Q_PTR2IDX(qhp->wq.rq_wptr, in build_zero_stag_recv()
[all …]
|
| HD | iw_cxgb_ev.c | 80 post_qp_event(struct iwch_dev *rnicp, struct iwch_qp *qhp, struct iwch_cq *chp, in post_qp_event() argument
90 if (!qhp) { in post_qp_event()
98 if ((qhp->attr.state == IWCH_QP_STATE_ERROR) || in post_qp_event()
99 (qhp->attr.state == IWCH_QP_STATE_TERMINATE)) { in post_qp_event()
102 qhp->attr.state, qhp->wq.qpid, CQE_STATUS(rsp_msg->cqe)); in post_qp_event()
115 if (qhp->attr.state == IWCH_QP_STATE_RTS) { in post_qp_event()
117 iwch_modify_qp(qhp->rhp, qhp, IWCH_QP_ATTR_NEXT_STATE, in post_qp_event()
120 iwch_post_terminate(qhp, rsp_msg); in post_qp_event()
128 event.element.qp = &qhp->ibqp; in post_qp_event()
130 if (qhp->ibqp.event_handler) in post_qp_event()
[all …]
|
| HD | iw_cxgb_provider.c | 737 struct iwch_qp *qhp; in iwch_destroy_qp() local
741 qhp = to_iwch_qp(ib_qp); in iwch_destroy_qp()
742 rhp = qhp->rhp; in iwch_destroy_qp()
745 iwch_modify_qp(rhp, qhp, IWCH_QP_ATTR_NEXT_STATE, &attrs, 0); in iwch_destroy_qp()
746 mtx_lock(&qhp->lock); in iwch_destroy_qp()
747 if (qhp->ep) in iwch_destroy_qp()
748 msleep(qhp, &qhp->lock, 0, "iwch_destroy_qp1", 0); in iwch_destroy_qp()
749 mtx_unlock(&qhp->lock); in iwch_destroy_qp()
751 remove_handle(rhp, &rhp->qpidr, qhp->wq.qpid); in iwch_destroy_qp()
753 mtx_lock(&qhp->lock); in iwch_destroy_qp()
[all …]
|
| HD | iw_cxgb_cq.c | 91 struct iwch_qp *qhp = NULL; in iwch_poll_cq_one() local
104 qhp = get_qhp(rhp, CQE_QPID(*rd_cqe)); in iwch_poll_cq_one()
105 if (!qhp) in iwch_poll_cq_one()
108 mtx_lock(&qhp->lock); in iwch_poll_cq_one()
109 wq = &(qhp->wq); in iwch_poll_cq_one()
126 wc->qp = &qhp->ibqp; in iwch_poll_cq_one()
226 mtx_unlock(&qhp->lock); in iwch_poll_cq_one()
|
| HD | iw_cxgb_provider.h | 169 qp_quiesced(struct iwch_qp *qhp) in qp_quiesced() argument
171 return qhp->flags & QP_QUIESCED; in qp_quiesced()
258 struct iwch_qp *qhp,
337 int iwch_post_terminate(struct iwch_qp *qhp, struct respQ_msg_t *rsp_msg);
340 void stop_read_rep_timer(struct iwch_qp *qhp);
|
| /NextBSD/sys/dev/cxgbe/iw_cxgbe/ |
| HD | qp.c | 71 static void set_state(struct c4iw_qp *qhp, enum c4iw_qp_state state) in set_state() argument
74 spin_lock_irqsave(&qhp->lock, flag); in set_state()
75 qhp->attr.state = state; in set_state()
76 spin_unlock_irqrestore(&qhp->lock, flag); in set_state()
494 static int build_rdma_recv(struct c4iw_qp *qhp, union t4_recv_wr *wqe, in build_rdma_recv() argument
499 ret = build_isgl((__be64 *)qhp->wq.rq.queue, in build_rdma_recv()
500 (__be64 *)&qhp->wq.rq.queue[qhp->wq.rq.size], in build_rdma_recv()
586 struct c4iw_qp *qhp; in c4iw_post_send() local
593 qhp = to_c4iw_qp(ibqp); in c4iw_post_send()
594 spin_lock_irqsave(&qhp->lock, flag); in c4iw_post_send()
[all …]
|
| HD | ev.c | 43 struct c4iw_qp *qhp, in post_qp_event() argument
51 if ((qhp->attr.state == C4IW_QP_STATE_ERROR) || in post_qp_event()
52 (qhp->attr.state == C4IW_QP_STATE_TERMINATE)) { in post_qp_event()
55 qhp->attr.state, qhp->wq.sq.qid, CQE_STATUS(err_cqe)); in post_qp_event()
65 if (qhp->attr.state == C4IW_QP_STATE_RTS) { in post_qp_event()
67 c4iw_modify_qp(qhp->rhp, qhp, C4IW_QP_ATTR_NEXT_STATE, in post_qp_event()
76 event.element.qp = &qhp->ibqp; in post_qp_event()
77 if (qhp->ibqp.event_handler) in post_qp_event()
78 (*qhp->ibqp.event_handler)(&event, qhp->ibqp.qp_context); in post_qp_event()
88 struct c4iw_qp *qhp; in c4iw_ev_dispatch() local
[all …]
|
| HD | cq.c | 593 struct c4iw_qp *qhp = NULL; in c4iw_poll_cq_one() local
606 qhp = get_qhp(chp->rhp, CQE_QPID(rd_cqe)); in c4iw_poll_cq_one()
607 if (!qhp) in c4iw_poll_cq_one()
610 spin_lock(&qhp->lock); in c4iw_poll_cq_one()
611 wq = &(qhp->wq); in c4iw_poll_cq_one()
618 wc->qp = &qhp->ibqp; in c4iw_poll_cq_one()
732 spin_unlock(&qhp->lock); in c4iw_poll_cq_one()
|
| HD | iw_cxgbe.h | 522 struct c4iw_qp *qhp,
908 u16 c4iw_rqes_posted(struct c4iw_qp *qhp);
909 int c4iw_post_terminate(struct c4iw_qp *qhp, struct t4_cqe *err_cqe);
|
| /NextBSD/contrib/unbound/doc/ |
| HD | unbound.doxygen | 1005 # .qhp file.
|
| /NextBSD/contrib/ldns/ |
| HD | libdns.doxygen | 1080 # .qhp file.
|