Home
last modified time | relevance | path

Searched refs:psn (Results 1 – 25 of 39) sorted by relevance

12

/linux/drivers/infiniband/hw/hfi1/
H A Dtrace_rc.h18 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 Dtrace_tid.h40 #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 Drc.c16 struct rvt_ack_entry *find_prev_entry(struct rvt_qp *qp, u32 psn, u8 *prev, in find_prev_entry() argument
40 if (cmp_psn(psn, e->psn) >= 0) { in find_prev_entry()
42 cmp_psn(psn, e->lpsn) <= 0) in find_prev_entry()
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
2511 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 Drc.h36 u32 psn, u32 pmtu) in restart_sge() argument
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,
H A Dtid_rdma.c130 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; in hfi1_kern_exp_rcv_setup()
1526 qpriv->flow_state.psn += flow->npkts; in hfi1_kern_exp_rcv_setup()
1682 u32 psn, u16 *fidx) in find_flow_ib() argument
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()
1893 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
1987 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
2415 find_tid_request(struct rvt_qp * qp,u32 psn,enum ib_wr_opcode opcode) find_tid_request() argument
2657 handle_read_kdeth_eflags(struct hfi1_ctxtdata * rcd,struct hfi1_packet * packet,u8 rcv_type,u8 rte,u32 psn,u32 ibpsn) handle_read_kdeth_eflags() argument
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
4881 u32 psn, generation, idx, gen_next; hfi1_rc_rcv_tid_rdma_resync() local
5505 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 Dtrace_ibhdrs.h77 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...]
H A Dverbs.h347 static inline u32 __full_flow_psn(struct flow_state *state, u32 psn) in __full_flow_psn() argument
350 (psn & HFI1_KDETH_BTH_SEQ_MASK)); in __full_flow_psn()
353 static inline u32 full_flow_psn(struct tid_rdma_flow *flow, u32 psn) in full_flow_psn() argument
355 return __full_flow_psn(&flow->flow_state, psn); in full_flow_psn()
390 void hfi1_restart_rc(struct rvt_qp *qp, u32 psn, int wait);
H A Dtrace.c120 u16 *pkey, u32 *psn, u32 *qpn) in hfi1_trace_parse_9b_bth() argument
131 *psn = mask_psn(ib_bth_get_psn(ohdr)); in hfi1_trace_parse_9b_bth()
138 u32 *psn, u32 *qpn) in hfi1_trace_parse_16b_bth() argument
146 *psn = mask_psn(ib_bth_get_psn(ohdr)); in hfi1_trace_parse_16b_bth()
215 "f:%d b:%d qpn:0x%.6x a:%d psn:0x%.8x"
218 "qpn:0x%.6x a:%d psn:0x%.8x"
224 u8 tver, u16 pkey, u32 psn, u32 qpn, in hfi1_trace_fmt_rest() argument
236 se, mig, pad, tver, qpn, ack, psn); in hfi1_trace_fmt_rest()
242 qpn, ack, psn); in hfi1_trace_fmt_rest()
H A Duc.c111 qp->s_psn = wqe->psn; in hfi1_make_uc_req()
268 u32 psn; in hfi1_uc_rcv() local
281 psn = ib_bth_get_psn(ohdr); in hfi1_uc_rcv()
283 if (unlikely(cmp_psn(psn, qp->r_psn) != 0)) { in hfi1_uc_rcv()
288 qp->r_psn = psn; in hfi1_uc_rcv()
H A Duser_sdma.c904 psn = val & mask; in set_pkt_bth_psn() local
906 psn = (psn & ~HFI1_KDETH_BTH_SEQ_MASK) | in set_pkt_bth_psn()
907 ((psn + frags) & HFI1_KDETH_BTH_SEQ_MASK); in set_pkt_bth_psn()
909 psn = psn + frags; in set_pkt_bth_psn()
910 return psn & mask; in set_pkt_bth_psn()
H A Dtid_rdma.h79 u32 psn; member
/linux/drivers/infiniband/sw/rdmavt/
H A Dtrace_rc.h18 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 Dtrace_tx.h45 "[%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,
/linux/drivers/infiniband/sw/rxe/
H A Drxe_resp.c73 int diff = psn_compare(pkt->psn, qp->resp.psn); in check_psn()
623 res->first_psn = pkt->psn; in rxe_prepare_res()
624 res->cur_psn = pkt->psn; in rxe_prepare_res()
625 res->last_psn = (pkt->psn + pkts - 1) & BTH_PSN_MASK; in rxe_prepare_res()
631 res->first_psn = pkt->psn; in rxe_prepare_res()
632 res->last_psn = pkt->psn; in rxe_prepare_res()
633 res->cur_psn = pkt->psn; in rxe_prepare_res()
680 /* next expected psn, read handles this separately */ in process_flush()
681 qp->resp.psn in process_flush()
782 prepare_ack_packet(struct rxe_qp * qp,struct rxe_pkt_info * ack,int opcode,int payload,u32 psn,u8 syndrome) prepare_ack_packet() argument
1184 send_common_ack(struct rxe_qp * qp,u8 syndrome,u32 psn,int opcode,const char * msg) send_common_ack() argument
1202 send_ack(struct rxe_qp * qp,u8 syndrome,u32 psn) send_ack() argument
1208 send_atomic_ack(struct rxe_qp * qp,u8 syndrome,u32 psn) send_atomic_ack() argument
1220 send_read_response_ack(struct rxe_qp * qp,u8 syndrome,u32 psn) send_read_response_ack() argument
1271 find_resource(struct rxe_qp * qp,u32 psn) find_resource() argument
[all...]
H A Drxe_req.c52 qp->req.psn = qp->comp.psn; in req_retry()
82 npsn = (qp->comp.psn - wqe->first_psn) & in req_retry()
454 ack_req, pkt->psn); in init_req_packet()
568 wqe->first_psn = qp->req.psn; in update_wqe_psn()
569 wqe->last_psn = (qp->req.psn + num_pkt - 1) & BTH_PSN_MASK; in update_wqe_psn()
573 qp->req.psn = (wqe->first_psn + num_pkt) & BTH_PSN_MASK; in update_wqe_psn()
575 qp->req.psn = (qp->req.psn + 1) & BTH_PSN_MASK; in update_wqe_psn()
715 psn_compare(qp->req.psn, (q in rxe_requester()
[all...]
H A Drxe_hdr.h20 u32 psn; /* bth psn of packet */ member
271 static inline void __bth_set_psn(void *arg, u32 psn) in __bth_set_psn() argument
276 bth->apsn = cpu_to_be32((BTH_PSN_MASK & psn) | in __bth_set_psn()
400 static inline void bth_set_psn(struct rxe_pkt_info *pkt, u32 psn) in bth_set_psn() argument
402 __bth_set_psn(pkt->hdr, psn); in bth_set_psn()
407 u32 psn) in bth_init() argument
419 psn &= BTH_PSN_MASK; in bth_init()
421 psn |= BTH_ACK_MASK; in bth_init()
422 bth->apsn = cpu_to_be32(psn); in bth_init()
[all...]
H A Drxe_verbs.h107 u32 psn; member
120 u32 psn; member
202 u32 psn; member
H A Drxe_recv.c329 pkt->psn = bth_psn(pkt); in rxe_rcv()
/linux/drivers/infiniband/ulp/ipoib/
H A Dipoib_cm.c275 unsigned int psn) in ipoib_cm_modify_rx_qp() argument
298 qp_attr.rq_psn = psn; in ipoib_cm_modify_rx_qp()
423 unsigned int psn) in ipoib_cm_send_rep() argument
438 rep.starting_psn = psn; in ipoib_cm_send_rep()
448 unsigned int psn; in ipoib_cm_req_handler() local
468 psn = get_random_u32() & 0xffffff; in ipoib_cm_req_handler()
469 ret = ipoib_cm_modify_rx_qp(dev, cm_id, p->qp, psn); in ipoib_cm_req_handler()
489 ret = ipoib_cm_send_rep(dev, cm_id, p->qp, &event->param.req_rcvd, psn); in ipoib_cm_req_handler()
/linux/drivers/infiniband/hw/bnxt_re/
H A Dqplib_fp.c977 /* First psn entry */ in bnxt_qplib_init_psn_ptr()
1418 req.rq_psn = cpu_to_le32(qp->rq.psn); in bnxt_qplib_modify_qp()
1421 req.sq_psn = cpu_to_le32(qp->sq.psn); in bnxt_qplib_modify_qp()
1527 qp->rq.psn = le32_to_cpu(sb->rq_psn); in bnxt_qplib_query_qp()
1529 qp->sq.psn = le32_to_cpu(sb->sq_psn); in bnxt_qplib_query_qp()
1695 /* Fil the MSN table into the next psn row */
1916 swq->start_psn = sq->psn & BTH_PSN_MASK; in bnxt_qplib_post_send()
1979 sq->psn = (sq->psn + 1) & BTH_PSN_MASK; in bnxt_qplib_post_send()
1991 sq->psn in bnxt_qplib_post_send()
[all...]
/linux/lib/zstd/common/
H A Dcpu.h147 D(psn, 18)
/linux/drivers/infiniband/hw/mana/
H A Dwr.c123 send_oob.psn = qp->ud_qp.sq_psn; in mana_ib_post_send_ud()
/linux/include/rdma/
H A Dib_pack.h200 __be32 psn; member
H A Drdmavt_qp.h175 u32 psn; /* first packet sequence number */ member
293 u32 psn; member
424 u32 s_ahgpsn; /* set to the psn in the copy of the header */
H A Drdma_vt.h358 void (*notify_restart_rc)(struct rvt_qp *qp, u32 psn, int wait);

12