Lines Matching refs:psn
44 u32 psn, u32 pmtu)
48 len = ((psn - wqe->psn) & QIB_PSN_MASK) * pmtu;
150 qp->s_ack_rdma_psn = e->psn;
163 bth2 = e->psn & QIB_PSN_MASK;
328 wqe->psn = qp->s_next_psn;
348 wqe->lpsn = wqe->psn;
387 wqe->lpsn = wqe->psn;
461 wqe->lpsn = wqe->psn;
603 len = ((qp->s_psn - wqe->psn) & QIB_PSN_MASK) * pmtu;
621 delta = (((int) bth2 - (int) wqe->psn) << 8) >> 8;
782 * @psn: the packet sequence number to restart at
788 static void reset_psn(struct qib_qp *qp, u32 psn)
800 if (qib_cmp24(psn, wqe->psn) <= 0) {
815 diff = qib_cmp24(psn, wqe->psn);
858 qp->s_psn = psn;
873 static void qib_restart_rc(struct qib_qp *qp, u32 psn, int wait)
895 ibp->n_rc_resends += (qp->s_psn - psn) & QIB_PSN_MASK;
902 reset_psn(qp, psn);
947 * This would be psn+1 except when RDMA reads are present.
949 static void reset_sending_psn(struct qib_qp *qp, u32 psn)
957 if (qib_cmp24(psn, wqe->lpsn) <= 0) {
961 qp->s_sending_psn = psn + 1;
981 u32 psn;
1000 psn = be32_to_cpu(ohdr->bth[2]);
1001 reset_sending_psn(qp, psn);
1007 if ((psn & IB_BTH_REQ_ACK) && qp->s_acked != qp->s_tail &&
1048 static inline void update_last_psn(struct qib_qp *qp, u32 psn)
1050 qp->s_last_psn = psn;
1108 qp->s_psn = wqe->psn;
1123 * @psn: the packet sequence number of the ACK
1131 static int do_rc_ack(struct qib_qp *qp, u32 aeth, u32 psn, int opcode,
1153 ack_psn = psn;
1247 if (qib_cmp24(qp->s_psn, psn) <= 0)
1248 reset_psn(qp, psn + 1);
1249 } else if (qib_cmp24(qp->s_psn, psn) <= 0) {
1251 qp->s_psn = psn + 1;
1260 update_last_psn(qp, psn);
1278 update_last_psn(qp, psn - 1);
1280 ibp->n_rc_resends += (qp->s_psn - psn) & QIB_PSN_MASK;
1282 reset_psn(qp, psn);
1297 update_last_psn(qp, psn - 1);
1308 qib_restart_rc(qp, psn, 0);
1354 static void rdma_seq_err(struct qib_qp *qp, struct qib_ibport *ibp, u32 psn,
1367 while (qib_cmp24(psn, wqe->lpsn) > 0) {
1393 * @psn: the packet sequence number for this packet
1406 u32 psn, u32 hdrsize, u32 pmtu,
1420 if (qib_cmp24(psn, qp->s_next_psn) >= 0)
1424 diff = qib_cmp24(psn, qp->s_last_psn);
1440 if (qib_cmp24(psn, qp->s_last_psn + 1) != 0)
1462 if (!do_rc_ack(qp, aeth, psn, opcode, val, rcd) ||
1475 wqe, psn, pmtu);
1480 if (unlikely(qib_cmp24(psn, qp->s_last_psn + 1)))
1511 update_last_psn(qp, psn);
1518 if (!do_rc_ack(qp, aeth, psn, opcode, 0, rcd))
1536 wqe, psn, pmtu);
1541 if (unlikely(qib_cmp24(psn, qp->s_last_psn + 1)))
1561 (void) do_rc_ack(qp, aeth, psn,
1571 rdma_seq_err(qp, ibp, psn, rcd);
1593 * @psn: the packet sequence number for this packet
1606 u32 psn,
1679 if (qib_cmp24(psn, e->psn) >= 0) {
1681 qib_cmp24(psn, e->lpsn) <= 0)
1707 offset = ((psn - e->psn) & QIB_PSN_MASK) *
1730 e->psn = psn;
1755 if (!(psn & IB_BTH_REQ_ACK) || old_req)
1770 qp->r_ack_psn = qp->s_ack_queue[i].psn - 1;
1844 u32 psn;
1868 psn = be32_to_cpu(ohdr->bth[2]);
1879 qib_rc_rcv_resp(ibp, ohdr, data, tlen, qp, opcode, psn,
1885 diff = qib_cmp24(psn, qp->r_psn);
1887 if (qib_rc_rcv_error(ohdr, data, qp, opcode, psn, diff, rcd))
2115 e->psn = psn;
2184 e->psn = psn;
2185 e->lpsn = psn;
2205 qp->r_ack_psn = psn;
2208 if (psn & (1 << 31))