/freebsd/sys/dev/nvmf/host/ |
H A D | nvmf_qpair.c | 61 nq = qp->qp; in nvmf_allocate_request() 71 req->qp = qp; in nvmf_allocate_request() 82 if (qp->allocating == 0 && qp->shutting_down) in nvmf_allocate_request() 185 if (qp->qp == NULL) { in nvmf_receive_capsule() 237 strlcpy(qp->name, name, sizeof(qp->name)); in nvmf_init_qp() 259 qp, nvmf_receive_capsule, qp); in nvmf_init_qp() 260 if (qp->qp == NULL) { in nvmf_init_qp() 282 nq = qp->qp; in nvmf_shutdown_qp() 283 qp->qp = NULL; in nvmf_shutdown_qp() 358 qp = req->qp; in nvmf_submit_request() [all …]
|
/freebsd/sys/dev/nvmf/controller/ |
H A D | nvmft_qpair.c | 97 nvmft_handle_io_command(qp, qp->qid, nc); in nvmft_receive_capsule() 107 qp = malloc(sizeof(*qp), M_NVMFT, M_WAITOK | M_ZERO); in nvmft_qpair_init() 114 strlcpy(qp->name, name, sizeof(qp->name)); in nvmft_qpair_init() 119 qp, nvmft_receive_capsule, qp); in nvmft_qpair_init() 120 if (qp->qp == NULL) { in nvmft_qpair_init() 137 nq = qp->qp; in nvmft_qpair_shutdown() 138 qp->qp = NULL; in nvmft_qpair_shutdown() 181 nq = qp->qp; in _nvmft_send_response() 190 qp->sqhd = (qp->sqhd + 1) % qp->qsize; in _nvmft_send_response() 302 nq = qp->qp; in nvmft_send_connect_response() [all …]
|
/freebsd/contrib/nvi/common/ |
H A D | seq.c | 48 if ((qp = in seq_set() 134 if (qp->stype == stype && qp->ilen == ilen) { in seq_delete() 165 free(qp); in seq_free() 196 for (qp = SLIST_FIRST(sp->gp->seqq); qp != NULL; in seq_find() 197 lqp = qp, qp = SLIST_NEXT(qp, q)) { in seq_find() 206 qp->stype != stype || F_ISSET(qp, SEQ_FUNCMAP)) in seq_find() 213 qp->stype != stype || F_ISSET(qp, SEQ_FUNCMAP)) in seq_find() 259 SEQ *qp; in seq_close() local 278 SEQ *qp; in seq_dump() local 284 if (stype != qp->stype || F_ISSET(qp, SEQ_FUNCMAP)) in seq_dump() [all …]
|
/freebsd/sys/dev/ntb/ |
H A D | ntb_transport.c | 724 entry->qp = qp; in ntb_transport_create_queue() 730 entry->qp = qp; in ntb_transport_create_queue() 830 qp->tx_handler(qp, qp->cb_data, entry->buf, in ntb_tx_copy_callback() 867 offset = qp->tx_mw + qp->tx_max_frame * qp->tx_index; in ntb_async_tx() 884 qp->tx_pkts, qp->tx_index, qp->remote_rx_info->entry); in ntb_process_tx() 893 qp->tx_handler(qp, qp->cb_data, entry->buf, in ntb_process_tx() 946 offset = qp->rx_buff + qp->rx_max_frame * qp->rx_index; in ntb_process_rxc() 1076 qp->rx_handler(qp, qp->cb_data, m, len); in ntb_complete_rxc() 1454 qp->tx_index = qp->rx_index = 0; in ntb_qp_link_down_reset() 1455 qp->tx_bytes = qp->rx_bytes = 0; in ntb_qp_link_down_reset() [all …]
|
/freebsd/sys/dev/mthca/ |
H A D | mthca_qp.c | 257 qp->port = qp->alt_port; in mthca_qp_event() 261 event.element.qp = &qp->ibqp; in mthca_qp_event() 829 qp->sq.last = get_send_wqe(qp, qp->sq.max - 1); in __mthca_modify_qp() 832 qp->rq.last = get_recv_wqe(qp, qp->rq.max - 1); in __mthca_modify_qp() 1036 qp->send_wqe_offset = ALIGN(qp->rq.max << qp->rq.wqe_shift, in mthca_alloc_wqe_buf() 1056 &qp->queue, &qp->is_direct, pd, 0, &qp->mr); in mthca_alloc_wqe_buf() 1072 &qp->queue, qp->is_direct, &qp->mr); in mthca_free_wqe_buf() 1121 qp->qpn, &qp->rq.db); in mthca_alloc_memfree() 1126 qp->qpn, &qp->sq.db); in mthca_alloc_memfree() 1228 qp->sq.last = get_send_wqe(qp, qp->sq.max - 1); in mthca_alloc_qp_common() [all …]
|
/freebsd/contrib/ofed/libirdma/ |
H A D | irdma_uk.c | 170 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 176 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 180 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 185 qp->initial_ring.head = qp->sq_ring.head; in irdma_uk_qp_post_wr() 198 qp->initial_ring.head = qp->sq_ring.head; in irdma_qp_ring_push_db() 266 qp->swqe_polarity = !qp->swqe_polarity; in irdma_qp_get_next_send_wqe() 306 qp->rwqe_polarity = !qp->rwqe_polarity; in irdma_qp_get_next_recv_wqe() 449 if (qp->rd_fence_rate && (qp->ord_cnt++ == qp->rd_fence_rate)) { in irdma_uk_rdma_read() 1370 if (!qp || qp->destroy_pending) { in irdma_uk_cq_poll_cmpl() 1433 if (wqe_idx < qp->conn_wqes && qp->sq_ring.head == qp->sq_ring.tail) { in irdma_uk_cq_poll_cmpl() [all …]
|
/freebsd/sys/dev/irdma/ |
H A D | irdma_uk.c | 170 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 176 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 180 db_wr32(qp->qp_id, qp->wqe_alloc_db); in irdma_uk_qp_post_wr() 185 qp->initial_ring.head = qp->sq_ring.head; in irdma_uk_qp_post_wr() 198 qp->initial_ring.head = qp->sq_ring.head; in irdma_qp_ring_push_db() 266 qp->swqe_polarity = !qp->swqe_polarity; in irdma_qp_get_next_send_wqe() 306 qp->rwqe_polarity = !qp->rwqe_polarity; in irdma_qp_get_next_recv_wqe() 449 if (qp->rd_fence_rate && (qp->ord_cnt++ == qp->rd_fence_rate)) { in irdma_uk_rdma_read() 1261 if (!qp || qp->destroy_pending) { in irdma_uk_cq_poll_cmpl() 1324 if (wqe_idx < qp->conn_wqes && qp->sq_ring.head == qp->sq_ring.tail) { in irdma_uk_cq_poll_cmpl() [all …]
|
/freebsd/sys/dev/mlx4/mlx4_ib/ |
H A D | mlx4_ib_qp.c | 199 return get_wqe(qp, qp->rq.offset + (n << qp->rq.wqe_shift)); in get_recv_wqe() 204 return get_wqe(qp, qp->sq.offset + (n << qp->sq.wqe_shift)); in get_send_wqe() 519 qp->buf_size = (qp->rq.wqe_cnt << qp->rq.wqe_shift) + in set_kernel_sq_size() 523 qp->sq.offset = qp->rq.wqe_cnt << qp->rq.wqe_shift; in set_kernel_sq_size() 525 qp->rq.offset = qp->sq.wqe_cnt << qp->sq.wqe_shift; in set_kernel_sq_size() 530 (qp->sq.wqe_cnt - qp->sq_spare_wqes) / qp->sq_max_wqes_per_wr; in set_kernel_sq_size() 554 qp->buf_size = (qp->rq.wqe_cnt << qp->rq.wqe_shift) + in set_user_sq_size() 704 qp = &sqp->qp; in create_qp_common() 1036 if (qp->pri.smac || (!qp->pri.smac && qp->pri.smac_port)) { in destroy_qp_common() 2071 if (qp->pri.smac || (!qp->pri.smac && qp->pri.smac_port)) { in __mlx4_ib_modify_qp() [all …]
|
/freebsd/sys/dev/nvmf/ |
H A D | nvmf_tcp.c | 181 cb->qp = qp; in tcp_alloc_command_buffer() 323 qp->header_digests, qp->data_digests, qp->rxpda, &data_len, &fes, in nvmf_tcp_validate_pdu() 396 nvmf_capsule_received(&qp->qp, nc); in nvmf_tcp_save_command_capsule() 423 nvmf_capsule_received(&qp->qp, nc); in nvmf_tcp_save_response_capsule() 846 nvmf_capsule_received(&qp->qp, nc); in nvmf_tcp_handle_c2h_data() 1107 nvmf_qpair_error(&qp->qp, error); in nvmf_tcp_receive() 1319 nvmf_qpair_error(&qp->qp, error); in nvmf_tcp_send() 1499 tcp_free_qpair(&qp->qp); in tcp_allocate_qpair() 1505 tcp_free_qpair(&qp->qp); in tcp_allocate_qpair() 1509 return (&qp->qp); in tcp_allocate_qpair() [all …]
|
/freebsd/lib/libnvmf/ |
H A D | nvmf_tcp.c | 100 cb->qp = qp; in tcp_alloc_command_buffer() 248 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_validate_pdu() 261 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_validate_pdu() 503 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 512 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 522 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 533 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 541 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 550 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_h2c_data() 582 nvmf_tcp_report_error(qp->qp.nq_association, qp, in nvmf_tcp_handle_c2h_data() [all …]
|
H A D | nvmf_host.c | 47 struct nvmf_qpair *qp; in nvmf_connect() local 52 qp = NULL; in nvmf_connect() 87 if (qp == NULL) in nvmf_connect() 179 return (qp); in nvmf_connect() 186 if (qp != NULL) in nvmf_connect() 205 new_sqtail = (qp->nq_sqtail + 1) % qp->nq_qsize; in nvmf_host_transmit_command() 212 qp->nq_cid++; in nvmf_host_transmit_command() 214 qp->nq_cid = 0; in nvmf_host_transmit_command() 232 if (qp->nq_sqhd == qp->nq_sqtail) in nvmf_host_receive_capsule() 248 qp->nq_sqhd = (qp->nq_sqhd + 1) % qp->nq_qsize; in nvmf_host_receive_capsule() [all …]
|
H A D | nvmf_transport.c | 95 struct nvmf_qpair *qp; in nvmf_allocate_qpair() local 99 if (qp == NULL) in nvmf_allocate_qpair() 103 qp->nq_association = na; in nvmf_allocate_qpair() 106 return (qp); in nvmf_allocate_qpair() 119 na = qp->nq_association; in nvmf_free_qpair() 129 nc = qp->nq_association->na_ops->allocate_capsule(qp); in nvmf_allocate_command() 133 nc->nc_qpair = qp; in nvmf_allocate_command() 148 nc = qp->nq_association->na_ops->allocate_capsule(qp); in nvmf_allocate_response() 152 nc->nc_qpair = qp; in nvmf_allocate_response() 188 return (qp->nq_association->na_ops->receive_capsule(qp, ncp)); in nvmf_receive_capsule() [all …]
|
H A D | nvmf_controller.c | 73 qp->nq_sqhd = (qp->nq_sqhd + 1) % qp->nq_qsize; in nvmf_controller_transmit_response() 143 struct nvmf_qpair *qp; in nvmf_accept() local 150 qp = NULL; in nvmf_accept() 161 if (qp == NULL) in nvmf_accept() 208 qp->nq_admin = true; in nvmf_accept() 236 qp->nq_admin = false; in nvmf_accept() 238 qp->nq_qsize = qsize; in nvmf_accept() 319 qp->nq_sqhd = 0; in nvmf_accept() 322 return (qp); in nvmf_accept() 330 if (qp != NULL) in nvmf_accept() [all …]
|
/freebsd/sys/crypto/ccp/ |
H A D | ccp_hardware.c | 333 bus_dmamem_free(qp->ring_desc_tag, qp->desc_ring, qp->ring_desc_map); in ccp_hw_detach_queue() 856 desc = &qp->desc_ring[qp->cq_tail]; in ccp_passthrough() 1046 desc = &qp->desc_ring[qp->cq_tail]; in ccp_sha_single_desc() 1421 desc = &qp->desc_ring[qp->cq_tail]; in ccp_do_xts() 1458 qp->cq_tail = (qp->cq_tail + 1) % in ccp_do_xts() 1662 qp->cq_tail = (qp->cq_tail + 1) % in ccp_do_blkcipher() 1751 qp->cq_tail = (qp->cq_tail + 1) % in ccp_do_ghash_aad() 1766 desc = &qp->desc_ring[qp->cq_tail]; in ccp_do_gctr() 1789 qp->cq_tail = (qp->cq_tail + 1) % in ccp_do_gctr() 1802 desc = &qp->desc_ring[qp->cq_tail]; in ccp_do_ghash_final() [all …]
|
H A D | ccp.c | 140 struct ccp_queue *qp; in ccp_initialize_queues() local 146 qp->cq_softc = sc; in ccp_initialize_queues() 147 qp->cq_qindex = i; in ccp_initialize_queues() 537 qp = NULL; in ccp_process() 652 sc = qp->cq_softc; in ccp_queue_reserve_space() 663 msleep(&qp->cq_tail, &qp->cq_lock, 0, "ccpqfull", 0); in ccp_queue_reserve_space() 673 qp->cq_acq_tail = qp->cq_tail; in ccp_queue_acquire_reserve() 685 if (qp->cq_tail != qp->cq_acq_tail) { in ccp_queue_release() 700 for (i = qp->cq_acq_tail; i != qp->cq_tail; in ccp_queue_abort() 702 memset(&qp->desc_ring[i], 0, sizeof(qp->desc_ring[i])); in ccp_queue_abort() [all …]
|
/freebsd/sys/dev/qlnx/qlnxe/ |
H A D | ecore_roce.c | 403 if (!qp->has_resp) in ecore_roce_sp_create_responder() 413 if (!qp->irq) { in ecore_roce_sp_create_responder() 459 qp->use_srq); in ecore_roce_sp_create_responder() 550 qp->irq, in ecore_roce_sp_create_responder() 570 if (!qp->has_req) in ecore_roce_sp_create_requester() 580 if (!qp->orq) in ecore_roce_sp_create_requester() 702 qp->orq, in ecore_roce_sp_create_requester() 826 if (!qp->has_req) in ecore_roce_sp_modify_requester() 988 qp->irq, in ecore_roce_sp_destroy_qp_responder() 1066 qp->orq, in ecore_roce_sp_destroy_qp_requester() [all …]
|
/freebsd/contrib/ofed/libmlx4/ |
H A D | qp.c | 61 return qp->buf.buf + qp->rq.offset + (n << qp->rq.wqe_shift); in get_recv_wqe() 66 return qp->buf.buf + qp->sq.offset + (n << qp->sq.wqe_shift); in get_send_wqe() 526 ind = qp->rq.head & (qp->rq.wqe_cnt - 1); in mlx4_post_recv() 567 *qp->db = htobe32(qp->rq.head & 0xffff); in mlx4_post_recv() 677 qp->buf_size = (qp->rq.wqe_cnt << qp->rq.wqe_shift) + in mlx4_alloc_qp_buf() 678 (qp->sq.wqe_cnt << qp->sq.wqe_shift); in mlx4_alloc_qp_buf() 679 if (qp->rq.wqe_shift > qp->sq.wqe_shift) { in mlx4_alloc_qp_buf() 681 qp->sq.offset = qp->rq.wqe_cnt << qp->rq.wqe_shift; in mlx4_alloc_qp_buf() 683 qp->rq.offset = qp->sq.wqe_cnt << qp->sq.wqe_shift; in mlx4_alloc_qp_buf() 696 memset(qp->buf.buf, 0, qp->buf_size); in mlx4_alloc_qp_buf() [all …]
|
H A D | verbs.c | 821 qp = calloc(1, sizeof *qp); in mlx4_create_qp_ex() 890 ret = mlx4_store_qp(to_mctx(context), qp->verbs_qp.qp.qp_num, qp); in mlx4_create_qp_ex() 901 qp->doorbell_qpn = htobe32(qp->verbs_qp.qp.qp_num << 8); in mlx4_create_qp_ex() 907 return &qp->verbs_qp.qp; in mlx4_create_qp_ex() 910 ibv_cmd_destroy_qp(&qp->verbs_qp.qp); in mlx4_create_qp_ex() 953 qp = calloc(1, sizeof *qp); in mlx4_open_qp() 962 return &qp->verbs_qp.qp; in mlx4_open_qp() 1044 if (qp->send_cq && qp->send_cq != qp->recv_cq) in mlx4_modify_qp() 1060 if (!qp->send_cq || !qp->recv_cq) { in mlx4_lock_cqs() 1082 if (!qp->send_cq || !qp->recv_cq) { in mlx4_unlock_cqs() [all …]
|
/freebsd/sys/dev/bnxt/bnxt_re/ |
H A D | qplib_fp.c | 68 qp); in __bnxt_qplib_add_flush_qp() 89 if (qp->scq == qp->rcq) in bnxt_qplib_acquire_cq_flush_locks() 98 if (qp->scq == qp->rcq) in bnxt_qplib_release_cq_flush_locks() 1484 qp->cur_qp_state = qp->state; in bnxt_qplib_modify_qp() 1495 qp->cur_qp_state = qp->state; in bnxt_qplib_modify_qp() 1530 qp->cur_qp_state = qp->state; in bnxt_qplib_query_qp() 1751 qp->msn %= qp->msn_tbl_sz; in bnxt_qplib_fill_msn_search() 1952 qp->id, qp->state); in bnxt_qplib_post_send() 2315 qp->id, qp->state); in bnxt_qplib_post_recv() 2732 qp->state = qp->cur_qp_state; in bnxt_qplib_mark_qp_error() [all …]
|
/freebsd/sys/dev/qlnx/qlnxr/ |
H A D | qlnxr_cm.c | 125 qp->rqe_wr_id[qp->rq.gsi_cons].rc = in qlnxr_ll2_complete_rx_packet() 129 qp->rqe_wr_id[qp->rq.gsi_cons].sg_list[0].length = in qlnxr_ll2_complete_rx_packet() 414 qp->rqe_wr_id = kzalloc(qp->rq.max_wr * sizeof(*qp->rqe_wr_id), in qlnxr_create_gsi_qp() 421 qp->wqe_wr_id = kzalloc(qp->sq.max_wr * sizeof(*qp->wqe_wr_id), in qlnxr_create_gsi_qp() 655 qp->wqe_wr_id[qp->sq.prod].bytes_len += in qlnxr_gsi_build_packet() 714 qp->wqe_wr_id[qp->sq.prod].signaled = in qlnxr_gsi_post_send() 780 memset(&qp->rqe_wr_id[qp->rq.prod], 0, in qlnxr_gsi_post_recv() 781 sizeof(qp->rqe_wr_id[qp->rq.prod])); in qlnxr_gsi_post_recv() 819 wc[i].qp = &qp->ibqp; in qlnxr_gsi_poll_cq() 832 if (qp->rqe_wr_id[qp->rq.cons].vlan_id) { in qlnxr_gsi_poll_cq() [all …]
|
H A D | qlnxr_verbs.c | 2472 qp, qp->usq.buf_addr, qp->usq.buf_len, qp->urq.buf_addr, in qlnxr_qp_user_print() 3228 qp, new_state, qp->state); in qlnxr_update_qp_state() 3897 qp->sig = ~qp->sig; in qlnxr_destroy_qp() 4284 qp->icid, qp->state); in qlnxr_post_send() 4785 wc->qp = &qp->ibqp; in process_req() 5000 wc->qp = &qp->ibqp; in __process_resp_one() 5029 wc->qp = &qp->ibqp; in process_resp_one_srq() 5085 wc->qp = &qp->ibqp; in process_resp_flush() 5259 wc->qp = &qp->ibqp; in qlnxr_poll_cq() 6111 ep->qp = qp; in qlnxr_iw_connect() [all …]
|
/freebsd/contrib/ofed/libmlx5/ |
H A D | verbs.c | 1060 qp->sq.wrid = malloc(qp->sq.wqe_cnt * sizeof(*qp->sq.wrid)); in mlx5_alloc_qp_buf() 1067 qp->sq.wr_data = malloc(qp->sq.wqe_cnt * sizeof(*qp->sq.wr_data)); in mlx5_alloc_qp_buf() 1132 mlx5_free_actual_buf(to_mctx(qp->verbs_qp.qp.context), &qp->buf); in mlx5_alloc_qp_buf() 1266 qp = calloc(1, sizeof(*qp)); in create_qp() 1300 qp->buf_size = qp->sq.offset; in create_qp() 1314 qp->sq_start = qp->sq_buf.buf; in create_qp() 1315 qp->sq.qend = qp->sq_buf.buf + in create_qp() 1318 qp->sq_start = qp->buf.buf + qp->sq.offset; in create_qp() 1319 qp->sq.qend = qp->buf.buf + qp->sq.offset + in create_qp() 1391 qp->rq.max_post = qp->rq.wqe_cnt; in create_qp() [all …]
|
H A D | qp.c | 63 return qp->buf.buf + qp->rq.offset + (n << qp->rq.wqe_shift); in get_recv_wqe() 166 qp->sq.head = 0; in mlx5_init_qp_indices() 167 qp->sq.tail = 0; in mlx5_init_qp_indices() 168 qp->rq.head = 0; in mlx5_init_qp_indices() 169 qp->rq.tail = 0; in mlx5_init_qp_indices() 170 qp->sq.cur_post = 0; in mlx5_init_qp_indices() 672 idx = qp->sq.cur_post & (qp->sq.wqe_cnt - 1); in _mlx5_post_send() 910 qp->sq.wqe_head[idx] = qp->sq.head + nreq; in _mlx5_post_send() 929 qp->db[MLX5_SND_DBR] = htobe32(qp->sq.cur_post & 0xffff); in _mlx5_post_send() 1147 ind = qp->rq.head & (qp->rq.wqe_cnt - 1); in mlx5_post_recv() [all …]
|
/freebsd/sys/dev/mlx5/mlx5_ib/ |
H A D | mlx5_ib_qp.c | 107 return get_wqe(qp, qp->rq.offset + (n << qp->rq.wqe_shift)); in get_recv_wqe() 255 qp->rq.max_post = qp->rq.wqe_cnt; in set_rq_size() 272 qp->rq.max_post = qp->rq.wqe_cnt; in set_rq_size() 821 qp->sq.offset = qp->rq.wqe_cnt << qp->rq.wqe_shift; in create_user_qp() 958 qp->sq.offset = qp->rq.wqe_cnt << qp->rq.wqe_shift; in create_kernel_qp() 968 qp->sq.qend = mlx5_get_send_wqe(qp, qp->sq.wqe_cnt); in create_kernel_qp() 1000 qp->sq.wrid = kmalloc(qp->sq.wqe_cnt * sizeof(*qp->sq.wrid), GFP_KERNEL); in create_kernel_qp() 1002 qp->rq.wrid = kmalloc(qp->rq.wqe_cnt * sizeof(*qp->rq.wrid), GFP_KERNEL); in create_kernel_qp() 1006 if (!qp->sq.wrid || !qp->sq.wr_data || !qp->rq.wrid || in create_kernel_qp() 2025 get_cqs(qp->ibqp.qp_type, qp->ibqp.send_cq, qp->ibqp.recv_cq, in destroy_qp_common() [all …]
|
/freebsd/sys/ofed/drivers/infiniband/core/ |
H A D | ib_verbs.c | 811 qp = kzalloc(sizeof *qp, GFP_KERNEL); in __ib_open_qp() 812 if (!qp) in __ib_open_qp() 858 qp->qp_context = qp; in ib_create_xrc_qp() 860 qp->send_cq = qp->recv_cq = NULL; in ib_create_xrc_qp() 892 qp->real_qp = qp; in ib_create_qp() 1497 if (qp->real_qp != qp) in ib_destroy_qp_user() 1506 ret = qp->device->destroy_qp(qp, udata); in ib_destroy_qp_user() 1748 ret = qp->device->attach_mcast(qp, gid, lid); in ib_attach_mcast() 1766 ret = qp->device->detach_mcast(qp, gid, lid); in ib_detach_mcast() 2241 qp->device->drain_sq(qp); in ib_drain_sq() [all …]
|