sw/rxe/rxe_recv.c

13 static int check_type_state(struct rxe_dev *rxe, struct rxe_pkt_info *pkt,
22 	pkt_type = pkt->opcode & 0xe0;
43 	if (pkt->mask & RXE_REQ_MASK) {
75 static int check_keys(struct rxe_dev *rxe, struct rxe_pkt_info *pkt,
79 	u16 pkey = bth_pkey(pkt);
81 	pkt->pkey_index = 0;
91 		if (unlikely(deth_qkey(pkt) != qkey)) {
100 static int check_addr(struct rxe_dev *rxe, struct rxe_pkt_info *pkt,
103 	struct sk_buff *skb = PKT_TO_SKB(pkt);
108 	if (unlikely(pkt->port_num != qp->attr.port_num))
135 static int hdr_check(struct rxe_pkt_info *pkt)
137 	struct rxe_dev *rxe = pkt->rxe;
140 	u32 qpn = bth_qpn(pkt);
144 	if (unlikely(bth_tver(pkt) != BTH_TVER))
157 		err = check_type_state(rxe, pkt, qp);
161 		err = check_addr(rxe, pkt, qp);
165 		err = check_keys(rxe, pkt, qpn, qp);
169 		if (unlikely((pkt->mask & RXE_GRH_MASK) == 0))
173 	pkt->qp = qp;
182 static inline void rxe_rcv_pkt(struct rxe_pkt_info *pkt, struct sk_buff *skb)
184 	if (pkt->mask & RXE_REQ_MASK)
185 		rxe_resp_queue_pkt(pkt->qp, skb);
187 		rxe_comp_queue_pkt(pkt->qp, skb);
192 	struct rxe_pkt_info *pkt = SKB_TO_PKT(skb);
221 		err = check_type_state(rxe, pkt, qp);
225 		err = check_keys(rxe, pkt, bth_qpn(pkt), qp);
251 			pkt->qp = qp;
253 			rxe_rcv_pkt(pkt, skb);
286 	struct rxe_pkt_info *pkt = SKB_TO_PKT(skb);
291 	if (pkt->mask & RXE_LOOPBACK_MASK)
319 	struct rxe_pkt_info *pkt = SKB_TO_PKT(skb);
320 	struct rxe_dev *rxe = pkt->rxe;
328 	pkt->opcode = bth_opcode(pkt);
329 	pkt->psn = bth_psn(pkt);
330 	pkt->qp = NULL;
331 	pkt->mask |= rxe_opcode[pkt->opcode].mask;
333 	if (unlikely(skb->len < header_size(pkt)))
336 	err = hdr_check(pkt);
340 	err = rxe_icrc_check(skb, pkt);
346 	if (unlikely(bth_qpn(pkt) == IB_MULTICAST_QPN))
349 		rxe_rcv_pkt(pkt, skb);
354 	if (pkt->qp)
355 		rxe_put(pkt->qp);