| /kernel/linux/linux-5.10/drivers/infiniband/sw/rxe/ |
| H A D | rxe.c | 9 #include "rxe.h"
18 /* free resources for a rxe device all objects created for this device must
23 struct rxe_dev *rxe = container_of(ib_dev, struct rxe_dev, ib_dev); in rxe_dealloc() local
25 rxe_pool_cleanup(&rxe->uc_pool); in rxe_dealloc()
26 rxe_pool_cleanup(&rxe->pd_pool); in rxe_dealloc()
27 rxe_pool_cleanup(&rxe->ah_pool); in rxe_dealloc()
28 rxe_pool_cleanup(&rxe->srq_pool); in rxe_dealloc()
29 rxe_pool_cleanup(&rxe->qp_pool); in rxe_dealloc()
30 rxe_pool_cleanup(&rxe->cq_pool); in rxe_dealloc()
31 rxe_pool_cleanup(&rxe in rxe_dealloc()
41 rxe_init_device_param(struct rxe_dev *rxe) rxe_init_device_param() argument
107 rxe_init_ports(struct rxe_dev *rxe) rxe_init_ports() argument
118 rxe_init_pools(struct rxe_dev *rxe) rxe_init_pools() argument
197 rxe_init(struct rxe_dev *rxe) rxe_init() argument
220 rxe_set_mtu(struct rxe_dev *rxe, unsigned int ndev_mtu) rxe_set_mtu() argument
237 rxe_add(struct rxe_dev *rxe, unsigned int mtu, const char *ibdev_name) rxe_add() argument
[all...] |
| H A D | rxe_mmap.c | 13 #include "rxe.h"
21 struct rxe_dev *rxe = to_rdev(ip->context->device); in rxe_mmap_release() local
23 spin_lock_bh(&rxe->pending_lock); in rxe_mmap_release()
28 spin_unlock_bh(&rxe->pending_lock); in rxe_mmap_release()
65 struct rxe_dev *rxe = to_rdev(context->device); in rxe_mmap() local
76 spin_lock_bh(&rxe->pending_lock); in rxe_mmap()
77 list_for_each_entry_safe(ip, pp, &rxe->pending_mmaps, pending_mmaps) { in rxe_mmap()
84 spin_unlock_bh(&rxe->pending_lock); in rxe_mmap()
92 spin_unlock_bh(&rxe->pending_lock); in rxe_mmap()
98 spin_unlock_bh(&rxe in rxe_mmap()
116 rxe_create_mmap_info(struct rxe_dev *rxe, u32 size, struct ib_udata *udata, void *obj) rxe_create_mmap_info() argument
[all...] |
| H A D | rxe_net.c | 17 #include "rxe.h"
23 int rxe_mcast_add(struct rxe_dev *rxe, union ib_gid *mgid) in rxe_mcast_add() argument
29 err = dev_mc_add(rxe->ndev, ll_addr); in rxe_mcast_add()
34 int rxe_mcast_delete(struct rxe_dev *rxe, union ib_gid *mgid) in rxe_mcast_delete() argument
40 err = dev_mc_del(rxe->ndev, ll_addr); in rxe_mcast_delete()
158 struct rxe_dev *rxe = rxe_get_dev_from_net(ndev); in rxe_udp_encap_recv() local
161 if (!rxe && is_vlan_dev(rdev)) { in rxe_udp_encap_recv()
163 rxe = rxe_get_dev_from_net(rdev); in rxe_udp_encap_recv()
165 if (!rxe) in rxe_udp_encap_recv()
170 ib_device_put(&rxe in rxe_udp_encap_recv()
423 rxe_init_packet(struct rxe_dev *rxe, struct rxe_av *av, int paylen, struct rxe_pkt_info *pkt) rxe_init_packet() argument
482 rxe_parent_name(struct rxe_dev *rxe, unsigned int port_num) rxe_parent_name() argument
490 struct rxe_dev *rxe = NULL; rxe_net_add() local
507 rxe_port_event(struct rxe_dev *rxe, enum ib_event_type event) rxe_port_event() argument
520 rxe_port_up(struct rxe_dev *rxe) rxe_port_up() argument
532 rxe_port_down(struct rxe_dev *rxe) rxe_port_down() argument
544 rxe_set_port_state(struct rxe_dev *rxe) rxe_set_port_state() argument
557 struct rxe_dev *rxe = rxe_get_dev_from_net(ndev); rxe_notify() local
[all...] |
| H A D | rxe_mcast.c | 7 #include "rxe.h"
10 int rxe_mcast_get_grp(struct rxe_dev *rxe, union ib_gid *mgid, in rxe_mcast_get_grp() argument
16 if (rxe->attr.max_mcast_qp_attach == 0) { in rxe_mcast_get_grp()
21 grp = rxe_pool_get_key(&rxe->mc_grp_pool, mgid); in rxe_mcast_get_grp()
25 grp = rxe_alloc(&rxe->mc_grp_pool); in rxe_mcast_get_grp()
33 grp->rxe = rxe; in rxe_mcast_get_grp()
37 err = rxe_mcast_add(rxe, mgid); in rxe_mcast_get_grp()
51 int rxe_mcast_add_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_mcast_add_grp_elem() argument
67 if (grp->num_qp >= rxe in rxe_mcast_add_grp_elem()
95 rxe_mcast_drop_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp, union ib_gid *mgid) rxe_mcast_drop_grp_elem() argument
159 struct rxe_dev *rxe = grp->rxe; rxe_mc_cleanup() local
[all...] |
| H A D | rxe_loc.h | 13 int rxe_av_chk_attr(struct rxe_dev *rxe, struct rdma_ah_attr *attr);
25 int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq,
28 int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe,
43 int rxe_mcast_get_grp(struct rxe_dev *rxe, union ib_gid *mgid,
46 int rxe_mcast_add_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp,
49 int rxe_mcast_drop_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp,
115 struct sk_buff *rxe_init_packet(struct rxe_dev *rxe, struct rxe_av *av,
118 const char *rxe_parent_name(struct rxe_dev *rxe, unsigned int port_num);
119 struct device *rxe_dma_device(struct rxe_dev *rxe);
120 int rxe_mcast_add(struct rxe_dev *rxe, unio
224 struct rxe_dev *rxe = to_rdev(qp->ibqp.device); rxe_xmit_packet() local
[all...] |
| H A D | rxe_verbs.c | 10 #include "rxe.h"
19 struct rxe_dev *rxe = to_rdev(dev); in rxe_query_device() local
24 *attr = rxe->attr; in rxe_query_device()
31 struct rxe_dev *rxe = to_rdev(dev); in rxe_query_port() local
35 port = &rxe->port; in rxe_query_port()
40 mutex_lock(&rxe->usdev_lock); in rxe_query_port()
46 else if (dev_get_flags(rxe->ndev) & IFF_UP) in rxe_query_port()
51 mutex_unlock(&rxe->usdev_lock); in rxe_query_port()
69 struct rxe_dev *rxe = to_rdev(dev); in rxe_modify_device() local
76 rxe in rxe_modify_device()
89 struct rxe_dev *rxe = to_rdev(dev); rxe_modify_port() local
111 struct rxe_dev *rxe = to_rdev(uctx->device); rxe_alloc_ucontext() local
145 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_alloc_pd() local
165 struct rxe_dev *rxe = to_rdev(ibah->device); rxe_create_ah() local
183 struct rxe_dev *rxe = to_rdev(ibah->device); rxe_modify_ah() local
263 struct rxe_dev *rxe = to_rdev(ibsrq->device); rxe_create_srq() local
304 struct rxe_dev *rxe = to_rdev(ibsrq->device); rxe_modify_srq() local
384 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_create_qp() local
433 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_modify_qp() local
757 struct rxe_dev *rxe = to_rdev(dev); rxe_create_cq() local
796 struct rxe_dev *rxe = to_rdev(ibcq->device); rxe_resize_cq() local
868 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_get_dma_mr() local
890 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_reg_user_mr() local
933 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_alloc_mr() local
1007 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_attach_mcast() local
1024 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_detach_mcast() local
1033 struct rxe_dev *rxe = parent_show() local
1052 struct rxe_dev *rxe = container_of(ib_dev, struct rxe_dev, ib_dev); rxe_enable_driver() local
1116 rxe_register_device(struct rxe_dev *rxe, const char *ibdev_name) rxe_register_device() argument
[all...] |
| H A D | rxe.h | 45 static inline u32 rxe_crc32(struct rxe_dev *rxe, in rxe_crc32() argument
51 SHASH_DESC_ON_STACK(shash, rxe->tfm); in rxe_crc32()
53 shash->tfm = rxe->tfm; in rxe_crc32()
66 void rxe_set_mtu(struct rxe_dev *rxe, unsigned int dev_mtu);
68 int rxe_add(struct rxe_dev *rxe, unsigned int mtu, const char *ibdev_name);
83 void rxe_port_up(struct rxe_dev *rxe);
84 void rxe_port_down(struct rxe_dev *rxe);
85 void rxe_set_port_state(struct rxe_dev *rxe);
|
| H A D | rxe_srq.c | 8 #include "rxe.h"
12 int rxe_srq_chk_attr(struct rxe_dev *rxe, struct rxe_srq *srq, in rxe_srq_chk_attr() argument
21 if (attr->max_wr > rxe->attr.max_srq_wr) { in rxe_srq_chk_attr()
23 attr->max_wr, rxe->attr.max_srq_wr); in rxe_srq_chk_attr()
43 if (attr->srq_limit > rxe->attr.max_srq_wr) { in rxe_srq_chk_attr()
45 attr->srq_limit, rxe->attr.max_srq_wr); in rxe_srq_chk_attr()
58 if (attr->max_sge > rxe->attr.max_srq_sge) { in rxe_srq_chk_attr()
60 attr->max_sge, rxe->attr.max_srq_sge); in rxe_srq_chk_attr()
74 int rxe_srq_from_init(struct rxe_dev *rxe, struct rxe_srq *srq, in rxe_srq_from_init() argument
94 q = rxe_queue_init(rxe, in rxe_srq_from_init()
122 rxe_srq_from_attr(struct rxe_dev *rxe, struct rxe_srq *srq, struct ib_srq_attr *attr, enum ib_srq_attr_mask mask, struct rxe_modify_srq_cmd *ucmd, struct ib_udata *udata) rxe_srq_from_attr() argument
[all...] |
| H A D | rxe_recv.c | 9 #include "rxe.h"
13 static int check_type_state(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_type_state() argument
79 static int check_keys(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_keys() argument
82 struct rxe_port *port = &rxe->port; in check_keys()
111 static int check_addr(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_addr() argument
173 struct rxe_dev *rxe = pkt->rxe; in hdr_check() local
174 struct rxe_port *port = &rxe->port; in hdr_check()
193 qp = rxe_pool_get_index(&rxe->qp_pool, index); in hdr_check()
199 err = check_type_state(rxe, pk in hdr_check()
234 rxe_rcv_mcast_pkt(struct rxe_dev *rxe, struct sk_buff *skb) rxe_rcv_mcast_pkt() argument
312 rxe_chk_dgid(struct rxe_dev *rxe, struct sk_buff *skb) rxe_chk_dgid() argument
348 struct rxe_dev *rxe = pkt->rxe; rxe_rcv() local
[all...] |
| H A D | rxe_qp.c | 13 #include "rxe.h"
18 static int rxe_qp_chk_cap(struct rxe_dev *rxe, struct ib_qp_cap *cap, in rxe_qp_chk_cap() argument
21 if (cap->max_send_wr > rxe->attr.max_qp_wr) { in rxe_qp_chk_cap()
23 cap->max_send_wr, rxe->attr.max_qp_wr); in rxe_qp_chk_cap()
27 if (cap->max_send_sge > rxe->attr.max_send_sge) { in rxe_qp_chk_cap()
29 cap->max_send_sge, rxe->attr.max_send_sge); in rxe_qp_chk_cap()
34 if (cap->max_recv_wr > rxe->attr.max_qp_wr) { in rxe_qp_chk_cap()
36 cap->max_recv_wr, rxe->attr.max_qp_wr); in rxe_qp_chk_cap()
40 if (cap->max_recv_sge > rxe->attr.max_recv_sge) { in rxe_qp_chk_cap()
42 cap->max_recv_sge, rxe in rxe_qp_chk_cap()
59 rxe_qp_chk_init(struct rxe_dev *rxe, struct ib_qp_init_attr *init) rxe_qp_chk_init() argument
149 rxe_qp_init_misc(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init) rxe_qp_init_misc() argument
202 rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init, struct ib_udata *udata, struct rxe_create_qp_resp __user *uresp) rxe_qp_init_req() argument
264 rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init, struct ib_udata *udata, struct rxe_create_qp_resp __user *uresp) rxe_qp_init_resp() argument
308 rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, struct ib_qp_init_attr *init, struct rxe_create_qp_resp __user *uresp, struct ib_pd *ibpd, struct ib_udata *udata) rxe_qp_from_init() argument
391 rxe_qp_chk_attr(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_attr *attr, int mask) rxe_qp_chk_attr() argument
[all...] |
| H A D | rxe_queue.c | 8 #include "rxe.h"
12 int do_mmap_info(struct rxe_dev *rxe, struct mminfo __user *outbuf, in do_mmap_info() argument
20 ip = rxe_create_mmap_info(rxe, buf_size, udata, buf); in do_mmap_info()
31 spin_lock_bh(&rxe->pending_lock); in do_mmap_info()
32 list_add(&ip->pending_mmaps, &rxe->pending_mmaps); in do_mmap_info()
33 spin_unlock_bh(&rxe->pending_lock); in do_mmap_info()
55 struct rxe_queue *rxe_queue_init(struct rxe_dev *rxe, in rxe_queue_init() argument
71 q->rxe = rxe; in rxe_queue_init()
139 new_q = rxe_queue_init(q->rxe, in rxe_queue_resize()
[all...] |
| H A D | rxe_cq.c | 7 #include "rxe.h"
11 int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq, in rxe_cq_chk_attr() argument
21 if (cqe > rxe->attr.max_cqe) { in rxe_cq_chk_attr()
23 cqe, rxe->attr.max_cqe); in rxe_cq_chk_attr()
57 int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe, in rxe_cq_from_init() argument
63 cq->queue = rxe_queue_init(rxe, &cqe, in rxe_cq_from_init()
70 err = do_mmap_info(rxe, uresp ? &uresp->mi : NULL, udata, in rxe_cq_from_init()
|
| /kernel/linux/linux-6.6/drivers/infiniband/sw/rxe/ |
| H A D | rxe.c | 9 #include "rxe.h"
16 /* free resources for a rxe device all objects created for this device must
21 struct rxe_dev *rxe = container_of(ib_dev, struct rxe_dev, ib_dev); in rxe_dealloc() local
23 rxe_pool_cleanup(&rxe->uc_pool); in rxe_dealloc()
24 rxe_pool_cleanup(&rxe->pd_pool); in rxe_dealloc()
25 rxe_pool_cleanup(&rxe->ah_pool); in rxe_dealloc()
26 rxe_pool_cleanup(&rxe->srq_pool); in rxe_dealloc()
27 rxe_pool_cleanup(&rxe->qp_pool); in rxe_dealloc()
28 rxe_pool_cleanup(&rxe->cq_pool); in rxe_dealloc()
29 rxe_pool_cleanup(&rxe in rxe_dealloc()
39 rxe_init_device_param(struct rxe_dev *rxe) rxe_init_device_param() argument
107 rxe_init_ports(struct rxe_dev *rxe) rxe_init_ports() argument
118 rxe_init_pools(struct rxe_dev *rxe) rxe_init_pools() argument
131 rxe_init(struct rxe_dev *rxe) rxe_init() argument
151 rxe_set_mtu(struct rxe_dev *rxe, unsigned int ndev_mtu) rxe_set_mtu() argument
170 rxe_add(struct rxe_dev *rxe, unsigned int mtu, const char *ibdev_name) rxe_add() argument
180 struct rxe_dev *rxe; rxe_newlink() local
[all...] |
| H A D | rxe_mcast.c | 19 * mcast packets in the rxe receive path.
22 #include "rxe.h"
25 * rxe_mcast_add - add multicast address to rxe device
26 * @rxe: rxe device object
31 static int rxe_mcast_add(struct rxe_dev *rxe, union ib_gid *mgid) in rxe_mcast_add() argument
37 return dev_mc_add(rxe->ndev, ll_addr); in rxe_mcast_add()
41 * rxe_mcast_del - delete multicast address from rxe device
42 * @rxe: rxe devic
47 rxe_mcast_del(struct rxe_dev *rxe, union ib_gid *mgid) rxe_mcast_del() argument
105 __rxe_lookup_mcg(struct rxe_dev *rxe, union ib_gid *mgid) __rxe_lookup_mcg() argument
143 rxe_lookup_mcg(struct rxe_dev *rxe, union ib_gid *mgid) rxe_lookup_mcg() argument
162 __rxe_init_mcg(struct rxe_dev *rxe, union ib_gid *mgid, struct rxe_mcg *mcg) __rxe_init_mcg() argument
188 rxe_get_mcg(struct rxe_dev *rxe, union ib_gid *mgid) rxe_get_mcg() argument
258 struct rxe_dev *rxe = mcg->rxe; __rxe_destroy_mcg() local
297 struct rxe_dev *rxe = to_rdev(qp->ibqp.device); __rxe_init_mca() local
333 struct rxe_dev *rxe = mcg->rxe; rxe_attach_mcg() local
398 struct rxe_dev *rxe = mcg->rxe; rxe_detach_mcg() local
436 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_attach_mcast() local
466 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_detach_mcast() local
[all...] |
| H A D | rxe_mmap.c | 12 #include "rxe.h"
20 struct rxe_dev *rxe = to_rdev(ip->context->device); in rxe_mmap_release() local
22 spin_lock_bh(&rxe->pending_lock); in rxe_mmap_release()
27 spin_unlock_bh(&rxe->pending_lock); in rxe_mmap_release()
64 struct rxe_dev *rxe = to_rdev(context->device); in rxe_mmap() local
75 spin_lock_bh(&rxe->pending_lock); in rxe_mmap()
76 list_for_each_entry_safe(ip, pp, &rxe->pending_mmaps, pending_mmaps) { in rxe_mmap()
82 rxe_dbg_dev(rxe, "mmap region is larger than the object!\n"); in rxe_mmap()
83 spin_unlock_bh(&rxe->pending_lock); in rxe_mmap()
90 rxe_dbg_dev(rxe, "unabl in rxe_mmap()
115 rxe_create_mmap_info(struct rxe_dev *rxe, u32 size, struct ib_udata *udata, void *obj) rxe_create_mmap_info() argument
[all...] |
| H A D | rxe_net.c | 17 #include "rxe.h"
137 struct rxe_dev *rxe; in rxe_udp_encap_recv() local
141 /* takes a reference on rxe->ib_dev in rxe_udp_encap_recv()
144 rxe = rxe_get_dev_from_net(ndev); in rxe_udp_encap_recv()
145 if (!rxe && is_vlan_dev(ndev)) in rxe_udp_encap_recv()
146 rxe = rxe_get_dev_from_net(vlan_dev_real_dev(ndev)); in rxe_udp_encap_recv()
147 if (!rxe) in rxe_udp_encap_recv()
151 ib_device_put(&rxe->ib_dev); in rxe_udp_encap_recv()
156 pkt->rxe = rxe; in rxe_udp_encap_recv()
420 struct rxe_dev *rxe = to_rdev(qp->ibqp.device); rxe_xmit_packet() local
459 rxe_init_packet(struct rxe_dev *rxe, struct rxe_av *av, int paylen, struct rxe_pkt_info *pkt) rxe_init_packet() argument
518 rxe_parent_name(struct rxe_dev *rxe, unsigned int port_num) rxe_parent_name() argument
526 struct rxe_dev *rxe = NULL; rxe_net_add() local
543 rxe_port_event(struct rxe_dev *rxe, enum ib_event_type event) rxe_port_event() argument
556 rxe_port_up(struct rxe_dev *rxe) rxe_port_up() argument
568 rxe_port_down(struct rxe_dev *rxe) rxe_port_down() argument
580 rxe_set_port_state(struct rxe_dev *rxe) rxe_set_port_state() argument
593 struct rxe_dev *rxe = rxe_get_dev_from_net(ndev); rxe_notify() local
[all...] |
| H A D | rxe_recv.c | 9 #include "rxe.h"
13 static int check_type_state(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_type_state() argument
75 static int check_keys(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_keys() argument
78 struct rxe_port *port = &rxe->port; in check_keys()
100 static int check_addr(struct rxe_dev *rxe, struct rxe_pkt_info *pkt, in check_addr() argument
137 struct rxe_dev *rxe = pkt->rxe; in hdr_check() local
138 struct rxe_port *port = &rxe->port; in hdr_check()
153 qp = rxe_pool_get_index(&rxe->qp_pool, index); in hdr_check()
157 err = check_type_state(rxe, pk in hdr_check()
190 rxe_rcv_mcast_pkt(struct rxe_dev *rxe, struct sk_buff *skb) rxe_rcv_mcast_pkt() argument
284 rxe_chk_dgid(struct rxe_dev *rxe, struct sk_buff *skb) rxe_chk_dgid() argument
320 struct rxe_dev *rxe = pkt->rxe; rxe_rcv() local
[all...] |
| H A D | rxe_srq.c | 8 #include "rxe.h"
11 int rxe_srq_chk_init(struct rxe_dev *rxe, struct ib_srq_init_attr *init) in rxe_srq_chk_init() argument
15 if (attr->max_wr > rxe->attr.max_srq_wr) { in rxe_srq_chk_init()
16 rxe_dbg_dev(rxe, "max_wr(%d) > max_srq_wr(%d)\n", in rxe_srq_chk_init()
17 attr->max_wr, rxe->attr.max_srq_wr); in rxe_srq_chk_init()
22 rxe_dbg_dev(rxe, "max_wr(%d) <= 0\n", attr->max_wr); in rxe_srq_chk_init()
29 if (attr->max_sge > rxe->attr.max_srq_sge) { in rxe_srq_chk_init()
30 rxe_dbg_dev(rxe, "max_sge(%d) > max_srq_sge(%d)\n", in rxe_srq_chk_init()
31 attr->max_sge, rxe->attr.max_srq_sge); in rxe_srq_chk_init()
44 int rxe_srq_from_init(struct rxe_dev *rxe, struc argument
100 rxe_srq_chk_attr(struct rxe_dev *rxe, struct rxe_srq *srq, struct ib_srq_attr *attr, enum ib_srq_attr_mask mask) rxe_srq_chk_attr() argument
151 rxe_srq_from_attr(struct rxe_dev *rxe, struct rxe_srq *srq, struct ib_srq_attr *attr, enum ib_srq_attr_mask mask, struct rxe_modify_srq_cmd *ucmd, struct ib_udata *udata) rxe_srq_from_attr() argument
[all...] |
| H A D | rxe_verbs.c | 11 #include "rxe.h"
22 struct rxe_dev *rxe = to_rdev(ibdev); in rxe_query_device() local
26 rxe_dbg_dev(rxe, "malformed udata"); in rxe_query_device()
31 memcpy(attr, &rxe->attr, sizeof(*attr)); in rxe_query_device()
36 rxe_err_dev(rxe, "returned err = %d", err); in rxe_query_device()
43 struct rxe_dev *rxe = to_rdev(ibdev); in rxe_query_port() local
48 rxe_dbg_dev(rxe, "bad port_num = %d", port_num); in rxe_query_port()
52 memcpy(attr, &rxe->port.attr, sizeof(*attr)); in rxe_query_port()
54 mutex_lock(&rxe->usdev_lock); in rxe_query_port()
60 else if (dev_get_flags(rxe in rxe_query_port()
77 struct rxe_dev *rxe = to_rdev(ibdev); rxe_query_pkey() local
97 struct rxe_dev *rxe = to_rdev(ibdev); rxe_modify_device() local
125 struct rxe_dev *rxe = to_rdev(ibdev); rxe_modify_port() local
159 struct rxe_dev *rxe = to_rdev(ibdev); rxe_get_link_layer() local
178 struct rxe_dev *rxe = to_rdev(ibdev); rxe_port_immutable() local
207 struct rxe_dev *rxe = to_rdev(ibuc->device); rxe_alloc_ucontext() local
231 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_alloc_pd() local
265 struct rxe_dev *rxe = to_rdev(ibah->device); rxe_create_ah() local
370 struct rxe_dev *rxe = to_rdev(ibsrq->device); rxe_create_srq() local
429 struct rxe_dev *rxe = to_rdev(ibsrq->device); rxe_modify_srq() local
530 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_create_qp() local
594 struct rxe_dev *rxe = to_rdev(ibqp->device); rxe_modify_qp() local
1060 struct rxe_dev *rxe = to_rdev(dev); rxe_create_cq() local
1113 struct rxe_dev *rxe = to_rdev(ibcq->device); rxe_resize_cq() local
1223 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_get_dma_mr() local
1256 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_reg_user_mr() local
1337 struct rxe_dev *rxe = to_rdev(ibpd->device); rxe_alloc_mr() local
1408 struct rxe_dev *rxe = parent_show() local
1427 struct rxe_dev *rxe = container_of(ib_dev, struct rxe_dev, ib_dev); rxe_enable_driver() local
1498 rxe_register_device(struct rxe_dev *rxe, const char *ibdev_name) rxe_register_device() argument
[all...] |
| H A D | rxe_qp.c | 13 #include "rxe.h"
18 static int rxe_qp_chk_cap(struct rxe_dev *rxe, struct ib_qp_cap *cap, in rxe_qp_chk_cap() argument
21 if (cap->max_send_wr > rxe->attr.max_qp_wr) { in rxe_qp_chk_cap()
22 rxe_dbg_dev(rxe, "invalid send wr = %u > %d\n", in rxe_qp_chk_cap()
23 cap->max_send_wr, rxe->attr.max_qp_wr); in rxe_qp_chk_cap()
27 if (cap->max_send_sge > rxe->attr.max_send_sge) { in rxe_qp_chk_cap()
28 rxe_dbg_dev(rxe, "invalid send sge = %u > %d\n", in rxe_qp_chk_cap()
29 cap->max_send_sge, rxe->attr.max_send_sge); in rxe_qp_chk_cap()
34 if (cap->max_recv_wr > rxe->attr.max_qp_wr) { in rxe_qp_chk_cap()
35 rxe_dbg_dev(rxe, "invali in rxe_qp_chk_cap()
59 rxe_qp_chk_init(struct rxe_dev *rxe, struct ib_qp_init_attr *init) rxe_qp_chk_init() argument
148 rxe_qp_init_misc(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init) rxe_qp_init_misc() argument
190 struct rxe_dev *rxe = to_rdev(qp->ibqp.device); rxe_init_sq() local
235 rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init, struct ib_udata *udata, struct rxe_create_qp_resp __user *uresp) rxe_qp_init_req() argument
283 struct rxe_dev *rxe = to_rdev(qp->ibqp.device); rxe_init_rq() local
324 rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_init_attr *init, struct ib_udata *udata, struct rxe_create_qp_resp __user *uresp) rxe_qp_init_resp() argument
349 rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, struct ib_qp_init_attr *init, struct rxe_create_qp_resp __user *uresp, struct ib_pd *ibpd, struct ib_udata *udata) rxe_qp_from_init() argument
439 rxe_qp_chk_attr(struct rxe_dev *rxe, struct rxe_qp *qp, struct ib_qp_attr *attr, int mask) rxe_qp_chk_attr() argument
[all...] |
| H A D | rxe_icrc.c | 9 #include "rxe.h"
14 * @rxe: rdma_rxe device object
18 int rxe_icrc_init(struct rxe_dev *rxe) in rxe_icrc_init() argument
24 rxe_dbg_dev(rxe, "failed to init crc32 algorithm err: %ld\n", in rxe_icrc_init()
29 rxe->tfm = tfm; in rxe_icrc_init()
36 * @rxe: rdma_rxe device object
43 static __be32 rxe_crc32(struct rxe_dev *rxe, __be32 crc, void *next, size_t len) in rxe_crc32() argument
48 SHASH_DESC_ON_STACK(shash, rxe->tfm); in rxe_crc32()
50 shash->tfm = rxe->tfm; in rxe_crc32()
54 rxe_dbg_dev(rxe, "faile in rxe_crc32()
[all...] |
| H A D | rxe_cq.c | 7 #include "rxe.h"
11 int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq, in rxe_cq_chk_attr() argument
17 rxe_dbg_dev(rxe, "cqe(%d) <= 0\n", cqe); in rxe_cq_chk_attr()
21 if (cqe > rxe->attr.max_cqe) { in rxe_cq_chk_attr()
22 rxe_dbg_dev(rxe, "cqe(%d) > max_cqe(%d)\n", in rxe_cq_chk_attr()
23 cqe, rxe->attr.max_cqe); in rxe_cq_chk_attr()
42 int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe, in rxe_cq_from_init() argument
50 cq->queue = rxe_queue_init(rxe, &cqe, in rxe_cq_from_init()
53 rxe_dbg_dev(rxe, "unable to create cq\n"); in rxe_cq_from_init()
57 err = do_mmap_info(rxe, ures in rxe_cq_from_init()
[all...] |
| H A D | rxe_queue.c | 8 #include "rxe.h"
12 int do_mmap_info(struct rxe_dev *rxe, struct mminfo __user *outbuf, in do_mmap_info() argument
20 ip = rxe_create_mmap_info(rxe, buf_size, udata, buf); in do_mmap_info()
31 spin_lock_bh(&rxe->pending_lock); in do_mmap_info()
32 list_add(&ip->pending_mmaps, &rxe->pending_mmaps); in do_mmap_info()
33 spin_unlock_bh(&rxe->pending_lock); in do_mmap_info()
55 struct rxe_queue *rxe_queue_init(struct rxe_dev *rxe, int *num_elem, in rxe_queue_init() argument
70 q->rxe = rxe; in rxe_queue_init()
158 new_q = rxe_queue_init(q->rxe, in rxe_queue_resize()
[all...] |
| H A D | rxe_loc.h | 21 int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq,
24 int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe,
37 struct rxe_mcg *rxe_lookup_mcg(struct rxe_dev *rxe, union ib_gid *mgid);
62 int rxe_mr_init_user(struct rxe_dev *rxe, u64 start, u64 length, u64 iova,
92 struct sk_buff *rxe_init_packet(struct rxe_dev *rxe, struct rxe_av *av,
98 const char *rxe_parent_name(struct rxe_dev *rxe, unsigned int port_num);
101 int rxe_qp_chk_init(struct rxe_dev *rxe, struct ib_qp_init_attr *init);
102 int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd,
107 int rxe_qp_chk_attr(struct rxe_dev *rxe, struct rxe_qp *qp,
152 int rxe_srq_chk_init(struct rxe_dev *rxe, struc
[all...] |
| H A D | rxe.h | 42 #define rxe_dbg_dev(rxe, fmt, ...) ibdev_dbg(&(rxe)->ib_dev, \
63 #define rxe_err_dev(rxe, fmt, ...) ibdev_err_ratelimited(&(rxe)->ib_dev, \
84 #define rxe_info_dev(rxe, fmt, ...) ibdev_info_ratelimited(&(rxe)->ib_dev, \
140 void rxe_set_mtu(struct rxe_dev *rxe, unsigned int dev_mtu);
142 int rxe_add(struct rxe_dev *rxe, unsigned int mtu, const char *ibdev_name);
157 void rxe_port_up(struct rxe_dev *rxe);
158 void rxe_port_down(struct rxe_dev *rxe);
[all...] |