Lines Matching refs:psn
83 int diff = psn_compare(pkt->psn, qp->resp.psn);
620 res->first_psn = pkt->psn;
621 res->cur_psn = pkt->psn;
622 res->last_psn = (pkt->psn + pkts - 1) & BTH_PSN_MASK;
628 res->first_psn = pkt->psn;
629 res->last_psn = pkt->psn;
630 res->cur_psn = pkt->psn;
677 /* next expected psn, read handles this separately */
678 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
679 qp->resp.ack_psn = qp->resp.psn;
711 /* next expected psn, read handles this separately */
712 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
713 qp->resp.ack_psn = qp->resp.psn;
750 /* next expected psn, read handles this separately */
751 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
752 qp->resp.ack_psn = qp->resp.psn;
764 u32 psn,
787 ack->psn = psn;
790 qp->attr.dest_qp_num, 0, psn);
958 if (psn_compare(res->cur_psn, qp->resp.psn) >= 0)
959 qp->resp.psn = res->cur_psn;
1036 /* next expected psn, read handles this separately */
1037 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
1038 qp->resp.ack_psn = qp->resp.psn;
1166 static int send_common_ack(struct rxe_qp *qp, u8 syndrome, u32 psn,
1173 skb = prepare_ack_packet(qp, &ack_pkt, opcode, 0, psn, syndrome);
1184 static int send_ack(struct rxe_qp *qp, u8 syndrome, u32 psn)
1186 return send_common_ack(qp, syndrome, psn,
1190 static int send_atomic_ack(struct rxe_qp *qp, u8 syndrome, u32 psn)
1192 int ret = send_common_ack(qp, syndrome, psn,
1202 static int send_read_response_ack(struct rxe_qp *qp, u8 syndrome, u32 psn)
1204 int ret = send_common_ack(qp, syndrome, psn,
1222 send_ack(qp, qp->resp.aeth_syndrome, pkt->psn);
1224 send_atomic_ack(qp, AETH_ACK_UNLIMITED, pkt->psn);
1226 send_read_response_ack(qp, AETH_ACK_UNLIMITED, pkt->psn);
1228 send_ack(qp, AETH_ACK_UNLIMITED, pkt->psn);
1253 static struct resp_res *find_resource(struct rxe_qp *qp, u32 psn)
1263 if (psn_compare(psn, res->first_psn) >= 0 &&
1264 psn_compare(psn, res->last_psn) <= 0) {
1287 res = find_resource(qp, pkt->psn);
1290 res->cur_psn = pkt->psn;
1302 res = find_resource(qp, pkt->psn);
1329 res->cur_psn = pkt->psn;
1330 res->state = (pkt->psn == res->first_psn) ?
1349 res = find_resource(qp, pkt->psn);
1352 res->cur_psn = pkt->psn;
1565 send_ack(qp, AETH_NAK_PSN_SEQ_ERROR, qp->resp.psn);
1590 pkt->psn);