/kernel/linux/linux-6.6/drivers/infiniband/sw/rxe/ |
H A D | rxe_loc.h | 12 int rxe_av_chk_attr(struct rxe_qp *qp, struct rdma_ah_attr *attr); 79 int rxe_invalidate_mr(struct rxe_qp *qp, u32 key); 80 int rxe_reg_fast_mr(struct rxe_qp *qp, struct rxe_send_wqe *wqe); 86 int rxe_bind_mw(struct rxe_qp *qp, struct rxe_send_wqe *wqe); 87 int rxe_invalidate_mw(struct rxe_qp *qp, u32 rkey); 88 struct rxe_mw *rxe_lookup_mw(struct rxe_qp *qp, int access, u32 rkey); 96 int rxe_xmit_packet(struct rxe_qp *qp, struct rxe_pkt_info *pkt, 100 /* rxe_qp.c */ 102 int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, 106 int rxe_qp_to_init(struct rxe_qp *q [all...] |
H A D | rxe_task.h | 28 struct rxe_qp *qp; 29 int (*func)(struct rxe_qp *qp); 44 int rxe_init_task(struct rxe_task *task, struct rxe_qp *qp, 45 int (*func)(struct rxe_qp *));
|
H A D | rxe_comp.c | 117 struct rxe_qp *qp = from_timer(qp, t, retrans_timer); in retransmit_timer() 130 void rxe_comp_queue_pkt(struct rxe_qp *qp, struct sk_buff *skb) in rxe_comp_queue_pkt() 146 static inline enum comp_state get_wqe(struct rxe_qp *qp, in get_wqe() 174 static inline void reset_retry_counters(struct rxe_qp *qp) in reset_retry_counters() 181 static inline enum comp_state check_psn(struct rxe_qp *qp, in check_psn() 224 static inline enum comp_state check_ack(struct rxe_qp *qp, in check_ack() 363 static inline enum comp_state do_read(struct rxe_qp *qp, in do_read() 383 static inline enum comp_state do_atomic(struct rxe_qp *qp, in do_atomic() 402 static void make_send_cqe(struct rxe_qp *qp, struct rxe_send_wqe *wqe, in make_send_cqe() 449 static void do_complete(struct rxe_qp *q [all...] |
H A D | rxe_req.c | 14 static int next_opcode(struct rxe_qp *qp, struct rxe_send_wqe *wqe, 17 static inline void retry_first_write_send(struct rxe_qp *qp, in retry_first_write_send() 38 static void req_retry(struct rxe_qp *qp) in req_retry() 101 struct rxe_qp *qp = from_timer(qp, t, rnr_nak_timer); in rnr_nak_timer() 116 static void req_check_sq_drain_done(struct rxe_qp *qp) in req_check_sq_drain_done() 162 static struct rxe_send_wqe *__req_next_wqe(struct rxe_qp *qp) in __req_next_wqe() 175 static struct rxe_send_wqe *req_next_wqe(struct rxe_qp *qp) in req_next_wqe() 206 static int rxe_wqe_is_fenced(struct rxe_qp *qp, struct rxe_send_wqe *wqe) in rxe_wqe_is_fenced() 224 static int next_opcode_rc(struct rxe_qp *qp, u32 opcode, int fits) in next_opcode_rc() 303 static int next_opcode_uc(struct rxe_qp *q [all...] |
H A D | rxe_qp.c | 103 static int alloc_rd_atomic_resources(struct rxe_qp *qp, unsigned int n) in alloc_rd_atomic_resources() 115 static void free_rd_atomic_resources(struct rxe_qp *qp) in free_rd_atomic_resources() 135 static void cleanup_rd_atomic_resources(struct rxe_qp *qp) in cleanup_rd_atomic_resources() 148 static void rxe_qp_init_misc(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_misc() 186 static int rxe_init_sq(struct rxe_qp *qp, struct ib_qp_init_attr *init, in rxe_init_sq() 235 static int rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_req() 279 static int rxe_init_rq(struct rxe_qp *qp, struct ib_qp_init_attr *init, in rxe_init_rq() 324 static int rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_resp() 349 int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, in rxe_qp_from_init() 414 int rxe_qp_to_init(struct rxe_qp *q [all...] |
H A D | rxe_mw.c | 50 static int rxe_check_bind_mw(struct rxe_qp *qp, struct rxe_send_wqe *wqe, in rxe_check_bind_mw() 135 static void rxe_do_bind_mw(struct rxe_qp *qp, struct rxe_send_wqe *wqe, in rxe_do_bind_mw() 164 int rxe_bind_mw(struct rxe_qp *qp, struct rxe_send_wqe *wqe) in rxe_bind_mw() 224 static int rxe_check_invalidate_mw(struct rxe_qp *qp, struct rxe_mw *mw) in rxe_check_invalidate_mw() 238 struct rxe_qp *qp; in rxe_do_invalidate_mw() 258 int rxe_invalidate_mw(struct rxe_qp *qp, u32 rkey) in rxe_invalidate_mw() 290 struct rxe_mw *rxe_lookup_mw(struct rxe_qp *qp, int access, u32 rkey) in rxe_lookup_mw() 328 struct rxe_qp *qp = mw->qp; in rxe_mw_cleanup()
|
H A D | rxe_resp.c | 50 void rxe_resp_queue_pkt(struct rxe_qp *qp, struct sk_buff *skb) in rxe_resp_queue_pkt() 66 static inline enum resp_states get_req(struct rxe_qp *qp, in get_req() 80 static enum resp_states check_psn(struct rxe_qp *qp, in check_psn() 124 static enum resp_states check_op_seq(struct rxe_qp *qp, in check_op_seq() 214 static bool check_qp_attr_access(struct rxe_qp *qp, in check_qp_attr_access() 238 static enum resp_states check_op_valid(struct rxe_qp *qp, in check_op_valid() 269 static enum resp_states get_srq_wqe(struct rxe_qp *qp) in get_srq_wqe() 320 static enum resp_states check_resource(struct rxe_qp *qp, in check_resource() 348 static enum resp_states rxe_resp_check_length(struct rxe_qp *qp, in rxe_resp_check_length() 401 static void qp_resp_from_reth(struct rxe_qp *q [all...] |
H A D | rxe_verbs.h | 202 struct rxe_qp { struct 338 struct rxe_qp *qp; /* Type 2 only */ 359 struct rxe_qp *qp; 438 static inline struct rxe_qp *to_rqp(struct ib_qp *qp) in to_rqp() 440 return qp ? container_of(qp, struct rxe_qp, ibqp) : NULL; in to_rqp()
|
H A D | rxe_recv.c | 14 struct rxe_qp *qp) in check_type_state() 76 u32 qpn, struct rxe_qp *qp) in check_keys() 101 struct rxe_qp *qp) in check_addr() 139 struct rxe_qp *qp = NULL; in hdr_check() 195 struct rxe_qp *qp; in rxe_rcv_mcast_pkt()
|
H A D | rxe_mcast.c | 294 static int __rxe_init_mca(struct rxe_qp *qp, struct rxe_mcg *mcg, in __rxe_init_mca() 331 static int rxe_attach_mcg(struct rxe_mcg *mcg, struct rxe_qp *qp) in rxe_attach_mcg() 396 static int rxe_detach_mcg(struct rxe_mcg *mcg, struct rxe_qp *qp) in rxe_detach_mcg() 437 struct rxe_qp *qp = to_rqp(ibqp); in rxe_attach_mcast() 467 struct rxe_qp *qp = to_rqp(ibqp); in rxe_detach_mcast()
|
H A D | rxe_net.c | 23 static struct dst_entry *rxe_find_route4(struct rxe_qp *qp, in rxe_find_route4() 47 static struct dst_entry *rxe_find_route6(struct rxe_qp *qp, in rxe_find_route6() 82 static struct dst_entry *rxe_find_route6(struct rxe_qp *qp, in rxe_find_route6() 93 struct rxe_qp *qp, in rxe_find_route() 282 struct rxe_qp *qp = pkt->qp; in prepare4() 308 struct rxe_qp *qp = pkt->qp; in prepare6() 349 struct rxe_qp *qp = sk->sk_user_data; in rxe_skb_tx_dtor() 415 int rxe_xmit_packet(struct rxe_qp *qp, struct rxe_pkt_info *pkt, in rxe_xmit_packet()
|
H A D | rxe_av.c | 22 struct rxe_qp *qp; in chk_attr() 63 int rxe_av_chk_attr(struct rxe_qp *qp, struct rdma_ah_attr *attr) in rxe_av_chk_attr()
|
H A D | Makefile | 15 rxe_qp.o \
|
H A D | rxe_task.c | 190 int rxe_init_task(struct rxe_task *task, struct rxe_qp *qp, in rxe_init_task() 191 int (*func)(struct rxe_qp *)) in rxe_init_task()
|
H A D | rxe_pool.c | 56 .size = sizeof(struct rxe_qp), 57 .elem_offset = offsetof(struct rxe_qp, elem),
|
/kernel/linux/linux-5.10/drivers/infiniband/sw/rxe/ |
H A D | rxe_loc.h | 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, 52 void rxe_drop_all_mcast_groups(struct rxe_qp *qp); 123 /* rxe_qp.c */ 126 int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, 131 int rxe_qp_to_init(struct rxe_qp *qp, struct ib_qp_init_attr *init); 133 int rxe_qp_chk_attr(struct rxe_dev *rxe, struct rxe_qp *qp, 136 int rxe_qp_from_attr(struct rxe_qp *qp, struct ib_qp_attr *attr, 139 int rxe_qp_to_attr(struct rxe_qp *qp, struct ib_qp_attr *attr, int mask); 141 void rxe_qp_error(struct rxe_qp *q [all...] |
H A D | rxe_comp.c | 114 struct rxe_qp *qp = from_timer(qp, t, retrans_timer); in retransmit_timer() 122 void rxe_comp_queue_pkt(struct rxe_qp *qp, struct sk_buff *skb) in rxe_comp_queue_pkt() 135 static inline enum comp_state get_wqe(struct rxe_qp *qp, in get_wqe() 163 static inline void reset_retry_counters(struct rxe_qp *qp) in reset_retry_counters() 170 static inline enum comp_state check_psn(struct rxe_qp *qp, in check_psn() 209 static inline enum comp_state check_ack(struct rxe_qp *qp, in check_ack() 340 static inline enum comp_state do_read(struct rxe_qp *qp, in do_read() 358 static inline enum comp_state do_atomic(struct rxe_qp *qp, in do_atomic() 375 static void make_send_cqe(struct rxe_qp *qp, struct rxe_send_wqe *wqe, in make_send_cqe() 413 static void do_complete(struct rxe_qp *q [all...] |
H A D | rxe_resp.c | 80 void rxe_resp_queue_pkt(struct rxe_qp *qp, struct sk_buff *skb) in rxe_resp_queue_pkt() 93 static inline enum resp_states get_req(struct rxe_qp *qp, in get_req() 117 static enum resp_states check_psn(struct rxe_qp *qp, in check_psn() 161 static enum resp_states check_op_seq(struct rxe_qp *qp, in check_op_seq() 251 static enum resp_states check_op_valid(struct rxe_qp *qp, in check_op_valid() 289 static enum resp_states get_srq_wqe(struct rxe_qp *qp) in get_srq_wqe() 331 static enum resp_states check_resource(struct rxe_qp *qp, in check_resource() 375 static enum resp_states check_length(struct rxe_qp *qp, in check_length() 390 static enum resp_states check_rkey(struct rxe_qp *qp, in check_rkey() 480 static enum resp_states send_data_in(struct rxe_qp *q [all...] |
H A D | rxe_req.c | 14 static int next_opcode(struct rxe_qp *qp, struct rxe_send_wqe *wqe, 17 static inline void retry_first_write_send(struct rxe_qp *qp, in retry_first_write_send() 41 static void req_retry(struct rxe_qp *qp) in req_retry() 99 struct rxe_qp *qp = from_timer(qp, t, rnr_nak_timer); in rnr_nak_timer() 105 static struct rxe_send_wqe *req_next_wqe(struct rxe_qp *qp) in req_next_wqe() 167 static int next_opcode_rc(struct rxe_qp *qp, u32 opcode, int fits) in next_opcode_rc() 239 static int next_opcode_uc(struct rxe_qp *qp, u32 opcode, int fits) in next_opcode_uc() 290 static int next_opcode(struct rxe_qp *qp, struct rxe_send_wqe *wqe, in next_opcode() 321 static inline int check_init_depth(struct rxe_qp *qp, struct rxe_send_wqe *wqe) in check_init_depth() 341 static inline int get_mtu(struct rxe_qp *q [all...] |
H A D | rxe_qp.c | 98 static int alloc_rd_atomic_resources(struct rxe_qp *qp, unsigned int n) in alloc_rd_atomic_resources() 110 static void free_rd_atomic_resources(struct rxe_qp *qp) in free_rd_atomic_resources() 125 void free_rd_atomic_resource(struct rxe_qp *qp, struct resp_res *res) in free_rd_atomic_resource() 136 static void cleanup_rd_atomic_resources(struct rxe_qp *qp) in cleanup_rd_atomic_resources() 149 static void rxe_qp_init_misc(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_misc() 202 static int rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_req() 264 static int rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_qp_init_resp() 308 int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, in rxe_qp_from_init() 363 int rxe_qp_to_init(struct rxe_qp *qp, struct ib_qp_init_attr *init) in rxe_qp_to_init() 391 int rxe_qp_chk_attr(struct rxe_dev *rxe, struct rxe_qp *q [all...] |
H A D | rxe_mcast.c | 51 int rxe_mcast_add_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_mcast_add_grp_elem() 95 int rxe_mcast_drop_grp_elem(struct rxe_dev *rxe, struct rxe_qp *qp, in rxe_mcast_drop_grp_elem() 130 void rxe_drop_all_mcast_groups(struct rxe_qp *qp) in rxe_drop_all_mcast_groups()
|
H A D | rxe_verbs.c | 386 struct rxe_qp *qp; in rxe_create_qp() 434 struct rxe_qp *qp = to_rqp(ibqp); in rxe_modify_qp() 453 struct rxe_qp *qp = to_rqp(ibqp); in rxe_query_qp() 463 struct rxe_qp *qp = to_rqp(ibqp); in rxe_destroy_qp() 471 static int validate_send_wr(struct rxe_qp *qp, const struct ib_send_wr *ibwr, in validate_send_wr() 498 static void init_send_wr(struct rxe_qp *qp, struct rxe_send_wr *wr, in init_send_wr() 554 static int init_send_wqe(struct rxe_qp *qp, const struct ib_send_wr *ibwr, in init_send_wqe() 602 static int post_one_send(struct rxe_qp *qp, const struct ib_send_wr *ibwr, in post_one_send() 643 static int rxe_post_send_kernel(struct rxe_qp *qp, const struct ib_send_wr *wr, in rxe_post_send_kernel() 692 struct rxe_qp *q in rxe_post_send() [all...] |
H A D | rxe_verbs.h | 208 struct rxe_qp { struct 337 struct rxe_qp *qp; 416 static inline struct rxe_qp *to_rqp(struct ib_qp *qp) in to_rqp() 418 return qp ? container_of(qp, struct rxe_qp, ibqp) : NULL; in to_rqp()
|
H A D | rxe_recv.c | 14 struct rxe_qp *qp) in check_type_state() 80 u32 qpn, struct rxe_qp *qp) in check_keys() 112 struct rxe_qp *qp) in check_addr() 175 struct rxe_qp *qp = NULL; in hdr_check() 239 struct rxe_qp *qp; in rxe_rcv_mcast_pkt()
|
H A D | Makefile | 15 rxe_qp.o \
|