Lines Matching defs:pkt
147 struct rxe_pkt_info *pkt,
160 return pkt ? COMPST_DONE : COMPST_EXIT;
171 return pkt ? COMPST_CHECK_PSN : COMPST_EXIT;
182 struct rxe_pkt_info *pkt,
190 diff = psn_compare(pkt->psn, wqe->last_psn);
204 diff = psn_compare(pkt->psn, qp->comp.psn);
209 if (pkt->psn == wqe->last_psn)
211 else if (pkt->opcode == IB_OPCODE_RC_ACKNOWLEDGE &&
225 struct rxe_pkt_info *pkt,
228 unsigned int mask = pkt->mask;
244 if (pkt->opcode == IB_OPCODE_RC_ACKNOWLEDGE)
247 if (pkt->opcode != IB_OPCODE_RC_RDMA_READ_RESPONSE_MIDDLE &&
248 pkt->opcode != IB_OPCODE_RC_RDMA_READ_RESPONSE_LAST) {
252 if ((pkt->psn == wqe->first_psn &&
253 pkt->opcode ==
256 pkt->opcode ==
268 switch (pkt->opcode) {
272 syn = aeth_syn(pkt);
294 syn = aeth_syn(pkt);
306 syn = aeth_syn(pkt);
322 if (psn_compare(pkt->psn, qp->comp.psn) > 0) {
325 qp->comp.psn = pkt->psn;
364 struct rxe_pkt_info *pkt,
370 &wqe->dma, payload_addr(pkt),
371 payload_size(pkt), RXE_TO_MR_OBJ);
377 if (wqe->dma.resid == 0 && (pkt->mask & RXE_END_MASK))
384 struct rxe_pkt_info *pkt,
389 u64 atomic_orig = atmack_orig(pkt);
509 struct rxe_pkt_info *pkt,
526 if (psn_compare(pkt->psn, qp->comp.psn) >= 0)
533 struct rxe_pkt_info *pkt,
536 if (pkt && wqe->state == wqe_state_pending) {
614 static void free_pkt(struct rxe_pkt_info *pkt)
616 struct sk_buff *skb = PKT_TO_SKB(pkt);
617 struct rxe_qp *qp = pkt->qp;
652 struct rxe_pkt_info *pkt = NULL;
687 pkt = SKB_TO_PKT(skb);
694 state = get_wqe(qp, pkt, &wqe);
698 state = check_psn(qp, pkt, wqe);
702 state = check_ack(qp, pkt, wqe);
706 state = do_read(qp, pkt, wqe);
710 state = do_atomic(qp, pkt, wqe);
715 wqe->last_psn == pkt->psn)
722 state = complete_ack(qp, pkt, wqe);
726 state = complete_wqe(qp, pkt, wqe);
730 if (pkt->mask & RXE_END_MASK)
733 qp->comp.opcode = pkt->opcode;
735 if (psn_compare(pkt->psn, qp->comp.psn) >= 0)
736 qp->comp.psn = (pkt->psn + 1) & BTH_PSN_MASK;
819 jiffies + rnrnak_jiffies(aeth_syn(pkt)
848 if (pkt)
849 free_pkt(pkt);