1ca9c54d2SDexuan Cui // SPDX-License-Identifier: GPL-2.0 OR BSD-3-Clause
2ca9c54d2SDexuan Cui /* Copyright (c) 2021, Microsoft Corporation. */
3ca9c54d2SDexuan Cui 
43b80b73aSJakub Kicinski #include <uapi/linux/bpf.h>
53b80b73aSJakub Kicinski 
6ca9c54d2SDexuan Cui #include <linux/inetdevice.h>
7ca9c54d2SDexuan Cui #include <linux/etherdevice.h>
8ca9c54d2SDexuan Cui #include <linux/ethtool.h>
97a8938cdSHaiyang Zhang #include <linux/filter.h>
10ca9c54d2SDexuan Cui #include <linux/mm.h>
11ca9c54d2SDexuan Cui 
12ca9c54d2SDexuan Cui #include <net/checksum.h>
13ca9c54d2SDexuan Cui #include <net/ip6_checksum.h>
14ca9c54d2SDexuan Cui 
15fd325cd6SLong Li #include <net/mana/mana.h>
16fd325cd6SLong Li #include <net/mana/mana_auxiliary.h>
17a69839d4SLong Li 
18a69839d4SLong Li static DEFINE_IDA(mana_adev_ida);
19a69839d4SLong Li 
20a69839d4SLong Li static int mana_adev_idx_alloc(void)
21a69839d4SLong Li {
22a69839d4SLong Li 	return ida_alloc(&mana_adev_ida, GFP_KERNEL);
23a69839d4SLong Li }
24a69839d4SLong Li 
25a69839d4SLong Li static void mana_adev_idx_free(int idx)
26a69839d4SLong Li {
27a69839d4SLong Li 	ida_free(&mana_adev_ida, idx);
28a69839d4SLong Li }
29ca9c54d2SDexuan Cui 
30ca9c54d2SDexuan Cui /* Microsoft Azure Network Adapter (MANA) functions */
31ca9c54d2SDexuan Cui 
32ca9c54d2SDexuan Cui static int mana_open(struct net_device *ndev)
33ca9c54d2SDexuan Cui {
34ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
35ca9c54d2SDexuan Cui 	int err;
36ca9c54d2SDexuan Cui 
37ca9c54d2SDexuan Cui 	err = mana_alloc_queues(ndev);
38ca9c54d2SDexuan Cui 	if (err)
39ca9c54d2SDexuan Cui 		return err;
40ca9c54d2SDexuan Cui 
41ca9c54d2SDexuan Cui 	apc->port_is_up = true;
42ca9c54d2SDexuan Cui 
43ca9c54d2SDexuan Cui 	/* Ensure port state updated before txq state */
44ca9c54d2SDexuan Cui 	smp_wmb();
45ca9c54d2SDexuan Cui 
46ca9c54d2SDexuan Cui 	netif_carrier_on(ndev);
47ca9c54d2SDexuan Cui 	netif_tx_wake_all_queues(ndev);
48ca9c54d2SDexuan Cui 
49ca9c54d2SDexuan Cui 	return 0;
50ca9c54d2SDexuan Cui }
51ca9c54d2SDexuan Cui 
52ca9c54d2SDexuan Cui static int mana_close(struct net_device *ndev)
53ca9c54d2SDexuan Cui {
54ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
55ca9c54d2SDexuan Cui 
56ca9c54d2SDexuan Cui 	if (!apc->port_is_up)
57ca9c54d2SDexuan Cui 		return 0;
58ca9c54d2SDexuan Cui 
59ca9c54d2SDexuan Cui 	return mana_detach(ndev, true);
60ca9c54d2SDexuan Cui }
61ca9c54d2SDexuan Cui 
62ca9c54d2SDexuan Cui static bool mana_can_tx(struct gdma_queue *wq)
63ca9c54d2SDexuan Cui {
64ca9c54d2SDexuan Cui 	return mana_gd_wq_avail_space(wq) >= MAX_TX_WQE_SIZE;
65ca9c54d2SDexuan Cui }
66ca9c54d2SDexuan Cui 
67ca9c54d2SDexuan Cui static unsigned int mana_checksum_info(struct sk_buff *skb)
68ca9c54d2SDexuan Cui {
69ca9c54d2SDexuan Cui 	if (skb->protocol == htons(ETH_P_IP)) {
70ca9c54d2SDexuan Cui 		struct iphdr *ip = ip_hdr(skb);
71ca9c54d2SDexuan Cui 
72ca9c54d2SDexuan Cui 		if (ip->protocol == IPPROTO_TCP)
73ca9c54d2SDexuan Cui 			return IPPROTO_TCP;
74ca9c54d2SDexuan Cui 
75ca9c54d2SDexuan Cui 		if (ip->protocol == IPPROTO_UDP)
76ca9c54d2SDexuan Cui 			return IPPROTO_UDP;
77ca9c54d2SDexuan Cui 	} else if (skb->protocol == htons(ETH_P_IPV6)) {
78ca9c54d2SDexuan Cui 		struct ipv6hdr *ip6 = ipv6_hdr(skb);
79ca9c54d2SDexuan Cui 
80ca9c54d2SDexuan Cui 		if (ip6->nexthdr == IPPROTO_TCP)
81ca9c54d2SDexuan Cui 			return IPPROTO_TCP;
82ca9c54d2SDexuan Cui 
83ca9c54d2SDexuan Cui 		if (ip6->nexthdr == IPPROTO_UDP)
84ca9c54d2SDexuan Cui 			return IPPROTO_UDP;
85ca9c54d2SDexuan Cui 	}
86ca9c54d2SDexuan Cui 
87ca9c54d2SDexuan Cui 	/* No csum offloading */
88ca9c54d2SDexuan Cui 	return 0;
89ca9c54d2SDexuan Cui }
90ca9c54d2SDexuan Cui 
91ca9c54d2SDexuan Cui static int mana_map_skb(struct sk_buff *skb, struct mana_port_context *apc,
92ca9c54d2SDexuan Cui 			struct mana_tx_package *tp)
93ca9c54d2SDexuan Cui {
94ca9c54d2SDexuan Cui 	struct mana_skb_head *ash = (struct mana_skb_head *)skb->head;
95ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
96ca9c54d2SDexuan Cui 	struct gdma_context *gc;
97ca9c54d2SDexuan Cui 	struct device *dev;
98ca9c54d2SDexuan Cui 	skb_frag_t *frag;
99ca9c54d2SDexuan Cui 	dma_addr_t da;
100ca9c54d2SDexuan Cui 	int i;
101ca9c54d2SDexuan Cui 
102ca9c54d2SDexuan Cui 	gc = gd->gdma_context;
103ca9c54d2SDexuan Cui 	dev = gc->dev;
104ca9c54d2SDexuan Cui 	da = dma_map_single(dev, skb->data, skb_headlen(skb), DMA_TO_DEVICE);
105ca9c54d2SDexuan Cui 
106ca9c54d2SDexuan Cui 	if (dma_mapping_error(dev, da))
107ca9c54d2SDexuan Cui 		return -ENOMEM;
108ca9c54d2SDexuan Cui 
109ca9c54d2SDexuan Cui 	ash->dma_handle[0] = da;
110ca9c54d2SDexuan Cui 	ash->size[0] = skb_headlen(skb);
111ca9c54d2SDexuan Cui 
112ca9c54d2SDexuan Cui 	tp->wqe_req.sgl[0].address = ash->dma_handle[0];
113ca9c54d2SDexuan Cui 	tp->wqe_req.sgl[0].mem_key = gd->gpa_mkey;
114ca9c54d2SDexuan Cui 	tp->wqe_req.sgl[0].size = ash->size[0];
115ca9c54d2SDexuan Cui 
116ca9c54d2SDexuan Cui 	for (i = 0; i < skb_shinfo(skb)->nr_frags; i++) {
117ca9c54d2SDexuan Cui 		frag = &skb_shinfo(skb)->frags[i];
118ca9c54d2SDexuan Cui 		da = skb_frag_dma_map(dev, frag, 0, skb_frag_size(frag),
119ca9c54d2SDexuan Cui 				      DMA_TO_DEVICE);
120ca9c54d2SDexuan Cui 
121ca9c54d2SDexuan Cui 		if (dma_mapping_error(dev, da))
122ca9c54d2SDexuan Cui 			goto frag_err;
123ca9c54d2SDexuan Cui 
124ca9c54d2SDexuan Cui 		ash->dma_handle[i + 1] = da;
125ca9c54d2SDexuan Cui 		ash->size[i + 1] = skb_frag_size(frag);
126ca9c54d2SDexuan Cui 
127ca9c54d2SDexuan Cui 		tp->wqe_req.sgl[i + 1].address = ash->dma_handle[i + 1];
128ca9c54d2SDexuan Cui 		tp->wqe_req.sgl[i + 1].mem_key = gd->gpa_mkey;
129ca9c54d2SDexuan Cui 		tp->wqe_req.sgl[i + 1].size = ash->size[i + 1];
130ca9c54d2SDexuan Cui 	}
131ca9c54d2SDexuan Cui 
132ca9c54d2SDexuan Cui 	return 0;
133ca9c54d2SDexuan Cui 
134ca9c54d2SDexuan Cui frag_err:
135ca9c54d2SDexuan Cui 	for (i = i - 1; i >= 0; i--)
136ca9c54d2SDexuan Cui 		dma_unmap_page(dev, ash->dma_handle[i + 1], ash->size[i + 1],
137ca9c54d2SDexuan Cui 			       DMA_TO_DEVICE);
138ca9c54d2SDexuan Cui 
139ca9c54d2SDexuan Cui 	dma_unmap_single(dev, ash->dma_handle[0], ash->size[0], DMA_TO_DEVICE);
140ca9c54d2SDexuan Cui 
141ca9c54d2SDexuan Cui 	return -ENOMEM;
142ca9c54d2SDexuan Cui }
143ca9c54d2SDexuan Cui 
1440c9ef08aSNathan Huckleberry netdev_tx_t mana_start_xmit(struct sk_buff *skb, struct net_device *ndev)
145ca9c54d2SDexuan Cui {
146ca9c54d2SDexuan Cui 	enum mana_tx_pkt_format pkt_fmt = MANA_SHORT_PKT_FMT;
147ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
148ca9c54d2SDexuan Cui 	u16 txq_idx = skb_get_queue_mapping(skb);
149ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
150ca9c54d2SDexuan Cui 	bool ipv4 = false, ipv6 = false;
151ca9c54d2SDexuan Cui 	struct mana_tx_package pkg = {};
152ca9c54d2SDexuan Cui 	struct netdev_queue *net_txq;
153f90f8420SHaiyang Zhang 	struct mana_stats_tx *tx_stats;
154ca9c54d2SDexuan Cui 	struct gdma_queue *gdma_sq;
155ca9c54d2SDexuan Cui 	unsigned int csum_type;
156ca9c54d2SDexuan Cui 	struct mana_txq *txq;
157ca9c54d2SDexuan Cui 	struct mana_cq *cq;
158ca9c54d2SDexuan Cui 	int err, len;
159bd7fc6e1SShradha Gupta 	u16 ihs;
160ca9c54d2SDexuan Cui 
161ca9c54d2SDexuan Cui 	if (unlikely(!apc->port_is_up))
162ca9c54d2SDexuan Cui 		goto tx_drop;
163ca9c54d2SDexuan Cui 
164ca9c54d2SDexuan Cui 	if (skb_cow_head(skb, MANA_HEADROOM))
165ca9c54d2SDexuan Cui 		goto tx_drop_count;
166ca9c54d2SDexuan Cui 
167ca9c54d2SDexuan Cui 	txq = &apc->tx_qp[txq_idx].txq;
168ca9c54d2SDexuan Cui 	gdma_sq = txq->gdma_sq;
169ca9c54d2SDexuan Cui 	cq = &apc->tx_qp[txq_idx].tx_cq;
170bd7fc6e1SShradha Gupta 	tx_stats = &txq->stats;
171ca9c54d2SDexuan Cui 
172ca9c54d2SDexuan Cui 	pkg.tx_oob.s_oob.vcq_num = cq->gdma_id;
173ca9c54d2SDexuan Cui 	pkg.tx_oob.s_oob.vsq_frame = txq->vsq_frame;
174ca9c54d2SDexuan Cui 
175ca9c54d2SDexuan Cui 	if (txq->vp_offset > MANA_SHORT_VPORT_OFFSET_MAX) {
176ca9c54d2SDexuan Cui 		pkg.tx_oob.l_oob.long_vp_offset = txq->vp_offset;
177ca9c54d2SDexuan Cui 		pkt_fmt = MANA_LONG_PKT_FMT;
178ca9c54d2SDexuan Cui 	} else {
179ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.short_vp_offset = txq->vp_offset;
180ca9c54d2SDexuan Cui 	}
181ca9c54d2SDexuan Cui 
182ca9c54d2SDexuan Cui 	pkg.tx_oob.s_oob.pkt_fmt = pkt_fmt;
183ca9c54d2SDexuan Cui 
184bd7fc6e1SShradha Gupta 	if (pkt_fmt == MANA_SHORT_PKT_FMT) {
185ca9c54d2SDexuan Cui 		pkg.wqe_req.inline_oob_size = sizeof(struct mana_tx_short_oob);
186bd7fc6e1SShradha Gupta 		u64_stats_update_begin(&tx_stats->syncp);
187bd7fc6e1SShradha Gupta 		tx_stats->short_pkt_fmt++;
188bd7fc6e1SShradha Gupta 		u64_stats_update_end(&tx_stats->syncp);
189bd7fc6e1SShradha Gupta 	} else {
190ca9c54d2SDexuan Cui 		pkg.wqe_req.inline_oob_size = sizeof(struct mana_tx_oob);
191bd7fc6e1SShradha Gupta 		u64_stats_update_begin(&tx_stats->syncp);
192bd7fc6e1SShradha Gupta 		tx_stats->long_pkt_fmt++;
193bd7fc6e1SShradha Gupta 		u64_stats_update_end(&tx_stats->syncp);
194bd7fc6e1SShradha Gupta 	}
195ca9c54d2SDexuan Cui 
196ca9c54d2SDexuan Cui 	pkg.wqe_req.inline_oob_data = &pkg.tx_oob;
197ca9c54d2SDexuan Cui 	pkg.wqe_req.flags = 0;
198ca9c54d2SDexuan Cui 	pkg.wqe_req.client_data_unit = 0;
199ca9c54d2SDexuan Cui 
200ca9c54d2SDexuan Cui 	pkg.wqe_req.num_sge = 1 + skb_shinfo(skb)->nr_frags;
201aa565497SLong Li 	WARN_ON_ONCE(pkg.wqe_req.num_sge > MAX_TX_WQE_SGL_ENTRIES);
202ca9c54d2SDexuan Cui 
203ca9c54d2SDexuan Cui 	if (pkg.wqe_req.num_sge <= ARRAY_SIZE(pkg.sgl_array)) {
204ca9c54d2SDexuan Cui 		pkg.wqe_req.sgl = pkg.sgl_array;
205ca9c54d2SDexuan Cui 	} else {
206ca9c54d2SDexuan Cui 		pkg.sgl_ptr = kmalloc_array(pkg.wqe_req.num_sge,
207ca9c54d2SDexuan Cui 					    sizeof(struct gdma_sge),
208ca9c54d2SDexuan Cui 					    GFP_ATOMIC);
209ca9c54d2SDexuan Cui 		if (!pkg.sgl_ptr)
210ca9c54d2SDexuan Cui 			goto tx_drop_count;
211ca9c54d2SDexuan Cui 
212ca9c54d2SDexuan Cui 		pkg.wqe_req.sgl = pkg.sgl_ptr;
213ca9c54d2SDexuan Cui 	}
214ca9c54d2SDexuan Cui 
215ca9c54d2SDexuan Cui 	if (skb->protocol == htons(ETH_P_IP))
216ca9c54d2SDexuan Cui 		ipv4 = true;
217ca9c54d2SDexuan Cui 	else if (skb->protocol == htons(ETH_P_IPV6))
218ca9c54d2SDexuan Cui 		ipv6 = true;
219ca9c54d2SDexuan Cui 
220ca9c54d2SDexuan Cui 	if (skb_is_gso(skb)) {
221ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.is_outer_ipv4 = ipv4;
222ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.is_outer_ipv6 = ipv6;
223ca9c54d2SDexuan Cui 
224ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.comp_iphdr_csum = 1;
225ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.comp_tcp_csum = 1;
226ca9c54d2SDexuan Cui 		pkg.tx_oob.s_oob.trans_off = skb_transport_offset(skb);
227ca9c54d2SDexuan Cui 
228ca9c54d2SDexuan Cui 		pkg.wqe_req.client_data_unit = skb_shinfo(skb)->gso_size;
229ca9c54d2SDexuan Cui 		pkg.wqe_req.flags = GDMA_WR_OOB_IN_SGL | GDMA_WR_PAD_BY_SGE0;
230ca9c54d2SDexuan Cui 		if (ipv4) {
231ca9c54d2SDexuan Cui 			ip_hdr(skb)->tot_len = 0;
232ca9c54d2SDexuan Cui 			ip_hdr(skb)->check = 0;
233ca9c54d2SDexuan Cui 			tcp_hdr(skb)->check =
234ca9c54d2SDexuan Cui 				~csum_tcpudp_magic(ip_hdr(skb)->saddr,
235ca9c54d2SDexuan Cui 						   ip_hdr(skb)->daddr, 0,
236ca9c54d2SDexuan Cui 						   IPPROTO_TCP, 0);
237ca9c54d2SDexuan Cui 		} else {
238ca9c54d2SDexuan Cui 			ipv6_hdr(skb)->payload_len = 0;
239ca9c54d2SDexuan Cui 			tcp_hdr(skb)->check =
240ca9c54d2SDexuan Cui 				~csum_ipv6_magic(&ipv6_hdr(skb)->saddr,
241ca9c54d2SDexuan Cui 						 &ipv6_hdr(skb)->daddr, 0,
242ca9c54d2SDexuan Cui 						 IPPROTO_TCP, 0);
243ca9c54d2SDexuan Cui 		}
244bd7fc6e1SShradha Gupta 
245bd7fc6e1SShradha Gupta 		if (skb->encapsulation) {
246bd7fc6e1SShradha Gupta 			ihs = skb_inner_tcp_all_headers(skb);
247bd7fc6e1SShradha Gupta 			u64_stats_update_begin(&tx_stats->syncp);
248bd7fc6e1SShradha Gupta 			tx_stats->tso_inner_packets++;
249bd7fc6e1SShradha Gupta 			tx_stats->tso_inner_bytes += skb->len - ihs;
250bd7fc6e1SShradha Gupta 			u64_stats_update_end(&tx_stats->syncp);
251bd7fc6e1SShradha Gupta 		} else {
252bd7fc6e1SShradha Gupta 			if (skb_shinfo(skb)->gso_type & SKB_GSO_UDP_L4) {
253bd7fc6e1SShradha Gupta 				ihs = skb_transport_offset(skb) + sizeof(struct udphdr);
254bd7fc6e1SShradha Gupta 			} else {
255bd7fc6e1SShradha Gupta 				ihs = skb_tcp_all_headers(skb);
256bd7fc6e1SShradha Gupta 				if (ipv6_has_hopopt_jumbo(skb))
257bd7fc6e1SShradha Gupta 					ihs -= sizeof(struct hop_jumbo_hdr);
258bd7fc6e1SShradha Gupta 			}
259bd7fc6e1SShradha Gupta 
260bd7fc6e1SShradha Gupta 			u64_stats_update_begin(&tx_stats->syncp);
261bd7fc6e1SShradha Gupta 			tx_stats->tso_packets++;
262bd7fc6e1SShradha Gupta 			tx_stats->tso_bytes += skb->len - ihs;
263bd7fc6e1SShradha Gupta 			u64_stats_update_end(&tx_stats->syncp);
264bd7fc6e1SShradha Gupta 		}
265bd7fc6e1SShradha Gupta 
266ca9c54d2SDexuan Cui 	} else if (skb->ip_summed == CHECKSUM_PARTIAL) {
267ca9c54d2SDexuan Cui 		csum_type = mana_checksum_info(skb);
268ca9c54d2SDexuan Cui 
269bd7fc6e1SShradha Gupta 		u64_stats_update_begin(&tx_stats->syncp);
270bd7fc6e1SShradha Gupta 		tx_stats->csum_partial++;
271bd7fc6e1SShradha Gupta 		u64_stats_update_end(&tx_stats->syncp);
272bd7fc6e1SShradha Gupta 
273ca9c54d2SDexuan Cui 		if (csum_type == IPPROTO_TCP) {
274ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.is_outer_ipv4 = ipv4;
275ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.is_outer_ipv6 = ipv6;
276ca9c54d2SDexuan Cui 
277ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.comp_tcp_csum = 1;
278ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.trans_off = skb_transport_offset(skb);
279ca9c54d2SDexuan Cui 
280ca9c54d2SDexuan Cui 		} else if (csum_type == IPPROTO_UDP) {
281ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.is_outer_ipv4 = ipv4;
282ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.is_outer_ipv6 = ipv6;
283ca9c54d2SDexuan Cui 
284ca9c54d2SDexuan Cui 			pkg.tx_oob.s_oob.comp_udp_csum = 1;
285ca9c54d2SDexuan Cui 		} else {
286ca9c54d2SDexuan Cui 			/* Can't do offload of this type of checksum */
287ca9c54d2SDexuan Cui 			if (skb_checksum_help(skb))
288ca9c54d2SDexuan Cui 				goto free_sgl_ptr;
289ca9c54d2SDexuan Cui 		}
290ca9c54d2SDexuan Cui 	}
291ca9c54d2SDexuan Cui 
292bd7fc6e1SShradha Gupta 	if (mana_map_skb(skb, apc, &pkg)) {
293bd7fc6e1SShradha Gupta 		u64_stats_update_begin(&tx_stats->syncp);
294bd7fc6e1SShradha Gupta 		tx_stats->mana_map_err++;
295bd7fc6e1SShradha Gupta 		u64_stats_update_end(&tx_stats->syncp);
296ca9c54d2SDexuan Cui 		goto free_sgl_ptr;
297bd7fc6e1SShradha Gupta 	}
298ca9c54d2SDexuan Cui 
299ca9c54d2SDexuan Cui 	skb_queue_tail(&txq->pending_skbs, skb);
300ca9c54d2SDexuan Cui 
301ca9c54d2SDexuan Cui 	len = skb->len;
302ca9c54d2SDexuan Cui 	net_txq = netdev_get_tx_queue(ndev, txq_idx);
303ca9c54d2SDexuan Cui 
304ca9c54d2SDexuan Cui 	err = mana_gd_post_work_request(gdma_sq, &pkg.wqe_req,
305ca9c54d2SDexuan Cui 					(struct gdma_posted_wqe_info *)skb->cb);
306ca9c54d2SDexuan Cui 	if (!mana_can_tx(gdma_sq)) {
307ca9c54d2SDexuan Cui 		netif_tx_stop_queue(net_txq);
308ca9c54d2SDexuan Cui 		apc->eth_stats.stop_queue++;
309ca9c54d2SDexuan Cui 	}
310ca9c54d2SDexuan Cui 
311ca9c54d2SDexuan Cui 	if (err) {
312ca9c54d2SDexuan Cui 		(void)skb_dequeue_tail(&txq->pending_skbs);
313ca9c54d2SDexuan Cui 		netdev_warn(ndev, "Failed to post TX OOB: %d\n", err);
314ca9c54d2SDexuan Cui 		err = NETDEV_TX_BUSY;
315ca9c54d2SDexuan Cui 		goto tx_busy;
316ca9c54d2SDexuan Cui 	}
317ca9c54d2SDexuan Cui 
318ca9c54d2SDexuan Cui 	err = NETDEV_TX_OK;
319ca9c54d2SDexuan Cui 	atomic_inc(&txq->pending_sends);
320ca9c54d2SDexuan Cui 
321ca9c54d2SDexuan Cui 	mana_gd_wq_ring_doorbell(gd->gdma_context, gdma_sq);
322ca9c54d2SDexuan Cui 
323ca9c54d2SDexuan Cui 	/* skb may be freed after mana_gd_post_work_request. Do not use it. */
324ca9c54d2SDexuan Cui 	skb = NULL;
325ca9c54d2SDexuan Cui 
326ca9c54d2SDexuan Cui 	tx_stats = &txq->stats;
327ca9c54d2SDexuan Cui 	u64_stats_update_begin(&tx_stats->syncp);
328ca9c54d2SDexuan Cui 	tx_stats->packets++;
329ca9c54d2SDexuan Cui 	tx_stats->bytes += len;
330ca9c54d2SDexuan Cui 	u64_stats_update_end(&tx_stats->syncp);
331ca9c54d2SDexuan Cui 
332ca9c54d2SDexuan Cui tx_busy:
333ca9c54d2SDexuan Cui 	if (netif_tx_queue_stopped(net_txq) && mana_can_tx(gdma_sq)) {
334ca9c54d2SDexuan Cui 		netif_tx_wake_queue(net_txq);
335ca9c54d2SDexuan Cui 		apc->eth_stats.wake_queue++;
336ca9c54d2SDexuan Cui 	}
337ca9c54d2SDexuan Cui 
338ca9c54d2SDexuan Cui 	kfree(pkg.sgl_ptr);
339ca9c54d2SDexuan Cui 	return err;
340ca9c54d2SDexuan Cui 
341ca9c54d2SDexuan Cui free_sgl_ptr:
342ca9c54d2SDexuan Cui 	kfree(pkg.sgl_ptr);
343ca9c54d2SDexuan Cui tx_drop_count:
344ca9c54d2SDexuan Cui 	ndev->stats.tx_dropped++;
345ca9c54d2SDexuan Cui tx_drop:
346ca9c54d2SDexuan Cui 	dev_kfree_skb_any(skb);
347ca9c54d2SDexuan Cui 	return NETDEV_TX_OK;
348ca9c54d2SDexuan Cui }
349ca9c54d2SDexuan Cui 
350ca9c54d2SDexuan Cui static void mana_get_stats64(struct net_device *ndev,
351ca9c54d2SDexuan Cui 			     struct rtnl_link_stats64 *st)
352ca9c54d2SDexuan Cui {
353ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
354ca9c54d2SDexuan Cui 	unsigned int num_queues = apc->num_queues;
355f90f8420SHaiyang Zhang 	struct mana_stats_rx *rx_stats;
356f90f8420SHaiyang Zhang 	struct mana_stats_tx *tx_stats;
357ca9c54d2SDexuan Cui 	unsigned int start;
358ca9c54d2SDexuan Cui 	u64 packets, bytes;
359ca9c54d2SDexuan Cui 	int q;
360ca9c54d2SDexuan Cui 
361ca9c54d2SDexuan Cui 	if (!apc->port_is_up)
362ca9c54d2SDexuan Cui 		return;
363ca9c54d2SDexuan Cui 
364ca9c54d2SDexuan Cui 	netdev_stats_to_stats64(st, &ndev->stats);
365ca9c54d2SDexuan Cui 
366ca9c54d2SDexuan Cui 	for (q = 0; q < num_queues; q++) {
367f90f8420SHaiyang Zhang 		rx_stats = &apc->rxqs[q]->stats;
368ca9c54d2SDexuan Cui 
369ca9c54d2SDexuan Cui 		do {
370068c38adSThomas Gleixner 			start = u64_stats_fetch_begin(&rx_stats->syncp);
371f90f8420SHaiyang Zhang 			packets = rx_stats->packets;
372f90f8420SHaiyang Zhang 			bytes = rx_stats->bytes;
373068c38adSThomas Gleixner 		} while (u64_stats_fetch_retry(&rx_stats->syncp, start));
374ca9c54d2SDexuan Cui 
375ca9c54d2SDexuan Cui 		st->rx_packets += packets;
376ca9c54d2SDexuan Cui 		st->rx_bytes += bytes;
377ca9c54d2SDexuan Cui 	}
378ca9c54d2SDexuan Cui 
379ca9c54d2SDexuan Cui 	for (q = 0; q < num_queues; q++) {
380f90f8420SHaiyang Zhang 		tx_stats = &apc->tx_qp[q].txq.stats;
381ca9c54d2SDexuan Cui 
382ca9c54d2SDexuan Cui 		do {
383068c38adSThomas Gleixner 			start = u64_stats_fetch_begin(&tx_stats->syncp);
384f90f8420SHaiyang Zhang 			packets = tx_stats->packets;
385f90f8420SHaiyang Zhang 			bytes = tx_stats->bytes;
386068c38adSThomas Gleixner 		} while (u64_stats_fetch_retry(&tx_stats->syncp, start));
387ca9c54d2SDexuan Cui 
388ca9c54d2SDexuan Cui 		st->tx_packets += packets;
389ca9c54d2SDexuan Cui 		st->tx_bytes += bytes;
390ca9c54d2SDexuan Cui 	}
391ca9c54d2SDexuan Cui }
392ca9c54d2SDexuan Cui 
393ca9c54d2SDexuan Cui static int mana_get_tx_queue(struct net_device *ndev, struct sk_buff *skb,
394ca9c54d2SDexuan Cui 			     int old_q)
395ca9c54d2SDexuan Cui {
396ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
397ca9c54d2SDexuan Cui 	u32 hash = skb_get_hash(skb);
398ca9c54d2SDexuan Cui 	struct sock *sk = skb->sk;
399ca9c54d2SDexuan Cui 	int txq;
400ca9c54d2SDexuan Cui 
401ca9c54d2SDexuan Cui 	txq = apc->indir_table[hash & MANA_INDIRECT_TABLE_MASK];
402ca9c54d2SDexuan Cui 
403ca9c54d2SDexuan Cui 	if (txq != old_q && sk && sk_fullsock(sk) &&
404ca9c54d2SDexuan Cui 	    rcu_access_pointer(sk->sk_dst_cache))
405ca9c54d2SDexuan Cui 		sk_tx_queue_set(sk, txq);
406ca9c54d2SDexuan Cui 
407ca9c54d2SDexuan Cui 	return txq;
408ca9c54d2SDexuan Cui }
409ca9c54d2SDexuan Cui 
410ca9c54d2SDexuan Cui static u16 mana_select_queue(struct net_device *ndev, struct sk_buff *skb,
411ca9c54d2SDexuan Cui 			     struct net_device *sb_dev)
412ca9c54d2SDexuan Cui {
413ca9c54d2SDexuan Cui 	int txq;
414ca9c54d2SDexuan Cui 
415ca9c54d2SDexuan Cui 	if (ndev->real_num_tx_queues == 1)
416ca9c54d2SDexuan Cui 		return 0;
417ca9c54d2SDexuan Cui 
418ca9c54d2SDexuan Cui 	txq = sk_tx_queue_get(skb->sk);
419ca9c54d2SDexuan Cui 
420ca9c54d2SDexuan Cui 	if (txq < 0 || skb->ooo_okay || txq >= ndev->real_num_tx_queues) {
421ca9c54d2SDexuan Cui 		if (skb_rx_queue_recorded(skb))
422ca9c54d2SDexuan Cui 			txq = skb_get_rx_queue(skb);
423ca9c54d2SDexuan Cui 		else
424ca9c54d2SDexuan Cui 			txq = mana_get_tx_queue(ndev, skb, txq);
425ca9c54d2SDexuan Cui 	}
426ca9c54d2SDexuan Cui 
427ca9c54d2SDexuan Cui 	return txq;
428ca9c54d2SDexuan Cui }
429ca9c54d2SDexuan Cui 
430ca9c54d2SDexuan Cui static const struct net_device_ops mana_devops = {
431ca9c54d2SDexuan Cui 	.ndo_open		= mana_open,
432ca9c54d2SDexuan Cui 	.ndo_stop		= mana_close,
433ca9c54d2SDexuan Cui 	.ndo_select_queue	= mana_select_queue,
434ca9c54d2SDexuan Cui 	.ndo_start_xmit		= mana_start_xmit,
435ca9c54d2SDexuan Cui 	.ndo_validate_addr	= eth_validate_addr,
436ca9c54d2SDexuan Cui 	.ndo_get_stats64	= mana_get_stats64,
437ed5356b5SHaiyang Zhang 	.ndo_bpf		= mana_bpf,
4387a8938cdSHaiyang Zhang 	.ndo_xdp_xmit		= mana_xdp_xmit,
439ca9c54d2SDexuan Cui };
440ca9c54d2SDexuan Cui 
441ca9c54d2SDexuan Cui static void mana_cleanup_port_context(struct mana_port_context *apc)
442ca9c54d2SDexuan Cui {
443ca9c54d2SDexuan Cui 	kfree(apc->rxqs);
444ca9c54d2SDexuan Cui 	apc->rxqs = NULL;
445ca9c54d2SDexuan Cui }
446ca9c54d2SDexuan Cui 
447ca9c54d2SDexuan Cui static int mana_init_port_context(struct mana_port_context *apc)
448ca9c54d2SDexuan Cui {
449ca9c54d2SDexuan Cui 	apc->rxqs = kcalloc(apc->num_queues, sizeof(struct mana_rxq *),
450ca9c54d2SDexuan Cui 			    GFP_KERNEL);
451ca9c54d2SDexuan Cui 
452ca9c54d2SDexuan Cui 	return !apc->rxqs ? -ENOMEM : 0;
453ca9c54d2SDexuan Cui }
454ca9c54d2SDexuan Cui 
455ca9c54d2SDexuan Cui static int mana_send_request(struct mana_context *ac, void *in_buf,
456ca9c54d2SDexuan Cui 			     u32 in_len, void *out_buf, u32 out_len)
457ca9c54d2SDexuan Cui {
458ca9c54d2SDexuan Cui 	struct gdma_context *gc = ac->gdma_dev->gdma_context;
459ca9c54d2SDexuan Cui 	struct gdma_resp_hdr *resp = out_buf;
460ca9c54d2SDexuan Cui 	struct gdma_req_hdr *req = in_buf;
461ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
462ca9c54d2SDexuan Cui 	static atomic_t activity_id;
463ca9c54d2SDexuan Cui 	int err;
464ca9c54d2SDexuan Cui 
465ca9c54d2SDexuan Cui 	req->dev_id = gc->mana.dev_id;
466ca9c54d2SDexuan Cui 	req->activity_id = atomic_inc_return(&activity_id);
467ca9c54d2SDexuan Cui 
468ca9c54d2SDexuan Cui 	err = mana_gd_send_request(gc, in_len, in_buf, out_len,
469ca9c54d2SDexuan Cui 				   out_buf);
470ca9c54d2SDexuan Cui 	if (err || resp->status) {
471ca9c54d2SDexuan Cui 		dev_err(dev, "Failed to send mana message: %d, 0x%x\n",
472ca9c54d2SDexuan Cui 			err, resp->status);
473ca9c54d2SDexuan Cui 		return err ? err : -EPROTO;
474ca9c54d2SDexuan Cui 	}
475ca9c54d2SDexuan Cui 
476ca9c54d2SDexuan Cui 	if (req->dev_id.as_uint32 != resp->dev_id.as_uint32 ||
477ca9c54d2SDexuan Cui 	    req->activity_id != resp->activity_id) {
478ca9c54d2SDexuan Cui 		dev_err(dev, "Unexpected mana message response: %x,%x,%x,%x\n",
479ca9c54d2SDexuan Cui 			req->dev_id.as_uint32, resp->dev_id.as_uint32,
480ca9c54d2SDexuan Cui 			req->activity_id, resp->activity_id);
481ca9c54d2SDexuan Cui 		return -EPROTO;
482ca9c54d2SDexuan Cui 	}
483ca9c54d2SDexuan Cui 
484ca9c54d2SDexuan Cui 	return 0;
485ca9c54d2SDexuan Cui }
486ca9c54d2SDexuan Cui 
487ca9c54d2SDexuan Cui static int mana_verify_resp_hdr(const struct gdma_resp_hdr *resp_hdr,
488ca9c54d2SDexuan Cui 				const enum mana_command_code expected_code,
489ca9c54d2SDexuan Cui 				const u32 min_size)
490ca9c54d2SDexuan Cui {
491ca9c54d2SDexuan Cui 	if (resp_hdr->response.msg_type != expected_code)
492ca9c54d2SDexuan Cui 		return -EPROTO;
493ca9c54d2SDexuan Cui 
494ca9c54d2SDexuan Cui 	if (resp_hdr->response.msg_version < GDMA_MESSAGE_V1)
495ca9c54d2SDexuan Cui 		return -EPROTO;
496ca9c54d2SDexuan Cui 
497ca9c54d2SDexuan Cui 	if (resp_hdr->response.msg_size < min_size)
498ca9c54d2SDexuan Cui 		return -EPROTO;
499ca9c54d2SDexuan Cui 
500ca9c54d2SDexuan Cui 	return 0;
501ca9c54d2SDexuan Cui }
502ca9c54d2SDexuan Cui 
5031566e7d6SDexuan Cui static int mana_pf_register_hw_vport(struct mana_port_context *apc)
5041566e7d6SDexuan Cui {
5051566e7d6SDexuan Cui 	struct mana_register_hw_vport_resp resp = {};
5061566e7d6SDexuan Cui 	struct mana_register_hw_vport_req req = {};
5071566e7d6SDexuan Cui 	int err;
5081566e7d6SDexuan Cui 
5091566e7d6SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_REGISTER_HW_PORT,
5101566e7d6SDexuan Cui 			     sizeof(req), sizeof(resp));
5111566e7d6SDexuan Cui 	req.attached_gfid = 1;
5121566e7d6SDexuan Cui 	req.is_pf_default_vport = 1;
5131566e7d6SDexuan Cui 	req.allow_all_ether_types = 1;
5141566e7d6SDexuan Cui 
5151566e7d6SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
5161566e7d6SDexuan Cui 				sizeof(resp));
5171566e7d6SDexuan Cui 	if (err) {
5181566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to register hw vPort: %d\n", err);
5191566e7d6SDexuan Cui 		return err;
5201566e7d6SDexuan Cui 	}
5211566e7d6SDexuan Cui 
5221566e7d6SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_REGISTER_HW_PORT,
5231566e7d6SDexuan Cui 				   sizeof(resp));
5241566e7d6SDexuan Cui 	if (err || resp.hdr.status) {
5251566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to register hw vPort: %d, 0x%x\n",
5261566e7d6SDexuan Cui 			   err, resp.hdr.status);
5271566e7d6SDexuan Cui 		return err ? err : -EPROTO;
5281566e7d6SDexuan Cui 	}
5291566e7d6SDexuan Cui 
5301566e7d6SDexuan Cui 	apc->port_handle = resp.hw_vport_handle;
5311566e7d6SDexuan Cui 	return 0;
5321566e7d6SDexuan Cui }
5331566e7d6SDexuan Cui 
5341566e7d6SDexuan Cui static void mana_pf_deregister_hw_vport(struct mana_port_context *apc)
5351566e7d6SDexuan Cui {
5361566e7d6SDexuan Cui 	struct mana_deregister_hw_vport_resp resp = {};
5371566e7d6SDexuan Cui 	struct mana_deregister_hw_vport_req req = {};
5381566e7d6SDexuan Cui 	int err;
5391566e7d6SDexuan Cui 
5401566e7d6SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_DEREGISTER_HW_PORT,
5411566e7d6SDexuan Cui 			     sizeof(req), sizeof(resp));
5421566e7d6SDexuan Cui 	req.hw_vport_handle = apc->port_handle;
5431566e7d6SDexuan Cui 
5441566e7d6SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
5451566e7d6SDexuan Cui 				sizeof(resp));
5461566e7d6SDexuan Cui 	if (err) {
5471566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to unregister hw vPort: %d\n",
5481566e7d6SDexuan Cui 			   err);
5491566e7d6SDexuan Cui 		return;
5501566e7d6SDexuan Cui 	}
5511566e7d6SDexuan Cui 
5521566e7d6SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_DEREGISTER_HW_PORT,
5531566e7d6SDexuan Cui 				   sizeof(resp));
5541566e7d6SDexuan Cui 	if (err || resp.hdr.status)
5551566e7d6SDexuan Cui 		netdev_err(apc->ndev,
5561566e7d6SDexuan Cui 			   "Failed to deregister hw vPort: %d, 0x%x\n",
5571566e7d6SDexuan Cui 			   err, resp.hdr.status);
5581566e7d6SDexuan Cui }
5591566e7d6SDexuan Cui 
5601566e7d6SDexuan Cui static int mana_pf_register_filter(struct mana_port_context *apc)
5611566e7d6SDexuan Cui {
5621566e7d6SDexuan Cui 	struct mana_register_filter_resp resp = {};
5631566e7d6SDexuan Cui 	struct mana_register_filter_req req = {};
5641566e7d6SDexuan Cui 	int err;
5651566e7d6SDexuan Cui 
5661566e7d6SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_REGISTER_FILTER,
5671566e7d6SDexuan Cui 			     sizeof(req), sizeof(resp));
5681566e7d6SDexuan Cui 	req.vport = apc->port_handle;
5691566e7d6SDexuan Cui 	memcpy(req.mac_addr, apc->mac_addr, ETH_ALEN);
5701566e7d6SDexuan Cui 
5711566e7d6SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
5721566e7d6SDexuan Cui 				sizeof(resp));
5731566e7d6SDexuan Cui 	if (err) {
5741566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to register filter: %d\n", err);
5751566e7d6SDexuan Cui 		return err;
5761566e7d6SDexuan Cui 	}
5771566e7d6SDexuan Cui 
5781566e7d6SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_REGISTER_FILTER,
5791566e7d6SDexuan Cui 				   sizeof(resp));
5801566e7d6SDexuan Cui 	if (err || resp.hdr.status) {
5811566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to register filter: %d, 0x%x\n",
5821566e7d6SDexuan Cui 			   err, resp.hdr.status);
5831566e7d6SDexuan Cui 		return err ? err : -EPROTO;
5841566e7d6SDexuan Cui 	}
5851566e7d6SDexuan Cui 
5861566e7d6SDexuan Cui 	apc->pf_filter_handle = resp.filter_handle;
5871566e7d6SDexuan Cui 	return 0;
5881566e7d6SDexuan Cui }
5891566e7d6SDexuan Cui 
5901566e7d6SDexuan Cui static void mana_pf_deregister_filter(struct mana_port_context *apc)
5911566e7d6SDexuan Cui {
5921566e7d6SDexuan Cui 	struct mana_deregister_filter_resp resp = {};
5931566e7d6SDexuan Cui 	struct mana_deregister_filter_req req = {};
5941566e7d6SDexuan Cui 	int err;
5951566e7d6SDexuan Cui 
5961566e7d6SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_DEREGISTER_FILTER,
5971566e7d6SDexuan Cui 			     sizeof(req), sizeof(resp));
5981566e7d6SDexuan Cui 	req.filter_handle = apc->pf_filter_handle;
5991566e7d6SDexuan Cui 
6001566e7d6SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
6011566e7d6SDexuan Cui 				sizeof(resp));
6021566e7d6SDexuan Cui 	if (err) {
6031566e7d6SDexuan Cui 		netdev_err(apc->ndev, "Failed to unregister filter: %d\n",
6041566e7d6SDexuan Cui 			   err);
6051566e7d6SDexuan Cui 		return;
6061566e7d6SDexuan Cui 	}
6071566e7d6SDexuan Cui 
6081566e7d6SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_DEREGISTER_FILTER,
6091566e7d6SDexuan Cui 				   sizeof(resp));
6101566e7d6SDexuan Cui 	if (err || resp.hdr.status)
6111566e7d6SDexuan Cui 		netdev_err(apc->ndev,
6121566e7d6SDexuan Cui 			   "Failed to deregister filter: %d, 0x%x\n",
6131566e7d6SDexuan Cui 			   err, resp.hdr.status);
6141566e7d6SDexuan Cui }
6151566e7d6SDexuan Cui 
616ca9c54d2SDexuan Cui static int mana_query_device_cfg(struct mana_context *ac, u32 proto_major_ver,
617ca9c54d2SDexuan Cui 				 u32 proto_minor_ver, u32 proto_micro_ver,
618ca9c54d2SDexuan Cui 				 u16 *max_num_vports)
619ca9c54d2SDexuan Cui {
620ca9c54d2SDexuan Cui 	struct gdma_context *gc = ac->gdma_dev->gdma_context;
621ca9c54d2SDexuan Cui 	struct mana_query_device_cfg_resp resp = {};
622ca9c54d2SDexuan Cui 	struct mana_query_device_cfg_req req = {};
623ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
624ca9c54d2SDexuan Cui 	int err = 0;
625ca9c54d2SDexuan Cui 
626ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_QUERY_DEV_CONFIG,
627ca9c54d2SDexuan Cui 			     sizeof(req), sizeof(resp));
628ca9c54d2SDexuan Cui 	req.proto_major_ver = proto_major_ver;
629ca9c54d2SDexuan Cui 	req.proto_minor_ver = proto_minor_ver;
630ca9c54d2SDexuan Cui 	req.proto_micro_ver = proto_micro_ver;
631ca9c54d2SDexuan Cui 
632ca9c54d2SDexuan Cui 	err = mana_send_request(ac, &req, sizeof(req), &resp, sizeof(resp));
633ca9c54d2SDexuan Cui 	if (err) {
634ca9c54d2SDexuan Cui 		dev_err(dev, "Failed to query config: %d", err);
635ca9c54d2SDexuan Cui 		return err;
636ca9c54d2SDexuan Cui 	}
637ca9c54d2SDexuan Cui 
638ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_QUERY_DEV_CONFIG,
639ca9c54d2SDexuan Cui 				   sizeof(resp));
640ca9c54d2SDexuan Cui 	if (err || resp.hdr.status) {
641ca9c54d2SDexuan Cui 		dev_err(dev, "Invalid query result: %d, 0x%x\n", err,
642ca9c54d2SDexuan Cui 			resp.hdr.status);
643ca9c54d2SDexuan Cui 		if (!err)
644ca9c54d2SDexuan Cui 			err = -EPROTO;
645ca9c54d2SDexuan Cui 		return err;
646ca9c54d2SDexuan Cui 	}
647ca9c54d2SDexuan Cui 
648ca9c54d2SDexuan Cui 	*max_num_vports = resp.max_num_vports;
649ca9c54d2SDexuan Cui 
650ca9c54d2SDexuan Cui 	return 0;
651ca9c54d2SDexuan Cui }
652ca9c54d2SDexuan Cui 
653ca9c54d2SDexuan Cui static int mana_query_vport_cfg(struct mana_port_context *apc, u32 vport_index,
654ca9c54d2SDexuan Cui 				u32 *max_sq, u32 *max_rq, u32 *num_indir_entry)
655ca9c54d2SDexuan Cui {
656ca9c54d2SDexuan Cui 	struct mana_query_vport_cfg_resp resp = {};
657ca9c54d2SDexuan Cui 	struct mana_query_vport_cfg_req req = {};
658ca9c54d2SDexuan Cui 	int err;
659ca9c54d2SDexuan Cui 
660ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_QUERY_VPORT_CONFIG,
661ca9c54d2SDexuan Cui 			     sizeof(req), sizeof(resp));
662ca9c54d2SDexuan Cui 
663ca9c54d2SDexuan Cui 	req.vport_index = vport_index;
664ca9c54d2SDexuan Cui 
665ca9c54d2SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
666ca9c54d2SDexuan Cui 				sizeof(resp));
667ca9c54d2SDexuan Cui 	if (err)
668ca9c54d2SDexuan Cui 		return err;
669ca9c54d2SDexuan Cui 
670ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_QUERY_VPORT_CONFIG,
671ca9c54d2SDexuan Cui 				   sizeof(resp));
672ca9c54d2SDexuan Cui 	if (err)
673ca9c54d2SDexuan Cui 		return err;
674ca9c54d2SDexuan Cui 
675ca9c54d2SDexuan Cui 	if (resp.hdr.status)
676ca9c54d2SDexuan Cui 		return -EPROTO;
677ca9c54d2SDexuan Cui 
678ca9c54d2SDexuan Cui 	*max_sq = resp.max_num_sq;
679ca9c54d2SDexuan Cui 	*max_rq = resp.max_num_rq;
680ca9c54d2SDexuan Cui 	*num_indir_entry = resp.num_indirection_ent;
681ca9c54d2SDexuan Cui 
682ca9c54d2SDexuan Cui 	apc->port_handle = resp.vport;
683ca9c54d2SDexuan Cui 	ether_addr_copy(apc->mac_addr, resp.mac_addr);
684ca9c54d2SDexuan Cui 
685ca9c54d2SDexuan Cui 	return 0;
686ca9c54d2SDexuan Cui }
687ca9c54d2SDexuan Cui 
688b5c1c985SLong Li void mana_uncfg_vport(struct mana_port_context *apc)
689b5c1c985SLong Li {
690b5c1c985SLong Li 	mutex_lock(&apc->vport_mutex);
691b5c1c985SLong Li 	apc->vport_use_count--;
692b5c1c985SLong Li 	WARN_ON(apc->vport_use_count < 0);
693b5c1c985SLong Li 	mutex_unlock(&apc->vport_mutex);
694b5c1c985SLong Li }
695b5c1c985SLong Li EXPORT_SYMBOL_NS(mana_uncfg_vport, NET_MANA);
696b5c1c985SLong Li 
697b5c1c985SLong Li int mana_cfg_vport(struct mana_port_context *apc, u32 protection_dom_id,
698ca9c54d2SDexuan Cui 		   u32 doorbell_pg_id)
699ca9c54d2SDexuan Cui {
700ca9c54d2SDexuan Cui 	struct mana_config_vport_resp resp = {};
701ca9c54d2SDexuan Cui 	struct mana_config_vport_req req = {};
702ca9c54d2SDexuan Cui 	int err;
703ca9c54d2SDexuan Cui 
704b5c1c985SLong Li 	/* This function is used to program the Ethernet port in the hardware
705b5c1c985SLong Li 	 * table. It can be called from the Ethernet driver or the RDMA driver.
706b5c1c985SLong Li 	 *
707b5c1c985SLong Li 	 * For Ethernet usage, the hardware supports only one active user on a
708b5c1c985SLong Li 	 * physical port. The driver checks on the port usage before programming
709b5c1c985SLong Li 	 * the hardware when creating the RAW QP (RDMA driver) or exposing the
710b5c1c985SLong Li 	 * device to kernel NET layer (Ethernet driver).
711b5c1c985SLong Li 	 *
712b5c1c985SLong Li 	 * Because the RDMA driver doesn't know in advance which QP type the
713b5c1c985SLong Li 	 * user will create, it exposes the device with all its ports. The user
714b5c1c985SLong Li 	 * may not be able to create RAW QP on a port if this port is already
715b5c1c985SLong Li 	 * in used by the Ethernet driver from the kernel.
716b5c1c985SLong Li 	 *
717b5c1c985SLong Li 	 * This physical port limitation only applies to the RAW QP. For RC QP,
718b5c1c985SLong Li 	 * the hardware doesn't have this limitation. The user can create RC
719b5c1c985SLong Li 	 * QPs on a physical port up to the hardware limits independent of the
720b5c1c985SLong Li 	 * Ethernet usage on the same port.
721b5c1c985SLong Li 	 */
722b5c1c985SLong Li 	mutex_lock(&apc->vport_mutex);
723b5c1c985SLong Li 	if (apc->vport_use_count > 0) {
724b5c1c985SLong Li 		mutex_unlock(&apc->vport_mutex);
725b5c1c985SLong Li 		return -EBUSY;
726b5c1c985SLong Li 	}
727b5c1c985SLong Li 	apc->vport_use_count++;
728b5c1c985SLong Li 	mutex_unlock(&apc->vport_mutex);
729b5c1c985SLong Li 
730ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_CONFIG_VPORT_TX,
731ca9c54d2SDexuan Cui 			     sizeof(req), sizeof(resp));
732ca9c54d2SDexuan Cui 	req.vport = apc->port_handle;
733ca9c54d2SDexuan Cui 	req.pdid = protection_dom_id;
734ca9c54d2SDexuan Cui 	req.doorbell_pageid = doorbell_pg_id;
735ca9c54d2SDexuan Cui 
736ca9c54d2SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
737ca9c54d2SDexuan Cui 				sizeof(resp));
738ca9c54d2SDexuan Cui 	if (err) {
739ca9c54d2SDexuan Cui 		netdev_err(apc->ndev, "Failed to configure vPort: %d\n", err);
740ca9c54d2SDexuan Cui 		goto out;
741ca9c54d2SDexuan Cui 	}
742ca9c54d2SDexuan Cui 
743ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_CONFIG_VPORT_TX,
744ca9c54d2SDexuan Cui 				   sizeof(resp));
745ca9c54d2SDexuan Cui 	if (err || resp.hdr.status) {
746ca9c54d2SDexuan Cui 		netdev_err(apc->ndev, "Failed to configure vPort: %d, 0x%x\n",
747ca9c54d2SDexuan Cui 			   err, resp.hdr.status);
748ca9c54d2SDexuan Cui 		if (!err)
749ca9c54d2SDexuan Cui 			err = -EPROTO;
750ca9c54d2SDexuan Cui 
751ca9c54d2SDexuan Cui 		goto out;
752ca9c54d2SDexuan Cui 	}
753ca9c54d2SDexuan Cui 
754ca9c54d2SDexuan Cui 	apc->tx_shortform_allowed = resp.short_form_allowed;
755ca9c54d2SDexuan Cui 	apc->tx_vp_offset = resp.tx_vport_offset;
756b5c1c985SLong Li 
757b5c1c985SLong Li 	netdev_info(apc->ndev, "Configured vPort %llu PD %u DB %u\n",
758b5c1c985SLong Li 		    apc->port_handle, protection_dom_id, doorbell_pg_id);
759ca9c54d2SDexuan Cui out:
760b5c1c985SLong Li 	if (err)
761b5c1c985SLong Li 		mana_uncfg_vport(apc);
762b5c1c985SLong Li 
763ca9c54d2SDexuan Cui 	return err;
764ca9c54d2SDexuan Cui }
765b5c1c985SLong Li EXPORT_SYMBOL_NS(mana_cfg_vport, NET_MANA);
766ca9c54d2SDexuan Cui 
767ca9c54d2SDexuan Cui static int mana_cfg_vport_steering(struct mana_port_context *apc,
768ca9c54d2SDexuan Cui 				   enum TRI_STATE rx,
769ca9c54d2SDexuan Cui 				   bool update_default_rxobj, bool update_key,
770ca9c54d2SDexuan Cui 				   bool update_tab)
771ca9c54d2SDexuan Cui {
772ca9c54d2SDexuan Cui 	u16 num_entries = MANA_INDIRECT_TABLE_SIZE;
773ca9c54d2SDexuan Cui 	struct mana_cfg_rx_steer_req *req = NULL;
774ca9c54d2SDexuan Cui 	struct mana_cfg_rx_steer_resp resp = {};
775ca9c54d2SDexuan Cui 	struct net_device *ndev = apc->ndev;
776ca9c54d2SDexuan Cui 	mana_handle_t *req_indir_tab;
777ca9c54d2SDexuan Cui 	u32 req_buf_size;
778ca9c54d2SDexuan Cui 	int err;
779ca9c54d2SDexuan Cui 
780ca9c54d2SDexuan Cui 	req_buf_size = sizeof(*req) + sizeof(mana_handle_t) * num_entries;
781ca9c54d2SDexuan Cui 	req = kzalloc(req_buf_size, GFP_KERNEL);
782ca9c54d2SDexuan Cui 	if (!req)
783ca9c54d2SDexuan Cui 		return -ENOMEM;
784ca9c54d2SDexuan Cui 
785ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req->hdr, MANA_CONFIG_VPORT_RX, req_buf_size,
786ca9c54d2SDexuan Cui 			     sizeof(resp));
787ca9c54d2SDexuan Cui 
788ca9c54d2SDexuan Cui 	req->vport = apc->port_handle;
789ca9c54d2SDexuan Cui 	req->num_indir_entries = num_entries;
790ca9c54d2SDexuan Cui 	req->indir_tab_offset = sizeof(*req);
791ca9c54d2SDexuan Cui 	req->rx_enable = rx;
792ca9c54d2SDexuan Cui 	req->rss_enable = apc->rss_state;
793ca9c54d2SDexuan Cui 	req->update_default_rxobj = update_default_rxobj;
794ca9c54d2SDexuan Cui 	req->update_hashkey = update_key;
795ca9c54d2SDexuan Cui 	req->update_indir_tab = update_tab;
796ca9c54d2SDexuan Cui 	req->default_rxobj = apc->default_rxobj;
797ca9c54d2SDexuan Cui 
798ca9c54d2SDexuan Cui 	if (update_key)
799ca9c54d2SDexuan Cui 		memcpy(&req->hashkey, apc->hashkey, MANA_HASH_KEY_SIZE);
800ca9c54d2SDexuan Cui 
801ca9c54d2SDexuan Cui 	if (update_tab) {
802ca9c54d2SDexuan Cui 		req_indir_tab = (mana_handle_t *)(req + 1);
803ca9c54d2SDexuan Cui 		memcpy(req_indir_tab, apc->rxobj_table,
804ca9c54d2SDexuan Cui 		       req->num_indir_entries * sizeof(mana_handle_t));
805ca9c54d2SDexuan Cui 	}
806ca9c54d2SDexuan Cui 
807ca9c54d2SDexuan Cui 	err = mana_send_request(apc->ac, req, req_buf_size, &resp,
808ca9c54d2SDexuan Cui 				sizeof(resp));
809ca9c54d2SDexuan Cui 	if (err) {
810ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to configure vPort RX: %d\n", err);
811ca9c54d2SDexuan Cui 		goto out;
812ca9c54d2SDexuan Cui 	}
813ca9c54d2SDexuan Cui 
814ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_CONFIG_VPORT_RX,
815ca9c54d2SDexuan Cui 				   sizeof(resp));
816ca9c54d2SDexuan Cui 	if (err) {
817ca9c54d2SDexuan Cui 		netdev_err(ndev, "vPort RX configuration failed: %d\n", err);
818ca9c54d2SDexuan Cui 		goto out;
819ca9c54d2SDexuan Cui 	}
820ca9c54d2SDexuan Cui 
821ca9c54d2SDexuan Cui 	if (resp.hdr.status) {
822ca9c54d2SDexuan Cui 		netdev_err(ndev, "vPort RX configuration failed: 0x%x\n",
823ca9c54d2SDexuan Cui 			   resp.hdr.status);
824ca9c54d2SDexuan Cui 		err = -EPROTO;
825ca9c54d2SDexuan Cui 	}
826b5c1c985SLong Li 
827b5c1c985SLong Li 	netdev_info(ndev, "Configured steering vPort %llu entries %u\n",
828b5c1c985SLong Li 		    apc->port_handle, num_entries);
829ca9c54d2SDexuan Cui out:
830ca9c54d2SDexuan Cui 	kfree(req);
831ca9c54d2SDexuan Cui 	return err;
832ca9c54d2SDexuan Cui }
833ca9c54d2SDexuan Cui 
8344c0ff7a1SLong Li int mana_create_wq_obj(struct mana_port_context *apc,
835ca9c54d2SDexuan Cui 		       mana_handle_t vport,
836ca9c54d2SDexuan Cui 		       u32 wq_type, struct mana_obj_spec *wq_spec,
837ca9c54d2SDexuan Cui 		       struct mana_obj_spec *cq_spec,
838ca9c54d2SDexuan Cui 		       mana_handle_t *wq_obj)
839ca9c54d2SDexuan Cui {
840ca9c54d2SDexuan Cui 	struct mana_create_wqobj_resp resp = {};
841ca9c54d2SDexuan Cui 	struct mana_create_wqobj_req req = {};
842ca9c54d2SDexuan Cui 	struct net_device *ndev = apc->ndev;
843ca9c54d2SDexuan Cui 	int err;
844ca9c54d2SDexuan Cui 
845ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_CREATE_WQ_OBJ,
846ca9c54d2SDexuan Cui 			     sizeof(req), sizeof(resp));
847ca9c54d2SDexuan Cui 	req.vport = vport;
848ca9c54d2SDexuan Cui 	req.wq_type = wq_type;
849ca9c54d2SDexuan Cui 	req.wq_gdma_region = wq_spec->gdma_region;
850ca9c54d2SDexuan Cui 	req.cq_gdma_region = cq_spec->gdma_region;
851ca9c54d2SDexuan Cui 	req.wq_size = wq_spec->queue_size;
852ca9c54d2SDexuan Cui 	req.cq_size = cq_spec->queue_size;
853ca9c54d2SDexuan Cui 	req.cq_moderation_ctx_id = cq_spec->modr_ctx_id;
854ca9c54d2SDexuan Cui 	req.cq_parent_qid = cq_spec->attached_eq;
855ca9c54d2SDexuan Cui 
856ca9c54d2SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
857ca9c54d2SDexuan Cui 				sizeof(resp));
858ca9c54d2SDexuan Cui 	if (err) {
859ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to create WQ object: %d\n", err);
860ca9c54d2SDexuan Cui 		goto out;
861ca9c54d2SDexuan Cui 	}
862ca9c54d2SDexuan Cui 
863ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_CREATE_WQ_OBJ,
864ca9c54d2SDexuan Cui 				   sizeof(resp));
865ca9c54d2SDexuan Cui 	if (err || resp.hdr.status) {
866ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to create WQ object: %d, 0x%x\n", err,
867ca9c54d2SDexuan Cui 			   resp.hdr.status);
868ca9c54d2SDexuan Cui 		if (!err)
869ca9c54d2SDexuan Cui 			err = -EPROTO;
870ca9c54d2SDexuan Cui 		goto out;
871ca9c54d2SDexuan Cui 	}
872ca9c54d2SDexuan Cui 
873ca9c54d2SDexuan Cui 	if (resp.wq_obj == INVALID_MANA_HANDLE) {
874ca9c54d2SDexuan Cui 		netdev_err(ndev, "Got an invalid WQ object handle\n");
875ca9c54d2SDexuan Cui 		err = -EPROTO;
876ca9c54d2SDexuan Cui 		goto out;
877ca9c54d2SDexuan Cui 	}
878ca9c54d2SDexuan Cui 
879ca9c54d2SDexuan Cui 	*wq_obj = resp.wq_obj;
880ca9c54d2SDexuan Cui 	wq_spec->queue_index = resp.wq_id;
881ca9c54d2SDexuan Cui 	cq_spec->queue_index = resp.cq_id;
882ca9c54d2SDexuan Cui 
883ca9c54d2SDexuan Cui 	return 0;
884ca9c54d2SDexuan Cui out:
885ca9c54d2SDexuan Cui 	return err;
886ca9c54d2SDexuan Cui }
8874c0ff7a1SLong Li EXPORT_SYMBOL_NS(mana_create_wq_obj, NET_MANA);
888ca9c54d2SDexuan Cui 
8894c0ff7a1SLong Li void mana_destroy_wq_obj(struct mana_port_context *apc, u32 wq_type,
890ca9c54d2SDexuan Cui 			 mana_handle_t wq_obj)
891ca9c54d2SDexuan Cui {
892ca9c54d2SDexuan Cui 	struct mana_destroy_wqobj_resp resp = {};
893ca9c54d2SDexuan Cui 	struct mana_destroy_wqobj_req req = {};
894ca9c54d2SDexuan Cui 	struct net_device *ndev = apc->ndev;
895ca9c54d2SDexuan Cui 	int err;
896ca9c54d2SDexuan Cui 
897ca9c54d2SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_DESTROY_WQ_OBJ,
898ca9c54d2SDexuan Cui 			     sizeof(req), sizeof(resp));
899ca9c54d2SDexuan Cui 	req.wq_type = wq_type;
900ca9c54d2SDexuan Cui 	req.wq_obj_handle = wq_obj;
901ca9c54d2SDexuan Cui 
902ca9c54d2SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
903ca9c54d2SDexuan Cui 				sizeof(resp));
904ca9c54d2SDexuan Cui 	if (err) {
905ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to destroy WQ object: %d\n", err);
906ca9c54d2SDexuan Cui 		return;
907ca9c54d2SDexuan Cui 	}
908ca9c54d2SDexuan Cui 
909ca9c54d2SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_DESTROY_WQ_OBJ,
910ca9c54d2SDexuan Cui 				   sizeof(resp));
911ca9c54d2SDexuan Cui 	if (err || resp.hdr.status)
912ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to destroy WQ object: %d, 0x%x\n", err,
913ca9c54d2SDexuan Cui 			   resp.hdr.status);
914ca9c54d2SDexuan Cui }
9154c0ff7a1SLong Li EXPORT_SYMBOL_NS(mana_destroy_wq_obj, NET_MANA);
916ca9c54d2SDexuan Cui 
9171e2d0824SHaiyang Zhang static void mana_destroy_eq(struct mana_context *ac)
918ca9c54d2SDexuan Cui {
9191e2d0824SHaiyang Zhang 	struct gdma_context *gc = ac->gdma_dev->gdma_context;
920ca9c54d2SDexuan Cui 	struct gdma_queue *eq;
921ca9c54d2SDexuan Cui 	int i;
922ca9c54d2SDexuan Cui 
9231e2d0824SHaiyang Zhang 	if (!ac->eqs)
924ca9c54d2SDexuan Cui 		return;
925ca9c54d2SDexuan Cui 
9261e2d0824SHaiyang Zhang 	for (i = 0; i < gc->max_num_queues; i++) {
9271e2d0824SHaiyang Zhang 		eq = ac->eqs[i].eq;
928ca9c54d2SDexuan Cui 		if (!eq)
929ca9c54d2SDexuan Cui 			continue;
930ca9c54d2SDexuan Cui 
931ca9c54d2SDexuan Cui 		mana_gd_destroy_queue(gc, eq);
932ca9c54d2SDexuan Cui 	}
933ca9c54d2SDexuan Cui 
9341e2d0824SHaiyang Zhang 	kfree(ac->eqs);
9351e2d0824SHaiyang Zhang 	ac->eqs = NULL;
936ca9c54d2SDexuan Cui }
937ca9c54d2SDexuan Cui 
9381e2d0824SHaiyang Zhang static int mana_create_eq(struct mana_context *ac)
939ca9c54d2SDexuan Cui {
9401e2d0824SHaiyang Zhang 	struct gdma_dev *gd = ac->gdma_dev;
9411e2d0824SHaiyang Zhang 	struct gdma_context *gc = gd->gdma_context;
942ca9c54d2SDexuan Cui 	struct gdma_queue_spec spec = {};
943ca9c54d2SDexuan Cui 	int err;
944ca9c54d2SDexuan Cui 	int i;
945ca9c54d2SDexuan Cui 
9461e2d0824SHaiyang Zhang 	ac->eqs = kcalloc(gc->max_num_queues, sizeof(struct mana_eq),
947ca9c54d2SDexuan Cui 			  GFP_KERNEL);
9481e2d0824SHaiyang Zhang 	if (!ac->eqs)
949ca9c54d2SDexuan Cui 		return -ENOMEM;
950ca9c54d2SDexuan Cui 
951ca9c54d2SDexuan Cui 	spec.type = GDMA_EQ;
952ca9c54d2SDexuan Cui 	spec.monitor_avl_buf = false;
953ca9c54d2SDexuan Cui 	spec.queue_size = EQ_SIZE;
954ca9c54d2SDexuan Cui 	spec.eq.callback = NULL;
9551e2d0824SHaiyang Zhang 	spec.eq.context = ac->eqs;
956ca9c54d2SDexuan Cui 	spec.eq.log2_throttle_limit = LOG2_EQ_THROTTLE;
957ca9c54d2SDexuan Cui 
9581e2d0824SHaiyang Zhang 	for (i = 0; i < gc->max_num_queues; i++) {
9591e2d0824SHaiyang Zhang 		err = mana_gd_create_mana_eq(gd, &spec, &ac->eqs[i].eq);
960ca9c54d2SDexuan Cui 		if (err)
961ca9c54d2SDexuan Cui 			goto out;
962ca9c54d2SDexuan Cui 	}
963ca9c54d2SDexuan Cui 
964ca9c54d2SDexuan Cui 	return 0;
965ca9c54d2SDexuan Cui out:
9661e2d0824SHaiyang Zhang 	mana_destroy_eq(ac);
967ca9c54d2SDexuan Cui 	return err;
968ca9c54d2SDexuan Cui }
969ca9c54d2SDexuan Cui 
9706cc74443SDexuan Cui static int mana_fence_rq(struct mana_port_context *apc, struct mana_rxq *rxq)
9716cc74443SDexuan Cui {
9726cc74443SDexuan Cui 	struct mana_fence_rq_resp resp = {};
9736cc74443SDexuan Cui 	struct mana_fence_rq_req req = {};
9746cc74443SDexuan Cui 	int err;
9756cc74443SDexuan Cui 
9766cc74443SDexuan Cui 	init_completion(&rxq->fence_event);
9776cc74443SDexuan Cui 
9786cc74443SDexuan Cui 	mana_gd_init_req_hdr(&req.hdr, MANA_FENCE_RQ,
9796cc74443SDexuan Cui 			     sizeof(req), sizeof(resp));
9806cc74443SDexuan Cui 	req.wq_obj_handle =  rxq->rxobj;
9816cc74443SDexuan Cui 
9826cc74443SDexuan Cui 	err = mana_send_request(apc->ac, &req, sizeof(req), &resp,
9836cc74443SDexuan Cui 				sizeof(resp));
9846cc74443SDexuan Cui 	if (err) {
9856cc74443SDexuan Cui 		netdev_err(apc->ndev, "Failed to fence RQ %u: %d\n",
9866cc74443SDexuan Cui 			   rxq->rxq_idx, err);
9876cc74443SDexuan Cui 		return err;
9886cc74443SDexuan Cui 	}
9896cc74443SDexuan Cui 
9906cc74443SDexuan Cui 	err = mana_verify_resp_hdr(&resp.hdr, MANA_FENCE_RQ, sizeof(resp));
9916cc74443SDexuan Cui 	if (err || resp.hdr.status) {
9926cc74443SDexuan Cui 		netdev_err(apc->ndev, "Failed to fence RQ %u: %d, 0x%x\n",
9936cc74443SDexuan Cui 			   rxq->rxq_idx, err, resp.hdr.status);
9946cc74443SDexuan Cui 		if (!err)
9956cc74443SDexuan Cui 			err = -EPROTO;
9966cc74443SDexuan Cui 
9976cc74443SDexuan Cui 		return err;
9986cc74443SDexuan Cui 	}
9996cc74443SDexuan Cui 
10006cc74443SDexuan Cui 	if (wait_for_completion_timeout(&rxq->fence_event, 10 * HZ) == 0) {
10016cc74443SDexuan Cui 		netdev_err(apc->ndev, "Failed to fence RQ %u: timed out\n",
10026cc74443SDexuan Cui 			   rxq->rxq_idx);
10036cc74443SDexuan Cui 		return -ETIMEDOUT;
10046cc74443SDexuan Cui 	}
10056cc74443SDexuan Cui 
10066cc74443SDexuan Cui 	return 0;
10076cc74443SDexuan Cui }
10086cc74443SDexuan Cui 
10096cc74443SDexuan Cui static void mana_fence_rqs(struct mana_port_context *apc)
10106cc74443SDexuan Cui {
10116cc74443SDexuan Cui 	unsigned int rxq_idx;
10126cc74443SDexuan Cui 	struct mana_rxq *rxq;
10136cc74443SDexuan Cui 	int err;
10146cc74443SDexuan Cui 
10156cc74443SDexuan Cui 	for (rxq_idx = 0; rxq_idx < apc->num_queues; rxq_idx++) {
10166cc74443SDexuan Cui 		rxq = apc->rxqs[rxq_idx];
10176cc74443SDexuan Cui 		err = mana_fence_rq(apc, rxq);
10186cc74443SDexuan Cui 
10196cc74443SDexuan Cui 		/* In case of any error, use sleep instead. */
10206cc74443SDexuan Cui 		if (err)
10216cc74443SDexuan Cui 			msleep(100);
10226cc74443SDexuan Cui 	}
10236cc74443SDexuan Cui }
10246cc74443SDexuan Cui 
1025ca9c54d2SDexuan Cui static int mana_move_wq_tail(struct gdma_queue *wq, u32 num_units)
1026ca9c54d2SDexuan Cui {
1027ca9c54d2SDexuan Cui 	u32 used_space_old;
1028ca9c54d2SDexuan Cui 	u32 used_space_new;
1029ca9c54d2SDexuan Cui 
1030ca9c54d2SDexuan Cui 	used_space_old = wq->head - wq->tail;
1031ca9c54d2SDexuan Cui 	used_space_new = wq->head - (wq->tail + num_units);
1032ca9c54d2SDexuan Cui 
1033ca9c54d2SDexuan Cui 	if (WARN_ON_ONCE(used_space_new > used_space_old))
1034ca9c54d2SDexuan Cui 		return -ERANGE;
1035ca9c54d2SDexuan Cui 
1036ca9c54d2SDexuan Cui 	wq->tail += num_units;
1037ca9c54d2SDexuan Cui 	return 0;
1038ca9c54d2SDexuan Cui }
1039ca9c54d2SDexuan Cui 
1040ca9c54d2SDexuan Cui static void mana_unmap_skb(struct sk_buff *skb, struct mana_port_context *apc)
1041ca9c54d2SDexuan Cui {
1042ca9c54d2SDexuan Cui 	struct mana_skb_head *ash = (struct mana_skb_head *)skb->head;
1043ca9c54d2SDexuan Cui 	struct gdma_context *gc = apc->ac->gdma_dev->gdma_context;
1044ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
1045ca9c54d2SDexuan Cui 	int i;
1046ca9c54d2SDexuan Cui 
1047ca9c54d2SDexuan Cui 	dma_unmap_single(dev, ash->dma_handle[0], ash->size[0], DMA_TO_DEVICE);
1048ca9c54d2SDexuan Cui 
1049ca9c54d2SDexuan Cui 	for (i = 1; i < skb_shinfo(skb)->nr_frags + 1; i++)
1050ca9c54d2SDexuan Cui 		dma_unmap_page(dev, ash->dma_handle[i], ash->size[i],
1051ca9c54d2SDexuan Cui 			       DMA_TO_DEVICE);
1052ca9c54d2SDexuan Cui }
1053ca9c54d2SDexuan Cui 
1054ca9c54d2SDexuan Cui static void mana_poll_tx_cq(struct mana_cq *cq)
1055ca9c54d2SDexuan Cui {
1056ca9c54d2SDexuan Cui 	struct gdma_comp *completions = cq->gdma_comp_buf;
1057ca9c54d2SDexuan Cui 	struct gdma_posted_wqe_info *wqe_info;
1058ca9c54d2SDexuan Cui 	unsigned int pkt_transmitted = 0;
1059ca9c54d2SDexuan Cui 	unsigned int wqe_unit_cnt = 0;
1060ca9c54d2SDexuan Cui 	struct mana_txq *txq = cq->txq;
1061ca9c54d2SDexuan Cui 	struct mana_port_context *apc;
1062ca9c54d2SDexuan Cui 	struct netdev_queue *net_txq;
1063ca9c54d2SDexuan Cui 	struct gdma_queue *gdma_wq;
1064ca9c54d2SDexuan Cui 	unsigned int avail_space;
1065ca9c54d2SDexuan Cui 	struct net_device *ndev;
1066ca9c54d2SDexuan Cui 	struct sk_buff *skb;
1067ca9c54d2SDexuan Cui 	bool txq_stopped;
1068ca9c54d2SDexuan Cui 	int comp_read;
1069ca9c54d2SDexuan Cui 	int i;
1070ca9c54d2SDexuan Cui 
1071ca9c54d2SDexuan Cui 	ndev = txq->ndev;
1072ca9c54d2SDexuan Cui 	apc = netdev_priv(ndev);
1073ca9c54d2SDexuan Cui 
1074ca9c54d2SDexuan Cui 	comp_read = mana_gd_poll_cq(cq->gdma_cq, completions,
1075ca9c54d2SDexuan Cui 				    CQE_POLLING_BUFFER);
1076ca9c54d2SDexuan Cui 
1077e1b5683fSHaiyang Zhang 	if (comp_read < 1)
1078e1b5683fSHaiyang Zhang 		return;
1079e1b5683fSHaiyang Zhang 
1080bd7fc6e1SShradha Gupta 	apc->eth_stats.tx_cqes = comp_read;
1081bd7fc6e1SShradha Gupta 
1082ca9c54d2SDexuan Cui 	for (i = 0; i < comp_read; i++) {
1083ca9c54d2SDexuan Cui 		struct mana_tx_comp_oob *cqe_oob;
1084ca9c54d2SDexuan Cui 
1085ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(!completions[i].is_sq))
1086ca9c54d2SDexuan Cui 			return;
1087ca9c54d2SDexuan Cui 
1088ca9c54d2SDexuan Cui 		cqe_oob = (struct mana_tx_comp_oob *)completions[i].cqe_data;
1089ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(cqe_oob->cqe_hdr.client_type !=
1090ca9c54d2SDexuan Cui 				 MANA_CQE_COMPLETION))
1091ca9c54d2SDexuan Cui 			return;
1092ca9c54d2SDexuan Cui 
1093ca9c54d2SDexuan Cui 		switch (cqe_oob->cqe_hdr.cqe_type) {
1094ca9c54d2SDexuan Cui 		case CQE_TX_OKAY:
1095ca9c54d2SDexuan Cui 			break;
1096ca9c54d2SDexuan Cui 
1097ca9c54d2SDexuan Cui 		case CQE_TX_SA_DROP:
1098ca9c54d2SDexuan Cui 		case CQE_TX_MTU_DROP:
1099ca9c54d2SDexuan Cui 		case CQE_TX_INVALID_OOB:
1100ca9c54d2SDexuan Cui 		case CQE_TX_INVALID_ETH_TYPE:
1101ca9c54d2SDexuan Cui 		case CQE_TX_HDR_PROCESSING_ERROR:
1102ca9c54d2SDexuan Cui 		case CQE_TX_VF_DISABLED:
1103ca9c54d2SDexuan Cui 		case CQE_TX_VPORT_IDX_OUT_OF_RANGE:
1104ca9c54d2SDexuan Cui 		case CQE_TX_VPORT_DISABLED:
1105ca9c54d2SDexuan Cui 		case CQE_TX_VLAN_TAGGING_VIOLATION:
1106ca9c54d2SDexuan Cui 			WARN_ONCE(1, "TX: CQE error %d: ignored.\n",
1107ca9c54d2SDexuan Cui 				  cqe_oob->cqe_hdr.cqe_type);
1108bd7fc6e1SShradha Gupta 			apc->eth_stats.tx_cqe_err++;
1109ca9c54d2SDexuan Cui 			break;
1110ca9c54d2SDexuan Cui 
1111ca9c54d2SDexuan Cui 		default:
1112ca9c54d2SDexuan Cui 			/* If the CQE type is unexpected, log an error, assert,
1113ca9c54d2SDexuan Cui 			 * and go through the error path.
1114ca9c54d2SDexuan Cui 			 */
1115ca9c54d2SDexuan Cui 			WARN_ONCE(1, "TX: Unexpected CQE type %d: HW BUG?\n",
1116ca9c54d2SDexuan Cui 				  cqe_oob->cqe_hdr.cqe_type);
1117bd7fc6e1SShradha Gupta 			apc->eth_stats.tx_cqe_unknown_type++;
1118ca9c54d2SDexuan Cui 			return;
1119ca9c54d2SDexuan Cui 		}
1120ca9c54d2SDexuan Cui 
1121ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(txq->gdma_txq_id != completions[i].wq_num))
1122ca9c54d2SDexuan Cui 			return;
1123ca9c54d2SDexuan Cui 
1124ca9c54d2SDexuan Cui 		skb = skb_dequeue(&txq->pending_skbs);
1125ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(!skb))
1126ca9c54d2SDexuan Cui 			return;
1127ca9c54d2SDexuan Cui 
1128ca9c54d2SDexuan Cui 		wqe_info = (struct gdma_posted_wqe_info *)skb->cb;
1129ca9c54d2SDexuan Cui 		wqe_unit_cnt += wqe_info->wqe_size_in_bu;
1130ca9c54d2SDexuan Cui 
1131ca9c54d2SDexuan Cui 		mana_unmap_skb(skb, apc);
1132ca9c54d2SDexuan Cui 
1133e1b5683fSHaiyang Zhang 		napi_consume_skb(skb, cq->budget);
1134ca9c54d2SDexuan Cui 
1135ca9c54d2SDexuan Cui 		pkt_transmitted++;
1136ca9c54d2SDexuan Cui 	}
1137ca9c54d2SDexuan Cui 
1138ca9c54d2SDexuan Cui 	if (WARN_ON_ONCE(wqe_unit_cnt == 0))
1139ca9c54d2SDexuan Cui 		return;
1140ca9c54d2SDexuan Cui 
1141ca9c54d2SDexuan Cui 	mana_move_wq_tail(txq->gdma_sq, wqe_unit_cnt);
1142ca9c54d2SDexuan Cui 
1143ca9c54d2SDexuan Cui 	gdma_wq = txq->gdma_sq;
1144ca9c54d2SDexuan Cui 	avail_space = mana_gd_wq_avail_space(gdma_wq);
1145ca9c54d2SDexuan Cui 
1146ca9c54d2SDexuan Cui 	/* Ensure tail updated before checking q stop */
1147ca9c54d2SDexuan Cui 	smp_mb();
1148ca9c54d2SDexuan Cui 
1149ca9c54d2SDexuan Cui 	net_txq = txq->net_txq;
1150ca9c54d2SDexuan Cui 	txq_stopped = netif_tx_queue_stopped(net_txq);
1151ca9c54d2SDexuan Cui 
1152ca9c54d2SDexuan Cui 	/* Ensure checking txq_stopped before apc->port_is_up. */
1153ca9c54d2SDexuan Cui 	smp_rmb();
1154ca9c54d2SDexuan Cui 
1155ca9c54d2SDexuan Cui 	if (txq_stopped && apc->port_is_up && avail_space >= MAX_TX_WQE_SIZE) {
1156ca9c54d2SDexuan Cui 		netif_tx_wake_queue(net_txq);
1157ca9c54d2SDexuan Cui 		apc->eth_stats.wake_queue++;
1158ca9c54d2SDexuan Cui 	}
1159ca9c54d2SDexuan Cui 
1160ca9c54d2SDexuan Cui 	if (atomic_sub_return(pkt_transmitted, &txq->pending_sends) < 0)
1161ca9c54d2SDexuan Cui 		WARN_ON_ONCE(1);
1162e1b5683fSHaiyang Zhang 
1163e1b5683fSHaiyang Zhang 	cq->work_done = pkt_transmitted;
1164bd7fc6e1SShradha Gupta 
1165bd7fc6e1SShradha Gupta 	apc->eth_stats.tx_cqes -= pkt_transmitted;
1166ca9c54d2SDexuan Cui }
1167ca9c54d2SDexuan Cui 
1168ca9c54d2SDexuan Cui static void mana_post_pkt_rxq(struct mana_rxq *rxq)
1169ca9c54d2SDexuan Cui {
1170ca9c54d2SDexuan Cui 	struct mana_recv_buf_oob *recv_buf_oob;
1171ca9c54d2SDexuan Cui 	u32 curr_index;
1172ca9c54d2SDexuan Cui 	int err;
1173ca9c54d2SDexuan Cui 
1174ca9c54d2SDexuan Cui 	curr_index = rxq->buf_index++;
1175ca9c54d2SDexuan Cui 	if (rxq->buf_index == rxq->num_rx_buf)
1176ca9c54d2SDexuan Cui 		rxq->buf_index = 0;
1177ca9c54d2SDexuan Cui 
1178ca9c54d2SDexuan Cui 	recv_buf_oob = &rxq->rx_oobs[curr_index];
1179ca9c54d2SDexuan Cui 
1180ca9c54d2SDexuan Cui 	err = mana_gd_post_and_ring(rxq->gdma_rq, &recv_buf_oob->wqe_req,
1181ca9c54d2SDexuan Cui 				    &recv_buf_oob->wqe_inf);
1182ca9c54d2SDexuan Cui 	if (WARN_ON_ONCE(err))
1183ca9c54d2SDexuan Cui 		return;
1184ca9c54d2SDexuan Cui 
1185ca9c54d2SDexuan Cui 	WARN_ON_ONCE(recv_buf_oob->wqe_inf.wqe_size_in_bu != 1);
1186ca9c54d2SDexuan Cui }
1187ca9c54d2SDexuan Cui 
1188*2fbbd712SHaiyang Zhang static struct sk_buff *mana_build_skb(struct mana_rxq *rxq, void *buf_va,
1189*2fbbd712SHaiyang Zhang 				      uint pkt_len, struct xdp_buff *xdp)
1190ed5356b5SHaiyang Zhang {
1191*2fbbd712SHaiyang Zhang 	struct sk_buff *skb = napi_build_skb(buf_va, rxq->alloc_size);
1192ed5356b5SHaiyang Zhang 
1193ed5356b5SHaiyang Zhang 	if (!skb)
1194ed5356b5SHaiyang Zhang 		return NULL;
1195ed5356b5SHaiyang Zhang 
1196ed5356b5SHaiyang Zhang 	if (xdp->data_hard_start) {
1197ed5356b5SHaiyang Zhang 		skb_reserve(skb, xdp->data - xdp->data_hard_start);
1198ed5356b5SHaiyang Zhang 		skb_put(skb, xdp->data_end - xdp->data);
1199*2fbbd712SHaiyang Zhang 		return skb;
1200ed5356b5SHaiyang Zhang 	}
1201ed5356b5SHaiyang Zhang 
1202*2fbbd712SHaiyang Zhang 	skb_reserve(skb, rxq->headroom);
1203*2fbbd712SHaiyang Zhang 	skb_put(skb, pkt_len);
1204*2fbbd712SHaiyang Zhang 
1205ed5356b5SHaiyang Zhang 	return skb;
1206ed5356b5SHaiyang Zhang }
1207ed5356b5SHaiyang Zhang 
1208ca9c54d2SDexuan Cui static void mana_rx_skb(void *buf_va, struct mana_rxcomp_oob *cqe,
1209ca9c54d2SDexuan Cui 			struct mana_rxq *rxq)
1210ca9c54d2SDexuan Cui {
1211f90f8420SHaiyang Zhang 	struct mana_stats_rx *rx_stats = &rxq->stats;
1212ca9c54d2SDexuan Cui 	struct net_device *ndev = rxq->ndev;
1213ca9c54d2SDexuan Cui 	uint pkt_len = cqe->ppi[0].pkt_len;
1214ca9c54d2SDexuan Cui 	u16 rxq_idx = rxq->rxq_idx;
1215ca9c54d2SDexuan Cui 	struct napi_struct *napi;
1216ed5356b5SHaiyang Zhang 	struct xdp_buff xdp = {};
1217ca9c54d2SDexuan Cui 	struct sk_buff *skb;
1218ca9c54d2SDexuan Cui 	u32 hash_value;
1219ed5356b5SHaiyang Zhang 	u32 act;
1220ca9c54d2SDexuan Cui 
1221e1b5683fSHaiyang Zhang 	rxq->rx_cq.work_done++;
1222e1b5683fSHaiyang Zhang 	napi = &rxq->rx_cq.napi;
1223ca9c54d2SDexuan Cui 
1224ca9c54d2SDexuan Cui 	if (!buf_va) {
1225ca9c54d2SDexuan Cui 		++ndev->stats.rx_dropped;
1226ca9c54d2SDexuan Cui 		return;
1227ca9c54d2SDexuan Cui 	}
1228ca9c54d2SDexuan Cui 
1229ed5356b5SHaiyang Zhang 	act = mana_run_xdp(ndev, rxq, &xdp, buf_va, pkt_len);
1230ca9c54d2SDexuan Cui 
12317a8938cdSHaiyang Zhang 	if (act == XDP_REDIRECT && !rxq->xdp_rc)
12327a8938cdSHaiyang Zhang 		return;
12337a8938cdSHaiyang Zhang 
1234ed5356b5SHaiyang Zhang 	if (act != XDP_PASS && act != XDP_TX)
1235f90f8420SHaiyang Zhang 		goto drop_xdp;
1236ca9c54d2SDexuan Cui 
1237*2fbbd712SHaiyang Zhang 	skb = mana_build_skb(rxq, buf_va, pkt_len, &xdp);
1238ed5356b5SHaiyang Zhang 
1239ed5356b5SHaiyang Zhang 	if (!skb)
1240ed5356b5SHaiyang Zhang 		goto drop;
1241ed5356b5SHaiyang Zhang 
1242ca9c54d2SDexuan Cui 	skb->dev = napi->dev;
1243ca9c54d2SDexuan Cui 
1244ca9c54d2SDexuan Cui 	skb->protocol = eth_type_trans(skb, ndev);
1245ca9c54d2SDexuan Cui 	skb_checksum_none_assert(skb);
1246ca9c54d2SDexuan Cui 	skb_record_rx_queue(skb, rxq_idx);
1247ca9c54d2SDexuan Cui 
1248ca9c54d2SDexuan Cui 	if ((ndev->features & NETIF_F_RXCSUM) && cqe->rx_iphdr_csum_succeed) {
1249ca9c54d2SDexuan Cui 		if (cqe->rx_tcp_csum_succeed || cqe->rx_udp_csum_succeed)
1250ca9c54d2SDexuan Cui 			skb->ip_summed = CHECKSUM_UNNECESSARY;
1251ca9c54d2SDexuan Cui 	}
1252ca9c54d2SDexuan Cui 
1253ca9c54d2SDexuan Cui 	if (cqe->rx_hashtype != 0 && (ndev->features & NETIF_F_RXHASH)) {
1254ca9c54d2SDexuan Cui 		hash_value = cqe->ppi[0].pkt_hash;
1255ca9c54d2SDexuan Cui 
1256ca9c54d2SDexuan Cui 		if (cqe->rx_hashtype & MANA_HASH_L4)
1257ca9c54d2SDexuan Cui 			skb_set_hash(skb, hash_value, PKT_HASH_TYPE_L4);
1258ca9c54d2SDexuan Cui 		else
1259ca9c54d2SDexuan Cui 			skb_set_hash(skb, hash_value, PKT_HASH_TYPE_L3);
1260ca9c54d2SDexuan Cui 	}
1261ca9c54d2SDexuan Cui 
1262d356abb9SHaiyang Zhang 	u64_stats_update_begin(&rx_stats->syncp);
1263d356abb9SHaiyang Zhang 	rx_stats->packets++;
1264d356abb9SHaiyang Zhang 	rx_stats->bytes += pkt_len;
1265d356abb9SHaiyang Zhang 
1266d356abb9SHaiyang Zhang 	if (act == XDP_TX)
1267d356abb9SHaiyang Zhang 		rx_stats->xdp_tx++;
1268d356abb9SHaiyang Zhang 	u64_stats_update_end(&rx_stats->syncp);
1269d356abb9SHaiyang Zhang 
1270ed5356b5SHaiyang Zhang 	if (act == XDP_TX) {
1271ed5356b5SHaiyang Zhang 		skb_set_queue_mapping(skb, rxq_idx);
1272ed5356b5SHaiyang Zhang 		mana_xdp_tx(skb, ndev);
1273ed5356b5SHaiyang Zhang 		return;
1274ed5356b5SHaiyang Zhang 	}
1275ed5356b5SHaiyang Zhang 
1276ca9c54d2SDexuan Cui 	napi_gro_receive(napi, skb);
1277ca9c54d2SDexuan Cui 
1278ed5356b5SHaiyang Zhang 	return;
1279ed5356b5SHaiyang Zhang 
1280f90f8420SHaiyang Zhang drop_xdp:
1281f90f8420SHaiyang Zhang 	u64_stats_update_begin(&rx_stats->syncp);
1282f90f8420SHaiyang Zhang 	rx_stats->xdp_drop++;
1283f90f8420SHaiyang Zhang 	u64_stats_update_end(&rx_stats->syncp);
1284f90f8420SHaiyang Zhang 
1285ed5356b5SHaiyang Zhang drop:
1286a2917b23SHaiyang Zhang 	WARN_ON_ONCE(rxq->xdp_save_va);
1287a2917b23SHaiyang Zhang 	/* Save for reuse */
1288a2917b23SHaiyang Zhang 	rxq->xdp_save_va = buf_va;
1289a6bf5703SHaiyang Zhang 
1290ed5356b5SHaiyang Zhang 	++ndev->stats.rx_dropped;
1291f90f8420SHaiyang Zhang 
1292ed5356b5SHaiyang Zhang 	return;
1293ca9c54d2SDexuan Cui }
1294ca9c54d2SDexuan Cui 
1295a2917b23SHaiyang Zhang static void *mana_get_rxfrag(struct mana_rxq *rxq, struct device *dev,
1296a2917b23SHaiyang Zhang 			     dma_addr_t *da, bool is_napi)
1297a2917b23SHaiyang Zhang {
1298a2917b23SHaiyang Zhang 	struct page *page;
1299a2917b23SHaiyang Zhang 	void *va;
1300a2917b23SHaiyang Zhang 
1301a2917b23SHaiyang Zhang 	/* Reuse XDP dropped page if available */
1302a2917b23SHaiyang Zhang 	if (rxq->xdp_save_va) {
1303a2917b23SHaiyang Zhang 		va = rxq->xdp_save_va;
1304a2917b23SHaiyang Zhang 		rxq->xdp_save_va = NULL;
1305*2fbbd712SHaiyang Zhang 	} else if (rxq->alloc_size > PAGE_SIZE) {
1306*2fbbd712SHaiyang Zhang 		if (is_napi)
1307*2fbbd712SHaiyang Zhang 			va = napi_alloc_frag(rxq->alloc_size);
1308*2fbbd712SHaiyang Zhang 		else
1309*2fbbd712SHaiyang Zhang 			va = netdev_alloc_frag(rxq->alloc_size);
1310*2fbbd712SHaiyang Zhang 
1311*2fbbd712SHaiyang Zhang 		if (!va)
1312*2fbbd712SHaiyang Zhang 			return NULL;
1313a2917b23SHaiyang Zhang 	} else {
1314a2917b23SHaiyang Zhang 		page = dev_alloc_page();
1315a2917b23SHaiyang Zhang 		if (!page)
1316a2917b23SHaiyang Zhang 			return NULL;
1317a2917b23SHaiyang Zhang 
1318a2917b23SHaiyang Zhang 		va = page_to_virt(page);
1319a2917b23SHaiyang Zhang 	}
1320a2917b23SHaiyang Zhang 
1321*2fbbd712SHaiyang Zhang 	*da = dma_map_single(dev, va + rxq->headroom, rxq->datasize,
1322a2917b23SHaiyang Zhang 			     DMA_FROM_DEVICE);
1323a2917b23SHaiyang Zhang 
1324a2917b23SHaiyang Zhang 	if (dma_mapping_error(dev, *da)) {
1325a2917b23SHaiyang Zhang 		put_page(virt_to_head_page(va));
1326a2917b23SHaiyang Zhang 		return NULL;
1327a2917b23SHaiyang Zhang 	}
1328a2917b23SHaiyang Zhang 
1329a2917b23SHaiyang Zhang 	return va;
1330a2917b23SHaiyang Zhang }
1331a2917b23SHaiyang Zhang 
1332a2917b23SHaiyang Zhang /* Allocate frag for rx buffer, and save the old buf */
1333a2917b23SHaiyang Zhang static void mana_refill_rxoob(struct device *dev, struct mana_rxq *rxq,
1334a2917b23SHaiyang Zhang 			      struct mana_recv_buf_oob *rxoob, void **old_buf)
1335a2917b23SHaiyang Zhang {
1336a2917b23SHaiyang Zhang 	dma_addr_t da;
1337a2917b23SHaiyang Zhang 	void *va;
1338a2917b23SHaiyang Zhang 
1339a2917b23SHaiyang Zhang 	va = mana_get_rxfrag(rxq, dev, &da, true);
1340a2917b23SHaiyang Zhang 
1341a2917b23SHaiyang Zhang 	if (!va)
1342a2917b23SHaiyang Zhang 		return;
1343a2917b23SHaiyang Zhang 
1344a2917b23SHaiyang Zhang 	dma_unmap_single(dev, rxoob->sgl[0].address, rxq->datasize,
1345a2917b23SHaiyang Zhang 			 DMA_FROM_DEVICE);
1346a2917b23SHaiyang Zhang 	*old_buf = rxoob->buf_va;
1347a2917b23SHaiyang Zhang 
1348a2917b23SHaiyang Zhang 	rxoob->buf_va = va;
1349a2917b23SHaiyang Zhang 	rxoob->sgl[0].address = da;
1350a2917b23SHaiyang Zhang }
1351a2917b23SHaiyang Zhang 
1352ca9c54d2SDexuan Cui static void mana_process_rx_cqe(struct mana_rxq *rxq, struct mana_cq *cq,
1353ca9c54d2SDexuan Cui 				struct gdma_comp *cqe)
1354ca9c54d2SDexuan Cui {
1355ca9c54d2SDexuan Cui 	struct mana_rxcomp_oob *oob = (struct mana_rxcomp_oob *)cqe->cqe_data;
1356ca9c54d2SDexuan Cui 	struct gdma_context *gc = rxq->gdma_rq->gdma_dev->gdma_context;
1357ca9c54d2SDexuan Cui 	struct net_device *ndev = rxq->ndev;
1358ca9c54d2SDexuan Cui 	struct mana_recv_buf_oob *rxbuf_oob;
1359bd7fc6e1SShradha Gupta 	struct mana_port_context *apc;
1360ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
1361a2917b23SHaiyang Zhang 	void *old_buf = NULL;
1362ca9c54d2SDexuan Cui 	u32 curr, pktlen;
1363ca9c54d2SDexuan Cui 
1364bd7fc6e1SShradha Gupta 	apc = netdev_priv(ndev);
1365bd7fc6e1SShradha Gupta 
1366ca9c54d2SDexuan Cui 	switch (oob->cqe_hdr.cqe_type) {
1367ca9c54d2SDexuan Cui 	case CQE_RX_OKAY:
1368ca9c54d2SDexuan Cui 		break;
1369ca9c54d2SDexuan Cui 
1370ca9c54d2SDexuan Cui 	case CQE_RX_TRUNCATED:
1371e4b76219SHaiyang Zhang 		++ndev->stats.rx_dropped;
1372e4b76219SHaiyang Zhang 		rxbuf_oob = &rxq->rx_oobs[rxq->buf_index];
1373e4b76219SHaiyang Zhang 		netdev_warn_once(ndev, "Dropped a truncated packet\n");
1374e4b76219SHaiyang Zhang 		goto drop;
1375ca9c54d2SDexuan Cui 
1376ca9c54d2SDexuan Cui 	case CQE_RX_COALESCED_4:
1377ca9c54d2SDexuan Cui 		netdev_err(ndev, "RX coalescing is unsupported\n");
1378bd7fc6e1SShradha Gupta 		apc->eth_stats.rx_coalesced_err++;
1379ca9c54d2SDexuan Cui 		return;
1380ca9c54d2SDexuan Cui 
1381ca9c54d2SDexuan Cui 	case CQE_RX_OBJECT_FENCE:
13826cc74443SDexuan Cui 		complete(&rxq->fence_event);
1383ca9c54d2SDexuan Cui 		return;
1384ca9c54d2SDexuan Cui 
1385ca9c54d2SDexuan Cui 	default:
1386ca9c54d2SDexuan Cui 		netdev_err(ndev, "Unknown RX CQE type = %d\n",
1387ca9c54d2SDexuan Cui 			   oob->cqe_hdr.cqe_type);
1388bd7fc6e1SShradha Gupta 		apc->eth_stats.rx_cqe_unknown_type++;
1389ca9c54d2SDexuan Cui 		return;
1390ca9c54d2SDexuan Cui 	}
1391ca9c54d2SDexuan Cui 
1392ca9c54d2SDexuan Cui 	pktlen = oob->ppi[0].pkt_len;
1393ca9c54d2SDexuan Cui 
1394ca9c54d2SDexuan Cui 	if (pktlen == 0) {
1395ca9c54d2SDexuan Cui 		/* data packets should never have packetlength of zero */
1396ca9c54d2SDexuan Cui 		netdev_err(ndev, "RX pkt len=0, rq=%u, cq=%u, rxobj=0x%llx\n",
1397ca9c54d2SDexuan Cui 			   rxq->gdma_id, cq->gdma_id, rxq->rxobj);
1398ca9c54d2SDexuan Cui 		return;
1399ca9c54d2SDexuan Cui 	}
1400ca9c54d2SDexuan Cui 
1401ca9c54d2SDexuan Cui 	curr = rxq->buf_index;
1402ca9c54d2SDexuan Cui 	rxbuf_oob = &rxq->rx_oobs[curr];
1403ca9c54d2SDexuan Cui 	WARN_ON_ONCE(rxbuf_oob->wqe_inf.wqe_size_in_bu != 1);
1404ca9c54d2SDexuan Cui 
1405a2917b23SHaiyang Zhang 	mana_refill_rxoob(dev, rxq, rxbuf_oob, &old_buf);
1406ca9c54d2SDexuan Cui 
1407a2917b23SHaiyang Zhang 	/* Unsuccessful refill will have old_buf == NULL.
1408a2917b23SHaiyang Zhang 	 * In this case, mana_rx_skb() will drop the packet.
1409a2917b23SHaiyang Zhang 	 */
1410ca9c54d2SDexuan Cui 	mana_rx_skb(old_buf, oob, rxq);
1411ca9c54d2SDexuan Cui 
1412e4b76219SHaiyang Zhang drop:
1413ca9c54d2SDexuan Cui 	mana_move_wq_tail(rxq->gdma_rq, rxbuf_oob->wqe_inf.wqe_size_in_bu);
1414ca9c54d2SDexuan Cui 
1415ca9c54d2SDexuan Cui 	mana_post_pkt_rxq(rxq);
1416ca9c54d2SDexuan Cui }
1417ca9c54d2SDexuan Cui 
1418ca9c54d2SDexuan Cui static void mana_poll_rx_cq(struct mana_cq *cq)
1419ca9c54d2SDexuan Cui {
1420ca9c54d2SDexuan Cui 	struct gdma_comp *comp = cq->gdma_comp_buf;
14217a8938cdSHaiyang Zhang 	struct mana_rxq *rxq = cq->rxq;
1422bd7fc6e1SShradha Gupta 	struct mana_port_context *apc;
1423d90a9468SDexuan Cui 	int comp_read, i;
1424ca9c54d2SDexuan Cui 
1425bd7fc6e1SShradha Gupta 	apc = netdev_priv(rxq->ndev);
1426bd7fc6e1SShradha Gupta 
1427ca9c54d2SDexuan Cui 	comp_read = mana_gd_poll_cq(cq->gdma_cq, comp, CQE_POLLING_BUFFER);
1428ca9c54d2SDexuan Cui 	WARN_ON_ONCE(comp_read > CQE_POLLING_BUFFER);
1429ca9c54d2SDexuan Cui 
1430bd7fc6e1SShradha Gupta 	apc->eth_stats.rx_cqes = comp_read;
14317a8938cdSHaiyang Zhang 	rxq->xdp_flush = false;
14327a8938cdSHaiyang Zhang 
1433ca9c54d2SDexuan Cui 	for (i = 0; i < comp_read; i++) {
1434ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(comp[i].is_sq))
1435ca9c54d2SDexuan Cui 			return;
1436ca9c54d2SDexuan Cui 
1437ca9c54d2SDexuan Cui 		/* verify recv cqe references the right rxq */
1438ca9c54d2SDexuan Cui 		if (WARN_ON_ONCE(comp[i].wq_num != cq->rxq->gdma_id))
1439ca9c54d2SDexuan Cui 			return;
1440ca9c54d2SDexuan Cui 
14417a8938cdSHaiyang Zhang 		mana_process_rx_cqe(rxq, cq, &comp[i]);
1442bd7fc6e1SShradha Gupta 
1443bd7fc6e1SShradha Gupta 		apc->eth_stats.rx_cqes--;
1444ca9c54d2SDexuan Cui 	}
14457a8938cdSHaiyang Zhang 
14467a8938cdSHaiyang Zhang 	if (rxq->xdp_flush)
14477a8938cdSHaiyang Zhang 		xdp_do_flush();
1448ca9c54d2SDexuan Cui }
1449ca9c54d2SDexuan Cui 
145018010ff7SHaiyang Zhang static int mana_cq_handler(void *context, struct gdma_queue *gdma_queue)
1451ca9c54d2SDexuan Cui {
1452ca9c54d2SDexuan Cui 	struct mana_cq *cq = context;
1453e1b5683fSHaiyang Zhang 	u8 arm_bit;
145418010ff7SHaiyang Zhang 	int w;
1455ca9c54d2SDexuan Cui 
1456ca9c54d2SDexuan Cui 	WARN_ON_ONCE(cq->gdma_cq != gdma_queue);
1457ca9c54d2SDexuan Cui 
1458ca9c54d2SDexuan Cui 	if (cq->type == MANA_CQ_TYPE_RX)
1459ca9c54d2SDexuan Cui 		mana_poll_rx_cq(cq);
1460ca9c54d2SDexuan Cui 	else
1461ca9c54d2SDexuan Cui 		mana_poll_tx_cq(cq);
1462ca9c54d2SDexuan Cui 
146318010ff7SHaiyang Zhang 	w = cq->work_done;
146418010ff7SHaiyang Zhang 
146518010ff7SHaiyang Zhang 	if (w < cq->budget &&
146618010ff7SHaiyang Zhang 	    napi_complete_done(&cq->napi, w)) {
1467e1b5683fSHaiyang Zhang 		arm_bit = SET_ARM_BIT;
1468e1b5683fSHaiyang Zhang 	} else {
1469e1b5683fSHaiyang Zhang 		arm_bit = 0;
1470e1b5683fSHaiyang Zhang 	}
1471e1b5683fSHaiyang Zhang 
1472e1b5683fSHaiyang Zhang 	mana_gd_ring_cq(gdma_queue, arm_bit);
147318010ff7SHaiyang Zhang 
147418010ff7SHaiyang Zhang 	return w;
1475e1b5683fSHaiyang Zhang }
1476e1b5683fSHaiyang Zhang 
1477e1b5683fSHaiyang Zhang static int mana_poll(struct napi_struct *napi, int budget)
1478e1b5683fSHaiyang Zhang {
1479e1b5683fSHaiyang Zhang 	struct mana_cq *cq = container_of(napi, struct mana_cq, napi);
148018010ff7SHaiyang Zhang 	int w;
1481e1b5683fSHaiyang Zhang 
1482e1b5683fSHaiyang Zhang 	cq->work_done = 0;
1483e1b5683fSHaiyang Zhang 	cq->budget = budget;
1484e1b5683fSHaiyang Zhang 
148518010ff7SHaiyang Zhang 	w = mana_cq_handler(cq, cq->gdma_cq);
1486e1b5683fSHaiyang Zhang 
148718010ff7SHaiyang Zhang 	return min(w, budget);
1488e1b5683fSHaiyang Zhang }
1489e1b5683fSHaiyang Zhang 
1490e1b5683fSHaiyang Zhang static void mana_schedule_napi(void *context, struct gdma_queue *gdma_queue)
1491e1b5683fSHaiyang Zhang {
1492e1b5683fSHaiyang Zhang 	struct mana_cq *cq = context;
1493e1b5683fSHaiyang Zhang 
1494e1b5683fSHaiyang Zhang 	napi_schedule_irqoff(&cq->napi);
1495ca9c54d2SDexuan Cui }
1496ca9c54d2SDexuan Cui 
1497ca9c54d2SDexuan Cui static void mana_deinit_cq(struct mana_port_context *apc, struct mana_cq *cq)
1498ca9c54d2SDexuan Cui {
1499ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
1500ca9c54d2SDexuan Cui 
1501ca9c54d2SDexuan Cui 	if (!cq->gdma_cq)
1502ca9c54d2SDexuan Cui 		return;
1503ca9c54d2SDexuan Cui 
1504ca9c54d2SDexuan Cui 	mana_gd_destroy_queue(gd->gdma_context, cq->gdma_cq);
1505ca9c54d2SDexuan Cui }
1506ca9c54d2SDexuan Cui 
1507ca9c54d2SDexuan Cui static void mana_deinit_txq(struct mana_port_context *apc, struct mana_txq *txq)
1508ca9c54d2SDexuan Cui {
1509ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
1510ca9c54d2SDexuan Cui 
1511ca9c54d2SDexuan Cui 	if (!txq->gdma_sq)
1512ca9c54d2SDexuan Cui 		return;
1513ca9c54d2SDexuan Cui 
1514ca9c54d2SDexuan Cui 	mana_gd_destroy_queue(gd->gdma_context, txq->gdma_sq);
1515ca9c54d2SDexuan Cui }
1516ca9c54d2SDexuan Cui 
1517ca9c54d2SDexuan Cui static void mana_destroy_txq(struct mana_port_context *apc)
1518ca9c54d2SDexuan Cui {
1519e1b5683fSHaiyang Zhang 	struct napi_struct *napi;
1520ca9c54d2SDexuan Cui 	int i;
1521ca9c54d2SDexuan Cui 
1522ca9c54d2SDexuan Cui 	if (!apc->tx_qp)
1523ca9c54d2SDexuan Cui 		return;
1524ca9c54d2SDexuan Cui 
1525ca9c54d2SDexuan Cui 	for (i = 0; i < apc->num_queues; i++) {
1526e1b5683fSHaiyang Zhang 		napi = &apc->tx_qp[i].tx_cq.napi;
1527e1b5683fSHaiyang Zhang 		napi_synchronize(napi);
1528e1b5683fSHaiyang Zhang 		napi_disable(napi);
1529e1b5683fSHaiyang Zhang 		netif_napi_del(napi);
1530e1b5683fSHaiyang Zhang 
1531ca9c54d2SDexuan Cui 		mana_destroy_wq_obj(apc, GDMA_SQ, apc->tx_qp[i].tx_object);
1532ca9c54d2SDexuan Cui 
1533ca9c54d2SDexuan Cui 		mana_deinit_cq(apc, &apc->tx_qp[i].tx_cq);
1534ca9c54d2SDexuan Cui 
1535ca9c54d2SDexuan Cui 		mana_deinit_txq(apc, &apc->tx_qp[i].txq);
1536ca9c54d2SDexuan Cui 	}
1537ca9c54d2SDexuan Cui 
1538ca9c54d2SDexuan Cui 	kfree(apc->tx_qp);
1539ca9c54d2SDexuan Cui 	apc->tx_qp = NULL;
1540ca9c54d2SDexuan Cui }
1541ca9c54d2SDexuan Cui 
1542ca9c54d2SDexuan Cui static int mana_create_txq(struct mana_port_context *apc,
1543ca9c54d2SDexuan Cui 			   struct net_device *net)
1544ca9c54d2SDexuan Cui {
15451e2d0824SHaiyang Zhang 	struct mana_context *ac = apc->ac;
15461e2d0824SHaiyang Zhang 	struct gdma_dev *gd = ac->gdma_dev;
1547ca9c54d2SDexuan Cui 	struct mana_obj_spec wq_spec;
1548ca9c54d2SDexuan Cui 	struct mana_obj_spec cq_spec;
1549ca9c54d2SDexuan Cui 	struct gdma_queue_spec spec;
1550ca9c54d2SDexuan Cui 	struct gdma_context *gc;
1551ca9c54d2SDexuan Cui 	struct mana_txq *txq;
1552ca9c54d2SDexuan Cui 	struct mana_cq *cq;
1553ca9c54d2SDexuan Cui 	u32 txq_size;
1554ca9c54d2SDexuan Cui 	u32 cq_size;
1555ca9c54d2SDexuan Cui 	int err;
1556ca9c54d2SDexuan Cui 	int i;
1557ca9c54d2SDexuan Cui 
1558ca9c54d2SDexuan Cui 	apc->tx_qp = kcalloc(apc->num_queues, sizeof(struct mana_tx_qp),
1559ca9c54d2SDexuan Cui 			     GFP_KERNEL);
1560ca9c54d2SDexuan Cui 	if (!apc->tx_qp)
1561ca9c54d2SDexuan Cui 		return -ENOMEM;
1562ca9c54d2SDexuan Cui 
1563ca9c54d2SDexuan Cui 	/*  The minimum size of the WQE is 32 bytes, hence
1564ca9c54d2SDexuan Cui 	 *  MAX_SEND_BUFFERS_PER_QUEUE represents the maximum number of WQEs
1565ca9c54d2SDexuan Cui 	 *  the SQ can store. This value is then used to size other queues
1566ca9c54d2SDexuan Cui 	 *  to prevent overflow.
1567ca9c54d2SDexuan Cui 	 */
1568ca9c54d2SDexuan Cui 	txq_size = MAX_SEND_BUFFERS_PER_QUEUE * 32;
1569ca9c54d2SDexuan Cui 	BUILD_BUG_ON(!PAGE_ALIGNED(txq_size));
1570ca9c54d2SDexuan Cui 
1571ca9c54d2SDexuan Cui 	cq_size = MAX_SEND_BUFFERS_PER_QUEUE * COMP_ENTRY_SIZE;
1572ca9c54d2SDexuan Cui 	cq_size = PAGE_ALIGN(cq_size);
1573ca9c54d2SDexuan Cui 
1574ca9c54d2SDexuan Cui 	gc = gd->gdma_context;
1575ca9c54d2SDexuan Cui 
1576ca9c54d2SDexuan Cui 	for (i = 0; i < apc->num_queues; i++) {
1577ca9c54d2SDexuan Cui 		apc->tx_qp[i].tx_object = INVALID_MANA_HANDLE;
1578ca9c54d2SDexuan Cui 
1579ca9c54d2SDexuan Cui 		/* Create SQ */
1580ca9c54d2SDexuan Cui 		txq = &apc->tx_qp[i].txq;
1581ca9c54d2SDexuan Cui 
1582ca9c54d2SDexuan Cui 		u64_stats_init(&txq->stats.syncp);
1583ca9c54d2SDexuan Cui 		txq->ndev = net;
1584ca9c54d2SDexuan Cui 		txq->net_txq = netdev_get_tx_queue(net, i);
1585ca9c54d2SDexuan Cui 		txq->vp_offset = apc->tx_vp_offset;
1586ca9c54d2SDexuan Cui 		skb_queue_head_init(&txq->pending_skbs);
1587ca9c54d2SDexuan Cui 
1588ca9c54d2SDexuan Cui 		memset(&spec, 0, sizeof(spec));
1589ca9c54d2SDexuan Cui 		spec.type = GDMA_SQ;
1590ca9c54d2SDexuan Cui 		spec.monitor_avl_buf = true;
1591ca9c54d2SDexuan Cui 		spec.queue_size = txq_size;
1592ca9c54d2SDexuan Cui 		err = mana_gd_create_mana_wq_cq(gd, &spec, &txq->gdma_sq);
1593ca9c54d2SDexuan Cui 		if (err)
1594ca9c54d2SDexuan Cui 			goto out;
1595ca9c54d2SDexuan Cui 
1596ca9c54d2SDexuan Cui 		/* Create SQ's CQ */
1597ca9c54d2SDexuan Cui 		cq = &apc->tx_qp[i].tx_cq;
1598ca9c54d2SDexuan Cui 		cq->type = MANA_CQ_TYPE_TX;
1599ca9c54d2SDexuan Cui 
1600ca9c54d2SDexuan Cui 		cq->txq = txq;
1601ca9c54d2SDexuan Cui 
1602ca9c54d2SDexuan Cui 		memset(&spec, 0, sizeof(spec));
1603ca9c54d2SDexuan Cui 		spec.type = GDMA_CQ;
1604ca9c54d2SDexuan Cui 		spec.monitor_avl_buf = false;
1605ca9c54d2SDexuan Cui 		spec.queue_size = cq_size;
1606e1b5683fSHaiyang Zhang 		spec.cq.callback = mana_schedule_napi;
16071e2d0824SHaiyang Zhang 		spec.cq.parent_eq = ac->eqs[i].eq;
1608ca9c54d2SDexuan Cui 		spec.cq.context = cq;
1609ca9c54d2SDexuan Cui 		err = mana_gd_create_mana_wq_cq(gd, &spec, &cq->gdma_cq);
1610ca9c54d2SDexuan Cui 		if (err)
1611ca9c54d2SDexuan Cui 			goto out;
1612ca9c54d2SDexuan Cui 
1613ca9c54d2SDexuan Cui 		memset(&wq_spec, 0, sizeof(wq_spec));
1614ca9c54d2SDexuan Cui 		memset(&cq_spec, 0, sizeof(cq_spec));
1615ca9c54d2SDexuan Cui 
161628c66cfaSAjay Sharma 		wq_spec.gdma_region = txq->gdma_sq->mem_info.dma_region_handle;
1617ca9c54d2SDexuan Cui 		wq_spec.queue_size = txq->gdma_sq->queue_size;
1618ca9c54d2SDexuan Cui 
161928c66cfaSAjay Sharma 		cq_spec.gdma_region = cq->gdma_cq->mem_info.dma_region_handle;
1620ca9c54d2SDexuan Cui 		cq_spec.queue_size = cq->gdma_cq->queue_size;
1621ca9c54d2SDexuan Cui 		cq_spec.modr_ctx_id = 0;
1622ca9c54d2SDexuan Cui 		cq_spec.attached_eq = cq->gdma_cq->cq.parent->id;
1623ca9c54d2SDexuan Cui 
1624ca9c54d2SDexuan Cui 		err = mana_create_wq_obj(apc, apc->port_handle, GDMA_SQ,
1625ca9c54d2SDexuan Cui 					 &wq_spec, &cq_spec,
1626ca9c54d2SDexuan Cui 					 &apc->tx_qp[i].tx_object);
1627ca9c54d2SDexuan Cui 
1628ca9c54d2SDexuan Cui 		if (err)
1629ca9c54d2SDexuan Cui 			goto out;
1630ca9c54d2SDexuan Cui 
1631ca9c54d2SDexuan Cui 		txq->gdma_sq->id = wq_spec.queue_index;
1632ca9c54d2SDexuan Cui 		cq->gdma_cq->id = cq_spec.queue_index;
1633ca9c54d2SDexuan Cui 
163428c66cfaSAjay Sharma 		txq->gdma_sq->mem_info.dma_region_handle =
163528c66cfaSAjay Sharma 			GDMA_INVALID_DMA_REGION;
163628c66cfaSAjay Sharma 		cq->gdma_cq->mem_info.dma_region_handle =
163728c66cfaSAjay Sharma 			GDMA_INVALID_DMA_REGION;
1638ca9c54d2SDexuan Cui 
1639ca9c54d2SDexuan Cui 		txq->gdma_txq_id = txq->gdma_sq->id;
1640ca9c54d2SDexuan Cui 
1641ca9c54d2SDexuan Cui 		cq->gdma_id = cq->gdma_cq->id;
1642ca9c54d2SDexuan Cui 
1643b9078845SChristophe JAILLET 		if (WARN_ON(cq->gdma_id >= gc->max_num_cqs)) {
1644b9078845SChristophe JAILLET 			err = -EINVAL;
1645b9078845SChristophe JAILLET 			goto out;
1646b9078845SChristophe JAILLET 		}
1647ca9c54d2SDexuan Cui 
1648ca9c54d2SDexuan Cui 		gc->cq_table[cq->gdma_id] = cq->gdma_cq;
1649ca9c54d2SDexuan Cui 
165016d083e2SJakub Kicinski 		netif_napi_add_tx(net, &cq->napi, mana_poll);
1651e1b5683fSHaiyang Zhang 		napi_enable(&cq->napi);
1652e1b5683fSHaiyang Zhang 
1653e1b5683fSHaiyang Zhang 		mana_gd_ring_cq(cq->gdma_cq, SET_ARM_BIT);
1654ca9c54d2SDexuan Cui 	}
1655ca9c54d2SDexuan Cui 
1656ca9c54d2SDexuan Cui 	return 0;
1657ca9c54d2SDexuan Cui out:
1658ca9c54d2SDexuan Cui 	mana_destroy_txq(apc);
1659ca9c54d2SDexuan Cui 	return err;
1660ca9c54d2SDexuan Cui }
1661ca9c54d2SDexuan Cui 
1662ca9c54d2SDexuan Cui static void mana_destroy_rxq(struct mana_port_context *apc,
1663ca9c54d2SDexuan Cui 			     struct mana_rxq *rxq, bool validate_state)
1664ca9c54d2SDexuan Cui 
1665ca9c54d2SDexuan Cui {
1666ca9c54d2SDexuan Cui 	struct gdma_context *gc = apc->ac->gdma_dev->gdma_context;
1667ca9c54d2SDexuan Cui 	struct mana_recv_buf_oob *rx_oob;
1668ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
1669e1b5683fSHaiyang Zhang 	struct napi_struct *napi;
1670ca9c54d2SDexuan Cui 	int i;
1671ca9c54d2SDexuan Cui 
1672ca9c54d2SDexuan Cui 	if (!rxq)
1673ca9c54d2SDexuan Cui 		return;
1674ca9c54d2SDexuan Cui 
1675e1b5683fSHaiyang Zhang 	napi = &rxq->rx_cq.napi;
1676e1b5683fSHaiyang Zhang 
1677ca9c54d2SDexuan Cui 	if (validate_state)
1678e1b5683fSHaiyang Zhang 		napi_synchronize(napi);
1679e1b5683fSHaiyang Zhang 
1680e1b5683fSHaiyang Zhang 	napi_disable(napi);
1681ed5356b5SHaiyang Zhang 
1682ed5356b5SHaiyang Zhang 	xdp_rxq_info_unreg(&rxq->xdp_rxq);
1683ed5356b5SHaiyang Zhang 
1684e1b5683fSHaiyang Zhang 	netif_napi_del(napi);
1685ca9c54d2SDexuan Cui 
1686ca9c54d2SDexuan Cui 	mana_destroy_wq_obj(apc, GDMA_RQ, rxq->rxobj);
1687ca9c54d2SDexuan Cui 
1688ca9c54d2SDexuan Cui 	mana_deinit_cq(apc, &rxq->rx_cq);
1689ca9c54d2SDexuan Cui 
1690a2917b23SHaiyang Zhang 	if (rxq->xdp_save_va)
1691a2917b23SHaiyang Zhang 		put_page(virt_to_head_page(rxq->xdp_save_va));
1692a6bf5703SHaiyang Zhang 
1693ca9c54d2SDexuan Cui 	for (i = 0; i < rxq->num_rx_buf; i++) {
1694ca9c54d2SDexuan Cui 		rx_oob = &rxq->rx_oobs[i];
1695ca9c54d2SDexuan Cui 
1696ca9c54d2SDexuan Cui 		if (!rx_oob->buf_va)
1697ca9c54d2SDexuan Cui 			continue;
1698ca9c54d2SDexuan Cui 
1699a2917b23SHaiyang Zhang 		dma_unmap_single(dev, rx_oob->sgl[0].address,
1700a2917b23SHaiyang Zhang 				 rx_oob->sgl[0].size, DMA_FROM_DEVICE);
1701ca9c54d2SDexuan Cui 
1702a2917b23SHaiyang Zhang 		put_page(virt_to_head_page(rx_oob->buf_va));
1703ca9c54d2SDexuan Cui 		rx_oob->buf_va = NULL;
1704ca9c54d2SDexuan Cui 	}
1705ca9c54d2SDexuan Cui 
1706ca9c54d2SDexuan Cui 	if (rxq->gdma_rq)
1707ca9c54d2SDexuan Cui 		mana_gd_destroy_queue(gc, rxq->gdma_rq);
1708ca9c54d2SDexuan Cui 
1709ca9c54d2SDexuan Cui 	kfree(rxq);
1710ca9c54d2SDexuan Cui }
1711ca9c54d2SDexuan Cui 
1712a2917b23SHaiyang Zhang static int mana_fill_rx_oob(struct mana_recv_buf_oob *rx_oob, u32 mem_key,
1713a2917b23SHaiyang Zhang 			    struct mana_rxq *rxq, struct device *dev)
1714a2917b23SHaiyang Zhang {
1715a2917b23SHaiyang Zhang 	dma_addr_t da;
1716a2917b23SHaiyang Zhang 	void *va;
1717a2917b23SHaiyang Zhang 
1718a2917b23SHaiyang Zhang 	va = mana_get_rxfrag(rxq, dev, &da, false);
1719a2917b23SHaiyang Zhang 
1720a2917b23SHaiyang Zhang 	if (!va)
1721a2917b23SHaiyang Zhang 		return -ENOMEM;
1722a2917b23SHaiyang Zhang 
1723a2917b23SHaiyang Zhang 	rx_oob->buf_va = va;
1724a2917b23SHaiyang Zhang 
1725a2917b23SHaiyang Zhang 	rx_oob->sgl[0].address = da;
1726a2917b23SHaiyang Zhang 	rx_oob->sgl[0].size = rxq->datasize;
1727a2917b23SHaiyang Zhang 	rx_oob->sgl[0].mem_key = mem_key;
1728a2917b23SHaiyang Zhang 
1729a2917b23SHaiyang Zhang 	return 0;
1730a2917b23SHaiyang Zhang }
1731a2917b23SHaiyang Zhang 
1732ca9c54d2SDexuan Cui #define MANA_WQE_HEADER_SIZE 16
1733ca9c54d2SDexuan Cui #define MANA_WQE_SGE_SIZE 16
1734ca9c54d2SDexuan Cui 
1735ca9c54d2SDexuan Cui static int mana_alloc_rx_wqe(struct mana_port_context *apc,
1736ca9c54d2SDexuan Cui 			     struct mana_rxq *rxq, u32 *rxq_size, u32 *cq_size)
1737ca9c54d2SDexuan Cui {
1738ca9c54d2SDexuan Cui 	struct gdma_context *gc = apc->ac->gdma_dev->gdma_context;
1739ca9c54d2SDexuan Cui 	struct mana_recv_buf_oob *rx_oob;
1740ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
1741ca9c54d2SDexuan Cui 	u32 buf_idx;
1742a2917b23SHaiyang Zhang 	int ret;
1743ca9c54d2SDexuan Cui 
1744*2fbbd712SHaiyang Zhang 	WARN_ON(rxq->datasize == 0);
1745ca9c54d2SDexuan Cui 
1746ca9c54d2SDexuan Cui 	*rxq_size = 0;
1747ca9c54d2SDexuan Cui 	*cq_size = 0;
1748ca9c54d2SDexuan Cui 
1749ca9c54d2SDexuan Cui 	for (buf_idx = 0; buf_idx < rxq->num_rx_buf; buf_idx++) {
1750ca9c54d2SDexuan Cui 		rx_oob = &rxq->rx_oobs[buf_idx];
1751ca9c54d2SDexuan Cui 		memset(rx_oob, 0, sizeof(*rx_oob));
1752ca9c54d2SDexuan Cui 
1753ca9c54d2SDexuan Cui 		rx_oob->num_sge = 1;
1754a2917b23SHaiyang Zhang 
1755a2917b23SHaiyang Zhang 		ret = mana_fill_rx_oob(rx_oob, apc->ac->gdma_dev->gpa_mkey, rxq,
1756a2917b23SHaiyang Zhang 				       dev);
1757a2917b23SHaiyang Zhang 		if (ret)
1758a2917b23SHaiyang Zhang 			return ret;
1759ca9c54d2SDexuan Cui 
1760ca9c54d2SDexuan Cui 		rx_oob->wqe_req.sgl = rx_oob->sgl;
1761ca9c54d2SDexuan Cui 		rx_oob->wqe_req.num_sge = rx_oob->num_sge;
1762ca9c54d2SDexuan Cui 		rx_oob->wqe_req.inline_oob_size = 0;
1763ca9c54d2SDexuan Cui 		rx_oob->wqe_req.inline_oob_data = NULL;
1764ca9c54d2SDexuan Cui 		rx_oob->wqe_req.flags = 0;
1765ca9c54d2SDexuan Cui 		rx_oob->wqe_req.client_data_unit = 0;
1766ca9c54d2SDexuan Cui 
1767ca9c54d2SDexuan Cui 		*rxq_size += ALIGN(MANA_WQE_HEADER_SIZE +
1768ca9c54d2SDexuan Cui 				   MANA_WQE_SGE_SIZE * rx_oob->num_sge, 32);
1769ca9c54d2SDexuan Cui 		*cq_size += COMP_ENTRY_SIZE;
1770ca9c54d2SDexuan Cui 	}
1771ca9c54d2SDexuan Cui 
1772ca9c54d2SDexuan Cui 	return 0;
1773ca9c54d2SDexuan Cui }
1774ca9c54d2SDexuan Cui 
1775ca9c54d2SDexuan Cui static int mana_push_wqe(struct mana_rxq *rxq)
1776ca9c54d2SDexuan Cui {
1777ca9c54d2SDexuan Cui 	struct mana_recv_buf_oob *rx_oob;
1778ca9c54d2SDexuan Cui 	u32 buf_idx;
1779ca9c54d2SDexuan Cui 	int err;
1780ca9c54d2SDexuan Cui 
1781ca9c54d2SDexuan Cui 	for (buf_idx = 0; buf_idx < rxq->num_rx_buf; buf_idx++) {
1782ca9c54d2SDexuan Cui 		rx_oob = &rxq->rx_oobs[buf_idx];
1783ca9c54d2SDexuan Cui 
1784ca9c54d2SDexuan Cui 		err = mana_gd_post_and_ring(rxq->gdma_rq, &rx_oob->wqe_req,
1785ca9c54d2SDexuan Cui 					    &rx_oob->wqe_inf);
1786ca9c54d2SDexuan Cui 		if (err)
1787ca9c54d2SDexuan Cui 			return -ENOSPC;
1788ca9c54d2SDexuan Cui 	}
1789ca9c54d2SDexuan Cui 
1790ca9c54d2SDexuan Cui 	return 0;
1791ca9c54d2SDexuan Cui }
1792ca9c54d2SDexuan Cui 
1793ca9c54d2SDexuan Cui static struct mana_rxq *mana_create_rxq(struct mana_port_context *apc,
1794ca9c54d2SDexuan Cui 					u32 rxq_idx, struct mana_eq *eq,
1795ca9c54d2SDexuan Cui 					struct net_device *ndev)
1796ca9c54d2SDexuan Cui {
1797ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
1798ca9c54d2SDexuan Cui 	struct mana_obj_spec wq_spec;
1799ca9c54d2SDexuan Cui 	struct mana_obj_spec cq_spec;
1800*2fbbd712SHaiyang Zhang 	unsigned int mtu = ndev->mtu;
1801ca9c54d2SDexuan Cui 	struct gdma_queue_spec spec;
1802ca9c54d2SDexuan Cui 	struct mana_cq *cq = NULL;
1803ca9c54d2SDexuan Cui 	struct gdma_context *gc;
1804ca9c54d2SDexuan Cui 	u32 cq_size, rq_size;
1805ca9c54d2SDexuan Cui 	struct mana_rxq *rxq;
1806ca9c54d2SDexuan Cui 	int err;
1807ca9c54d2SDexuan Cui 
1808ca9c54d2SDexuan Cui 	gc = gd->gdma_context;
1809ca9c54d2SDexuan Cui 
1810ea89c862SGustavo A. R. Silva 	rxq = kzalloc(struct_size(rxq, rx_oobs, RX_BUFFERS_PER_QUEUE),
1811ca9c54d2SDexuan Cui 		      GFP_KERNEL);
1812ca9c54d2SDexuan Cui 	if (!rxq)
1813ca9c54d2SDexuan Cui 		return NULL;
1814ca9c54d2SDexuan Cui 
1815ca9c54d2SDexuan Cui 	rxq->ndev = ndev;
1816ca9c54d2SDexuan Cui 	rxq->num_rx_buf = RX_BUFFERS_PER_QUEUE;
1817ca9c54d2SDexuan Cui 	rxq->rxq_idx = rxq_idx;
1818ca9c54d2SDexuan Cui 	rxq->rxobj = INVALID_MANA_HANDLE;
1819ca9c54d2SDexuan Cui 
1820*2fbbd712SHaiyang Zhang 	rxq->datasize = ALIGN(mtu + ETH_HLEN, 64);
1821*2fbbd712SHaiyang Zhang 
1822*2fbbd712SHaiyang Zhang 	if (mtu > MANA_XDP_MTU_MAX) {
1823*2fbbd712SHaiyang Zhang 		rxq->alloc_size = mtu + MANA_RXBUF_PAD;
1824*2fbbd712SHaiyang Zhang 		rxq->headroom = 0;
1825*2fbbd712SHaiyang Zhang 	} else {
1826*2fbbd712SHaiyang Zhang 		rxq->alloc_size = mtu + MANA_RXBUF_PAD + XDP_PACKET_HEADROOM;
1827*2fbbd712SHaiyang Zhang 		rxq->headroom = XDP_PACKET_HEADROOM;
1828*2fbbd712SHaiyang Zhang 	}
1829a2917b23SHaiyang Zhang 
1830ca9c54d2SDexuan Cui 	err = mana_alloc_rx_wqe(apc, rxq, &rq_size, &cq_size);
1831ca9c54d2SDexuan Cui 	if (err)
1832ca9c54d2SDexuan Cui 		goto out;
1833ca9c54d2SDexuan Cui 
1834ca9c54d2SDexuan Cui 	rq_size = PAGE_ALIGN(rq_size);
1835ca9c54d2SDexuan Cui 	cq_size = PAGE_ALIGN(cq_size);
1836ca9c54d2SDexuan Cui 
1837ca9c54d2SDexuan Cui 	/* Create RQ */
1838ca9c54d2SDexuan Cui 	memset(&spec, 0, sizeof(spec));
1839ca9c54d2SDexuan Cui 	spec.type = GDMA_RQ;
1840ca9c54d2SDexuan Cui 	spec.monitor_avl_buf = true;
1841ca9c54d2SDexuan Cui 	spec.queue_size = rq_size;
1842ca9c54d2SDexuan Cui 	err = mana_gd_create_mana_wq_cq(gd, &spec, &rxq->gdma_rq);
1843ca9c54d2SDexuan Cui 	if (err)
1844ca9c54d2SDexuan Cui 		goto out;
1845ca9c54d2SDexuan Cui 
1846ca9c54d2SDexuan Cui 	/* Create RQ's CQ */
1847ca9c54d2SDexuan Cui 	cq = &rxq->rx_cq;
1848ca9c54d2SDexuan Cui 	cq->type = MANA_CQ_TYPE_RX;
1849ca9c54d2SDexuan Cui 	cq->rxq = rxq;
1850ca9c54d2SDexuan Cui 
1851ca9c54d2SDexuan Cui 	memset(&spec, 0, sizeof(spec));
1852ca9c54d2SDexuan Cui 	spec.type = GDMA_CQ;
1853ca9c54d2SDexuan Cui 	spec.monitor_avl_buf = false;
1854ca9c54d2SDexuan Cui 	spec.queue_size = cq_size;
1855e1b5683fSHaiyang Zhang 	spec.cq.callback = mana_schedule_napi;
1856ca9c54d2SDexuan Cui 	spec.cq.parent_eq = eq->eq;
1857ca9c54d2SDexuan Cui 	spec.cq.context = cq;
1858ca9c54d2SDexuan Cui 	err = mana_gd_create_mana_wq_cq(gd, &spec, &cq->gdma_cq);
1859ca9c54d2SDexuan Cui 	if (err)
1860ca9c54d2SDexuan Cui 		goto out;
1861ca9c54d2SDexuan Cui 
1862ca9c54d2SDexuan Cui 	memset(&wq_spec, 0, sizeof(wq_spec));
1863ca9c54d2SDexuan Cui 	memset(&cq_spec, 0, sizeof(cq_spec));
186428c66cfaSAjay Sharma 	wq_spec.gdma_region = rxq->gdma_rq->mem_info.dma_region_handle;
1865ca9c54d2SDexuan Cui 	wq_spec.queue_size = rxq->gdma_rq->queue_size;
1866ca9c54d2SDexuan Cui 
186728c66cfaSAjay Sharma 	cq_spec.gdma_region = cq->gdma_cq->mem_info.dma_region_handle;
1868ca9c54d2SDexuan Cui 	cq_spec.queue_size = cq->gdma_cq->queue_size;
1869ca9c54d2SDexuan Cui 	cq_spec.modr_ctx_id = 0;
1870ca9c54d2SDexuan Cui 	cq_spec.attached_eq = cq->gdma_cq->cq.parent->id;
1871ca9c54d2SDexuan Cui 
1872ca9c54d2SDexuan Cui 	err = mana_create_wq_obj(apc, apc->port_handle, GDMA_RQ,
1873ca9c54d2SDexuan Cui 				 &wq_spec, &cq_spec, &rxq->rxobj);
1874ca9c54d2SDexuan Cui 	if (err)
1875ca9c54d2SDexuan Cui 		goto out;
1876ca9c54d2SDexuan Cui 
1877ca9c54d2SDexuan Cui 	rxq->gdma_rq->id = wq_spec.queue_index;
1878ca9c54d2SDexuan Cui 	cq->gdma_cq->id = cq_spec.queue_index;
1879ca9c54d2SDexuan Cui 
188028c66cfaSAjay Sharma 	rxq->gdma_rq->mem_info.dma_region_handle = GDMA_INVALID_DMA_REGION;
188128c66cfaSAjay Sharma 	cq->gdma_cq->mem_info.dma_region_handle = GDMA_INVALID_DMA_REGION;
1882ca9c54d2SDexuan Cui 
1883ca9c54d2SDexuan Cui 	rxq->gdma_id = rxq->gdma_rq->id;
1884ca9c54d2SDexuan Cui 	cq->gdma_id = cq->gdma_cq->id;
1885ca9c54d2SDexuan Cui 
1886ca9c54d2SDexuan Cui 	err = mana_push_wqe(rxq);
1887ca9c54d2SDexuan Cui 	if (err)
1888ca9c54d2SDexuan Cui 		goto out;
1889ca9c54d2SDexuan Cui 
1890be049936SHaiyang Zhang 	if (WARN_ON(cq->gdma_id >= gc->max_num_cqs)) {
1891be049936SHaiyang Zhang 		err = -EINVAL;
1892ca9c54d2SDexuan Cui 		goto out;
1893be049936SHaiyang Zhang 	}
1894ca9c54d2SDexuan Cui 
1895ca9c54d2SDexuan Cui 	gc->cq_table[cq->gdma_id] = cq->gdma_cq;
1896ca9c54d2SDexuan Cui 
1897b707b89fSJakub Kicinski 	netif_napi_add_weight(ndev, &cq->napi, mana_poll, 1);
1898ed5356b5SHaiyang Zhang 
1899ed5356b5SHaiyang Zhang 	WARN_ON(xdp_rxq_info_reg(&rxq->xdp_rxq, ndev, rxq_idx,
1900ed5356b5SHaiyang Zhang 				 cq->napi.napi_id));
1901ed5356b5SHaiyang Zhang 	WARN_ON(xdp_rxq_info_reg_mem_model(&rxq->xdp_rxq,
1902ed5356b5SHaiyang Zhang 					   MEM_TYPE_PAGE_SHARED, NULL));
1903ed5356b5SHaiyang Zhang 
1904e1b5683fSHaiyang Zhang 	napi_enable(&cq->napi);
1905e1b5683fSHaiyang Zhang 
1906e1b5683fSHaiyang Zhang 	mana_gd_ring_cq(cq->gdma_cq, SET_ARM_BIT);
1907ca9c54d2SDexuan Cui out:
1908ca9c54d2SDexuan Cui 	if (!err)
1909ca9c54d2SDexuan Cui 		return rxq;
1910ca9c54d2SDexuan Cui 
1911ca9c54d2SDexuan Cui 	netdev_err(ndev, "Failed to create RXQ: err = %d\n", err);
1912ca9c54d2SDexuan Cui 
1913ca9c54d2SDexuan Cui 	mana_destroy_rxq(apc, rxq, false);
1914ca9c54d2SDexuan Cui 
1915ca9c54d2SDexuan Cui 	if (cq)
1916ca9c54d2SDexuan Cui 		mana_deinit_cq(apc, cq);
1917ca9c54d2SDexuan Cui 
1918ca9c54d2SDexuan Cui 	return NULL;
1919ca9c54d2SDexuan Cui }
1920ca9c54d2SDexuan Cui 
1921ca9c54d2SDexuan Cui static int mana_add_rx_queues(struct mana_port_context *apc,
1922ca9c54d2SDexuan Cui 			      struct net_device *ndev)
1923ca9c54d2SDexuan Cui {
19241e2d0824SHaiyang Zhang 	struct mana_context *ac = apc->ac;
1925ca9c54d2SDexuan Cui 	struct mana_rxq *rxq;
1926ca9c54d2SDexuan Cui 	int err = 0;
1927ca9c54d2SDexuan Cui 	int i;
1928ca9c54d2SDexuan Cui 
1929ca9c54d2SDexuan Cui 	for (i = 0; i < apc->num_queues; i++) {
19301e2d0824SHaiyang Zhang 		rxq = mana_create_rxq(apc, i, &ac->eqs[i], ndev);
1931ca9c54d2SDexuan Cui 		if (!rxq) {
1932ca9c54d2SDexuan Cui 			err = -ENOMEM;
1933ca9c54d2SDexuan Cui 			goto out;
1934ca9c54d2SDexuan Cui 		}
1935ca9c54d2SDexuan Cui 
1936ca9c54d2SDexuan Cui 		u64_stats_init(&rxq->stats.syncp);
1937ca9c54d2SDexuan Cui 
1938ca9c54d2SDexuan Cui 		apc->rxqs[i] = rxq;
1939ca9c54d2SDexuan Cui 	}
1940ca9c54d2SDexuan Cui 
1941ca9c54d2SDexuan Cui 	apc->default_rxobj = apc->rxqs[0]->rxobj;
1942ca9c54d2SDexuan Cui out:
1943ca9c54d2SDexuan Cui 	return err;
1944ca9c54d2SDexuan Cui }
1945ca9c54d2SDexuan Cui 
1946ca9c54d2SDexuan Cui static void mana_destroy_vport(struct mana_port_context *apc)
1947ca9c54d2SDexuan Cui {
19481566e7d6SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
1949ca9c54d2SDexuan Cui 	struct mana_rxq *rxq;
1950ca9c54d2SDexuan Cui 	u32 rxq_idx;
1951ca9c54d2SDexuan Cui 
1952ca9c54d2SDexuan Cui 	for (rxq_idx = 0; rxq_idx < apc->num_queues; rxq_idx++) {
1953ca9c54d2SDexuan Cui 		rxq = apc->rxqs[rxq_idx];
1954ca9c54d2SDexuan Cui 		if (!rxq)
1955ca9c54d2SDexuan Cui 			continue;
1956ca9c54d2SDexuan Cui 
1957ca9c54d2SDexuan Cui 		mana_destroy_rxq(apc, rxq, true);
1958ca9c54d2SDexuan Cui 		apc->rxqs[rxq_idx] = NULL;
1959ca9c54d2SDexuan Cui 	}
1960ca9c54d2SDexuan Cui 
1961ca9c54d2SDexuan Cui 	mana_destroy_txq(apc);
1962b5c1c985SLong Li 	mana_uncfg_vport(apc);
19631566e7d6SDexuan Cui 
19641566e7d6SDexuan Cui 	if (gd->gdma_context->is_pf)
19651566e7d6SDexuan Cui 		mana_pf_deregister_hw_vport(apc);
1966ca9c54d2SDexuan Cui }
1967ca9c54d2SDexuan Cui 
1968ca9c54d2SDexuan Cui static int mana_create_vport(struct mana_port_context *apc,
1969ca9c54d2SDexuan Cui 			     struct net_device *net)
1970ca9c54d2SDexuan Cui {
1971ca9c54d2SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
1972ca9c54d2SDexuan Cui 	int err;
1973ca9c54d2SDexuan Cui 
1974ca9c54d2SDexuan Cui 	apc->default_rxobj = INVALID_MANA_HANDLE;
1975ca9c54d2SDexuan Cui 
19761566e7d6SDexuan Cui 	if (gd->gdma_context->is_pf) {
19771566e7d6SDexuan Cui 		err = mana_pf_register_hw_vport(apc);
19781566e7d6SDexuan Cui 		if (err)
19791566e7d6SDexuan Cui 			return err;
19801566e7d6SDexuan Cui 	}
19811566e7d6SDexuan Cui 
1982ca9c54d2SDexuan Cui 	err = mana_cfg_vport(apc, gd->pdid, gd->doorbell);
1983ca9c54d2SDexuan Cui 	if (err)
1984ca9c54d2SDexuan Cui 		return err;
1985ca9c54d2SDexuan Cui 
1986ca9c54d2SDexuan Cui 	return mana_create_txq(apc, net);
1987ca9c54d2SDexuan Cui }
1988ca9c54d2SDexuan Cui 
1989ca9c54d2SDexuan Cui static void mana_rss_table_init(struct mana_port_context *apc)
1990ca9c54d2SDexuan Cui {
1991ca9c54d2SDexuan Cui 	int i;
1992ca9c54d2SDexuan Cui 
1993ca9c54d2SDexuan Cui 	for (i = 0; i < MANA_INDIRECT_TABLE_SIZE; i++)
1994ca9c54d2SDexuan Cui 		apc->indir_table[i] =
1995ca9c54d2SDexuan Cui 			ethtool_rxfh_indir_default(i, apc->num_queues);
1996ca9c54d2SDexuan Cui }
1997ca9c54d2SDexuan Cui 
1998ca9c54d2SDexuan Cui int mana_config_rss(struct mana_port_context *apc, enum TRI_STATE rx,
1999ca9c54d2SDexuan Cui 		    bool update_hash, bool update_tab)
2000ca9c54d2SDexuan Cui {
2001ca9c54d2SDexuan Cui 	u32 queue_idx;
20026cc74443SDexuan Cui 	int err;
2003ca9c54d2SDexuan Cui 	int i;
2004ca9c54d2SDexuan Cui 
2005ca9c54d2SDexuan Cui 	if (update_tab) {
2006ca9c54d2SDexuan Cui 		for (i = 0; i < MANA_INDIRECT_TABLE_SIZE; i++) {
2007ca9c54d2SDexuan Cui 			queue_idx = apc->indir_table[i];
2008ca9c54d2SDexuan Cui 			apc->rxobj_table[i] = apc->rxqs[queue_idx]->rxobj;
2009ca9c54d2SDexuan Cui 		}
2010ca9c54d2SDexuan Cui 	}
2011ca9c54d2SDexuan Cui 
20126cc74443SDexuan Cui 	err = mana_cfg_vport_steering(apc, rx, true, update_hash, update_tab);
20136cc74443SDexuan Cui 	if (err)
20146cc74443SDexuan Cui 		return err;
20156cc74443SDexuan Cui 
20166cc74443SDexuan Cui 	mana_fence_rqs(apc);
20176cc74443SDexuan Cui 
20186cc74443SDexuan Cui 	return 0;
2019ca9c54d2SDexuan Cui }
2020ca9c54d2SDexuan Cui 
2021ca9c54d2SDexuan Cui static int mana_init_port(struct net_device *ndev)
2022ca9c54d2SDexuan Cui {
2023ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
2024ca9c54d2SDexuan Cui 	u32 max_txq, max_rxq, max_queues;
2025ca9c54d2SDexuan Cui 	int port_idx = apc->port_idx;
2026ca9c54d2SDexuan Cui 	u32 num_indirect_entries;
2027ca9c54d2SDexuan Cui 	int err;
2028ca9c54d2SDexuan Cui 
2029ca9c54d2SDexuan Cui 	err = mana_init_port_context(apc);
2030ca9c54d2SDexuan Cui 	if (err)
2031ca9c54d2SDexuan Cui 		return err;
2032ca9c54d2SDexuan Cui 
2033ca9c54d2SDexuan Cui 	err = mana_query_vport_cfg(apc, port_idx, &max_txq, &max_rxq,
2034ca9c54d2SDexuan Cui 				   &num_indirect_entries);
2035ca9c54d2SDexuan Cui 	if (err) {
20366c7ea696SDexuan Cui 		netdev_err(ndev, "Failed to query info for vPort %d\n",
20376c7ea696SDexuan Cui 			   port_idx);
2038ca9c54d2SDexuan Cui 		goto reset_apc;
2039ca9c54d2SDexuan Cui 	}
2040ca9c54d2SDexuan Cui 
2041ca9c54d2SDexuan Cui 	max_queues = min_t(u32, max_txq, max_rxq);
2042ca9c54d2SDexuan Cui 	if (apc->max_queues > max_queues)
2043ca9c54d2SDexuan Cui 		apc->max_queues = max_queues;
2044ca9c54d2SDexuan Cui 
2045ca9c54d2SDexuan Cui 	if (apc->num_queues > apc->max_queues)
2046ca9c54d2SDexuan Cui 		apc->num_queues = apc->max_queues;
2047ca9c54d2SDexuan Cui 
2048f3956ebbSJakub Kicinski 	eth_hw_addr_set(ndev, apc->mac_addr);
2049ca9c54d2SDexuan Cui 
2050ca9c54d2SDexuan Cui 	return 0;
2051ca9c54d2SDexuan Cui 
2052ca9c54d2SDexuan Cui reset_apc:
2053ca9c54d2SDexuan Cui 	kfree(apc->rxqs);
2054ca9c54d2SDexuan Cui 	apc->rxqs = NULL;
2055ca9c54d2SDexuan Cui 	return err;
2056ca9c54d2SDexuan Cui }
2057ca9c54d2SDexuan Cui 
2058ca9c54d2SDexuan Cui int mana_alloc_queues(struct net_device *ndev)
2059ca9c54d2SDexuan Cui {
2060ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
20611566e7d6SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
2062ca9c54d2SDexuan Cui 	int err;
2063ca9c54d2SDexuan Cui 
2064ca9c54d2SDexuan Cui 	err = mana_create_vport(apc, ndev);
2065ca9c54d2SDexuan Cui 	if (err)
20661e2d0824SHaiyang Zhang 		return err;
2067ca9c54d2SDexuan Cui 
2068ca9c54d2SDexuan Cui 	err = netif_set_real_num_tx_queues(ndev, apc->num_queues);
2069ca9c54d2SDexuan Cui 	if (err)
2070ca9c54d2SDexuan Cui 		goto destroy_vport;
2071ca9c54d2SDexuan Cui 
2072ca9c54d2SDexuan Cui 	err = mana_add_rx_queues(apc, ndev);
2073ca9c54d2SDexuan Cui 	if (err)
2074ca9c54d2SDexuan Cui 		goto destroy_vport;
2075ca9c54d2SDexuan Cui 
2076ca9c54d2SDexuan Cui 	apc->rss_state = apc->num_queues > 1 ? TRI_STATE_TRUE : TRI_STATE_FALSE;
2077ca9c54d2SDexuan Cui 
2078ca9c54d2SDexuan Cui 	err = netif_set_real_num_rx_queues(ndev, apc->num_queues);
2079ca9c54d2SDexuan Cui 	if (err)
2080ca9c54d2SDexuan Cui 		goto destroy_vport;
2081ca9c54d2SDexuan Cui 
2082ca9c54d2SDexuan Cui 	mana_rss_table_init(apc);
2083ca9c54d2SDexuan Cui 
2084ca9c54d2SDexuan Cui 	err = mana_config_rss(apc, TRI_STATE_TRUE, true, true);
2085ca9c54d2SDexuan Cui 	if (err)
2086ca9c54d2SDexuan Cui 		goto destroy_vport;
2087ca9c54d2SDexuan Cui 
20881566e7d6SDexuan Cui 	if (gd->gdma_context->is_pf) {
20891566e7d6SDexuan Cui 		err = mana_pf_register_filter(apc);
20901566e7d6SDexuan Cui 		if (err)
20911566e7d6SDexuan Cui 			goto destroy_vport;
20921566e7d6SDexuan Cui 	}
20931566e7d6SDexuan Cui 
2094ed5356b5SHaiyang Zhang 	mana_chn_setxdp(apc, mana_xdp_get(apc));
2095ed5356b5SHaiyang Zhang 
2096ca9c54d2SDexuan Cui 	return 0;
2097ca9c54d2SDexuan Cui 
2098ca9c54d2SDexuan Cui destroy_vport:
2099ca9c54d2SDexuan Cui 	mana_destroy_vport(apc);
2100ca9c54d2SDexuan Cui 	return err;
2101ca9c54d2SDexuan Cui }
2102ca9c54d2SDexuan Cui 
2103ca9c54d2SDexuan Cui int mana_attach(struct net_device *ndev)
2104ca9c54d2SDexuan Cui {
2105ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
2106ca9c54d2SDexuan Cui 	int err;
2107ca9c54d2SDexuan Cui 
2108ca9c54d2SDexuan Cui 	ASSERT_RTNL();
2109ca9c54d2SDexuan Cui 
2110ca9c54d2SDexuan Cui 	err = mana_init_port(ndev);
2111ca9c54d2SDexuan Cui 	if (err)
2112ca9c54d2SDexuan Cui 		return err;
2113ca9c54d2SDexuan Cui 
2114a137c069SHaiyang Zhang 	if (apc->port_st_save) {
2115ca9c54d2SDexuan Cui 		err = mana_alloc_queues(ndev);
2116ca9c54d2SDexuan Cui 		if (err) {
2117a137c069SHaiyang Zhang 			mana_cleanup_port_context(apc);
2118ca9c54d2SDexuan Cui 			return err;
2119ca9c54d2SDexuan Cui 		}
2120a137c069SHaiyang Zhang 	}
2121ca9c54d2SDexuan Cui 
2122ca9c54d2SDexuan Cui 	apc->port_is_up = apc->port_st_save;
2123ca9c54d2SDexuan Cui 
2124ca9c54d2SDexuan Cui 	/* Ensure port state updated before txq state */
2125ca9c54d2SDexuan Cui 	smp_wmb();
2126ca9c54d2SDexuan Cui 
2127a137c069SHaiyang Zhang 	if (apc->port_is_up)
2128ca9c54d2SDexuan Cui 		netif_carrier_on(ndev);
2129a137c069SHaiyang Zhang 
2130a137c069SHaiyang Zhang 	netif_device_attach(ndev);
2131ca9c54d2SDexuan Cui 
2132ca9c54d2SDexuan Cui 	return 0;
2133ca9c54d2SDexuan Cui }
2134ca9c54d2SDexuan Cui 
2135ca9c54d2SDexuan Cui static int mana_dealloc_queues(struct net_device *ndev)
2136ca9c54d2SDexuan Cui {
2137ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
21381566e7d6SDexuan Cui 	struct gdma_dev *gd = apc->ac->gdma_dev;
2139ca9c54d2SDexuan Cui 	struct mana_txq *txq;
2140ca9c54d2SDexuan Cui 	int i, err;
2141ca9c54d2SDexuan Cui 
2142ca9c54d2SDexuan Cui 	if (apc->port_is_up)
2143ca9c54d2SDexuan Cui 		return -EINVAL;
2144ca9c54d2SDexuan Cui 
2145ed5356b5SHaiyang Zhang 	mana_chn_setxdp(apc, NULL);
2146ed5356b5SHaiyang Zhang 
21471566e7d6SDexuan Cui 	if (gd->gdma_context->is_pf)
21481566e7d6SDexuan Cui 		mana_pf_deregister_filter(apc);
21491566e7d6SDexuan Cui 
2150ca9c54d2SDexuan Cui 	/* No packet can be transmitted now since apc->port_is_up is false.
2151ca9c54d2SDexuan Cui 	 * There is still a tiny chance that mana_poll_tx_cq() can re-enable
2152ca9c54d2SDexuan Cui 	 * a txq because it may not timely see apc->port_is_up being cleared
2153ca9c54d2SDexuan Cui 	 * to false, but it doesn't matter since mana_start_xmit() drops any
2154ca9c54d2SDexuan Cui 	 * new packets due to apc->port_is_up being false.
2155ca9c54d2SDexuan Cui 	 *
2156ca9c54d2SDexuan Cui 	 * Drain all the in-flight TX packets
2157ca9c54d2SDexuan Cui 	 */
2158ca9c54d2SDexuan Cui 	for (i = 0; i < apc->num_queues; i++) {
2159ca9c54d2SDexuan Cui 		txq = &apc->tx_qp[i].txq;
2160ca9c54d2SDexuan Cui 
2161ca9c54d2SDexuan Cui 		while (atomic_read(&txq->pending_sends) > 0)
2162ca9c54d2SDexuan Cui 			usleep_range(1000, 2000);
2163ca9c54d2SDexuan Cui 	}
2164ca9c54d2SDexuan Cui 
2165ca9c54d2SDexuan Cui 	/* We're 100% sure the queues can no longer be woken up, because
2166ca9c54d2SDexuan Cui 	 * we're sure now mana_poll_tx_cq() can't be running.
2167ca9c54d2SDexuan Cui 	 */
2168ca9c54d2SDexuan Cui 
2169ca9c54d2SDexuan Cui 	apc->rss_state = TRI_STATE_FALSE;
2170ca9c54d2SDexuan Cui 	err = mana_config_rss(apc, TRI_STATE_FALSE, false, false);
2171ca9c54d2SDexuan Cui 	if (err) {
2172ca9c54d2SDexuan Cui 		netdev_err(ndev, "Failed to disable vPort: %d\n", err);
2173ca9c54d2SDexuan Cui 		return err;
2174ca9c54d2SDexuan Cui 	}
2175ca9c54d2SDexuan Cui 
2176ca9c54d2SDexuan Cui 	mana_destroy_vport(apc);
2177ca9c54d2SDexuan Cui 
2178ca9c54d2SDexuan Cui 	return 0;
2179ca9c54d2SDexuan Cui }
2180ca9c54d2SDexuan Cui 
2181ca9c54d2SDexuan Cui int mana_detach(struct net_device *ndev, bool from_close)
2182ca9c54d2SDexuan Cui {
2183ca9c54d2SDexuan Cui 	struct mana_port_context *apc = netdev_priv(ndev);
2184ca9c54d2SDexuan Cui 	int err;
2185ca9c54d2SDexuan Cui 
2186ca9c54d2SDexuan Cui 	ASSERT_RTNL();
2187ca9c54d2SDexuan Cui 
2188ca9c54d2SDexuan Cui 	apc->port_st_save = apc->port_is_up;
2189ca9c54d2SDexuan Cui 	apc->port_is_up = false;
2190ca9c54d2SDexuan Cui 
2191ca9c54d2SDexuan Cui 	/* Ensure port state updated before txq state */
2192ca9c54d2SDexuan Cui 	smp_wmb();
2193ca9c54d2SDexuan Cui 
2194ca9c54d2SDexuan Cui 	netif_tx_disable(ndev);
2195ca9c54d2SDexuan Cui 	netif_carrier_off(ndev);
2196ca9c54d2SDexuan Cui 
2197ca9c54d2SDexuan Cui 	if (apc->port_st_save) {
2198ca9c54d2SDexuan Cui 		err = mana_dealloc_queues(ndev);
2199ca9c54d2SDexuan Cui 		if (err)
2200ca9c54d2SDexuan Cui 			return err;
2201ca9c54d2SDexuan Cui 	}
2202ca9c54d2SDexuan Cui 
2203ca9c54d2SDexuan Cui 	if (!from_close) {
2204ca9c54d2SDexuan Cui 		netif_device_detach(ndev);
2205ca9c54d2SDexuan Cui 		mana_cleanup_port_context(apc);
2206ca9c54d2SDexuan Cui 	}
2207ca9c54d2SDexuan Cui 
2208ca9c54d2SDexuan Cui 	return 0;
2209ca9c54d2SDexuan Cui }
2210ca9c54d2SDexuan Cui 
2211ca9c54d2SDexuan Cui static int mana_probe_port(struct mana_context *ac, int port_idx,
2212ca9c54d2SDexuan Cui 			   struct net_device **ndev_storage)
2213ca9c54d2SDexuan Cui {
2214ca9c54d2SDexuan Cui 	struct gdma_context *gc = ac->gdma_dev->gdma_context;
2215ca9c54d2SDexuan Cui 	struct mana_port_context *apc;
2216ca9c54d2SDexuan Cui 	struct net_device *ndev;
2217ca9c54d2SDexuan Cui 	int err;
2218ca9c54d2SDexuan Cui 
2219ca9c54d2SDexuan Cui 	ndev = alloc_etherdev_mq(sizeof(struct mana_port_context),
2220ca9c54d2SDexuan Cui 				 gc->max_num_queues);
2221ca9c54d2SDexuan Cui 	if (!ndev)
2222ca9c54d2SDexuan Cui 		return -ENOMEM;
2223ca9c54d2SDexuan Cui 
2224ca9c54d2SDexuan Cui 	*ndev_storage = ndev;
2225ca9c54d2SDexuan Cui 
2226ca9c54d2SDexuan Cui 	apc = netdev_priv(ndev);
2227ca9c54d2SDexuan Cui 	apc->ac = ac;
2228ca9c54d2SDexuan Cui 	apc->ndev = ndev;
2229ca9c54d2SDexuan Cui 	apc->max_queues = gc->max_num_queues;
22301e2d0824SHaiyang Zhang 	apc->num_queues = gc->max_num_queues;
2231ca9c54d2SDexuan Cui 	apc->port_handle = INVALID_MANA_HANDLE;
22321566e7d6SDexuan Cui 	apc->pf_filter_handle = INVALID_MANA_HANDLE;
2233ca9c54d2SDexuan Cui 	apc->port_idx = port_idx;
2234ca9c54d2SDexuan Cui 
2235b5c1c985SLong Li 	mutex_init(&apc->vport_mutex);
2236b5c1c985SLong Li 	apc->vport_use_count = 0;
2237b5c1c985SLong Li 
2238ca9c54d2SDexuan Cui 	ndev->netdev_ops = &mana_devops;
2239ca9c54d2SDexuan Cui 	ndev->ethtool_ops = &mana_ethtool_ops;
2240ca9c54d2SDexuan Cui 	ndev->mtu = ETH_DATA_LEN;
2241ca9c54d2SDexuan Cui 	ndev->max_mtu = ndev->mtu;
2242ca9c54d2SDexuan Cui 	ndev->min_mtu = ndev->mtu;
2243ca9c54d2SDexuan Cui 	ndev->needed_headroom = MANA_HEADROOM;
2244d44089e5SLong Li 	ndev->dev_port = port_idx;
2245ca9c54d2SDexuan Cui 	SET_NETDEV_DEV(ndev, gc->dev);
2246ca9c54d2SDexuan Cui 
2247ca9c54d2SDexuan Cui 	netif_carrier_off(ndev);
2248ca9c54d2SDexuan Cui 
2249ca9c54d2SDexuan Cui 	netdev_rss_key_fill(apc->hashkey, MANA_HASH_KEY_SIZE);
2250ca9c54d2SDexuan Cui 
2251ca9c54d2SDexuan Cui 	err = mana_init_port(ndev);
2252ca9c54d2SDexuan Cui 	if (err)
2253ca9c54d2SDexuan Cui 		goto free_net;
2254ca9c54d2SDexuan Cui 
2255ca9c54d2SDexuan Cui 	netdev_lockdep_set_classes(ndev);
2256ca9c54d2SDexuan Cui 
2257ca9c54d2SDexuan Cui 	ndev->hw_features = NETIF_F_SG | NETIF_F_IP_CSUM | NETIF_F_IPV6_CSUM;
2258ca9c54d2SDexuan Cui 	ndev->hw_features |= NETIF_F_RXCSUM;
2259ca9c54d2SDexuan Cui 	ndev->hw_features |= NETIF_F_TSO | NETIF_F_TSO6;
2260ca9c54d2SDexuan Cui 	ndev->hw_features |= NETIF_F_RXHASH;
2261ca9c54d2SDexuan Cui 	ndev->features = ndev->hw_features;
2262ca9c54d2SDexuan Cui 	ndev->vlan_features = 0;
226366c0e13aSMarek Majtyka 	ndev->xdp_features = NETDEV_XDP_ACT_BASIC | NETDEV_XDP_ACT_REDIRECT |
226466c0e13aSMarek Majtyka 			     NETDEV_XDP_ACT_NDO_XMIT;
2265ca9c54d2SDexuan Cui 
2266ca9c54d2SDexuan Cui 	err = register_netdev(ndev);
2267ca9c54d2SDexuan Cui 	if (err) {
2268ca9c54d2SDexuan Cui 		netdev_err(ndev, "Unable to register netdev.\n");
2269ca9c54d2SDexuan Cui 		goto reset_apc;
2270ca9c54d2SDexuan Cui 	}
2271ca9c54d2SDexuan Cui 
2272ca9c54d2SDexuan Cui 	return 0;
2273ca9c54d2SDexuan Cui 
2274ca9c54d2SDexuan Cui reset_apc:
2275ca9c54d2SDexuan Cui 	kfree(apc->rxqs);
2276ca9c54d2SDexuan Cui 	apc->rxqs = NULL;
2277ca9c54d2SDexuan Cui free_net:
2278ca9c54d2SDexuan Cui 	*ndev_storage = NULL;
2279ca9c54d2SDexuan Cui 	netdev_err(ndev, "Failed to probe vPort %d: %d\n", port_idx, err);
2280ca9c54d2SDexuan Cui 	free_netdev(ndev);
2281ca9c54d2SDexuan Cui 	return err;
2282ca9c54d2SDexuan Cui }
2283ca9c54d2SDexuan Cui 
2284a69839d4SLong Li static void adev_release(struct device *dev)
2285a69839d4SLong Li {
2286a69839d4SLong Li 	struct mana_adev *madev = container_of(dev, struct mana_adev, adev.dev);
2287a69839d4SLong Li 
2288a69839d4SLong Li 	kfree(madev);
2289a69839d4SLong Li }
2290a69839d4SLong Li 
2291a69839d4SLong Li static void remove_adev(struct gdma_dev *gd)
2292a69839d4SLong Li {
2293a69839d4SLong Li 	struct auxiliary_device *adev = gd->adev;
2294a69839d4SLong Li 	int id = adev->id;
2295a69839d4SLong Li 
2296a69839d4SLong Li 	auxiliary_device_delete(adev);
2297a69839d4SLong Li 	auxiliary_device_uninit(adev);
2298a69839d4SLong Li 
2299a69839d4SLong Li 	mana_adev_idx_free(id);
2300a69839d4SLong Li 	gd->adev = NULL;
2301a69839d4SLong Li }
2302a69839d4SLong Li 
2303a69839d4SLong Li static int add_adev(struct gdma_dev *gd)
2304a69839d4SLong Li {
2305a69839d4SLong Li 	struct auxiliary_device *adev;
2306a69839d4SLong Li 	struct mana_adev *madev;
2307a69839d4SLong Li 	int ret;
2308a69839d4SLong Li 
2309a69839d4SLong Li 	madev = kzalloc(sizeof(*madev), GFP_KERNEL);
2310a69839d4SLong Li 	if (!madev)
2311a69839d4SLong Li 		return -ENOMEM;
2312a69839d4SLong Li 
2313a69839d4SLong Li 	adev = &madev->adev;
2314a69839d4SLong Li 	ret = mana_adev_idx_alloc();
2315a69839d4SLong Li 	if (ret < 0)
2316a69839d4SLong Li 		goto idx_fail;
2317a69839d4SLong Li 	adev->id = ret;
2318a69839d4SLong Li 
2319a69839d4SLong Li 	adev->name = "rdma";
2320a69839d4SLong Li 	adev->dev.parent = gd->gdma_context->dev;
2321a69839d4SLong Li 	adev->dev.release = adev_release;
2322a69839d4SLong Li 	madev->mdev = gd;
2323a69839d4SLong Li 
2324a69839d4SLong Li 	ret = auxiliary_device_init(adev);
2325a69839d4SLong Li 	if (ret)
2326a69839d4SLong Li 		goto init_fail;
2327a69839d4SLong Li 
2328a69839d4SLong Li 	ret = auxiliary_device_add(adev);
2329a69839d4SLong Li 	if (ret)
2330a69839d4SLong Li 		goto add_fail;
2331a69839d4SLong Li 
2332a69839d4SLong Li 	gd->adev = adev;
2333a69839d4SLong Li 	return 0;
2334a69839d4SLong Li 
2335a69839d4SLong Li add_fail:
2336a69839d4SLong Li 	auxiliary_device_uninit(adev);
2337a69839d4SLong Li 
2338a69839d4SLong Li init_fail:
2339a69839d4SLong Li 	mana_adev_idx_free(adev->id);
2340a69839d4SLong Li 
2341a69839d4SLong Li idx_fail:
2342a69839d4SLong Li 	kfree(madev);
2343a69839d4SLong Li 
2344a69839d4SLong Li 	return ret;
2345a69839d4SLong Li }
2346a69839d4SLong Li 
2347635096a8SDexuan Cui int mana_probe(struct gdma_dev *gd, bool resuming)
2348ca9c54d2SDexuan Cui {
2349ca9c54d2SDexuan Cui 	struct gdma_context *gc = gd->gdma_context;
2350635096a8SDexuan Cui 	struct mana_context *ac = gd->driver_data;
2351ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
2352635096a8SDexuan Cui 	u16 num_ports = 0;
2353ca9c54d2SDexuan Cui 	int err;
2354ca9c54d2SDexuan Cui 	int i;
2355ca9c54d2SDexuan Cui 
2356ca9c54d2SDexuan Cui 	dev_info(dev,
2357ca9c54d2SDexuan Cui 		 "Microsoft Azure Network Adapter protocol version: %d.%d.%d\n",
2358ca9c54d2SDexuan Cui 		 MANA_MAJOR_VERSION, MANA_MINOR_VERSION, MANA_MICRO_VERSION);
2359ca9c54d2SDexuan Cui 
2360ca9c54d2SDexuan Cui 	err = mana_gd_register_device(gd);
2361ca9c54d2SDexuan Cui 	if (err)
2362ca9c54d2SDexuan Cui 		return err;
2363ca9c54d2SDexuan Cui 
2364635096a8SDexuan Cui 	if (!resuming) {
2365ca9c54d2SDexuan Cui 		ac = kzalloc(sizeof(*ac), GFP_KERNEL);
2366ca9c54d2SDexuan Cui 		if (!ac)
2367ca9c54d2SDexuan Cui 			return -ENOMEM;
2368ca9c54d2SDexuan Cui 
2369ca9c54d2SDexuan Cui 		ac->gdma_dev = gd;
2370ca9c54d2SDexuan Cui 		gd->driver_data = ac;
2371635096a8SDexuan Cui 	}
2372ca9c54d2SDexuan Cui 
23731e2d0824SHaiyang Zhang 	err = mana_create_eq(ac);
23741e2d0824SHaiyang Zhang 	if (err)
23751e2d0824SHaiyang Zhang 		goto out;
23761e2d0824SHaiyang Zhang 
2377ca9c54d2SDexuan Cui 	err = mana_query_device_cfg(ac, MANA_MAJOR_VERSION, MANA_MINOR_VERSION,
2378635096a8SDexuan Cui 				    MANA_MICRO_VERSION, &num_ports);
2379ca9c54d2SDexuan Cui 	if (err)
2380ca9c54d2SDexuan Cui 		goto out;
2381ca9c54d2SDexuan Cui 
2382635096a8SDexuan Cui 	if (!resuming) {
2383635096a8SDexuan Cui 		ac->num_ports = num_ports;
2384635096a8SDexuan Cui 	} else {
2385635096a8SDexuan Cui 		if (ac->num_ports != num_ports) {
2386635096a8SDexuan Cui 			dev_err(dev, "The number of vPorts changed: %d->%d\n",
2387635096a8SDexuan Cui 				ac->num_ports, num_ports);
2388635096a8SDexuan Cui 			err = -EPROTO;
2389635096a8SDexuan Cui 			goto out;
2390635096a8SDexuan Cui 		}
2391635096a8SDexuan Cui 	}
2392635096a8SDexuan Cui 
2393635096a8SDexuan Cui 	if (ac->num_ports == 0)
2394635096a8SDexuan Cui 		dev_err(dev, "Failed to detect any vPort\n");
2395635096a8SDexuan Cui 
2396ca9c54d2SDexuan Cui 	if (ac->num_ports > MAX_PORTS_IN_MANA_DEV)
2397ca9c54d2SDexuan Cui 		ac->num_ports = MAX_PORTS_IN_MANA_DEV;
2398ca9c54d2SDexuan Cui 
2399635096a8SDexuan Cui 	if (!resuming) {
2400ca9c54d2SDexuan Cui 		for (i = 0; i < ac->num_ports; i++) {
2401ca9c54d2SDexuan Cui 			err = mana_probe_port(ac, i, &ac->ports[i]);
2402ca9c54d2SDexuan Cui 			if (err)
2403ca9c54d2SDexuan Cui 				break;
2404ca9c54d2SDexuan Cui 		}
2405635096a8SDexuan Cui 	} else {
2406635096a8SDexuan Cui 		for (i = 0; i < ac->num_ports; i++) {
2407635096a8SDexuan Cui 			rtnl_lock();
2408635096a8SDexuan Cui 			err = mana_attach(ac->ports[i]);
2409635096a8SDexuan Cui 			rtnl_unlock();
2410635096a8SDexuan Cui 			if (err)
2411635096a8SDexuan Cui 				break;
2412635096a8SDexuan Cui 		}
2413635096a8SDexuan Cui 	}
2414a69839d4SLong Li 
2415a69839d4SLong Li 	err = add_adev(gd);
2416ca9c54d2SDexuan Cui out:
2417ca9c54d2SDexuan Cui 	if (err)
2418635096a8SDexuan Cui 		mana_remove(gd, false);
2419ca9c54d2SDexuan Cui 
2420ca9c54d2SDexuan Cui 	return err;
2421ca9c54d2SDexuan Cui }
2422ca9c54d2SDexuan Cui 
2423635096a8SDexuan Cui void mana_remove(struct gdma_dev *gd, bool suspending)
2424ca9c54d2SDexuan Cui {
2425ca9c54d2SDexuan Cui 	struct gdma_context *gc = gd->gdma_context;
2426ca9c54d2SDexuan Cui 	struct mana_context *ac = gd->driver_data;
2427ca9c54d2SDexuan Cui 	struct device *dev = gc->dev;
2428ca9c54d2SDexuan Cui 	struct net_device *ndev;
2429635096a8SDexuan Cui 	int err;
2430ca9c54d2SDexuan Cui 	int i;
2431ca9c54d2SDexuan Cui 
2432a69839d4SLong Li 	/* adev currently doesn't support suspending, always remove it */
2433a69839d4SLong Li 	if (gd->adev)
2434a69839d4SLong Li 		remove_adev(gd);
2435a69839d4SLong Li 
2436ca9c54d2SDexuan Cui 	for (i = 0; i < ac->num_ports; i++) {
2437ca9c54d2SDexuan Cui 		ndev = ac->ports[i];
2438ca9c54d2SDexuan Cui 		if (!ndev) {
2439ca9c54d2SDexuan Cui 			if (i == 0)
2440ca9c54d2SDexuan Cui 				dev_err(dev, "No net device to remove\n");
2441ca9c54d2SDexuan Cui 			goto out;
2442ca9c54d2SDexuan Cui 		}
2443ca9c54d2SDexuan Cui 
2444ca9c54d2SDexuan Cui 		/* All cleanup actions should stay after rtnl_lock(), otherwise
2445ca9c54d2SDexuan Cui 		 * other functions may access partially cleaned up data.
2446ca9c54d2SDexuan Cui 		 */
2447ca9c54d2SDexuan Cui 		rtnl_lock();
2448ca9c54d2SDexuan Cui 
2449635096a8SDexuan Cui 		err = mana_detach(ndev, false);
2450635096a8SDexuan Cui 		if (err)
2451635096a8SDexuan Cui 			netdev_err(ndev, "Failed to detach vPort %d: %d\n",
2452635096a8SDexuan Cui 				   i, err);
2453635096a8SDexuan Cui 
2454635096a8SDexuan Cui 		if (suspending) {
2455635096a8SDexuan Cui 			/* No need to unregister the ndev. */
2456635096a8SDexuan Cui 			rtnl_unlock();
2457635096a8SDexuan Cui 			continue;
2458635096a8SDexuan Cui 		}
2459ca9c54d2SDexuan Cui 
2460ca9c54d2SDexuan Cui 		unregister_netdevice(ndev);
2461ca9c54d2SDexuan Cui 
2462ca9c54d2SDexuan Cui 		rtnl_unlock();
2463ca9c54d2SDexuan Cui 
2464ca9c54d2SDexuan Cui 		free_netdev(ndev);
2465ca9c54d2SDexuan Cui 	}
24661e2d0824SHaiyang Zhang 
24671e2d0824SHaiyang Zhang 	mana_destroy_eq(ac);
2468ca9c54d2SDexuan Cui out:
2469ca9c54d2SDexuan Cui 	mana_gd_deregister_device(gd);
2470635096a8SDexuan Cui 
2471635096a8SDexuan Cui 	if (suspending)
2472635096a8SDexuan Cui 		return;
2473635096a8SDexuan Cui 
2474ca9c54d2SDexuan Cui 	gd->driver_data = NULL;
2475ca9c54d2SDexuan Cui 	gd->gdma_context = NULL;
2476ca9c54d2SDexuan Cui 	kfree(ac);
2477ca9c54d2SDexuan Cui }
2478