Lines Matching refs:psn
43 u32 psn, u32 pmtu)
47 len = ((psn - wqe->psn) & IPATH_PSN_MASK) * pmtu;
139 qp->s_ack_rdma_psn = e->psn;
152 bth2 = e->psn;
299 wqe->psn = qp->s_next_psn;
319 wqe->lpsn = wqe->psn;
358 wqe->lpsn = wqe->psn;
431 wqe->lpsn = wqe->psn;
568 len = ((qp->s_psn - wqe->psn) & IPATH_PSN_MASK) * pmtu;
718 * @psn: the packet sequence number to restart at
724 static void reset_psn(struct ipath_qp *qp, u32 psn)
736 if (ipath_cmp24(psn, wqe->psn) <= 0) {
751 diff = ipath_cmp24(psn, wqe->psn);
794 qp->s_psn = psn;
800 * @psn: packet sequence number for the request
805 void ipath_restart_rc(struct ipath_qp *qp, u32 psn)
832 dev->n_rc_resends += (qp->s_psn - psn) & IPATH_PSN_MASK;
834 reset_psn(qp, psn);
841 static inline void update_last_psn(struct ipath_qp *qp, u32 psn)
843 qp->s_last_psn = psn;
849 * @psn: the packet sequence number of the ACK
857 static int do_rc_ack(struct ipath_qp *qp, u32 aeth, u32 psn, int opcode,
885 ack_psn = psn;
925 update_last_psn(qp, wqe->psn - 1);
927 ipath_restart_rc(qp, wqe->psn);
976 qp->s_psn = wqe->psn;
1003 if (ipath_cmp24(qp->s_psn, psn) <= 0) {
1004 reset_psn(qp, psn + 1);
1007 } else if (ipath_cmp24(qp->s_psn, psn) <= 0) {
1009 qp->s_psn = psn + 1;
1014 update_last_psn(qp, psn);
1030 update_last_psn(qp, psn - 1);
1036 (qp->s_psn - psn) & IPATH_PSN_MASK;
1038 reset_psn(qp, psn);
1051 update_last_psn(qp, psn - 1);
1062 ipath_restart_rc(qp, psn);
1108 * @psn: the packet sequence number for this packet
1122 u32 psn, u32 hdrsize, u32 pmtu,
1140 if (ipath_cmp24(psn, qp->s_next_psn) >= 0)
1144 diff = ipath_cmp24(psn, qp->s_last_psn);
1185 if (!do_rc_ack(qp, aeth, psn, opcode, val) ||
1199 wqe, psn, pmtu);
1204 if (unlikely(ipath_cmp24(psn, qp->s_last_psn + 1))) {
1235 update_last_psn(qp, psn);
1245 if (!do_rc_ack(qp, aeth, psn, opcode, 0))
1263 wqe, psn, pmtu);
1268 if (unlikely(ipath_cmp24(psn, qp->s_last_psn + 1))) {
1298 (void) do_rc_ack(qp, aeth, psn,
1325 * @psn: the packet sequence number for this packet
1340 u32 psn,
1378 psn &= IPATH_PSN_MASK;
1403 if (ipath_cmp24(psn, e->psn) >= 0) {
1436 offset = ((psn - e->psn) & IPATH_PSN_MASK) *
1459 e->psn = psn;
1497 qp->r_ack_psn = qp->s_ack_queue[i].psn - 1;
1571 u32 psn;
1588 psn = be32_to_cpu(ohdr->bth[2]);
1600 psn = be32_to_cpu(((__be32 *) data)[0]);
1603 psn = be32_to_cpu(ohdr->bth[2]);
1615 ipath_rc_rcv_resp(dev, ohdr, data, tlen, qp, opcode, psn,
1621 diff = ipath_cmp24(psn, qp->r_psn);
1624 psn, diff, header_in_data))
1842 e->psn = psn;
1910 e->psn = psn & IPATH_PSN_MASK;
1929 qp->r_ack_psn = psn;
1932 if (psn & (1 << 31))