Home
last modified time | relevance | path

Searched refs:wr_id (Results 1 – 25 of 74) sorted by relevance

123

/freebsd/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_ib.c161 priv->rx_wr.wr_id = id | IPOIB_OP_RECV; in ipoib_ib_post_receive()
203 unsigned int wr_id = wc->wr_id & ~IPOIB_OP_RECV; in ipoib_ib_handle_rx_wc() local
209 wr_id, wc->status); in ipoib_ib_handle_rx_wc()
211 if (unlikely(wr_id >= ipoib_recvq_size)) { in ipoib_ib_handle_rx_wc()
213 wr_id, ipoib_recvq_size); in ipoib_ib_handle_rx_wc()
217 mb = priv->rx_ring[wr_id].mb; in ipoib_ib_handle_rx_wc()
223 wc->status, wr_id, wc->vendor_err); in ipoib_ib_handle_rx_wc()
227 ipoib_dma_unmap_rx(priv, &priv->rx_ring[wr_id]); in ipoib_ib_handle_rx_wc()
229 priv->rx_ring[wr_id].mb = NULL; in ipoib_ib_handle_rx_wc()
241 memcpy(&saverx, &priv->rx_ring[wr_id], sizeof(saverx)); in ipoib_ib_handle_rx_wc()
[all …]
H A Dipoib_cm.c77 .wr_id = IPOIB_CM_RX_DRAIN_WRID,
106 priv->cm.rx_wr.wr_id = id | IPOIB_OP_CM | IPOIB_OP_RECV; in ipoib_cm_post_receive_srq()
137 wr->wr_id = id | IPOIB_OP_CM | IPOIB_OP_RECV; in ipoib_cm_post_receive_nonsrq()
480 unsigned int wr_id = wc->wr_id & ~(IPOIB_OP_CM | IPOIB_OP_RECV); in ipoib_cm_handle_rx_wc() local
487 wr_id, wc->status); in ipoib_cm_handle_rx_wc()
489 if (unlikely(wr_id >= ipoib_recvq_size)) { in ipoib_cm_handle_rx_wc()
490 if (wr_id == (IPOIB_CM_RX_DRAIN_WRID & ~(IPOIB_OP_CM | IPOIB_OP_RECV))) { in ipoib_cm_handle_rx_wc()
500 wr_id, ipoib_recvq_size); in ipoib_cm_handle_rx_wc()
509 mb = rx_ring[wr_id].mb; in ipoib_cm_handle_rx_wc()
514 wc->status, wr_id, wc->vendor_err); in ipoib_cm_handle_rx_wc()
[all …]
/freebsd/sys/dev/iser/
H A Diser_verbs.c64 is_iser_tx_desc(struct iser_conn *iser_conn, void *wr_id) in is_iser_tx_desc() argument
71 if (wr_id >= start && wr_id < end) in is_iser_tx_desc()
74 return ((uintptr_t)wr_id != (uintptr_t)iser_conn->login_resp_buf); in is_iser_tx_desc()
93 void *wr_id = (void *)(uintptr_t)wc->wr_id; in iser_handle_comp_error() local
97 if (is_iser_tx_desc(iser_conn, wr_id)) { in iser_handle_comp_error()
124 rx_desc = (struct iser_rx_desc *)(uintptr_t)wc->wr_id; in iser_handle_wc()
129 tx_desc = (struct iser_tx_desc *)(uintptr_t)wc->wr_id; in iser_handle_wc()
139 iser_conn, (unsigned long long)wc->wr_id, in iser_handle_wc()
143 iser_conn, (unsigned long long)wc->wr_id); in iser_handle_wc()
146 if (wc->wr_id == ISER_BEACON_WRID) { in iser_handle_wc()
[all …]
H A Diser_memory.c143 inv_wr->wr_id = ISER_FASTREG_LI_WRID; in iser_inv_rkey()
182 fastreg_wr.wr.wr_id = ISER_FASTREG_LI_WRID; in iser_fast_reg_mr()
/freebsd/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_gsi.c97 u64 wr_id; in handle_single_completion() local
102 wr_id = wr->wc.wr_id; in handle_single_completion()
104 wr->wc.wr_id = wr_id; in handle_single_completion()
428 gsi_wr->wc.wr_id = wr->wr.wr_id; in mlx5_ib_add_outstanding_wr()
445 { .wr_id = wr->wr.wr_id }, in mlx5_ib_gsi_silent_drop()
H A Dmlx5_ib_cq.c188 wc->wr_id = srq->wrid[wqe_ctr]; in handle_responder()
195 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)]; in handle_responder()
455 wc->wr_id = wq->wrid[idx]; in sw_send_comp()
483 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)]; in sw_recv_comp()
578 wc->wr_id = wq->wrid[idx]; in mlx5_poll_one()
604 wc->wr_id = wq->wrid[idx]; in mlx5_poll_one()
612 wc->wr_id = srq->wrid[wqe_ctr]; in mlx5_poll_one()
616 wc->wr_id = wq->wrid[wq->tail & (wq->wqe_cnt - 1)]; in mlx5_poll_one()
/freebsd/contrib/libpcap/
H A Dpcap-rdmasniff.c94 rdmasniff_post_recv(pcap_t *handle, uint64_t wr_id) in rdmasniff_post_recv() argument
101 sg_entry.addr = (uintptr_t) handle->buffer + RDMASNIFF_RECEIVE_SIZE * wr_id; in rdmasniff_post_recv()
104 wr.wr_id = wr_id; in rdmasniff_post_recv()
161 wc.wr_id, in rdmasniff_read()
170 pktd = (u_char *) handle->buffer + wc.wr_id * RDMASNIFF_RECEIVE_SIZE; in rdmasniff_read()
179 rdmasniff_post_recv(handle, wc.wr_id); in rdmasniff_read()
/freebsd/contrib/ofed/librdmacm/
H A Drdma_verbs.h104 wr.wr_id = (uintptr_t) context; in rdma_post_recvv()
121 wr.wr_id = (uintptr_t) context; in rdma_post_sendv()
137 wr.wr_id = (uintptr_t) context; in rdma_post_readv()
155 wr.wr_id = (uintptr_t) context; in rdma_post_writev()
238 wr.wr_id = (uintptr_t) context; in rdma_post_ud_send()
H A Drsocket.c153 #define rs_wr_is_recv(wr_id) (wr_id & RS_WR_ID_FLAG_RECV) argument
154 #define rs_wr_is_msg_send(wr_id) (wr_id & RS_WR_ID_FLAG_MSG_SEND) argument
155 #define rs_wr_data(wr_id) ((uint32_t) wr_id) argument
818 wr.wr_id = rs_recv_wr_id(0); in rs_post_recv()
822 wr.wr_id = rs_recv_wr_id(rs->rbuf_msg_index); in rs_post_recv()
849 wr.wr_id = rs_recv_wr_id(offset); in ds_post_recv()
1654 wr.wr_id = rs_send_wr_id(msg); in rs_post_msg()
1682 wr.wr_id = rs_send_wr_id(wr_data); in rs_post_write()
1705 wr.wr_id = rs_send_wr_id(msg); in rs_post_write_msg()
1718 wr.wr_id = rs_send_wr_id(rs_msg_set(rs_msg_op(msg), 0)) | in rs_post_write_msg()
[all …]
/freebsd/contrib/ofed/libibverbs/examples/
H A Drc_pingpong.c551 .wr_id = PINGPONG_RECV_WRID, in pp_post_recv()
573 .wr_id = PINGPONG_SEND_WRID, in pp_post_send()
595 uint64_t wr_id, enum ibv_wc_status status, in parse_single_wc() argument
602 status, (int)wr_id); in parse_single_wc()
606 switch ((int)wr_id) { in parse_single_wc()
650 (int)wr_id); in parse_single_wc()
654 ctx->pending &= ~(int)wr_id; in parse_single_wc()
964 ctx->cq_s.cq_ex->wr_id, in main()
976 ctx->cq_s.cq_ex->wr_id, in main()
1000 wc[i].wr_id, in main()
H A Duc_pingpong.c481 .wr_id = PINGPONG_RECV_WRID, in pp_post_recv()
503 .wr_id = PINGPONG_SEND_WRID, in pp_post_send()
791 wc[i].status, (int) wc[i].wr_id); in main()
795 switch ((int) wc[i].wr_id) { in main()
816 (int) wc[i].wr_id); in main()
820 ctx->pending &= ~(int) wc[i].wr_id; in main()
H A Dud_pingpong.c498 .wr_id = PINGPONG_RECV_WRID, in pp_post_recv()
520 .wr_id = PINGPONG_SEND_WRID, in pp_post_send()
797 wc[i].status, (int) wc[i].wr_id); in main()
801 switch ((int) wc[i].wr_id) { in main()
822 (int) wc[i].wr_id); in main()
826 ctx->pending &= ~(int) wc[i].wr_id; in main()
H A Dsrq_pingpong.c561 .wr_id = PINGPONG_RECV_WRID, in pp_post_recv()
583 .wr_id = PINGPONG_SEND_WRID, in pp_post_send()
914 wc[i].status, (int) wc[i].wr_id); in main()
925 switch ((int) wc[i].wr_id) { in main()
946 (int) wc[i].wr_id); in main()
950 ctx->pending[qp_ind] &= ~(int) wc[i].wr_id; in main()
/freebsd/sys/dev/bnxt/bnxt_re/
H A Dqplib_fp.c801 srqe->wr_id |= cpu_to_le32((u32)next); in bnxt_qplib_post_srq_recv()
802 srq->swq[next].wr_id = wqe->wr_id; in bnxt_qplib_post_srq_recv()
1981 swq->wr_id = wqe->wr_id; in bnxt_qplib_post_send()
1991 qp->id, wqe_idx, swq->wr_id); in bnxt_qplib_post_send()
2329 swq->wr_id = wqe->wr_id; in bnxt_qplib_post_recv()
2333 wqe_idx, swq->wr_id); in bnxt_qplib_post_recv()
2359 base_hdr->wr_id |= cpu_to_le32(wqe_idx); in bnxt_qplib_post_recv()
2634 if (sq->swq[last].wr_id == BNXT_QPLIB_FENCE_WRID) { in __flush_sq()
2643 cqe->wr_id = sq->swq[last].wr_id; in __flush_sq()
2650 last, cqe->wr_id, cqe->status); in __flush_sq()
[all …]
/freebsd/contrib/ofed/libirdma/
H A Dirdma_user.h212 u64 wr_id; member
245 u64 wr_id; member
269 u64 wr_id; member
306 int irdma_uk_post_nop(struct irdma_qp_uk *qp, u64 wr_id, bool signaled,
460 int irdma_nop(struct irdma_qp_uk *qp, u64 wr_id, bool signaled, bool post_sq);
H A Dirdma_uverbs.c318 wr.wr_id = mw_bind->wr_id; in irdma_ubind_mw()
735 ibvcq_ex->wr_id = cur_cqe->wr_id; in irdma_process_cqe_ext()
755 entry->wr_id = cur_cqe->wr_id; in irdma_process_cqe()
1683 info.wr_id = (u64)(ib_wr->wr_id); in irdma_upost_send()
1866 post_recv.wr_id = ib_wr->wr_id; in irdma_upost_recv()
/freebsd/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_mad.c620 wr.wr.wr_id = ((u64) tun_tx_ix) | MLX4_TUN_SET_WRID_QPN(dest_qpt); in mlx4_ib_send_to_slave()
1292 recv_wr.wr_id = (u64) index | MLX4_TUN_WRID_RECV | in mlx4_ib_post_pv_qp_buf()
1408 wr.wr.wr_id = ((u64) wire_tx_ix) | MLX4_TUN_SET_WRID_QPN(src_qpnum); in mlx4_ib_send_to_wire()
1446 struct mlx4_ib_demux_pv_qp *tun_qp = &ctx->qp[MLX4_TUN_WRID_QPN(wc->wr_id)]; in mlx4_ib_multiplex_mad()
1447 int wr_ix = wc->wr_id & (MLX4_NUM_TUNNEL_BUFS - 1); in mlx4_ib_multiplex_mad()
1698 tun_qp = &ctx->qp[MLX4_TUN_WRID_QPN(wc.wr_id)]; in mlx4_ib_tunnel_comp_worker()
1704 wc.wr_id & in mlx4_ib_tunnel_comp_worker()
1708 "buf:%lld\n", (unsigned long long)wc.wr_id); in mlx4_ib_tunnel_comp_worker()
1713 (unsigned long long)wc.wr_id, wc.status); in mlx4_ib_tunnel_comp_worker()
1714 ib_destroy_ah(tun_qp->tx_ring[wc.wr_id & in mlx4_ib_tunnel_comp_worker()
[all …]
/freebsd/sys/dev/qlnx/qlnxr/
H A Dqlnxr_cm.c544 qp, swr->opcode, swr->wr_id, *roce_mode, grh->hop_limit, in qlnxr_gsi_build_header()
713 qp->wqe_wr_id[qp->sq.prod].wr_id = wr->wr_id; in qlnxr_gsi_post_send()
783 qp->rqe_wr_id[qp->rq.prod].wr_id = wr->wr_id; in qlnxr_gsi_post_recv()
820 wc[i].wr_id = qp->rqe_wr_id[qp->rq.cons].wr_id; in qlnxr_gsi_poll_cq()
845 wc[i].wr_id = qp->wqe_wr_id[qp->sq.cons].wr_id; in qlnxr_gsi_poll_cq()
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_tx.c139 tx_wr.wr_id = mseq | SDP_OP_SEND; in sdp_post_send()
213 mb = sdp_send_completion(ssk, wc->wr_id); in sdp_handle_send_comp()
230 if (likely(wc->wr_id & SDP_OP_SEND)) { in sdp_process_tx_wc()
236 if (wc->wr_id & SDP_OP_RDMA) { in sdp_process_tx_wc()
401 wr.wr_id = 0; in sdp_post_keepalive()
H A Dsdp_rx.c141 rx_wr.wr_id = id | SDP_OP_RECV; in sdp_post_recv()
477 mb = sdp_recv_completion(ssk, wc->wr_id); in sdp_process_rx_wc()
495 (int)wc->wr_id, wc->byte_len); in sdp_process_rx_wc()
513 if (mseq != (int)wc->wr_id) in sdp_process_rx_wc()
515 mseq, (int)wc->wr_id); in sdp_process_rx_wc()
545 BUG_ON(!(wc->wr_id & SDP_OP_RECV)); in sdp_poll_rx_cq()
/freebsd/sys/dev/irdma/
H A Dirdma_user.h308 u64 wr_id; member
341 u64 wr_id; member
365 u64 wr_id; member
405 int irdma_uk_post_nop(struct irdma_qp_uk *qp, u64 wr_id, bool signaled,
561 int irdma_nop(struct irdma_qp_uk *qp, u64 wr_id, bool signaled, bool post_sq);
/freebsd/contrib/ofed/libmlx5/
H A Dcq.c153 cq->ibv_cq.wr_id = srq->wrid[wqe_ctr]; in handle_responder_lazy()
171 cq->ibv_cq.wr_id = wq->wrid[wqe_ctr]; in handle_responder_lazy()
196 wc->wr_id = srq->wrid[wqe_ctr]; in handle_responder()
218 wc->wr_id = wq->wrid[wqe_ctr]; in handle_responder()
583 cq->ibv_cq.wr_id = wq->wrid[idx]; in mlx5_parse_cqe()
595 wc->wr_id = wq->wrid[idx]; in mlx5_parse_cqe()
657 cq->ibv_cq.wr_id = wq->wrid[idx]; in mlx5_parse_cqe()
659 wc->wr_id = wq->wrid[idx]; in mlx5_parse_cqe()
670 cq->ibv_cq.wr_id = (*cur_srq)->wrid[wqe_ctr]; in mlx5_parse_cqe()
672 wc->wr_id = (*cur_srq)->wrid[wqe_ctr]; in mlx5_parse_cqe()
[all …]
/freebsd/contrib/ofed/libcxgb4/
H A Dqp.c391 swsqe->wr_id = wr->wr_id; in c4iw_post_send()
395 __func__, (unsigned long long)wr->wr_id, qhp->wq.sq.pidx, in c4iw_post_send()
457 qhp->wq.rq.sw_rq[qhp->wq.rq.pidx].wr_id = wr->wr_id; in c4iw_post_receive()
467 (unsigned long long) wr->wr_id, qhp->wq.rq.pidx); in c4iw_post_receive()
/freebsd/contrib/ofed/libibverbs/
H A Dcompat-1_0.c85 uint64_t wr_id; member
112 uint64_t wr_id; member
376 real_wr->wr_id = w->wr_id; in post_srq_recv_wrapper_1_0()
414 real_wr->wr_id = w->wr_id; in post_send_wrapper_1_0()
494 real_wr->wr_id = w->wr_id; in post_recv_wrapper_1_0()
/freebsd/sys/ofed/include/uapi/rdma/
H A Dmlx5_user_ioctl_verbs.h58 __aligned_u64 wr_id; member

123