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