xref: /dpdk/drivers/net/bnxt/bnxt_ring.c (revision bdf4a3c6)
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(c) 2014-2021 Broadcom
3  * All rights reserved.
4  */
5 
6 #include <rte_bitmap.h>
7 #include <rte_memzone.h>
8 #include <rte_malloc.h>
9 #include <unistd.h>
10 
11 #include "bnxt.h"
12 #include "bnxt_hwrm.h"
13 #include "bnxt_ring.h"
14 #include "bnxt_rxq.h"
15 #include "bnxt_rxr.h"
16 #include "bnxt_txq.h"
17 #include "bnxt_txr.h"
18 
19 #include "hsi_struct_def_dpdk.h"
20 
21 /*
22  * Generic ring handling
23  */
24 
25 void bnxt_free_ring(struct bnxt_ring *ring)
26 {
27 	if (!ring)
28 		return;
29 
30 	if (ring->vmem_size && *ring->vmem) {
31 		memset((char *)*ring->vmem, 0, ring->vmem_size);
32 		*ring->vmem = NULL;
33 	}
34 	ring->mem_zone = NULL;
35 }
36 
37 /*
38  * Ring groups
39  */
40 
41 static void bnxt_init_ring_grps(struct bnxt *bp)
42 {
43 	unsigned int i;
44 
45 	for (i = 0; i < bp->max_ring_grps; i++)
46 		memset(&bp->grp_info[i], (uint8_t)HWRM_NA_SIGNATURE,
47 		       sizeof(struct bnxt_ring_grp_info));
48 }
49 
50 int bnxt_alloc_ring_grps(struct bnxt *bp)
51 {
52 	if (bp->max_tx_rings == 0) {
53 		PMD_DRV_LOG(ERR, "No TX rings available!\n");
54 		return -EBUSY;
55 	}
56 
57 	/* THOR does not support ring groups.
58 	 * But we will use the array to save RSS context IDs.
59 	 */
60 	if (BNXT_CHIP_P5(bp)) {
61 		bp->max_ring_grps = BNXT_MAX_RSS_CTXTS_P5;
62 	} else if (bp->max_ring_grps < bp->rx_cp_nr_rings) {
63 		/* 1 ring is for default completion ring */
64 		PMD_DRV_LOG(ERR, "Insufficient resource: Ring Group\n");
65 		return -ENOSPC;
66 	}
67 
68 	if (BNXT_HAS_RING_GRPS(bp)) {
69 		bp->grp_info = rte_zmalloc("bnxt_grp_info",
70 					   sizeof(*bp->grp_info) *
71 					   bp->max_ring_grps, 0);
72 		if (!bp->grp_info) {
73 			PMD_DRV_LOG(ERR,
74 				    "Failed to alloc grp info tbl.\n");
75 			return -ENOMEM;
76 		}
77 		bnxt_init_ring_grps(bp);
78 	}
79 
80 	return 0;
81 }
82 
83 /*
84  * Allocates a completion ring with vmem and stats optionally also allocating
85  * a TX and/or RX ring.  Passing NULL as tx_ring_info and/or rx_ring_info
86  * to not allocate them.
87  *
88  * Order in the allocation is:
89  * stats - Always non-zero length
90  * cp vmem - Always zero-length, supported for the bnxt_ring abstraction
91  * tx vmem - Only non-zero length if tx_ring_info is not NULL
92  * rx vmem - Only non-zero length if rx_ring_info is not NULL
93  * cp bd ring - Always non-zero length
94  * tx bd ring - Only non-zero length if tx_ring_info is not NULL
95  * rx bd ring - Only non-zero length if rx_ring_info is not NULL
96  */
97 int bnxt_alloc_rings(struct bnxt *bp, unsigned int socket_id, uint16_t qidx,
98 			    struct bnxt_tx_queue *txq,
99 			    struct bnxt_rx_queue *rxq,
100 			    struct bnxt_cp_ring_info *cp_ring_info,
101 			    struct bnxt_cp_ring_info *nq_ring_info,
102 			    const char *suffix)
103 {
104 	struct bnxt_ring *cp_ring = cp_ring_info->cp_ring_struct;
105 	struct bnxt_rx_ring_info *rx_ring_info = rxq ? rxq->rx_ring : NULL;
106 	struct bnxt_tx_ring_info *tx_ring_info = txq ? txq->tx_ring : NULL;
107 	struct bnxt_ring *tx_ring;
108 	struct bnxt_ring *rx_ring;
109 	struct rte_pci_device *pdev = bp->pdev;
110 	uint64_t rx_offloads = bp->eth_dev->data->dev_conf.rxmode.offloads;
111 	const struct rte_memzone *mz = NULL;
112 	char mz_name[RTE_MEMZONE_NAMESIZE];
113 	rte_iova_t mz_phys_addr;
114 
115 	int stats_len = (tx_ring_info || rx_ring_info) ?
116 	    RTE_CACHE_LINE_ROUNDUP(sizeof(struct hwrm_stat_ctx_query_output) -
117 				   sizeof (struct hwrm_resp_hdr)) : 0;
118 	stats_len = RTE_ALIGN(stats_len, 128);
119 
120 	int cp_vmem_start = stats_len;
121 	int cp_vmem_len = RTE_CACHE_LINE_ROUNDUP(cp_ring->vmem_size);
122 	cp_vmem_len = RTE_ALIGN(cp_vmem_len, 128);
123 
124 	int nq_vmem_len = nq_ring_info ?
125 		RTE_CACHE_LINE_ROUNDUP(cp_ring->vmem_size) : 0;
126 	nq_vmem_len = RTE_ALIGN(nq_vmem_len, 128);
127 
128 	int nq_vmem_start = cp_vmem_start + cp_vmem_len;
129 
130 	int tx_vmem_start = nq_vmem_start + nq_vmem_len;
131 	int tx_vmem_len =
132 	    tx_ring_info ? RTE_CACHE_LINE_ROUNDUP(tx_ring_info->
133 						tx_ring_struct->vmem_size) : 0;
134 	tx_vmem_len = RTE_ALIGN(tx_vmem_len, 128);
135 
136 	int rx_vmem_start = tx_vmem_start + tx_vmem_len;
137 	int rx_vmem_len = rx_ring_info ?
138 		RTE_CACHE_LINE_ROUNDUP(rx_ring_info->
139 						rx_ring_struct->vmem_size) : 0;
140 	rx_vmem_len = RTE_ALIGN(rx_vmem_len, 128);
141 	int ag_vmem_start = 0;
142 	int ag_vmem_len = 0;
143 	int cp_ring_start =  0;
144 	int nq_ring_start = 0;
145 
146 	ag_vmem_start = rx_vmem_start + rx_vmem_len;
147 	ag_vmem_len = rx_ring_info ? RTE_CACHE_LINE_ROUNDUP(
148 				rx_ring_info->ag_ring_struct->vmem_size) : 0;
149 	cp_ring_start = ag_vmem_start + ag_vmem_len;
150 	cp_ring_start = RTE_ALIGN(cp_ring_start, 4096);
151 
152 	int cp_ring_len = RTE_CACHE_LINE_ROUNDUP(cp_ring->ring_size *
153 						 sizeof(struct cmpl_base));
154 	cp_ring_len = RTE_ALIGN(cp_ring_len, 128);
155 	nq_ring_start = cp_ring_start + cp_ring_len;
156 	nq_ring_start = RTE_ALIGN(nq_ring_start, 4096);
157 
158 	int nq_ring_len = nq_ring_info ? cp_ring_len : 0;
159 
160 	int tx_ring_start = nq_ring_start + nq_ring_len;
161 	tx_ring_start = RTE_ALIGN(tx_ring_start, 4096);
162 	int tx_ring_len = tx_ring_info ?
163 	    RTE_CACHE_LINE_ROUNDUP(tx_ring_info->tx_ring_struct->ring_size *
164 				   sizeof(struct tx_bd_long)) : 0;
165 	tx_ring_len = RTE_ALIGN(tx_ring_len, 4096);
166 
167 	int rx_ring_start = tx_ring_start + tx_ring_len;
168 	rx_ring_start = RTE_ALIGN(rx_ring_start, 4096);
169 	int rx_ring_len =  rx_ring_info ?
170 		RTE_CACHE_LINE_ROUNDUP(rx_ring_info->rx_ring_struct->ring_size *
171 		sizeof(struct rx_prod_pkt_bd)) : 0;
172 	rx_ring_len = RTE_ALIGN(rx_ring_len, 4096);
173 
174 	int ag_ring_start = rx_ring_start + rx_ring_len;
175 	ag_ring_start = RTE_ALIGN(ag_ring_start, 4096);
176 	int ag_ring_len = rx_ring_len * AGG_RING_SIZE_FACTOR;
177 	ag_ring_len = RTE_ALIGN(ag_ring_len, 4096);
178 
179 	int ag_bitmap_start = ag_ring_start + ag_ring_len;
180 	int ag_bitmap_len =  rx_ring_info ?
181 		RTE_CACHE_LINE_ROUNDUP(rte_bitmap_get_memory_footprint(
182 			rx_ring_info->rx_ring_struct->ring_size *
183 			AGG_RING_SIZE_FACTOR)) : 0;
184 
185 	int tpa_info_start = ag_bitmap_start + ag_bitmap_len;
186 	int tpa_info_len = 0;
187 
188 	if (rx_ring_info && (rx_offloads & DEV_RX_OFFLOAD_TCP_LRO)) {
189 		int tpa_max = BNXT_TPA_MAX_AGGS(bp);
190 
191 		tpa_info_len = tpa_max * sizeof(struct bnxt_tpa_info);
192 		tpa_info_len = RTE_CACHE_LINE_ROUNDUP(tpa_info_len);
193 	}
194 
195 	int total_alloc_len = tpa_info_start;
196 	total_alloc_len += tpa_info_len;
197 
198 	snprintf(mz_name, RTE_MEMZONE_NAMESIZE,
199 		 "bnxt_" PCI_PRI_FMT "-%04x_%s", pdev->addr.domain,
200 		 pdev->addr.bus, pdev->addr.devid, pdev->addr.function, qidx,
201 		 suffix);
202 	mz_name[RTE_MEMZONE_NAMESIZE - 1] = 0;
203 	mz = rte_memzone_lookup(mz_name);
204 	if (!mz) {
205 		mz = rte_memzone_reserve_aligned(mz_name, total_alloc_len,
206 				socket_id,
207 				RTE_MEMZONE_2MB |
208 				RTE_MEMZONE_SIZE_HINT_ONLY |
209 				RTE_MEMZONE_IOVA_CONTIG,
210 				getpagesize());
211 		if (mz == NULL)
212 			return -ENOMEM;
213 	}
214 	memset(mz->addr, 0, mz->len);
215 	mz_phys_addr = mz->iova;
216 
217 	if (tx_ring_info) {
218 		txq->mz = mz;
219 		tx_ring = tx_ring_info->tx_ring_struct;
220 
221 		tx_ring->bd = ((char *)mz->addr + tx_ring_start);
222 		tx_ring_info->tx_desc_ring = (struct tx_bd_long *)tx_ring->bd;
223 		tx_ring->bd_dma = mz_phys_addr + tx_ring_start;
224 		tx_ring_info->tx_desc_mapping = tx_ring->bd_dma;
225 		tx_ring->mem_zone = (const void *)mz;
226 
227 		if (!tx_ring->bd)
228 			return -ENOMEM;
229 		if (tx_ring->vmem_size) {
230 			tx_ring->vmem =
231 			    (void **)((char *)mz->addr + tx_vmem_start);
232 			tx_ring_info->tx_buf_ring =
233 			    (struct rte_mbuf **)tx_ring->vmem;
234 		}
235 	}
236 
237 	if (rx_ring_info) {
238 		rxq->mz = mz;
239 		rx_ring = rx_ring_info->rx_ring_struct;
240 
241 		rx_ring->bd = ((char *)mz->addr + rx_ring_start);
242 		rx_ring_info->rx_desc_ring =
243 		    (struct rx_prod_pkt_bd *)rx_ring->bd;
244 		rx_ring->bd_dma = mz_phys_addr + rx_ring_start;
245 		rx_ring_info->rx_desc_mapping = rx_ring->bd_dma;
246 		rx_ring->mem_zone = (const void *)mz;
247 
248 		if (!rx_ring->bd)
249 			return -ENOMEM;
250 		if (rx_ring->vmem_size) {
251 			rx_ring->vmem =
252 			    (void **)((char *)mz->addr + rx_vmem_start);
253 			rx_ring_info->rx_buf_ring =
254 			    (struct rte_mbuf **)rx_ring->vmem;
255 		}
256 
257 		rx_ring = rx_ring_info->ag_ring_struct;
258 
259 		rx_ring->bd = ((char *)mz->addr + ag_ring_start);
260 		rx_ring_info->ag_desc_ring =
261 		    (struct rx_prod_pkt_bd *)rx_ring->bd;
262 		rx_ring->bd_dma = mz->iova + ag_ring_start;
263 		rx_ring_info->ag_desc_mapping = rx_ring->bd_dma;
264 		rx_ring->mem_zone = (const void *)mz;
265 
266 		if (!rx_ring->bd)
267 			return -ENOMEM;
268 		if (rx_ring->vmem_size) {
269 			rx_ring->vmem =
270 			    (void **)((char *)mz->addr + ag_vmem_start);
271 			rx_ring_info->ag_buf_ring =
272 			    (struct rte_mbuf **)rx_ring->vmem;
273 		}
274 
275 		rx_ring_info->ag_bitmap =
276 		    rte_bitmap_init(rx_ring_info->rx_ring_struct->ring_size *
277 				    AGG_RING_SIZE_FACTOR, (uint8_t *)mz->addr +
278 				    ag_bitmap_start, ag_bitmap_len);
279 
280 		/* TPA info */
281 		if (rx_offloads & DEV_RX_OFFLOAD_TCP_LRO)
282 			rx_ring_info->tpa_info =
283 				((struct bnxt_tpa_info *)((char *)mz->addr +
284 							  tpa_info_start));
285 	}
286 
287 	cp_ring->bd = ((char *)mz->addr + cp_ring_start);
288 	cp_ring->bd_dma = mz_phys_addr + cp_ring_start;
289 	cp_ring_info->cp_desc_ring = cp_ring->bd;
290 	cp_ring_info->cp_desc_mapping = cp_ring->bd_dma;
291 	cp_ring->mem_zone = (const void *)mz;
292 
293 	if (!cp_ring->bd)
294 		return -ENOMEM;
295 	if (cp_ring->vmem_size)
296 		*cp_ring->vmem = ((char *)mz->addr + stats_len);
297 	if (stats_len) {
298 		cp_ring_info->hw_stats = mz->addr;
299 		cp_ring_info->hw_stats_map = mz_phys_addr;
300 	}
301 	cp_ring_info->hw_stats_ctx_id = HWRM_NA_SIGNATURE;
302 
303 	if (nq_ring_info) {
304 		struct bnxt_ring *nq_ring = nq_ring_info->cp_ring_struct;
305 
306 		nq_ring->bd = (char *)mz->addr + nq_ring_start;
307 		nq_ring->bd_dma = mz_phys_addr + nq_ring_start;
308 		nq_ring_info->cp_desc_ring = nq_ring->bd;
309 		nq_ring_info->cp_desc_mapping = nq_ring->bd_dma;
310 		nq_ring->mem_zone = (const void *)mz;
311 
312 		if (!nq_ring->bd)
313 			return -ENOMEM;
314 		if (nq_ring->vmem_size)
315 			*nq_ring->vmem = (char *)mz->addr + nq_vmem_start;
316 
317 		nq_ring_info->hw_stats_ctx_id = HWRM_NA_SIGNATURE;
318 	}
319 
320 	return 0;
321 }
322 
323 static void bnxt_init_dflt_coal(struct bnxt_coal *coal)
324 {
325 	/* Tick values in micro seconds.
326 	 * 1 coal_buf x bufs_per_record = 1 completion record.
327 	 */
328 	coal->num_cmpl_aggr_int = BNXT_NUM_CMPL_AGGR_INT;
329 	/* This is a 6-bit value and must not be 0, or we'll get non stop IRQ */
330 	coal->num_cmpl_dma_aggr = BNXT_NUM_CMPL_DMA_AGGR;
331 	/* This is a 6-bit value and must not be 0, or we'll get non stop IRQ */
332 	coal->num_cmpl_dma_aggr_during_int = BNXT_NUM_CMPL_DMA_AGGR_DURING_INT;
333 	coal->int_lat_tmr_max = BNXT_INT_LAT_TMR_MAX;
334 	/* min timer set to 1/2 of interrupt timer */
335 	coal->int_lat_tmr_min = BNXT_INT_LAT_TMR_MIN;
336 	/* buf timer set to 1/4 of interrupt timer */
337 	coal->cmpl_aggr_dma_tmr = BNXT_CMPL_AGGR_DMA_TMR;
338 	coal->cmpl_aggr_dma_tmr_during_int = BNXT_CMPL_AGGR_DMA_TMR_DURING_INT;
339 }
340 
341 static void bnxt_set_db(struct bnxt *bp,
342 			struct bnxt_db_info *db,
343 			uint32_t ring_type,
344 			uint32_t map_idx,
345 			uint32_t fid,
346 			uint32_t ring_mask)
347 {
348 	if (BNXT_CHIP_P5(bp)) {
349 		int db_offset = DB_PF_OFFSET;
350 		switch (ring_type) {
351 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_TX:
352 			db->db_key64 = DBR_PATH_L2 | DBR_TYPE_SQ;
353 			break;
354 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_RX:
355 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_RX_AGG:
356 			db->db_key64 = DBR_PATH_L2 | DBR_TYPE_SRQ;
357 			break;
358 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_L2_CMPL:
359 			db->db_key64 = DBR_PATH_L2 | DBR_TYPE_CQ;
360 			break;
361 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_NQ:
362 			db->db_key64 = DBR_PATH_L2;
363 			break;
364 		}
365 		if (BNXT_CHIP_SR2(bp)) {
366 			db->db_key64 |= DBR_VALID;
367 			db_offset = bp->legacy_db_size;
368 		} else if (BNXT_VF(bp)) {
369 			db_offset = DB_VF_OFFSET;
370 		}
371 
372 		db->doorbell = (char *)bp->doorbell_base + db_offset;
373 		db->db_key64 |= (uint64_t)fid << DBR_XID_SFT;
374 		db->db_64 = true;
375 	} else {
376 		db->doorbell = (char *)bp->doorbell_base + map_idx * 0x80;
377 		switch (ring_type) {
378 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_TX:
379 			db->db_key32 = DB_KEY_TX;
380 			break;
381 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_RX:
382 			db->db_key32 = DB_KEY_RX;
383 			break;
384 		case HWRM_RING_ALLOC_INPUT_RING_TYPE_L2_CMPL:
385 			db->db_key32 = DB_KEY_CP;
386 			break;
387 		}
388 		db->db_64 = false;
389 	}
390 	db->db_ring_mask = ring_mask;
391 
392 	if (BNXT_CHIP_SR2(bp)) {
393 		db->db_epoch_mask = db->db_ring_mask + 1;
394 		db->db_epoch_shift = DBR_EPOCH_SFT -
395 					rte_log2_u32(db->db_epoch_mask);
396 	}
397 }
398 
399 static int bnxt_alloc_cmpl_ring(struct bnxt *bp, int queue_index,
400 				struct bnxt_cp_ring_info *cpr)
401 {
402 	struct bnxt_ring *cp_ring = cpr->cp_ring_struct;
403 	uint32_t nq_ring_id = HWRM_NA_SIGNATURE;
404 	int cp_ring_index = queue_index + BNXT_RX_VEC_START;
405 	struct bnxt_cp_ring_info *nqr = bp->rxtx_nq_ring;
406 	uint8_t ring_type;
407 	int rc = 0;
408 
409 	ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_L2_CMPL;
410 
411 	if (BNXT_HAS_NQ(bp)) {
412 		if (nqr) {
413 			nq_ring_id = nqr->cp_ring_struct->fw_ring_id;
414 		} else {
415 			PMD_DRV_LOG(ERR, "NQ ring is NULL\n");
416 			return -EINVAL;
417 		}
418 	}
419 
420 	rc = bnxt_hwrm_ring_alloc(bp, cp_ring, ring_type, cp_ring_index,
421 				  HWRM_NA_SIGNATURE, nq_ring_id, 0);
422 	if (rc)
423 		return rc;
424 
425 	cpr->cp_raw_cons = 0;
426 	bnxt_set_db(bp, &cpr->cp_db, ring_type, cp_ring_index,
427 		    cp_ring->fw_ring_id, cp_ring->ring_mask);
428 	bnxt_db_cq(cpr);
429 
430 	return 0;
431 }
432 
433 int bnxt_alloc_rxtx_nq_ring(struct bnxt *bp)
434 {
435 	struct bnxt_cp_ring_info *nqr;
436 	struct bnxt_ring *ring;
437 	int ring_index = BNXT_NUM_ASYNC_CPR(bp);
438 	uint8_t ring_type;
439 	int rc = 0;
440 
441 	if (!BNXT_HAS_NQ(bp) || bp->rxtx_nq_ring)
442 		return 0;
443 
444 	nqr = rte_zmalloc_socket("nqr",
445 				 sizeof(struct bnxt_cp_ring_info),
446 				 RTE_CACHE_LINE_SIZE,
447 				 bp->eth_dev->device->numa_node);
448 	if (nqr == NULL)
449 		return -ENOMEM;
450 
451 	ring = rte_zmalloc_socket("bnxt_cp_ring_struct",
452 				  sizeof(struct bnxt_ring),
453 				  RTE_CACHE_LINE_SIZE,
454 				  bp->eth_dev->device->numa_node);
455 	if (ring == NULL) {
456 		rte_free(nqr);
457 		return -ENOMEM;
458 	}
459 
460 	ring->bd = (void *)nqr->cp_desc_ring;
461 	ring->bd_dma = nqr->cp_desc_mapping;
462 	ring->ring_size = rte_align32pow2(DEFAULT_CP_RING_SIZE);
463 	ring->ring_mask = ring->ring_size - 1;
464 	ring->vmem_size = 0;
465 	ring->vmem = NULL;
466 	ring->fw_ring_id = INVALID_HW_RING_ID;
467 
468 	nqr->cp_ring_struct = ring;
469 	rc = bnxt_alloc_rings(bp, bp->eth_dev->device->numa_node, 0, NULL,
470 			      NULL, nqr, NULL, "l2_nqr");
471 	if (rc) {
472 		rte_free(ring);
473 		rte_free(nqr);
474 		return -ENOMEM;
475 	}
476 
477 	ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_NQ;
478 
479 	rc = bnxt_hwrm_ring_alloc(bp, ring, ring_type, ring_index,
480 				  HWRM_NA_SIGNATURE, HWRM_NA_SIGNATURE, 0);
481 	if (rc) {
482 		rte_free(ring);
483 		rte_free(nqr);
484 		return rc;
485 	}
486 
487 	bnxt_set_db(bp, &nqr->cp_db, ring_type, ring_index,
488 		    ring->fw_ring_id, ring->ring_mask);
489 	bnxt_db_nq(nqr);
490 
491 	bp->rxtx_nq_ring = nqr;
492 
493 	return 0;
494 }
495 
496 /* Free RX/TX NQ ring.  */
497 void bnxt_free_rxtx_nq_ring(struct bnxt *bp)
498 {
499 	struct bnxt_cp_ring_info *nqr = bp->rxtx_nq_ring;
500 
501 	if (!nqr)
502 		return;
503 
504 	bnxt_free_nq_ring(bp, nqr);
505 
506 	bnxt_free_ring(nqr->cp_ring_struct);
507 	rte_free(nqr->cp_ring_struct);
508 	nqr->cp_ring_struct = NULL;
509 	rte_free(nqr);
510 	bp->rxtx_nq_ring = NULL;
511 }
512 
513 static int bnxt_alloc_rx_ring(struct bnxt *bp, int queue_index)
514 {
515 	struct bnxt_rx_queue *rxq = bp->rx_queues[queue_index];
516 	struct bnxt_cp_ring_info *cpr = rxq->cp_ring;
517 	struct bnxt_ring *cp_ring = cpr->cp_ring_struct;
518 	struct bnxt_rx_ring_info *rxr = rxq->rx_ring;
519 	struct bnxt_ring *ring = rxr->rx_ring_struct;
520 	uint8_t ring_type;
521 	int rc = 0;
522 
523 	ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_RX;
524 
525 	rc = bnxt_hwrm_ring_alloc(bp, ring, ring_type,
526 				  queue_index, cpr->hw_stats_ctx_id,
527 				  cp_ring->fw_ring_id, 0);
528 	if (rc)
529 		return rc;
530 
531 	rxr->rx_raw_prod = 0;
532 	if (BNXT_HAS_RING_GRPS(bp))
533 		bp->grp_info[queue_index].rx_fw_ring_id = ring->fw_ring_id;
534 	bnxt_set_db(bp, &rxr->rx_db, ring_type, queue_index, ring->fw_ring_id,
535 		    ring->ring_mask);
536 	bnxt_db_write(&rxr->rx_db, rxr->rx_raw_prod);
537 
538 	return 0;
539 }
540 
541 static int bnxt_alloc_rx_agg_ring(struct bnxt *bp, int queue_index)
542 {
543 	unsigned int map_idx = queue_index + bp->rx_cp_nr_rings;
544 	struct bnxt_rx_queue *rxq = bp->rx_queues[queue_index];
545 	struct bnxt_cp_ring_info *cpr = rxq->cp_ring;
546 	struct bnxt_ring *cp_ring = cpr->cp_ring_struct;
547 	struct bnxt_rx_ring_info *rxr = rxq->rx_ring;
548 	struct bnxt_ring *ring = rxr->ag_ring_struct;
549 	uint32_t hw_stats_ctx_id = HWRM_NA_SIGNATURE;
550 	uint8_t ring_type;
551 	int rc = 0;
552 
553 	ring->fw_rx_ring_id = rxr->rx_ring_struct->fw_ring_id;
554 
555 	if (BNXT_CHIP_P5(bp)) {
556 		ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_RX_AGG;
557 		hw_stats_ctx_id = cpr->hw_stats_ctx_id;
558 	} else {
559 		ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_RX;
560 	}
561 
562 	rc = bnxt_hwrm_ring_alloc(bp, ring, ring_type, map_idx,
563 				  hw_stats_ctx_id, cp_ring->fw_ring_id, 0);
564 
565 	if (rc)
566 		return rc;
567 
568 	rxr->ag_raw_prod = 0;
569 	if (BNXT_HAS_RING_GRPS(bp))
570 		bp->grp_info[queue_index].ag_fw_ring_id = ring->fw_ring_id;
571 	bnxt_set_db(bp, &rxr->ag_db, ring_type, map_idx, ring->fw_ring_id,
572 		    ring->ring_mask);
573 	bnxt_db_write(&rxr->ag_db, rxr->ag_raw_prod);
574 
575 	return 0;
576 }
577 
578 int bnxt_alloc_hwrm_rx_ring(struct bnxt *bp, int queue_index)
579 {
580 	struct bnxt_rx_queue *rxq = bp->rx_queues[queue_index];
581 	struct bnxt_cp_ring_info *cpr = rxq->cp_ring;
582 	struct bnxt_ring *cp_ring = cpr->cp_ring_struct;
583 	struct bnxt_rx_ring_info *rxr = rxq->rx_ring;
584 	struct bnxt_coal coal;
585 	int rc;
586 
587 	/*
588 	 * Storage for the cp ring is allocated based on worst-case
589 	 * usage, the actual size to be used by hw is computed here.
590 	 */
591 	cp_ring->ring_size = rxr->rx_ring_struct->ring_size * 2;
592 
593 	if (bp->eth_dev->data->scattered_rx)
594 		cp_ring->ring_size *= AGG_RING_SIZE_FACTOR;
595 
596 	cp_ring->ring_mask = cp_ring->ring_size - 1;
597 
598 	rc = bnxt_alloc_cmpl_ring(bp, queue_index, cpr);
599 	if (rc)
600 		goto err_out;
601 
602 	rc = bnxt_hwrm_stat_ctx_alloc(bp, cpr);
603 	if (rc)
604 		goto err_out;
605 
606 	if (BNXT_HAS_RING_GRPS(bp)) {
607 		bp->grp_info[queue_index].fw_stats_ctx = cpr->hw_stats_ctx_id;
608 		bp->grp_info[queue_index].cp_fw_ring_id = cp_ring->fw_ring_id;
609 	}
610 
611 	bnxt_init_dflt_coal(&coal);
612 	bnxt_hwrm_set_ring_coal(bp, &coal, cp_ring->fw_ring_id);
613 
614 	if (!BNXT_NUM_ASYNC_CPR(bp) && !queue_index) {
615 		/*
616 		 * If a dedicated async event completion ring is not enabled,
617 		 * use the first completion ring from PF or VF as the default
618 		 * completion ring for async event handling.
619 		 */
620 		bp->async_cp_ring = cpr;
621 		rc = bnxt_hwrm_set_async_event_cr(bp);
622 		if (rc)
623 			goto err_out;
624 	}
625 
626 	rc = bnxt_alloc_rx_ring(bp, queue_index);
627 	if (rc)
628 		goto err_out;
629 
630 	rc = bnxt_alloc_rx_agg_ring(bp, queue_index);
631 	if (rc)
632 		goto err_out;
633 
634 	if (BNXT_HAS_RING_GRPS(bp)) {
635 		rc = bnxt_hwrm_ring_grp_alloc(bp, queue_index);
636 		if (rc)
637 			goto err_out;
638 	}
639 
640 	if (rxq->rx_started) {
641 		if (bnxt_init_one_rx_ring(rxq)) {
642 			PMD_DRV_LOG(ERR, "bnxt_init_one_rx_ring failed!\n");
643 			bnxt_rx_queue_release_op(rxq);
644 			rc = -ENOMEM;
645 			goto err_out;
646 		}
647 		bnxt_db_write(&rxr->rx_db, rxr->rx_raw_prod);
648 		bnxt_db_write(&rxr->ag_db, rxr->ag_raw_prod);
649 	}
650 	rxq->index = queue_index;
651 #if defined(RTE_ARCH_X86) || defined(RTE_ARCH_ARM64)
652 	bnxt_rxq_vec_setup(rxq);
653 #endif
654 
655 	return 0;
656 
657 err_out:
658 	PMD_DRV_LOG(ERR,
659 		    "Failed to allocate receive queue %d, rc %d.\n",
660 		    queue_index, rc);
661 	return rc;
662 }
663 
664 /* Initialise all rings to -1, its used to free rings later if allocation
665  * of few rings fails.
666  */
667 static void bnxt_init_all_rings(struct bnxt *bp)
668 {
669 	unsigned int i = 0;
670 	struct bnxt_rx_queue *rxq;
671 	struct bnxt_ring *cp_ring;
672 	struct bnxt_ring *ring;
673 	struct bnxt_rx_ring_info *rxr;
674 	struct bnxt_tx_queue *txq;
675 
676 	for (i = 0; i < bp->rx_cp_nr_rings; i++) {
677 		rxq = bp->rx_queues[i];
678 		/* Rx-compl */
679 		cp_ring = rxq->cp_ring->cp_ring_struct;
680 		cp_ring->fw_ring_id = INVALID_HW_RING_ID;
681 		/* Rx-Reg */
682 		rxr = rxq->rx_ring;
683 		ring = rxr->rx_ring_struct;
684 		ring->fw_ring_id = INVALID_HW_RING_ID;
685 		/* Rx-AGG */
686 		ring = rxr->ag_ring_struct;
687 		ring->fw_ring_id = INVALID_HW_RING_ID;
688 	}
689 	for (i = 0; i < bp->tx_cp_nr_rings; i++) {
690 		txq = bp->tx_queues[i];
691 		/* Tx cmpl */
692 		cp_ring = txq->cp_ring->cp_ring_struct;
693 		cp_ring->fw_ring_id = INVALID_HW_RING_ID;
694 		/*Tx Ring */
695 		ring = txq->tx_ring->tx_ring_struct;
696 		ring->fw_ring_id = INVALID_HW_RING_ID;
697 	}
698 }
699 
700 /* ring_grp usage:
701  * [0] = default completion ring
702  * [1 -> +rx_cp_nr_rings] = rx_cp, rx rings
703  * [1+rx_cp_nr_rings + 1 -> +tx_cp_nr_rings] = tx_cp, tx rings
704  */
705 int bnxt_alloc_hwrm_rings(struct bnxt *bp)
706 {
707 	struct bnxt_coal coal;
708 	unsigned int i;
709 	int rc = 0;
710 
711 	bnxt_init_dflt_coal(&coal);
712 	bnxt_init_all_rings(bp);
713 
714 	for (i = 0; i < bp->rx_cp_nr_rings; i++) {
715 		rc = bnxt_alloc_hwrm_rx_ring(bp, i);
716 		if (rc)
717 			goto err_out;
718 	}
719 
720 	/* If something is wrong with Rx ring alloc, skip Tx ring alloc */
721 	for (i = 0; i < bp->tx_cp_nr_rings; i++) {
722 		rc = bnxt_alloc_hwrm_tx_ring(bp, i);
723 		if (rc)
724 			goto err_out;
725 	}
726 
727 err_out:
728 	return rc;
729 }
730 
731 /* Allocate dedicated async completion ring. */
732 int bnxt_alloc_async_cp_ring(struct bnxt *bp)
733 {
734 	struct bnxt_cp_ring_info *cpr = bp->async_cp_ring;
735 	struct bnxt_ring *cp_ring;
736 	uint8_t ring_type;
737 	int rc;
738 
739 	if (BNXT_NUM_ASYNC_CPR(bp) == 0 || cpr == NULL)
740 		return 0;
741 
742 	cp_ring = cpr->cp_ring_struct;
743 
744 	if (BNXT_HAS_NQ(bp))
745 		ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_NQ;
746 	else
747 		ring_type = HWRM_RING_ALLOC_INPUT_RING_TYPE_L2_CMPL;
748 
749 	rc = bnxt_hwrm_ring_alloc(bp, cp_ring, ring_type, 0,
750 				  HWRM_NA_SIGNATURE, HWRM_NA_SIGNATURE, 0);
751 
752 	if (rc)
753 		return rc;
754 
755 	cpr->cp_raw_cons = 0;
756 	bnxt_set_db(bp, &cpr->cp_db, ring_type, 0,
757 		    cp_ring->fw_ring_id, cp_ring->ring_mask);
758 
759 	if (BNXT_HAS_NQ(bp))
760 		bnxt_db_nq(cpr);
761 	else
762 		bnxt_db_cq(cpr);
763 
764 	return bnxt_hwrm_set_async_event_cr(bp);
765 }
766 
767 /* Free dedicated async completion ring. */
768 void bnxt_free_async_cp_ring(struct bnxt *bp)
769 {
770 	struct bnxt_cp_ring_info *cpr = bp->async_cp_ring;
771 
772 	if (BNXT_NUM_ASYNC_CPR(bp) == 0 || cpr == NULL)
773 		return;
774 
775 	if (BNXT_HAS_NQ(bp))
776 		bnxt_free_nq_ring(bp, cpr);
777 	else
778 		bnxt_free_cp_ring(bp, cpr);
779 
780 	bnxt_free_ring(cpr->cp_ring_struct);
781 	rte_free(cpr->cp_ring_struct);
782 	cpr->cp_ring_struct = NULL;
783 	rte_free(cpr);
784 	bp->async_cp_ring = NULL;
785 }
786 
787 int bnxt_alloc_async_ring_struct(struct bnxt *bp)
788 {
789 	struct bnxt_cp_ring_info *cpr = NULL;
790 	struct bnxt_ring *ring = NULL;
791 
792 	if (BNXT_NUM_ASYNC_CPR(bp) == 0)
793 		return 0;
794 
795 	cpr = rte_zmalloc_socket("cpr",
796 				 sizeof(struct bnxt_cp_ring_info),
797 				 RTE_CACHE_LINE_SIZE,
798 				 bp->eth_dev->device->numa_node);
799 	if (cpr == NULL)
800 		return -ENOMEM;
801 
802 	ring = rte_zmalloc_socket("bnxt_cp_ring_struct",
803 				  sizeof(struct bnxt_ring),
804 				  RTE_CACHE_LINE_SIZE,
805 				  bp->eth_dev->device->numa_node);
806 	if (ring == NULL) {
807 		rte_free(cpr);
808 		return -ENOMEM;
809 	}
810 
811 	ring->bd = (void *)cpr->cp_desc_ring;
812 	ring->bd_dma = cpr->cp_desc_mapping;
813 	ring->ring_size = rte_align32pow2(DEFAULT_CP_RING_SIZE);
814 	ring->ring_mask = ring->ring_size - 1;
815 	ring->vmem_size = 0;
816 	ring->vmem = NULL;
817 
818 	bp->async_cp_ring = cpr;
819 	cpr->cp_ring_struct = ring;
820 
821 	return bnxt_alloc_rings(bp, bp->eth_dev->device->numa_node, 0, NULL,
822 				NULL, bp->async_cp_ring, NULL, "def_cp");
823 }
824 
825 int bnxt_alloc_hwrm_tx_ring(struct bnxt *bp, int queue_index)
826 {
827 	struct bnxt_tx_queue *txq = bp->tx_queues[queue_index];
828 	struct bnxt_cp_ring_info *cpr = txq->cp_ring;
829 	struct bnxt_ring *cp_ring = cpr->cp_ring_struct;
830 	struct bnxt_tx_ring_info *txr = txq->tx_ring;
831 	struct bnxt_ring *ring = txr->tx_ring_struct;
832 	unsigned int idx = queue_index + bp->rx_cp_nr_rings;
833 	uint16_t tx_cosq_id = 0;
834 	struct bnxt_coal coal;
835 	int rc = 0;
836 
837 	rc = bnxt_alloc_cmpl_ring(bp, idx, cpr);
838 	if (rc)
839 		goto err_out;
840 
841 	bnxt_init_dflt_coal(&coal);
842 	bnxt_hwrm_set_ring_coal(bp, &coal, cp_ring->fw_ring_id);
843 
844 	rc = bnxt_hwrm_stat_ctx_alloc(bp, cpr);
845 	if (rc)
846 		goto err_out;
847 
848 	if (bp->vnic_cap_flags & BNXT_VNIC_CAP_COS_CLASSIFY)
849 		tx_cosq_id = bp->tx_cosq_id[queue_index < bp->max_lltc ? queue_index : 0];
850 	else
851 		tx_cosq_id = bp->tx_cosq_id[0];
852 
853 	rc = bnxt_hwrm_ring_alloc(bp, ring,
854 				  HWRM_RING_ALLOC_INPUT_RING_TYPE_TX,
855 				  queue_index, cpr->hw_stats_ctx_id,
856 				  cp_ring->fw_ring_id,
857 				  tx_cosq_id);
858 	if (rc)
859 		goto err_out;
860 
861 	bnxt_set_db(bp, &txr->tx_db, HWRM_RING_ALLOC_INPUT_RING_TYPE_TX,
862 		    queue_index, ring->fw_ring_id,
863 		    ring->ring_mask);
864 	txq->index = idx;
865 
866 	return rc;
867 err_out:
868 	bnxt_free_hwrm_tx_ring(bp, queue_index);
869 	return rc;
870 }
871