Lines Matching refs:psn
120 int diff = psn_compare(pkt->psn, qp->resp.psn); in check_psn()
563 u32 psn, in prepare_ack_packet() argument
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) >= 0) in read_reply()
735 qp->resp.psn = res->cur_psn; in read_reply()
794 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in execute()
795 qp->resp.ack_psn = qp->resp.psn; in execute()
932 u8 syndrome, u32 psn) in send_ack() argument
939 0, psn, syndrome, NULL); in send_ack()
962 IB_OPCODE_RC_ATOMIC_ACKNOWLEDGE, 0, pkt->psn, in send_atomic_ack()
980 res->first_psn = ack_pkt.psn; in send_atomic_ack()
981 res->last_psn = ack_pkt.psn; in send_atomic_ack()
982 res->cur_psn = ack_pkt.psn; in send_atomic_ack()
1000 send_ack(qp, pkt, qp->resp.aeth_syndrome, pkt->psn); in acknowledge()
1004 send_ack(qp, pkt, AETH_ACK_UNLIMITED, pkt->psn); in acknowledge()
1028 static struct resp_res *find_resource(struct rxe_qp *qp, u32 psn) in find_resource() argument
1038 if (psn_compare(psn, res->first_psn) >= 0 && in find_resource()
1039 psn_compare(psn, res->last_psn) <= 0) { in find_resource()
1063 res = find_resource(qp, pkt->psn); in duplicate_request()
1090 res->cur_psn = pkt->psn; in duplicate_request()
1091 res->state = (pkt->psn == res->first_psn) ? in duplicate_request()
1110 res = find_resource(qp, pkt->psn); in duplicate_request()
1263 send_ack(qp, pkt, AETH_NAK_PSN_SEQ_ERROR, qp->resp.psn); in rxe_responder()
1288 pkt->psn); in rxe_responder()