Home | History | Annotate | Download | only in ldpaa_eth
      1 // SPDX-License-Identifier: GPL-2.0+
      2 /*
      3  * Copyright 2014-2016 Freescale Semiconductor, Inc.
      4  * Copyright 2017 NXP
      5  */
      6 
      7 #include <common.h>
      8 #include <asm/io.h>
      9 #include <asm/types.h>
     10 #include <malloc.h>
     11 #include <net.h>
     12 #include <hwconfig.h>
     13 #include <phy.h>
     14 #include <linux/compat.h>
     15 #include <fsl-mc/fsl_dpmac.h>
     16 
     17 #include <fsl-mc/ldpaa_wriop.h>
     18 #include "ldpaa_eth.h"
     19 
     20 #ifdef CONFIG_PHYLIB
     21 static int init_phy(struct eth_device *dev)
     22 {
     23 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)dev->priv;
     24 	struct phy_device *phydev = NULL;
     25 	struct mii_dev *bus;
     26 
     27 	bus = wriop_get_mdio(priv->dpmac_id);
     28 	if (bus == NULL)
     29 		return 0;
     30 
     31 	phydev = phy_connect(bus, wriop_get_phy_address(priv->dpmac_id),
     32 			     dev, wriop_get_enet_if(priv->dpmac_id));
     33 	if (!phydev) {
     34 		printf("Failed to connect\n");
     35 		return -1;
     36 	}
     37 
     38 	priv->phydev = phydev;
     39 
     40 	return phy_config(phydev);
     41 }
     42 #endif
     43 
     44 #ifdef DEBUG
     45 
     46 #define DPNI_STATS_PER_PAGE 6
     47 
     48 static const char *dpni_statistics[][DPNI_STATS_PER_PAGE] = {
     49 	{
     50 	"DPNI_CNT_ING_ALL_FRAMES",
     51 	"DPNI_CNT_ING_ALL_BYTES",
     52 	"DPNI_CNT_ING_MCAST_FRAMES",
     53 	"DPNI_CNT_ING_MCAST_BYTES",
     54 	"DPNI_CNT_ING_BCAST_FRAMES",
     55 	"DPNI_CNT_ING_BCAST_BYTES",
     56 	}, {
     57 	"DPNI_CNT_EGR_ALL_FRAMES",
     58 	"DPNI_CNT_EGR_ALL_BYTES",
     59 	"DPNI_CNT_EGR_MCAST_FRAMES",
     60 	"DPNI_CNT_EGR_MCAST_BYTES",
     61 	"DPNI_CNT_EGR_BCAST_FRAMES",
     62 	"DPNI_CNT_EGR_BCAST_BYTES",
     63 	}, {
     64 	"DPNI_CNT_ING_FILTERED_FRAMES",
     65 	"DPNI_CNT_ING_DISCARDED_FRAMES",
     66 	"DPNI_CNT_ING_NOBUFFER_DISCARDS",
     67 	"DPNI_CNT_EGR_DISCARDED_FRAMES",
     68 	"DPNI_CNT_EGR_CNF_FRAMES",
     69 	""
     70 	},
     71 };
     72 
     73 static void print_dpni_stats(const char *strings[],
     74 			     struct dpni_statistics dpni_stats)
     75 {
     76 	uint64_t *stat;
     77 	int i;
     78 
     79 	stat = (uint64_t *)&dpni_stats;
     80 	for (i = 0; i < DPNI_STATS_PER_PAGE; i++) {
     81 		if (strcmp(strings[i], "\0") == 0)
     82 			break;
     83 		printf("%s= %llu\n", strings[i], *stat);
     84 		stat++;
     85 	}
     86 }
     87 
     88 static void ldpaa_eth_get_dpni_counter(void)
     89 {
     90 	int err = 0;
     91 	unsigned int page = 0;
     92 	struct dpni_statistics dpni_stats;
     93 
     94 	printf("DPNI counters ..\n");
     95 	for (page = 0; page < 3; page++) {
     96 		err = dpni_get_statistics(dflt_mc_io, MC_CMD_NO_FLAGS,
     97 					  dflt_dpni->dpni_handle, page,
     98 					  &dpni_stats);
     99 		if (err < 0) {
    100 			printf("dpni_get_statistics: failed:");
    101 			printf("%d for page[%d]\n", err, page);
    102 			return;
    103 		}
    104 		print_dpni_stats(dpni_statistics[page], dpni_stats);
    105 	}
    106 }
    107 
    108 static void ldpaa_eth_get_dpmac_counter(struct eth_device *net_dev)
    109 {
    110 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)net_dev->priv;
    111 	int err = 0;
    112 	u64 value;
    113 
    114 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    115 		     priv->dpmac_handle,
    116 		     DPMAC_CNT_ING_BYTE,
    117 		     &value);
    118 	if (err < 0) {
    119 		printf("dpmac_get_counter: DPMAC_CNT_ING_BYTE failed\n");
    120 		return;
    121 	}
    122 	printf("\nDPMAC counters ..\n");
    123 	printf("DPMAC_CNT_ING_BYTE=%lld\n", value);
    124 
    125 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    126 		     priv->dpmac_handle,
    127 		     DPMAC_CNT_ING_FRAME_DISCARD,
    128 		     &value);
    129 	if (err < 0) {
    130 		printf("dpmac_get_counter: DPMAC_CNT_ING_FRAME_DISCARD failed\n");
    131 		return;
    132 	}
    133 	printf("DPMAC_CNT_ING_FRAME_DISCARD=%lld\n", value);
    134 
    135 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    136 		     priv->dpmac_handle,
    137 		     DPMAC_CNT_ING_ALIGN_ERR,
    138 		     &value);
    139 	if (err < 0) {
    140 		printf("dpmac_get_counter: DPMAC_CNT_ING_ALIGN_ERR failed\n");
    141 		return;
    142 	}
    143 	printf("DPMAC_CNT_ING_ALIGN_ERR =%lld\n", value);
    144 
    145 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    146 		     priv->dpmac_handle,
    147 		     DPMAC_CNT_ING_BYTE,
    148 		     &value);
    149 	if (err < 0) {
    150 		printf("dpmac_get_counter: DPMAC_CNT_ING_BYTE failed\n");
    151 		return;
    152 	}
    153 	printf("DPMAC_CNT_ING_BYTE=%lld\n", value);
    154 
    155 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    156 		     priv->dpmac_handle,
    157 		     DPMAC_CNT_ING_ERR_FRAME,
    158 		     &value);
    159 	if (err < 0) {
    160 		printf("dpmac_get_counter: DPMAC_CNT_ING_ERR_FRAME failed\n");
    161 		return;
    162 	}
    163 	printf("DPMAC_CNT_ING_ERR_FRAME=%lld\n", value);
    164 
    165 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    166 		     priv->dpmac_handle,
    167 		     DPMAC_CNT_EGR_BYTE ,
    168 		     &value);
    169 	if (err < 0) {
    170 		printf("dpmac_get_counter: DPMAC_CNT_EGR_BYTE failed\n");
    171 		return;
    172 	}
    173 	printf("DPMAC_CNT_EGR_BYTE =%lld\n", value);
    174 
    175 	err = dpmac_get_counter(dflt_mc_io, MC_CMD_NO_FLAGS,
    176 		     priv->dpmac_handle,
    177 		     DPMAC_CNT_EGR_ERR_FRAME ,
    178 		     &value);
    179 	if (err < 0) {
    180 		printf("dpmac_get_counter: DPMAC_CNT_EGR_ERR_FRAME failed\n");
    181 		return;
    182 	}
    183 	printf("DPMAC_CNT_EGR_ERR_FRAME =%lld\n", value);
    184 }
    185 #endif
    186 
    187 static void ldpaa_eth_rx(struct ldpaa_eth_priv *priv,
    188 			 const struct dpaa_fd *fd)
    189 {
    190 	u64 fd_addr;
    191 	uint16_t fd_offset;
    192 	uint32_t fd_length;
    193 	struct ldpaa_fas *fas;
    194 	uint32_t status, err;
    195 	u32 timeo = (CONFIG_SYS_HZ * 2) / 1000;
    196 	u32 time_start;
    197 	struct qbman_release_desc releasedesc;
    198 	struct qbman_swp *swp = dflt_dpio->sw_portal;
    199 
    200 	fd_addr = ldpaa_fd_get_addr(fd);
    201 	fd_offset = ldpaa_fd_get_offset(fd);
    202 	fd_length = ldpaa_fd_get_len(fd);
    203 
    204 	debug("Rx frame:data addr=0x%p size=0x%x\n", (u64 *)fd_addr, fd_length);
    205 
    206 	if (fd->simple.frc & LDPAA_FD_FRC_FASV) {
    207 		/* Read the frame annotation status word and check for errors */
    208 		fas = (struct ldpaa_fas *)
    209 				((uint8_t *)(fd_addr) +
    210 				dflt_dpni->buf_layout.private_data_size);
    211 		status = le32_to_cpu(fas->status);
    212 		if (status & LDPAA_ETH_RX_ERR_MASK) {
    213 			printf("Rx frame error(s): 0x%08x\n",
    214 			       status & LDPAA_ETH_RX_ERR_MASK);
    215 			goto error;
    216 		} else if (status & LDPAA_ETH_RX_UNSUPP_MASK) {
    217 			printf("Unsupported feature in bitmask: 0x%08x\n",
    218 			       status & LDPAA_ETH_RX_UNSUPP_MASK);
    219 			goto error;
    220 		}
    221 	}
    222 
    223 	debug("Rx frame: To Upper layer\n");
    224 	net_process_received_packet((uint8_t *)(fd_addr) + fd_offset,
    225 				    fd_length);
    226 
    227 error:
    228 	flush_dcache_range(fd_addr, fd_addr + LDPAA_ETH_RX_BUFFER_SIZE);
    229 	qbman_release_desc_clear(&releasedesc);
    230 	qbman_release_desc_set_bpid(&releasedesc, dflt_dpbp->dpbp_attr.bpid);
    231 	time_start = get_timer(0);
    232 	do {
    233 		/* Release buffer into the QBMAN */
    234 		err = qbman_swp_release(swp, &releasedesc, &fd_addr, 1);
    235 	} while (get_timer(time_start) < timeo && err == -EBUSY);
    236 
    237 	if (err == -EBUSY)
    238 		printf("Rx frame: QBMAN buffer release fails\n");
    239 
    240 	return;
    241 }
    242 
    243 static int ldpaa_eth_pull_dequeue_rx(struct eth_device *dev)
    244 {
    245 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)dev->priv;
    246 	const struct ldpaa_dq *dq;
    247 	const struct dpaa_fd *fd;
    248 	int i = 5, err = 0, status;
    249 	u32 timeo = (CONFIG_SYS_HZ * 2) / 1000;
    250 	u32 time_start;
    251 	static struct qbman_pull_desc pulldesc;
    252 	struct qbman_swp *swp = dflt_dpio->sw_portal;
    253 
    254 	while (--i) {
    255 		qbman_pull_desc_clear(&pulldesc);
    256 		qbman_pull_desc_set_numframes(&pulldesc, 1);
    257 		qbman_pull_desc_set_fq(&pulldesc, priv->rx_dflt_fqid);
    258 
    259 		err = qbman_swp_pull(swp, &pulldesc);
    260 		if (err < 0) {
    261 			printf("Dequeue frames error:0x%08x\n", err);
    262 			continue;
    263 		}
    264 
    265 		time_start = get_timer(0);
    266 
    267 		 do {
    268 			dq = qbman_swp_dqrr_next(swp);
    269 		} while (get_timer(time_start) < timeo && !dq);
    270 
    271 		if (dq) {
    272 			/* Check for valid frame. If not sent a consume
    273 			 * confirmation to QBMAN otherwise give it to NADK
    274 			 * application and then send consume confirmation to
    275 			 * QBMAN.
    276 			 */
    277 			status = (uint8_t)ldpaa_dq_flags(dq);
    278 			if ((status & LDPAA_DQ_STAT_VALIDFRAME) == 0) {
    279 				debug("Dequeue RX frames:");
    280 				debug("No frame delivered\n");
    281 
    282 				qbman_swp_dqrr_consume(swp, dq);
    283 				continue;
    284 			}
    285 
    286 			fd = ldpaa_dq_fd(dq);
    287 
    288 			/* Obtain FD and process it */
    289 			ldpaa_eth_rx(priv, fd);
    290 			qbman_swp_dqrr_consume(swp, dq);
    291 			break;
    292 		} else {
    293 			err = -ENODATA;
    294 			debug("No DQRR entries\n");
    295 			break;
    296 		}
    297 	}
    298 
    299 	return err;
    300 }
    301 
    302 static int ldpaa_eth_tx(struct eth_device *net_dev, void *buf, int len)
    303 {
    304 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)net_dev->priv;
    305 	struct dpaa_fd fd;
    306 	u64 buffer_start;
    307 	int data_offset, err;
    308 	u32 timeo = (CONFIG_SYS_HZ * 10) / 1000;
    309 	u32 time_start;
    310 	struct qbman_swp *swp = dflt_dpio->sw_portal;
    311 	struct qbman_eq_desc ed;
    312 	struct qbman_release_desc releasedesc;
    313 
    314 	/* Setup the FD fields */
    315 	memset(&fd, 0, sizeof(fd));
    316 
    317 	data_offset = priv->tx_data_offset;
    318 
    319 	do {
    320 		err = qbman_swp_acquire(dflt_dpio->sw_portal,
    321 					dflt_dpbp->dpbp_attr.bpid,
    322 					&buffer_start, 1);
    323 	} while (err == -EBUSY);
    324 
    325 	if (err <= 0) {
    326 		printf("qbman_swp_acquire() failed\n");
    327 		return -ENOMEM;
    328 	}
    329 
    330 	debug("TX data: malloc buffer start=0x%p\n", (u64 *)buffer_start);
    331 
    332 	memcpy(((uint8_t *)(buffer_start) + data_offset), buf, len);
    333 
    334 	flush_dcache_range(buffer_start, buffer_start +
    335 					LDPAA_ETH_RX_BUFFER_SIZE);
    336 
    337 	ldpaa_fd_set_addr(&fd, (u64)buffer_start);
    338 	ldpaa_fd_set_offset(&fd, (uint16_t)(data_offset));
    339 	ldpaa_fd_set_bpid(&fd, dflt_dpbp->dpbp_attr.bpid);
    340 	ldpaa_fd_set_len(&fd, len);
    341 
    342 	fd.simple.ctrl = LDPAA_FD_CTRL_ASAL | LDPAA_FD_CTRL_PTA |
    343 				LDPAA_FD_CTRL_PTV1;
    344 
    345 	qbman_eq_desc_clear(&ed);
    346 	qbman_eq_desc_set_no_orp(&ed, 0);
    347 	qbman_eq_desc_set_qd(&ed, priv->tx_qdid, priv->tx_flow_id, 0);
    348 
    349 	time_start = get_timer(0);
    350 
    351 	while (get_timer(time_start) < timeo) {
    352 		err = qbman_swp_enqueue(swp, &ed,
    353 				(const struct qbman_fd *)(&fd));
    354 		if (err != -EBUSY)
    355 			break;
    356 	}
    357 
    358 	if (err < 0) {
    359 		printf("error enqueueing Tx frame\n");
    360 		goto error;
    361 	}
    362 
    363 	return err;
    364 
    365 error:
    366 	qbman_release_desc_clear(&releasedesc);
    367 	qbman_release_desc_set_bpid(&releasedesc, dflt_dpbp->dpbp_attr.bpid);
    368 	time_start = get_timer(0);
    369 	do {
    370 		/* Release buffer into the QBMAN */
    371 		err = qbman_swp_release(swp, &releasedesc, &buffer_start, 1);
    372 	} while (get_timer(time_start) < timeo && err == -EBUSY);
    373 
    374 	if (err == -EBUSY)
    375 		printf("TX data: QBMAN buffer release fails\n");
    376 
    377 	return err;
    378 }
    379 
    380 static int ldpaa_eth_open(struct eth_device *net_dev, bd_t *bd)
    381 {
    382 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)net_dev->priv;
    383 	struct dpmac_link_state	dpmac_link_state = { 0 };
    384 #ifdef DEBUG
    385 	struct dpni_link_state link_state;
    386 #endif
    387 	int err = 0;
    388 	struct mii_dev *bus;
    389 	phy_interface_t enet_if;
    390 	struct dpni_queue d_queue;
    391 
    392 	if (net_dev->state == ETH_STATE_ACTIVE)
    393 		return 0;
    394 
    395 	if (get_mc_boot_status() != 0) {
    396 		printf("ERROR (MC is not booted)\n");
    397 		return -ENODEV;
    398 	}
    399 
    400 	if (get_dpl_apply_status() == 0) {
    401 		printf("ERROR (DPL is deployed. No device available)\n");
    402 		return -ENODEV;
    403 	}
    404 
    405 	/* DPMAC initialization */
    406 	err = ldpaa_dpmac_setup(priv);
    407 	if (err < 0)
    408 		goto err_dpmac_setup;
    409 
    410 #ifdef CONFIG_PHYLIB
    411 	if (priv->phydev) {
    412 		err = phy_startup(priv->phydev);
    413 		if (err) {
    414 			printf("%s: Could not initialize\n",
    415 			       priv->phydev->dev->name);
    416 			goto err_dpamc_bind;
    417 		}
    418 	}
    419 #else
    420 	priv->phydev = (struct phy_device *)malloc(sizeof(struct phy_device));
    421 	memset(priv->phydev, 0, sizeof(struct phy_device));
    422 
    423 	priv->phydev->speed = SPEED_1000;
    424 	priv->phydev->link = 1;
    425 	priv->phydev->duplex = DUPLEX_FULL;
    426 #endif
    427 
    428 	bus = wriop_get_mdio(priv->dpmac_id);
    429 	enet_if = wriop_get_enet_if(priv->dpmac_id);
    430 	if ((bus == NULL) &&
    431 	    (enet_if == PHY_INTERFACE_MODE_XGMII)) {
    432 		priv->phydev = (struct phy_device *)
    433 				malloc(sizeof(struct phy_device));
    434 		memset(priv->phydev, 0, sizeof(struct phy_device));
    435 
    436 		priv->phydev->speed = SPEED_10000;
    437 		priv->phydev->link = 1;
    438 		priv->phydev->duplex = DUPLEX_FULL;
    439 	}
    440 
    441 	if (!priv->phydev->link) {
    442 		printf("%s: No link.\n", priv->phydev->dev->name);
    443 		err = -1;
    444 		goto err_dpamc_bind;
    445 	}
    446 
    447 	/* DPMAC binding DPNI */
    448 	err = ldpaa_dpmac_bind(priv);
    449 	if (err)
    450 		goto err_dpamc_bind;
    451 
    452 	/* DPNI initialization */
    453 	err = ldpaa_dpni_setup(priv);
    454 	if (err < 0)
    455 		goto err_dpni_setup;
    456 
    457 	err = ldpaa_dpbp_setup();
    458 	if (err < 0)
    459 		goto err_dpbp_setup;
    460 
    461 	/* DPNI binding DPBP */
    462 	err = ldpaa_dpni_bind(priv);
    463 	if (err)
    464 		goto err_dpni_bind;
    465 
    466 	err = dpni_add_mac_addr(dflt_mc_io, MC_CMD_NO_FLAGS,
    467 				dflt_dpni->dpni_handle, net_dev->enetaddr);
    468 	if (err) {
    469 		printf("dpni_add_mac_addr() failed\n");
    470 		return err;
    471 	}
    472 
    473 	err = dpni_enable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    474 	if (err < 0) {
    475 		printf("dpni_enable() failed\n");
    476 		return err;
    477 	}
    478 
    479 	dpmac_link_state.rate = priv->phydev->speed;
    480 
    481 	if (priv->phydev->autoneg == AUTONEG_DISABLE)
    482 		dpmac_link_state.options &= ~DPMAC_LINK_OPT_AUTONEG;
    483 	else
    484 		dpmac_link_state.options |= DPMAC_LINK_OPT_AUTONEG;
    485 
    486 	if (priv->phydev->duplex == DUPLEX_HALF)
    487 		dpmac_link_state.options |= DPMAC_LINK_OPT_HALF_DUPLEX;
    488 
    489 	dpmac_link_state.up = priv->phydev->link;
    490 
    491 	err = dpmac_set_link_state(dflt_mc_io, MC_CMD_NO_FLAGS,
    492 				  priv->dpmac_handle, &dpmac_link_state);
    493 	if (err < 0) {
    494 		printf("dpmac_set_link_state() failed\n");
    495 		return err;
    496 	}
    497 
    498 #ifdef DEBUG
    499 	printf("DPMAC link status: %d - ", dpmac_link_state.up);
    500 	dpmac_link_state.up == 0 ? printf("down\n") :
    501 	dpmac_link_state.up == 1 ? printf("up\n") : printf("error state\n");
    502 
    503 	err = dpni_get_link_state(dflt_mc_io, MC_CMD_NO_FLAGS,
    504 				  dflt_dpni->dpni_handle, &link_state);
    505 	if (err < 0) {
    506 		printf("dpni_get_link_state() failed\n");
    507 		return err;
    508 	}
    509 
    510 	printf("DPNI link status: %d - ", link_state.up);
    511 	link_state.up == 0 ? printf("down\n") :
    512 	link_state.up == 1 ? printf("up\n") : printf("error state\n");
    513 #endif
    514 
    515 	memset(&d_queue, 0, sizeof(struct dpni_queue));
    516 	err = dpni_get_queue(dflt_mc_io, MC_CMD_NO_FLAGS,
    517 			     dflt_dpni->dpni_handle, DPNI_QUEUE_RX,
    518 			     0, 0, &d_queue);
    519 	if (err) {
    520 		printf("dpni_get_queue failed\n");
    521 		goto err_get_queue;
    522 	}
    523 
    524 	priv->rx_dflt_fqid = d_queue.fqid;
    525 
    526 	err = dpni_get_qdid(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle,
    527 			    &priv->tx_qdid);
    528 	if (err) {
    529 		printf("dpni_get_qdid() failed\n");
    530 		goto err_qdid;
    531 	}
    532 
    533 	return priv->phydev->link;
    534 
    535 err_qdid:
    536 err_get_queue:
    537 	dpni_disable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    538 err_dpni_bind:
    539 	ldpaa_dpbp_free();
    540 err_dpbp_setup:
    541 	dpni_close(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    542 err_dpni_setup:
    543 err_dpamc_bind:
    544 	dpmac_close(dflt_mc_io, MC_CMD_NO_FLAGS, priv->dpmac_handle);
    545 	dpmac_destroy(dflt_mc_io,
    546 		      dflt_dprc_handle,
    547 		      MC_CMD_NO_FLAGS, priv->dpmac_id);
    548 err_dpmac_setup:
    549 	return err;
    550 }
    551 
    552 static void ldpaa_eth_stop(struct eth_device *net_dev)
    553 {
    554 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)net_dev->priv;
    555 	int err = 0;
    556 #ifdef CONFIG_PHYLIB
    557 	struct mii_dev *bus = wriop_get_mdio(priv->dpmac_id);
    558 #endif
    559 
    560 	if ((net_dev->state == ETH_STATE_PASSIVE) ||
    561 	    (net_dev->state == ETH_STATE_INIT))
    562 		return;
    563 
    564 #ifdef DEBUG
    565 	ldpaa_eth_get_dpni_counter();
    566 	ldpaa_eth_get_dpmac_counter(net_dev);
    567 #endif
    568 
    569 	err = dprc_disconnect(dflt_mc_io, MC_CMD_NO_FLAGS,
    570 			      dflt_dprc_handle, &dpmac_endpoint);
    571 	if (err < 0)
    572 		printf("dprc_disconnect() failed dpmac_endpoint\n");
    573 
    574 	err = dpmac_close(dflt_mc_io, MC_CMD_NO_FLAGS, priv->dpmac_handle);
    575 	if (err < 0)
    576 		printf("dpmac_close() failed\n");
    577 
    578 	err = dpmac_destroy(dflt_mc_io,
    579 			    dflt_dprc_handle,
    580 			    MC_CMD_NO_FLAGS,
    581 			    priv->dpmac_id);
    582 	if (err < 0)
    583 		printf("dpmac_destroy() failed\n");
    584 
    585 	/* Stop Tx and Rx traffic */
    586 	err = dpni_disable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    587 	if (err < 0)
    588 		printf("dpni_disable() failed\n");
    589 
    590 #ifdef CONFIG_PHYLIB
    591 	if (priv->phydev && bus != NULL)
    592 		phy_shutdown(priv->phydev);
    593 	else {
    594 		free(priv->phydev);
    595 		priv->phydev = NULL;
    596 	}
    597 #endif
    598 
    599 	/* Free DPBP handle and reset. */
    600 	ldpaa_dpbp_free();
    601 
    602 	dpni_reset(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    603 	if (err < 0)
    604 		printf("dpni_reset() failed\n");
    605 
    606 	dpni_close(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    607 	if (err < 0)
    608 		printf("dpni_close() failed\n");
    609 }
    610 
    611 static void ldpaa_dpbp_drain_cnt(int count)
    612 {
    613 	uint64_t buf_array[7];
    614 	void *addr;
    615 	int ret, i;
    616 
    617 	BUG_ON(count > 7);
    618 
    619 	do {
    620 		ret = qbman_swp_acquire(dflt_dpio->sw_portal,
    621 					dflt_dpbp->dpbp_attr.bpid,
    622 					buf_array, count);
    623 		if (ret < 0) {
    624 			printf("qbman_swp_acquire() failed\n");
    625 			return;
    626 		}
    627 		for (i = 0; i < ret; i++) {
    628 			addr = (void *)buf_array[i];
    629 			debug("Free: buffer addr =0x%p\n", addr);
    630 			free(addr);
    631 		}
    632 	} while (ret);
    633 }
    634 
    635 static void ldpaa_dpbp_drain(void)
    636 {
    637 	int i;
    638 	for (i = 0; i < LDPAA_ETH_NUM_BUFS; i += 7)
    639 		ldpaa_dpbp_drain_cnt(7);
    640 }
    641 
    642 static int ldpaa_bp_add_7(uint16_t bpid)
    643 {
    644 	uint64_t buf_array[7];
    645 	u8 *addr;
    646 	int i;
    647 	struct qbman_release_desc rd;
    648 
    649 	for (i = 0; i < 7; i++) {
    650 		addr = memalign(LDPAA_ETH_BUF_ALIGN, LDPAA_ETH_RX_BUFFER_SIZE);
    651 		if (!addr) {
    652 			printf("addr allocation failed\n");
    653 			goto err_alloc;
    654 		}
    655 		memset(addr, 0x00, LDPAA_ETH_RX_BUFFER_SIZE);
    656 		flush_dcache_range((u64)addr,
    657 				   (u64)(addr + LDPAA_ETH_RX_BUFFER_SIZE));
    658 
    659 		buf_array[i] = (uint64_t)addr;
    660 		debug("Release: buffer addr =0x%p\n", addr);
    661 	}
    662 
    663 release_bufs:
    664 	/* In case the portal is busy, retry until successful.
    665 	 * This function is guaranteed to succeed in a reasonable amount
    666 	 * of time.
    667 	 */
    668 
    669 	do {
    670 		mdelay(1);
    671 		qbman_release_desc_clear(&rd);
    672 		qbman_release_desc_set_bpid(&rd, bpid);
    673 	} while (qbman_swp_release(dflt_dpio->sw_portal, &rd, buf_array, i));
    674 
    675 	return i;
    676 
    677 err_alloc:
    678 	if (i)
    679 		goto release_bufs;
    680 
    681 	return 0;
    682 }
    683 
    684 static int ldpaa_dpbp_seed(uint16_t bpid)
    685 {
    686 	int i;
    687 	int count;
    688 
    689 	for (i = 0; i < LDPAA_ETH_NUM_BUFS; i += 7) {
    690 		count = ldpaa_bp_add_7(bpid);
    691 		if (count < 7)
    692 			printf("Buffer Seed= %d\n", count);
    693 	}
    694 
    695 	return 0;
    696 }
    697 
    698 static int ldpaa_dpbp_setup(void)
    699 {
    700 	int err;
    701 
    702 	err = dpbp_open(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_attr.id,
    703 			&dflt_dpbp->dpbp_handle);
    704 	if (err) {
    705 		printf("dpbp_open() failed\n");
    706 		goto err_open;
    707 	}
    708 
    709 	err = dpbp_enable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    710 	if (err) {
    711 		printf("dpbp_enable() failed\n");
    712 		goto err_enable;
    713 	}
    714 
    715 	err = dpbp_get_attributes(dflt_mc_io, MC_CMD_NO_FLAGS,
    716 				  dflt_dpbp->dpbp_handle,
    717 				  &dflt_dpbp->dpbp_attr);
    718 	if (err) {
    719 		printf("dpbp_get_attributes() failed\n");
    720 		goto err_get_attr;
    721 	}
    722 
    723 	err = ldpaa_dpbp_seed(dflt_dpbp->dpbp_attr.bpid);
    724 
    725 	if (err) {
    726 		printf("Buffer seeding failed for DPBP %d (bpid=%d)\n",
    727 		       dflt_dpbp->dpbp_attr.id, dflt_dpbp->dpbp_attr.bpid);
    728 		goto err_seed;
    729 	}
    730 
    731 	return 0;
    732 
    733 err_seed:
    734 err_get_attr:
    735 	dpbp_disable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    736 err_enable:
    737 	dpbp_close(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    738 err_open:
    739 	return err;
    740 }
    741 
    742 static void ldpaa_dpbp_free(void)
    743 {
    744 	ldpaa_dpbp_drain();
    745 	dpbp_disable(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    746 	dpbp_reset(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    747 	dpbp_close(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpbp->dpbp_handle);
    748 }
    749 
    750 static int ldpaa_dpmac_version_check(struct fsl_mc_io *mc_io,
    751 				     struct ldpaa_eth_priv *priv)
    752 {
    753 	int error;
    754 	uint16_t major_ver, minor_ver;
    755 
    756 	error = dpmac_get_api_version(dflt_mc_io, 0,
    757 					&major_ver,
    758 					&minor_ver);
    759 	if ((major_ver < DPMAC_VER_MAJOR) ||
    760 	    (major_ver == DPMAC_VER_MAJOR && minor_ver < DPMAC_VER_MINOR)) {
    761 		printf("DPMAC version mismatch found %u.%u,",
    762 		       major_ver, minor_ver);
    763 		printf("supported version is %u.%u\n",
    764 		       DPMAC_VER_MAJOR, DPMAC_VER_MINOR);
    765 		return error;
    766 	}
    767 
    768 	return error;
    769 }
    770 
    771 static int ldpaa_dpmac_setup(struct ldpaa_eth_priv *priv)
    772 {
    773 	int err = 0;
    774 	struct dpmac_cfg dpmac_cfg;
    775 
    776 	dpmac_cfg.mac_id = priv->dpmac_id;
    777 
    778 	err = dpmac_create(dflt_mc_io,
    779 			   dflt_dprc_handle,
    780 			   MC_CMD_NO_FLAGS, &dpmac_cfg,
    781 			   &priv->dpmac_id);
    782 	if (err)
    783 		printf("dpmac_create() failed\n");
    784 
    785 	err = ldpaa_dpmac_version_check(dflt_mc_io, priv);
    786 	if (err < 0) {
    787 		printf("ldpaa_dpmac_version_check() failed: %d\n", err);
    788 		goto err_version_check;
    789 	}
    790 
    791 	err = dpmac_open(dflt_mc_io,
    792 			 MC_CMD_NO_FLAGS,
    793 			 priv->dpmac_id,
    794 			 &priv->dpmac_handle);
    795 	if (err < 0) {
    796 		printf("dpmac_open() failed: %d\n", err);
    797 		goto err_open;
    798 	}
    799 
    800 	return err;
    801 
    802 err_open:
    803 err_version_check:
    804 	dpmac_destroy(dflt_mc_io,
    805 		      dflt_dprc_handle,
    806 		      MC_CMD_NO_FLAGS, priv->dpmac_id);
    807 
    808 	return err;
    809 }
    810 
    811 static int ldpaa_dpmac_bind(struct ldpaa_eth_priv *priv)
    812 {
    813 	int err = 0;
    814 	struct dprc_connection_cfg dprc_connection_cfg = {
    815 		/* If both rates are zero the connection */
    816 		/* will be configured in "best effort" mode. */
    817 		.committed_rate = 0,
    818 		.max_rate = 0
    819 	};
    820 
    821 #ifdef DEBUG
    822 	struct dprc_endpoint dbg_endpoint;
    823 	int state = 0;
    824 #endif
    825 
    826 	memset(&dpmac_endpoint, 0, sizeof(struct dprc_endpoint));
    827 	strcpy(dpmac_endpoint.type, "dpmac");
    828 	dpmac_endpoint.id = priv->dpmac_id;
    829 
    830 	memset(&dpni_endpoint, 0, sizeof(struct dprc_endpoint));
    831 	strcpy(dpni_endpoint.type, "dpni");
    832 	dpni_endpoint.id = dflt_dpni->dpni_id;
    833 
    834 	err = dprc_connect(dflt_mc_io, MC_CMD_NO_FLAGS,
    835 			     dflt_dprc_handle,
    836 			     &dpmac_endpoint,
    837 			     &dpni_endpoint,
    838 			     &dprc_connection_cfg);
    839 	if (err)
    840 		printf("dprc_connect() failed\n");
    841 
    842 #ifdef DEBUG
    843 	err = dprc_get_connection(dflt_mc_io, MC_CMD_NO_FLAGS,
    844 				    dflt_dprc_handle, &dpni_endpoint,
    845 				    &dbg_endpoint, &state);
    846 	printf("%s, DPMAC Type= %s\n", __func__, dbg_endpoint.type);
    847 	printf("%s, DPMAC ID= %d\n", __func__, dbg_endpoint.id);
    848 	printf("%s, DPMAC State= %d\n", __func__, state);
    849 
    850 	memset(&dbg_endpoint, 0, sizeof(struct dprc_endpoint));
    851 	err = dprc_get_connection(dflt_mc_io, MC_CMD_NO_FLAGS,
    852 				    dflt_dprc_handle, &dpmac_endpoint,
    853 				    &dbg_endpoint, &state);
    854 	printf("%s, DPNI Type= %s\n", __func__, dbg_endpoint.type);
    855 	printf("%s, DPNI ID= %d\n", __func__, dbg_endpoint.id);
    856 	printf("%s, DPNI State= %d\n", __func__, state);
    857 #endif
    858 	return err;
    859 }
    860 
    861 static int ldpaa_dpni_setup(struct ldpaa_eth_priv *priv)
    862 {
    863 	int err;
    864 
    865 	/* and get a handle for the DPNI this interface is associate with */
    866 	err = dpni_open(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_id,
    867 			&dflt_dpni->dpni_handle);
    868 	if (err) {
    869 		printf("dpni_open() failed\n");
    870 		goto err_open;
    871 	}
    872 	err = dpni_get_attributes(dflt_mc_io, MC_CMD_NO_FLAGS,
    873 				  dflt_dpni->dpni_handle,
    874 				  &dflt_dpni->dpni_attrs);
    875 	if (err) {
    876 		printf("dpni_get_attributes() failed (err=%d)\n", err);
    877 		goto err_get_attr;
    878 	}
    879 
    880 	/* Configure our buffers' layout */
    881 	dflt_dpni->buf_layout.options = DPNI_BUF_LAYOUT_OPT_PARSER_RESULT |
    882 				   DPNI_BUF_LAYOUT_OPT_FRAME_STATUS |
    883 				   DPNI_BUF_LAYOUT_OPT_PRIVATE_DATA_SIZE |
    884 				   DPNI_BUF_LAYOUT_OPT_DATA_ALIGN;
    885 	dflt_dpni->buf_layout.pass_parser_result = true;
    886 	dflt_dpni->buf_layout.pass_frame_status = true;
    887 	dflt_dpni->buf_layout.private_data_size = LDPAA_ETH_SWA_SIZE;
    888 	/* HW erratum mandates data alignment in multiples of 256 */
    889 	dflt_dpni->buf_layout.data_align = LDPAA_ETH_BUF_ALIGN;
    890 
    891 	/* ...rx, ... */
    892 	err = dpni_set_buffer_layout(dflt_mc_io, MC_CMD_NO_FLAGS,
    893 				     dflt_dpni->dpni_handle,
    894 				     &dflt_dpni->buf_layout, DPNI_QUEUE_RX);
    895 	if (err) {
    896 		printf("dpni_set_buffer_layout() failed");
    897 		goto err_buf_layout;
    898 	}
    899 
    900 	/* ... tx, ... */
    901 	/* remove Rx-only options */
    902 	dflt_dpni->buf_layout.options &= ~(DPNI_BUF_LAYOUT_OPT_DATA_ALIGN |
    903 				      DPNI_BUF_LAYOUT_OPT_PARSER_RESULT);
    904 	err = dpni_set_buffer_layout(dflt_mc_io, MC_CMD_NO_FLAGS,
    905 				     dflt_dpni->dpni_handle,
    906 				     &dflt_dpni->buf_layout, DPNI_QUEUE_TX);
    907 	if (err) {
    908 		printf("dpni_set_buffer_layout() failed");
    909 		goto err_buf_layout;
    910 	}
    911 
    912 	/* ... tx-confirm. */
    913 	dflt_dpni->buf_layout.options &= ~DPNI_BUF_LAYOUT_OPT_PRIVATE_DATA_SIZE;
    914 	err = dpni_set_buffer_layout(dflt_mc_io, MC_CMD_NO_FLAGS,
    915 				     dflt_dpni->dpni_handle,
    916 				     &dflt_dpni->buf_layout,
    917 				     DPNI_QUEUE_TX_CONFIRM);
    918 	if (err) {
    919 		printf("dpni_set_buffer_layout() failed");
    920 		goto err_buf_layout;
    921 	}
    922 
    923 	/* Now that we've set our tx buffer layout, retrieve the minimum
    924 	 * required tx data offset.
    925 	 */
    926 	err = dpni_get_tx_data_offset(dflt_mc_io, MC_CMD_NO_FLAGS,
    927 				      dflt_dpni->dpni_handle,
    928 				      &priv->tx_data_offset);
    929 	if (err) {
    930 		printf("dpni_get_tx_data_offset() failed\n");
    931 		goto err_data_offset;
    932 	}
    933 
    934 	/* Warn in case TX data offset is not multiple of 64 bytes. */
    935 	WARN_ON(priv->tx_data_offset % 64);
    936 
    937 	/* Accomodate SWA space. */
    938 	priv->tx_data_offset += LDPAA_ETH_SWA_SIZE;
    939 	debug("priv->tx_data_offset=%d\n", priv->tx_data_offset);
    940 
    941 	return 0;
    942 
    943 err_data_offset:
    944 err_buf_layout:
    945 err_get_attr:
    946 	dpni_close(dflt_mc_io, MC_CMD_NO_FLAGS, dflt_dpni->dpni_handle);
    947 err_open:
    948 	return err;
    949 }
    950 
    951 static int ldpaa_dpni_bind(struct ldpaa_eth_priv *priv)
    952 {
    953 	struct dpni_pools_cfg pools_params;
    954 	struct dpni_queue tx_queue;
    955 	int err = 0;
    956 
    957 	memset(&pools_params, 0, sizeof(pools_params));
    958 	pools_params.num_dpbp = 1;
    959 	pools_params.pools[0].dpbp_id = (uint16_t)dflt_dpbp->dpbp_attr.id;
    960 	pools_params.pools[0].buffer_size = LDPAA_ETH_RX_BUFFER_SIZE;
    961 	err = dpni_set_pools(dflt_mc_io, MC_CMD_NO_FLAGS,
    962 			     dflt_dpni->dpni_handle, &pools_params);
    963 	if (err) {
    964 		printf("dpni_set_pools() failed\n");
    965 		return err;
    966 	}
    967 
    968 	memset(&tx_queue, 0, sizeof(struct dpni_queue));
    969 
    970 	err = dpni_set_queue(dflt_mc_io, MC_CMD_NO_FLAGS,
    971 			     dflt_dpni->dpni_handle,
    972 			     DPNI_QUEUE_TX, 0, 0, &tx_queue);
    973 
    974 	if (err) {
    975 		printf("dpni_set_queue() failed\n");
    976 		return err;
    977 	}
    978 
    979 	err = dpni_set_tx_confirmation_mode(dflt_mc_io, MC_CMD_NO_FLAGS,
    980 					    dflt_dpni->dpni_handle,
    981 					    DPNI_CONF_DISABLE);
    982 	if (err) {
    983 		printf("dpni_set_tx_confirmation_mode() failed\n");
    984 		return err;
    985 	}
    986 
    987 	return 0;
    988 }
    989 
    990 static int ldpaa_eth_netdev_init(struct eth_device *net_dev,
    991 				 phy_interface_t enet_if)
    992 {
    993 	int err;
    994 	struct ldpaa_eth_priv *priv = (struct ldpaa_eth_priv *)net_dev->priv;
    995 
    996 	sprintf(net_dev->name, "DPMAC%d@%s", priv->dpmac_id,
    997 		phy_interface_strings[enet_if]);
    998 
    999 	net_dev->iobase = 0;
   1000 	net_dev->init = ldpaa_eth_open;
   1001 	net_dev->halt = ldpaa_eth_stop;
   1002 	net_dev->send = ldpaa_eth_tx;
   1003 	net_dev->recv = ldpaa_eth_pull_dequeue_rx;
   1004 
   1005 #ifdef CONFIG_PHYLIB
   1006 	err = init_phy(net_dev);
   1007 	if (err < 0)
   1008 		return err;
   1009 #endif
   1010 
   1011 	err = eth_register(net_dev);
   1012 	if (err < 0) {
   1013 		printf("eth_register() = %d\n", err);
   1014 		return err;
   1015 	}
   1016 
   1017 	return 0;
   1018 }
   1019 
   1020 int ldpaa_eth_init(int dpmac_id, phy_interface_t enet_if)
   1021 {
   1022 	struct eth_device		*net_dev = NULL;
   1023 	struct ldpaa_eth_priv		*priv = NULL;
   1024 	int				err = 0;
   1025 
   1026 	/* Net device */
   1027 	net_dev = (struct eth_device *)malloc(sizeof(struct eth_device));
   1028 	if (!net_dev) {
   1029 		printf("eth_device malloc() failed\n");
   1030 		return -ENOMEM;
   1031 	}
   1032 	memset(net_dev, 0, sizeof(struct eth_device));
   1033 
   1034 	/* alloc the ldpaa ethernet private struct */
   1035 	priv = (struct ldpaa_eth_priv *)malloc(sizeof(struct ldpaa_eth_priv));
   1036 	if (!priv) {
   1037 		printf("ldpaa_eth_priv malloc() failed\n");
   1038 		return -ENOMEM;
   1039 	}
   1040 	memset(priv, 0, sizeof(struct ldpaa_eth_priv));
   1041 
   1042 	net_dev->priv = (void *)priv;
   1043 	priv->net_dev = (struct eth_device *)net_dev;
   1044 	priv->dpmac_id = dpmac_id;
   1045 	debug("%s dpmac_id=%d\n", __func__, dpmac_id);
   1046 
   1047 	err = ldpaa_eth_netdev_init(net_dev, enet_if);
   1048 	if (err)
   1049 		goto err_netdev_init;
   1050 
   1051 	debug("ldpaa ethernet: Probed interface %s\n", net_dev->name);
   1052 	return 0;
   1053 
   1054 err_netdev_init:
   1055 	free(priv);
   1056 	net_dev->priv = NULL;
   1057 	free(net_dev);
   1058 
   1059 	return err;
   1060 }
   1061