Lines Matching refs:comp
120 qp->comp.timeout = 1; in retransmit_timer()
121 rxe_run_task(&qp->comp.task, 1); in retransmit_timer()
135 rxe_run_task(&qp->comp.task, must_sched); in rxe_comp_queue_pkt()
168 qp->comp.retry_cnt = qp->attr.retry_cnt; in reset_retry_counters()
169 qp->comp.rnr_retry = qp->attr.rnr_retry; in reset_retry_counters()
170 qp->comp.started_retry = 0; in reset_retry_counters()
196 diff = psn_compare(pkt->psn, qp->comp.psn); in check_psn()
221 switch (qp->comp.opcode) { in check_ack()
302 if (psn_compare(pkt->psn, qp->comp.psn) > 0) { in check_ack()
305 qp->comp.psn = pkt->psn; in check_ack()
467 qp->comp.timeout_retry = 0; in complete_ack()
477 (qp->comp.psn == qp->req.psn)) { in complete_ack()
497 if (psn_compare(pkt->psn, qp->comp.psn) >= 0) in complete_ack()
508 if (psn_compare(wqe->last_psn, qp->comp.psn) >= 0) { in complete_wqe()
509 qp->comp.psn = (wqe->last_psn + 1) & BTH_PSN_MASK; in complete_wqe()
510 qp->comp.opcode = -1; in complete_wqe()
570 if (!qp->valid || qp->comp.state == QP_STATE_ERROR || in rxe_completer()
571 qp->comp.state == QP_STATE_RESET) { in rxe_completer()
573 qp->comp.state == QP_STATE_ERROR); in rxe_completer()
577 if (qp->comp.timeout) { in rxe_completer()
578 qp->comp.timeout_retry = 1; in rxe_completer()
579 qp->comp.timeout = 0; in rxe_completer()
581 qp->comp.timeout_retry = 0; in rxe_completer()
597 qp->comp.timeout_retry = 0; in rxe_completer()
640 qp->comp.opcode = -1; in rxe_completer()
642 qp->comp.opcode = pkt->opcode; in rxe_completer()
644 if (psn_compare(pkt->psn, qp->comp.psn) >= 0) in rxe_completer()
645 qp->comp.psn = (pkt->psn + 1) & BTH_PSN_MASK; in rxe_completer()
659 if (qp->comp.timeout_retry && wqe) { in rxe_completer()
674 (psn_compare(qp->req.psn, qp->comp.psn) > 0) && in rxe_completer()
696 if (qp->comp.started_retry && in rxe_completer()
697 !qp->comp.timeout_retry) in rxe_completer()
700 if (qp->comp.retry_cnt > 0) { in rxe_completer()
701 if (qp->comp.retry_cnt != 7) in rxe_completer()
702 qp->comp.retry_cnt--; in rxe_completer()
709 qp->comp.psn) > 0) { in rxe_completer()
716 qp->comp.started_retry = 1; in rxe_completer()
730 if (qp->comp.rnr_retry > 0) { in rxe_completer()
731 if (qp->comp.rnr_retry != 7) in rxe_completer()
732 qp->comp.rnr_retry--; in rxe_completer()