Lines Matching refs:psn

73 	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()
681 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in process_flush()
682 qp->resp.ack_psn = qp->resp.psn; in process_flush()
721 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in atomic_reply()
722 qp->resp.ack_psn = qp->resp.psn; in atomic_reply()
769 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in atomic_write_reply()
770 qp->resp.ack_psn = qp->resp.psn; in atomic_write_reply()
782 u32 psn, in prepare_ack_packet() argument
805 ack->psn = psn; in prepare_ack_packet()
808 qp->attr.dest_qp_num, 0, psn); in prepare_ack_packet()
976 if (psn_compare(res->cur_psn, qp->resp.psn) >= 0) in read_reply()
977 qp->resp.psn = res->cur_psn; in read_reply()
1055 qp->resp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in execute()
1056 qp->resp.ack_psn = qp->resp.psn; in execute()
1184 static int send_common_ack(struct rxe_qp *qp, u8 syndrome, u32 psn, in send_common_ack() argument
1191 skb = prepare_ack_packet(qp, &ack_pkt, opcode, 0, psn, syndrome); in send_common_ack()
1202 static int send_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) in send_ack() argument
1204 return send_common_ack(qp, syndrome, psn, in send_ack()
1208 static int send_atomic_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) in send_atomic_ack() argument
1210 int ret = send_common_ack(qp, syndrome, psn, in send_atomic_ack()
1220 static int send_read_response_ack(struct rxe_qp *qp, u8 syndrome, u32 psn) in send_read_response_ack() argument
1222 int ret = send_common_ack(qp, syndrome, psn, in send_read_response_ack()
1240 send_ack(qp, qp->resp.aeth_syndrome, pkt->psn); in acknowledge()
1242 send_atomic_ack(qp, AETH_ACK_UNLIMITED, pkt->psn); in acknowledge()
1244 send_read_response_ack(qp, AETH_ACK_UNLIMITED, pkt->psn); in acknowledge()
1246 send_ack(qp, AETH_ACK_UNLIMITED, pkt->psn); in acknowledge()
1271 static struct resp_res *find_resource(struct rxe_qp *qp, u32 psn) in find_resource() argument
1281 if (psn_compare(psn, res->first_psn) >= 0 && in find_resource()
1282 psn_compare(psn, res->last_psn) <= 0) { in find_resource()
1305 res = find_resource(qp, pkt->psn); in duplicate_request()
1308 res->cur_psn = pkt->psn; in duplicate_request()
1320 res = find_resource(qp, pkt->psn); in duplicate_request()
1347 res->cur_psn = pkt->psn; in duplicate_request()
1348 res->state = (pkt->psn == res->first_psn) ? in duplicate_request()
1367 res = find_resource(qp, pkt->psn); in duplicate_request()
1370 res->cur_psn = pkt->psn; in duplicate_request()
1583 send_ack(qp, AETH_NAK_PSN_SEQ_ERROR, qp->resp.psn); in rxe_receiver()
1608 pkt->psn); in rxe_receiver()