| /kernel/linux/linux-5.10/drivers/infiniband/hw/hfi1/ |
| H A D | trace_rc.h | 59 TP_PROTO(struct rvt_qp *qp, u32 psn),
60 TP_ARGS(qp, psn),
65 __field(u32, psn)
76 __entry->psn = psn;
84 "[%s] qpn 0x%x s_flags 0x%x psn 0x%x s_psn 0x%x s_next_psn 0x%x s_sending_psn 0x%x sending_hpsn 0x%x r_psn 0x%x",
88 __entry->psn,
98 TP_PROTO(struct rvt_qp *qp, u32 psn),
99 TP_ARGS(qp, psn)
103 TP_PROTO(struct rvt_qp *qp, u32 psn),
[all...] |
| H A D | trace_tid.h | 40 #define RSP_INFO_PRN "[%s] qpn 0x%x state 0x%x s_state 0x%x psn 0x%x " \
58 #define TID_REQ_PRN "[%s] qpn 0x%x newreq %u opcode 0x%x psn 0x%x lpsn 0x%x " \
66 "r_head_ack_queue %u opcode 0x%x psn 0x%x r_psn 0x%x " \
744 TP_PROTO(struct rvt_qp *qp, u32 psn),
745 TP_ARGS(qp, psn),
751 __field(u32, psn)
772 __entry->psn = psn;
791 __entry->psn,
808 TP_PROTO(struct rvt_qp *qp, u32 psn),
[all...] |
| H A D | rc.c | 58 struct rvt_ack_entry *find_prev_entry(struct rvt_qp *qp, u32 psn, u8 *prev,
82 if (cmp_psn(psn, e->psn) >= 0) {
84 cmp_psn(psn, e->lpsn) <= 0)
162 trace_hfi1_rsp_make_rc_ack(qp, e->psn); in make_rc_ack()
212 qp->s_ack_rdma_psn = e->psn; in make_rc_ack()
227 qp->s_ack_rdma_psn = mask_psn(e->psn + req->cur_seg); in make_rc_ack()
261 bth2 = mask_psn(e->psn); in make_rc_ack()
337 trace_hfi1_tid_req_make_rc_ack_write(qp, 0, e->opcode, e->psn, in make_rc_ack()
574 qp->s_psn = wqe->psn; in hfi1_make_rc_req()
1459 update_num_rd_atomic(struct rvt_qp *qp, u32 psn, struct rvt_swqe *wqe) update_num_rd_atomic() argument
1500 reset_psn(struct rvt_qp *qp, u32 psn) reset_psn() argument
1606 hfi1_restart_rc(struct rvt_qp *qp, u32 psn, int wait) hfi1_restart_rc() argument
1677 reset_sending_psn(struct rvt_qp *qp, u32 psn) reset_sending_psn() argument
1718 u32 psn; hfi1_rc_verbs_aborted() local
1741 u32 psn; hfi1_rc_send_complete() local
1856 update_last_psn(struct rvt_qp *qp, u32 psn) update_last_psn() argument
1972 update_qp_retry_state(struct rvt_qp *qp, u32 psn, u32 spsn, u32 lpsn) update_qp_retry_state() argument
2006 do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val, struct hfi1_ctxtdata *rcd) do_rc_ack() argument
2305 rdma_seq_err(struct rvt_qp *qp, struct hfi1_ibport *ibp, u32 psn, struct hfi1_ctxtdata *rcd) rdma_seq_err() argument
2358 u32 psn = ib_bth_get_psn(packet->ohdr); rc_rcv_resp() local
2551 rc_rcv_error(struct ib_other_headers *ohdr, void *data, struct rvt_qp *qp, u32 opcode, u32 psn, int diff, struct hfi1_ctxtdata *rcd) rc_rcv_error() argument
2815 u32 psn = ib_bth_get_psn(packet->ohdr); hfi1_rc_rcv() local
3258 u32 psn; hfi1_rc_hdrerr() local
[all...] |
| H A D | tid_rdma.c | 130 struct rvt_qp *qp, u32 psn, int diff, bool fecn);
348 qpriv->flow_state.psn = 0; in hfi1_qp_priv_init()
801 fs->psn = 0; in hfi1_kern_setup_hw_flow()
828 fs->psn = 0; in hfi1_kern_clear_hw_flow()
1515 flow->flow_state.spsn = qpriv->flow_state.psn;
1519 qpriv->flow_state.psn += flow->npkts;
1675 u32 psn, u16 *fidx) in find_flow_ib()
1685 if (cmp_psn(psn, flow->flow_state.ib_spsn) >= 0 && in find_flow_ib()
1686 cmp_psn(psn, flow->flow_state.ib_lpsn) <= 0) { in find_flow_ib()
1710 /* This is the IB psn use in hfi1_build_tid_rdma_read_packet()
1674 find_flow_ib(struct tid_rdma_request *req, u32 psn, u16 *fidx) find_flow_ib() argument
1882 tid_rdma_rcv_read_request(struct rvt_qp *qp, struct rvt_ack_entry *e, struct hfi1_packet *packet, struct ib_other_headers *ohdr, u32 bth0, u32 psn, u64 vaddr, u32 len) tid_rdma_rcv_read_request() argument
1978 tid_rdma_rcv_error(struct hfi1_packet *packet, struct ib_other_headers *ohdr, struct rvt_qp *qp, u32 psn, int diff) tid_rdma_rcv_error() argument
2231 u32 bth0, psn, len, rkey; hfi1_rc_rcv_tid_rdma_read_req() local
2851 u32 qp_num, psn, ibpsn; hfi1_handle_kdeth_eflags() local
3656 u32 bth0, psn, len, rkey, num_segs; hfi1_rc_rcv_tid_rdma_write_req() local
4036 u32 opcode, aeth, psn, flow_psn, i, tidlen = 0, pktlen; hfi1_rc_rcv_tid_rdma_write_resp() local
4268 u32 psn, next; hfi1_rc_rcv_tid_rdma_write_data() local
4408 hfi1_tid_rdma_is_resync_psn(u32 psn) hfi1_tid_rdma_is_resync_psn() argument
4493 u32 aeth, psn, req_psn, ack_psn, flpsn, resync_psn, ack_kpsn; hfi1_rc_rcv_tid_rdma_ack() local
4868 u32 psn, generation, idx, gen_next; hfi1_rc_rcv_tid_rdma_resync() local
5489 tid_rdma_rcv_err(struct hfi1_packet *packet, struct ib_other_headers *ohdr, struct rvt_qp *qp, u32 psn, int diff, bool fecn) tid_rdma_rcv_err() argument
[all...] |
| H A D | rc.h | 36 u32 psn, u32 pmtu) in restart_sge()
40 len = delta_psn(psn, wqe->psn) * pmtu; in restart_sge()
52 struct rvt_ack_entry *find_prev_entry(struct rvt_qp *qp, u32 psn, u8 *prev,
54 int do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val,
35 restart_sge(struct rvt_sge_state *ss, struct rvt_swqe *wqe, u32 psn, u32 pmtu) restart_sge() argument
|
| H A D | trace_ibhdrs.h | 118 u16 *pkey, u32 *psn, u32 *qpn);
125 u32 *psn, u32 *qpn);
141 u8 tver, u16 pkey, u32 psn, u32 qpn,
183 __field(u32, psn)
225 &__entry->psn,
249 &__entry->psn,
296 __entry->psn,
342 __field(u32, psn)
390 &__entry->psn,
417 &__entry->psn,
[all...] |
| H A D | trace.c | 162 u16 *pkey, u32 *psn, u32 *qpn) in hfi1_trace_parse_9b_bth()
173 *psn = mask_psn(ib_bth_get_psn(ohdr)); in hfi1_trace_parse_9b_bth()
180 u32 *psn, u32 *qpn) in hfi1_trace_parse_16b_bth()
188 *psn = mask_psn(ib_bth_get_psn(ohdr)); in hfi1_trace_parse_16b_bth()
252 "f:%d b:%d qpn:0x%.6x a:%d psn:0x%.8x"
255 "qpn:0x%.6x a:%d psn:0x%.8x"
261 u8 tver, u16 pkey, u32 psn, u32 qpn, in hfi1_trace_fmt_rest()
273 se, mig, pad, tver, qpn, ack, psn); in hfi1_trace_fmt_rest()
279 qpn, ack, psn); in hfi1_trace_fmt_rest()
159 hfi1_trace_parse_9b_bth(struct ib_other_headers *ohdr, u8 *ack, bool *becn, bool *fecn, u8 *mig, u8 *se, u8 *pad, u8 *opcode, u8 *tver, u16 *pkey, u32 *psn, u32 *qpn) hfi1_trace_parse_9b_bth() argument
177 hfi1_trace_parse_16b_bth(struct ib_other_headers *ohdr, u8 *ack, u8 *mig, u8 *opcode, u8 *pad, u8 *se, u8 *tver, u32 *psn, u32 *qpn) hfi1_trace_parse_16b_bth() argument
258 hfi1_trace_fmt_rest(struct trace_seq *p, bool bypass, u8 l4, u8 ack, bool becn, bool fecn, u8 mig, u8 se, u8 pad, u8 opcode, const char *opname, u8 tver, u16 pkey, u32 psn, u32 qpn, u32 dest_qpn, u32 src_qpn) hfi1_trace_fmt_rest() argument
|
| /kernel/linux/linux-6.6/drivers/infiniband/hw/hfi1/ |
| H A D | trace_rc.h | 18 TP_PROTO(struct rvt_qp *qp, u32 psn),
19 TP_ARGS(qp, psn),
24 __field(u32, psn)
35 __entry->psn = psn;
43 "[%s] qpn 0x%x s_flags 0x%x psn 0x%x s_psn 0x%x s_next_psn 0x%x s_sending_psn 0x%x sending_hpsn 0x%x r_psn 0x%x",
47 __entry->psn,
57 TP_PROTO(struct rvt_qp *qp, u32 psn),
58 TP_ARGS(qp, psn)
62 TP_PROTO(struct rvt_qp *qp, u32 psn),
[all...] |
| H A D | trace_tid.h | 40 #define RSP_INFO_PRN "[%s] qpn 0x%x state 0x%x s_state 0x%x psn 0x%x " \
58 #define TID_REQ_PRN "[%s] qpn 0x%x newreq %u opcode 0x%x psn 0x%x lpsn 0x%x " \
66 "r_head_ack_queue %u opcode 0x%x psn 0x%x r_psn 0x%x " \
744 TP_PROTO(struct rvt_qp *qp, u32 psn),
745 TP_ARGS(qp, psn),
751 __field(u32, psn)
772 __entry->psn = psn;
791 __entry->psn,
808 TP_PROTO(struct rvt_qp *qp, u32 psn),
[all...] |
| H A D | rc.c | 16 struct rvt_ack_entry *find_prev_entry(struct rvt_qp *qp, u32 psn, u8 *prev,
40 if (cmp_psn(psn, e->psn) >= 0) {
42 cmp_psn(psn, e->lpsn) <= 0)
120 trace_hfi1_rsp_make_rc_ack(qp, e->psn); in make_rc_ack()
170 qp->s_ack_rdma_psn = e->psn; in make_rc_ack()
185 qp->s_ack_rdma_psn = mask_psn(e->psn + req->cur_seg); in make_rc_ack()
219 bth2 = mask_psn(e->psn); in make_rc_ack()
295 trace_hfi1_tid_req_make_rc_ack_write(qp, 0, e->opcode, e->psn, in make_rc_ack()
533 qp->s_psn = wqe->psn; in hfi1_make_rc_req()
1417 update_num_rd_atomic(struct rvt_qp *qp, u32 psn, struct rvt_swqe *wqe) update_num_rd_atomic() argument
1458 reset_psn(struct rvt_qp *qp, u32 psn) reset_psn() argument
1564 hfi1_restart_rc(struct rvt_qp *qp, u32 psn, int wait) hfi1_restart_rc() argument
1635 reset_sending_psn(struct rvt_qp *qp, u32 psn) reset_sending_psn() argument
1676 u32 psn; hfi1_rc_verbs_aborted() local
1699 u32 psn; hfi1_rc_send_complete() local
1814 update_last_psn(struct rvt_qp *qp, u32 psn) update_last_psn() argument
1930 update_qp_retry_state(struct rvt_qp *qp, u32 psn, u32 spsn, u32 lpsn) update_qp_retry_state() argument
1964 do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val, struct hfi1_ctxtdata *rcd) do_rc_ack() argument
2263 rdma_seq_err(struct rvt_qp *qp, struct hfi1_ibport *ibp, u32 psn, struct hfi1_ctxtdata *rcd) rdma_seq_err() argument
2316 u32 psn = ib_bth_get_psn(packet->ohdr); rc_rcv_resp() local
2510 rc_rcv_error(struct ib_other_headers *ohdr, void *data, struct rvt_qp *qp, u32 opcode, u32 psn, int diff, struct hfi1_ctxtdata *rcd) rc_rcv_error() argument
2774 u32 psn = ib_bth_get_psn(packet->ohdr); hfi1_rc_rcv() local
3217 u32 psn; hfi1_rc_hdrerr() local
[all...] |
| H A D | tid_rdma.c | 130 struct rvt_qp *qp, u32 psn, int diff, bool fecn);
349 qpriv->flow_state.psn = 0; in hfi1_qp_priv_init()
806 fs->psn = 0; in hfi1_kern_setup_hw_flow()
833 fs->psn = 0; in hfi1_kern_clear_hw_flow()
1522 flow->flow_state.spsn = qpriv->flow_state.psn;
1526 qpriv->flow_state.psn += flow->npkts;
1682 u32 psn, u16 *fidx) in find_flow_ib()
1692 if (cmp_psn(psn, flow->flow_state.ib_spsn) >= 0 && in find_flow_ib()
1693 cmp_psn(psn, flow->flow_state.ib_lpsn) <= 0) { in find_flow_ib()
1717 /* This is the IB psn use in hfi1_build_tid_rdma_read_packet()
1681 find_flow_ib(struct tid_rdma_request *req, u32 psn, u16 *fidx) find_flow_ib() argument
1889 tid_rdma_rcv_read_request(struct rvt_qp *qp, struct rvt_ack_entry *e, struct hfi1_packet *packet, struct ib_other_headers *ohdr, u32 bth0, u32 psn, u64 vaddr, u32 len) tid_rdma_rcv_read_request() argument
1985 tid_rdma_rcv_error(struct hfi1_packet *packet, struct ib_other_headers *ohdr, struct rvt_qp *qp, u32 psn, int diff) tid_rdma_rcv_error() argument
2238 u32 bth0, psn, len, rkey; hfi1_rc_rcv_tid_rdma_read_req() local
2859 u32 qp_num, psn, ibpsn; hfi1_handle_kdeth_eflags() local
3668 u32 bth0, psn, len, rkey, num_segs; hfi1_rc_rcv_tid_rdma_write_req() local
4048 u32 opcode, aeth, psn, flow_psn, i, tidlen = 0, pktlen; hfi1_rc_rcv_tid_rdma_write_resp() local
4280 u32 psn, next; hfi1_rc_rcv_tid_rdma_write_data() local
4420 hfi1_tid_rdma_is_resync_psn(u32 psn) hfi1_tid_rdma_is_resync_psn() argument
4505 u32 aeth, psn, req_psn, ack_psn, flpsn, resync_psn, ack_kpsn; hfi1_rc_rcv_tid_rdma_ack() local
4880 u32 psn, generation, idx, gen_next; hfi1_rc_rcv_tid_rdma_resync() local
5501 tid_rdma_rcv_err(struct hfi1_packet *packet, struct ib_other_headers *ohdr, struct rvt_qp *qp, u32 psn, int diff, bool fecn) tid_rdma_rcv_err() argument
[all...] |
| H A D | rc.h | 36 u32 psn, u32 pmtu) in restart_sge()
40 len = delta_psn(psn, wqe->psn) * pmtu; in restart_sge()
52 struct rvt_ack_entry *find_prev_entry(struct rvt_qp *qp, u32 psn, u8 *prev,
54 int do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val,
35 restart_sge(struct rvt_sge_state *ss, struct rvt_swqe *wqe, u32 psn, u32 pmtu) restart_sge() argument
|
| H A D | trace_ibhdrs.h | 77 u16 *pkey, u32 *psn, u32 *qpn);
84 u32 *psn, u32 *qpn);
100 u8 tver, u16 pkey, u32 psn, u32 qpn,
142 __field(u32, psn)
184 &__entry->psn,
208 &__entry->psn,
255 __entry->psn,
301 __field(u32, psn)
349 &__entry->psn,
376 &__entry->psn,
[all...] |
| /kernel/linux/linux-5.10/drivers/infiniband/sw/rdmavt/ |
| H A D | trace_rc.h | 60 TP_PROTO(struct rvt_qp *qp, u32 psn),
61 TP_ARGS(qp, psn),
66 __field(u32, psn)
77 __entry->psn = psn;
85 "[%s] qpn 0x%x s_flags 0x%x psn 0x%x s_psn 0x%x s_next_psn 0x%x s_sending_psn 0x%x sending_hpsn 0x%x r_psn 0x%x",
89 __entry->psn,
99 TP_PROTO(struct rvt_qp *qp, u32 psn),
100 TP_ARGS(qp, psn)
|
| H A D | trace_tx.h | 87 "[%s] wqe %p wr_id %llx send_flags %x qpn %x qpt %u psn %x lpsn %x ssn %x length %u opcode 0x%.2x,%s size %u avail %u head %u last %u pid %u num_sge %u wr_num_sge %u"
99 __field(u32, psn)
119 __entry->psn = wqe->psn;
141 __entry->psn,
|
| /kernel/linux/linux-6.6/drivers/infiniband/sw/rdmavt/ |
| H A D | trace_rc.h | 18 TP_PROTO(struct rvt_qp *qp, u32 psn),
19 TP_ARGS(qp, psn),
24 __field(u32, psn)
35 __entry->psn = psn;
43 "[%s] qpn 0x%x s_flags 0x%x psn 0x%x s_psn 0x%x s_next_psn 0x%x s_sending_psn 0x%x sending_hpsn 0x%x r_psn 0x%x",
47 __entry->psn,
57 TP_PROTO(struct rvt_qp *qp, u32 psn),
58 TP_ARGS(qp, psn)
|
| H A D | trace_tx.h | 45 "[%s] wqe %p wr_id %llx send_flags %x qpn %x qpt %u psn %x lpsn %x ssn %x length %u opcode 0x%.2x,%s size %u avail %u head %u last %u pid %u num_sge %u wr_num_sge %u"
57 __field(u32, psn)
77 __entry->psn = wqe->psn;
99 __entry->psn,
|
| /kernel/linux/linux-5.10/drivers/infiniband/hw/qib/ |
| H A D | qib_rc.c | 43 u32 psn, u32 pmtu) in restart_sge()
47 len = ((psn - wqe->psn) & QIB_PSN_MASK) * pmtu; in restart_sge()
134 qp->s_ack_rdma_psn = e->psn; in qib_make_rc_ack()
144 bth2 = e->psn & QIB_PSN_MASK; in qib_make_rc_ack()
302 qp->s_psn = wqe->psn; in qib_make_rc_req()
551 len = ((qp->s_psn - wqe->psn) & QIB_PSN_MASK) * pmtu; in qib_make_rc_req()
569 delta = (((int) bth2 - (int) wqe->psn) << 8) >> 8; in qib_make_rc_req()
729 * @psn: the packet sequence number to restart at
735 static void reset_psn(struct rvt_qp *qp, u32 psn) in reset_psn() argument
42 restart_sge(struct rvt_sge_state *ss, struct rvt_swqe *wqe, u32 psn, u32 pmtu) restart_sge() argument
820 qib_restart_rc(struct rvt_qp *qp, u32 psn, int wait) qib_restart_rc() argument
856 reset_sending_psn(struct rvt_qp *qp, u32 psn) reset_sending_psn() argument
886 u32 psn; qib_rc_send_complete() local
940 update_last_psn(struct rvt_qp *qp, u32 psn) update_last_psn() argument
1006 do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val, struct qib_ctxtdata *rcd) do_rc_ack() argument
1223 rdma_seq_err(struct rvt_qp *qp, struct qib_ibport *ibp, u32 psn, struct qib_ctxtdata *rcd) rdma_seq_err() argument
1267 qib_rc_rcv_resp(struct qib_ibport *ibp, struct ib_other_headers *ohdr, void *data, u32 tlen, struct rvt_qp *qp, u32 opcode, u32 psn, u32 hdrsize, u32 pmtu, struct qib_ctxtdata *rcd) qib_rc_rcv_resp() argument
1490 qib_rc_rcv_error(struct ib_other_headers *ohdr, void *data, struct rvt_qp *qp, u32 opcode, u32 psn, int diff, struct qib_ctxtdata *rcd) qib_rc_rcv_error() argument
1718 u32 psn; qib_rc_rcv() local
[all...] |
| /kernel/linux/linux-6.6/drivers/infiniband/hw/qib/ |
| H A D | qib_rc.c | 43 u32 psn, u32 pmtu) in restart_sge()
47 len = ((psn - wqe->psn) & QIB_PSN_MASK) * pmtu; in restart_sge()
134 qp->s_ack_rdma_psn = e->psn; in qib_make_rc_ack()
144 bth2 = e->psn & QIB_PSN_MASK; in qib_make_rc_ack()
303 qp->s_psn = wqe->psn; in qib_make_rc_req()
552 len = ((qp->s_psn - wqe->psn) & QIB_PSN_MASK) * pmtu; in qib_make_rc_req()
570 delta = (((int) bth2 - (int) wqe->psn) << 8) >> 8; in qib_make_rc_req()
730 * @psn: the packet sequence number to restart at
736 static void reset_psn(struct rvt_qp *qp, u32 psn) in reset_psn() argument
42 restart_sge(struct rvt_sge_state *ss, struct rvt_swqe *wqe, u32 psn, u32 pmtu) restart_sge() argument
821 qib_restart_rc(struct rvt_qp *qp, u32 psn, int wait) qib_restart_rc() argument
857 reset_sending_psn(struct rvt_qp *qp, u32 psn) reset_sending_psn() argument
887 u32 psn; qib_rc_send_complete() local
941 update_last_psn(struct rvt_qp *qp, u32 psn) update_last_psn() argument
1007 do_rc_ack(struct rvt_qp *qp, u32 aeth, u32 psn, int opcode, u64 val, struct qib_ctxtdata *rcd) do_rc_ack() argument
1224 rdma_seq_err(struct rvt_qp *qp, struct qib_ibport *ibp, u32 psn, struct qib_ctxtdata *rcd) rdma_seq_err() argument
1269 qib_rc_rcv_resp(struct qib_ibport *ibp, struct ib_other_headers *ohdr, void *data, u32 tlen, struct rvt_qp *qp, u32 opcode, u32 psn, u32 hdrsize, u32 pmtu, struct qib_ctxtdata *rcd) qib_rc_rcv_resp() argument
1493 qib_rc_rcv_error(struct ib_other_headers *ohdr, void *data, struct rvt_qp *qp, u32 opcode, u32 psn, int diff, struct qib_ctxtdata *rcd) qib_rc_rcv_error() argument
1721 u32 psn; qib_rc_rcv() local
[all...] |
| /kernel/linux/linux-5.10/drivers/infiniband/sw/rxe/ |
| H A D | rxe_comp.c | 179 diff = psn_compare(pkt->psn, wqe->last_psn); in check_psn()
193 diff = psn_compare(pkt->psn, qp->comp.psn); in check_psn()
198 if (pkt->psn == wqe->last_psn) in check_psn()
233 if ((pkt->psn == wqe->first_psn && in check_ack()
299 if (psn_compare(pkt->psn, qp->comp.psn) > 0) { in check_ack()
302 qp->comp.psn = pkt->psn; in check_ack()
463 (qp->comp.psn in complete_ack()
[all...] |
| H A D | rxe_resp.c | 120 int diff = psn_compare(pkt->psn, qp->resp.psn); in check_psn()
563 u32 psn, in prepare_ack_packet()
598 bth_set_psn(ack, psn); in prepare_ack_packet()
600 ack->psn = psn; in prepare_ack_packet()
659 res->first_psn = req_pkt->psn; in read_reply()
662 res->last_psn = (req_pkt->psn + in read_reply()
668 res->cur_psn = req_pkt->psn; in read_reply()
734 if (psn_compare(res->cur_psn, qp->resp.psn) > in read_reply()
558 prepare_ack_packet(struct rxe_qp *qp, struct rxe_pkt_info *pkt, struct rxe_pkt_info *ack, int opcode, int payload, u32 psn, u8 syndrome, u32 *crcp) prepare_ack_packet() argument
931 send_ack(struct rxe_qp *qp, struct rxe_pkt_info *pkt, u8 syndrome, u32 psn) send_ack() argument
1028 find_resource(struct rxe_qp *qp, u32 psn) find_resource() argument
[all...] |
| H A D | rxe_req.c | 50 qp->req.psn = qp->comp.psn; in req_retry()
81 npsn = (qp->comp.psn - wqe->first_psn) & in req_retry()
375 pkt->psn = qp->req.psn; in init_req_packet()
405 ack_req, pkt->psn); in init_req_packet()
512 wqe->first_psn = qp->req.psn; in update_wqe_psn()
513 wqe->last_psn = (qp->req.psn + num_pkt - 1) & BTH_PSN_MASK; in update_wqe_psn()
517 qp->req.psn = (wqe->first_psn + num_pkt) & BTH_PSN_MASK; in update_wqe_psn()
519 qp->req.psn in update_wqe_psn()
[all...] |
| /kernel/linux/linux-6.6/drivers/infiniband/sw/rxe/ |
| H A D | rxe_comp.c | 190 diff = psn_compare(pkt->psn, wqe->last_psn); in check_psn()
204 diff = psn_compare(pkt->psn, qp->comp.psn); in check_psn()
209 if (pkt->psn == wqe->last_psn) in check_psn()
252 if ((pkt->psn == wqe->first_psn && in check_ack()
322 if (psn_compare(pkt->psn, qp->comp.psn) > 0) { in check_ack()
325 qp->comp.psn = pkt->psn; in check_ack()
489 if (qp->attr.sq_draining && qp->comp.psn in comp_check_sq_drain_done()
[all...] |
| H A D | rxe_resp.c | 83 int diff = psn_compare(pkt->psn, qp->resp.psn); in check_psn()
620 res->first_psn = pkt->psn; in rxe_prepare_res()
621 res->cur_psn = pkt->psn; in rxe_prepare_res()
622 res->last_psn = (pkt->psn + pkts - 1) & BTH_PSN_MASK; in rxe_prepare_res()
628 res->first_psn = pkt->psn; in rxe_prepare_res()
629 res->last_psn = pkt->psn; in rxe_prepare_res()
630 res->cur_psn = pkt->psn; in rxe_prepare_res()
677 /* next expected psn, read handles this separately */ in process_flush()
678 qp->resp.psn in process_flush()
760 prepare_ack_packet(struct rxe_qp *qp, struct rxe_pkt_info *ack, int opcode, int payload, u32 psn, u8 syndrome) prepare_ack_packet() argument
1166 send_common_ack(struct rxe_qp *qp, u8 syndrome, u32 psn, int opcode, const char *msg) send_common_ack() argument
1184 send_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) send_ack() argument
1190 send_atomic_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) send_atomic_ack() argument
1202 send_read_response_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) send_read_response_ack() argument
1253 find_resource(struct rxe_qp *qp, u32 psn) find_resource() argument
[all...] |
| H A D | rxe_req.c | 53 qp->req.psn = qp->comp.psn; in req_retry()
83 npsn = (qp->comp.psn - wqe->first_psn) & in req_retry()
454 ack_req, pkt->psn); in init_req_packet()
566 wqe->first_psn = qp->req.psn; in update_wqe_psn()
567 wqe->last_psn = (qp->req.psn + num_pkt - 1) & BTH_PSN_MASK; in update_wqe_psn()
571 qp->req.psn = (wqe->first_psn + num_pkt) & BTH_PSN_MASK; in update_wqe_psn()
573 qp->req.psn = (qp->req.psn + 1) & BTH_PSN_MASK; in update_wqe_psn()
585 *rollback_psn = qp->req.psn; in save_state()
[all...] |