1 // SPDX-License-Identifier: GPL-2.0+
2 
3 #include <linux/module.h>
4 #include <linux/if_bridge.h>
5 #include <linux/if_vlan.h>
6 #include <linux/iopoll.h>
7 #include <linux/ip.h>
8 #include <linux/of_platform.h>
9 #include <linux/of_net.h>
10 #include <linux/packing.h>
11 #include <linux/phy/phy.h>
12 #include <linux/reset.h>
13 #include <net/addrconf.h>
14 
15 #include "lan966x_main.h"
16 
17 #define XTR_EOF_0			0x00000080U
18 #define XTR_EOF_1			0x01000080U
19 #define XTR_EOF_2			0x02000080U
20 #define XTR_EOF_3			0x03000080U
21 #define XTR_PRUNED			0x04000080U
22 #define XTR_ABORT			0x05000080U
23 #define XTR_ESCAPE			0x06000080U
24 #define XTR_NOT_READY			0x07000080U
25 #define XTR_VALID_BYTES(x)		(4 - (((x) >> 24) & 3))
26 
27 #define READL_SLEEP_US			10
28 #define READL_TIMEOUT_US		100000000
29 
30 #define IO_RANGES 2
31 
32 static const struct of_device_id lan966x_match[] = {
33 	{ .compatible = "microchip,lan966x-switch" },
34 	{ }
35 };
36 MODULE_DEVICE_TABLE(of, lan966x_match);
37 
38 struct lan966x_main_io_resource {
39 	enum lan966x_target id;
40 	phys_addr_t offset;
41 	int range;
42 };
43 
44 static const struct lan966x_main_io_resource lan966x_main_iomap[] =  {
45 	{ TARGET_CPU,                   0xc0000, 0 }, /* 0xe00c0000 */
46 	{ TARGET_ORG,                         0, 1 }, /* 0xe2000000 */
47 	{ TARGET_GCB,                    0x4000, 1 }, /* 0xe2004000 */
48 	{ TARGET_QS,                     0x8000, 1 }, /* 0xe2008000 */
49 	{ TARGET_PTP,                    0xc000, 1 }, /* 0xe200c000 */
50 	{ TARGET_CHIP_TOP,              0x10000, 1 }, /* 0xe2010000 */
51 	{ TARGET_REW,                   0x14000, 1 }, /* 0xe2014000 */
52 	{ TARGET_SYS,                   0x28000, 1 }, /* 0xe2028000 */
53 	{ TARGET_DEV,                   0x34000, 1 }, /* 0xe2034000 */
54 	{ TARGET_DEV +  1,              0x38000, 1 }, /* 0xe2038000 */
55 	{ TARGET_DEV +  2,              0x3c000, 1 }, /* 0xe203c000 */
56 	{ TARGET_DEV +  3,              0x40000, 1 }, /* 0xe2040000 */
57 	{ TARGET_DEV +  4,              0x44000, 1 }, /* 0xe2044000 */
58 	{ TARGET_DEV +  5,              0x48000, 1 }, /* 0xe2048000 */
59 	{ TARGET_DEV +  6,              0x4c000, 1 }, /* 0xe204c000 */
60 	{ TARGET_DEV +  7,              0x50000, 1 }, /* 0xe2050000 */
61 	{ TARGET_QSYS,                 0x100000, 1 }, /* 0xe2100000 */
62 	{ TARGET_AFI,                  0x120000, 1 }, /* 0xe2120000 */
63 	{ TARGET_ANA,                  0x140000, 1 }, /* 0xe2140000 */
64 };
65 
66 static int lan966x_create_targets(struct platform_device *pdev,
67 				  struct lan966x *lan966x)
68 {
69 	struct resource *iores[IO_RANGES];
70 	void __iomem *begin[IO_RANGES];
71 	int idx;
72 
73 	/* Initially map the entire range and after that update each target to
74 	 * point inside the region at the correct offset. It is possible that
75 	 * other devices access the same region so don't add any checks about
76 	 * this.
77 	 */
78 	for (idx = 0; idx < IO_RANGES; idx++) {
79 		iores[idx] = platform_get_resource(pdev, IORESOURCE_MEM,
80 						   idx);
81 		if (!iores[idx]) {
82 			dev_err(&pdev->dev, "Invalid resource\n");
83 			return -EINVAL;
84 		}
85 
86 		begin[idx] = devm_ioremap(&pdev->dev,
87 					  iores[idx]->start,
88 					  resource_size(iores[idx]));
89 		if (!begin[idx]) {
90 			dev_err(&pdev->dev, "Unable to get registers: %s\n",
91 				iores[idx]->name);
92 			return -ENOMEM;
93 		}
94 	}
95 
96 	for (idx = 0; idx < ARRAY_SIZE(lan966x_main_iomap); idx++) {
97 		const struct lan966x_main_io_resource *iomap =
98 			&lan966x_main_iomap[idx];
99 
100 		lan966x->regs[iomap->id] = begin[iomap->range] + iomap->offset;
101 	}
102 
103 	return 0;
104 }
105 
106 static int lan966x_port_set_mac_address(struct net_device *dev, void *p)
107 {
108 	struct lan966x_port *port = netdev_priv(dev);
109 	struct lan966x *lan966x = port->lan966x;
110 	const struct sockaddr *addr = p;
111 	int ret;
112 
113 	/* Learn the new net device MAC address in the mac table. */
114 	ret = lan966x_mac_cpu_learn(lan966x, addr->sa_data, HOST_PVID);
115 	if (ret)
116 		return ret;
117 
118 	/* Then forget the previous one. */
119 	ret = lan966x_mac_cpu_forget(lan966x, dev->dev_addr, HOST_PVID);
120 	if (ret)
121 		return ret;
122 
123 	eth_hw_addr_set(dev, addr->sa_data);
124 	return ret;
125 }
126 
127 static int lan966x_port_get_phys_port_name(struct net_device *dev,
128 					   char *buf, size_t len)
129 {
130 	struct lan966x_port *port = netdev_priv(dev);
131 	int ret;
132 
133 	ret = snprintf(buf, len, "p%d", port->chip_port);
134 	if (ret >= len)
135 		return -EINVAL;
136 
137 	return 0;
138 }
139 
140 static int lan966x_port_open(struct net_device *dev)
141 {
142 	struct lan966x_port *port = netdev_priv(dev);
143 	struct lan966x *lan966x = port->lan966x;
144 	int err;
145 
146 	/* Enable receiving frames on the port, and activate auto-learning of
147 	 * MAC addresses.
148 	 */
149 	lan_rmw(ANA_PORT_CFG_LEARNAUTO_SET(1) |
150 		ANA_PORT_CFG_RECV_ENA_SET(1) |
151 		ANA_PORT_CFG_PORTID_VAL_SET(port->chip_port),
152 		ANA_PORT_CFG_LEARNAUTO |
153 		ANA_PORT_CFG_RECV_ENA |
154 		ANA_PORT_CFG_PORTID_VAL,
155 		lan966x, ANA_PORT_CFG(port->chip_port));
156 
157 	err = phylink_fwnode_phy_connect(port->phylink, port->fwnode, 0);
158 	if (err) {
159 		netdev_err(dev, "Could not attach to PHY\n");
160 		return err;
161 	}
162 
163 	phylink_start(port->phylink);
164 
165 	return 0;
166 }
167 
168 static int lan966x_port_stop(struct net_device *dev)
169 {
170 	struct lan966x_port *port = netdev_priv(dev);
171 
172 	lan966x_port_config_down(port);
173 	phylink_stop(port->phylink);
174 	phylink_disconnect_phy(port->phylink);
175 
176 	return 0;
177 }
178 
179 static int lan966x_port_inj_status(struct lan966x *lan966x)
180 {
181 	return lan_rd(lan966x, QS_INJ_STATUS);
182 }
183 
184 static int lan966x_port_inj_ready(struct lan966x *lan966x, u8 grp)
185 {
186 	u32 val;
187 
188 	if (lan_rd(lan966x, QS_INJ_STATUS) & QS_INJ_STATUS_FIFO_RDY_SET(BIT(grp)))
189 		return 0;
190 
191 	return readx_poll_timeout_atomic(lan966x_port_inj_status, lan966x, val,
192 					 QS_INJ_STATUS_FIFO_RDY_GET(val) & BIT(grp),
193 					 READL_SLEEP_US, READL_TIMEOUT_US);
194 }
195 
196 static int lan966x_port_ifh_xmit(struct sk_buff *skb,
197 				 __be32 *ifh,
198 				 struct net_device *dev)
199 {
200 	struct lan966x_port *port = netdev_priv(dev);
201 	struct lan966x *lan966x = port->lan966x;
202 	u32 i, count, last;
203 	u8 grp = 0;
204 	u32 val;
205 	int err;
206 
207 	val = lan_rd(lan966x, QS_INJ_STATUS);
208 	if (!(QS_INJ_STATUS_FIFO_RDY_GET(val) & BIT(grp)) ||
209 	    (QS_INJ_STATUS_WMARK_REACHED_GET(val) & BIT(grp)))
210 		goto err;
211 
212 	/* Write start of frame */
213 	lan_wr(QS_INJ_CTRL_GAP_SIZE_SET(1) |
214 	       QS_INJ_CTRL_SOF_SET(1),
215 	       lan966x, QS_INJ_CTRL(grp));
216 
217 	/* Write IFH header */
218 	for (i = 0; i < IFH_LEN; ++i) {
219 		/* Wait until the fifo is ready */
220 		err = lan966x_port_inj_ready(lan966x, grp);
221 		if (err)
222 			goto err;
223 
224 		lan_wr((__force u32)ifh[i], lan966x, QS_INJ_WR(grp));
225 	}
226 
227 	/* Write frame */
228 	count = DIV_ROUND_UP(skb->len, 4);
229 	last = skb->len % 4;
230 	for (i = 0; i < count; ++i) {
231 		/* Wait until the fifo is ready */
232 		err = lan966x_port_inj_ready(lan966x, grp);
233 		if (err)
234 			goto err;
235 
236 		lan_wr(((u32 *)skb->data)[i], lan966x, QS_INJ_WR(grp));
237 	}
238 
239 	/* Add padding */
240 	while (i < (LAN966X_BUFFER_MIN_SZ / 4)) {
241 		/* Wait until the fifo is ready */
242 		err = lan966x_port_inj_ready(lan966x, grp);
243 		if (err)
244 			goto err;
245 
246 		lan_wr(0, lan966x, QS_INJ_WR(grp));
247 		++i;
248 	}
249 
250 	/* Inidcate EOF and valid bytes in the last word */
251 	lan_wr(QS_INJ_CTRL_GAP_SIZE_SET(1) |
252 	       QS_INJ_CTRL_VLD_BYTES_SET(skb->len < LAN966X_BUFFER_MIN_SZ ?
253 				     0 : last) |
254 	       QS_INJ_CTRL_EOF_SET(1),
255 	       lan966x, QS_INJ_CTRL(grp));
256 
257 	/* Add dummy CRC */
258 	lan_wr(0, lan966x, QS_INJ_WR(grp));
259 	skb_tx_timestamp(skb);
260 
261 	dev->stats.tx_packets++;
262 	dev->stats.tx_bytes += skb->len;
263 
264 	if (skb_shinfo(skb)->tx_flags & SKBTX_HW_TSTAMP &&
265 	    LAN966X_SKB_CB(skb)->rew_op == IFH_REW_OP_TWO_STEP_PTP)
266 		return NETDEV_TX_OK;
267 
268 	dev_consume_skb_any(skb);
269 	return NETDEV_TX_OK;
270 
271 err:
272 	if (skb_shinfo(skb)->tx_flags & SKBTX_HW_TSTAMP &&
273 	    LAN966X_SKB_CB(skb)->rew_op == IFH_REW_OP_TWO_STEP_PTP)
274 		lan966x_ptp_txtstamp_release(port, skb);
275 
276 	return NETDEV_TX_BUSY;
277 }
278 
279 static void lan966x_ifh_set_bypass(void *ifh, u64 bypass)
280 {
281 	packing(ifh, &bypass, IFH_POS_BYPASS + IFH_WID_BYPASS - 1,
282 		IFH_POS_BYPASS, IFH_LEN * 4, PACK, 0);
283 }
284 
285 static void lan966x_ifh_set_port(void *ifh, u64 bypass)
286 {
287 	packing(ifh, &bypass, IFH_POS_DSTS + IFH_WID_DSTS - 1,
288 		IFH_POS_DSTS, IFH_LEN * 4, PACK, 0);
289 }
290 
291 static void lan966x_ifh_set_qos_class(void *ifh, u64 bypass)
292 {
293 	packing(ifh, &bypass, IFH_POS_QOS_CLASS + IFH_WID_QOS_CLASS - 1,
294 		IFH_POS_QOS_CLASS, IFH_LEN * 4, PACK, 0);
295 }
296 
297 static void lan966x_ifh_set_ipv(void *ifh, u64 bypass)
298 {
299 	packing(ifh, &bypass, IFH_POS_IPV + IFH_WID_IPV - 1,
300 		IFH_POS_IPV, IFH_LEN * 4, PACK, 0);
301 }
302 
303 static void lan966x_ifh_set_vid(void *ifh, u64 vid)
304 {
305 	packing(ifh, &vid, IFH_POS_TCI + IFH_WID_TCI - 1,
306 		IFH_POS_TCI, IFH_LEN * 4, PACK, 0);
307 }
308 
309 static void lan966x_ifh_set_rew_op(void *ifh, u64 rew_op)
310 {
311 	packing(ifh, &rew_op, IFH_POS_REW_CMD + IFH_WID_REW_CMD - 1,
312 		IFH_POS_REW_CMD, IFH_LEN * 4, PACK, 0);
313 }
314 
315 static void lan966x_ifh_set_timestamp(void *ifh, u64 timestamp)
316 {
317 	packing(ifh, &timestamp, IFH_POS_TIMESTAMP + IFH_WID_TIMESTAMP - 1,
318 		IFH_POS_TIMESTAMP, IFH_LEN * 4, PACK, 0);
319 }
320 
321 static int lan966x_port_xmit(struct sk_buff *skb, struct net_device *dev)
322 {
323 	struct lan966x_port *port = netdev_priv(dev);
324 	struct lan966x *lan966x = port->lan966x;
325 	__be32 ifh[IFH_LEN];
326 	int err;
327 
328 	memset(ifh, 0x0, sizeof(__be32) * IFH_LEN);
329 
330 	lan966x_ifh_set_bypass(ifh, 1);
331 	lan966x_ifh_set_port(ifh, BIT_ULL(port->chip_port));
332 	lan966x_ifh_set_qos_class(ifh, skb->priority >= 7 ? 0x7 : skb->priority);
333 	lan966x_ifh_set_ipv(ifh, skb->priority >= 7 ? 0x7 : skb->priority);
334 	lan966x_ifh_set_vid(ifh, skb_vlan_tag_get(skb));
335 
336 	if (port->lan966x->ptp && skb_shinfo(skb)->tx_flags & SKBTX_HW_TSTAMP) {
337 		err = lan966x_ptp_txtstamp_request(port, skb);
338 		if (err)
339 			return err;
340 
341 		lan966x_ifh_set_rew_op(ifh, LAN966X_SKB_CB(skb)->rew_op);
342 		lan966x_ifh_set_timestamp(ifh, LAN966X_SKB_CB(skb)->ts_id);
343 	}
344 
345 	spin_lock(&lan966x->tx_lock);
346 	err = lan966x_port_ifh_xmit(skb, ifh, dev);
347 	spin_unlock(&lan966x->tx_lock);
348 
349 	return err;
350 }
351 
352 static int lan966x_port_change_mtu(struct net_device *dev, int new_mtu)
353 {
354 	struct lan966x_port *port = netdev_priv(dev);
355 	struct lan966x *lan966x = port->lan966x;
356 
357 	lan_wr(DEV_MAC_MAXLEN_CFG_MAX_LEN_SET(new_mtu),
358 	       lan966x, DEV_MAC_MAXLEN_CFG(port->chip_port));
359 	dev->mtu = new_mtu;
360 
361 	return 0;
362 }
363 
364 static int lan966x_mc_unsync(struct net_device *dev, const unsigned char *addr)
365 {
366 	struct lan966x_port *port = netdev_priv(dev);
367 	struct lan966x *lan966x = port->lan966x;
368 
369 	return lan966x_mac_forget(lan966x, addr, HOST_PVID, ENTRYTYPE_LOCKED);
370 }
371 
372 static int lan966x_mc_sync(struct net_device *dev, const unsigned char *addr)
373 {
374 	struct lan966x_port *port = netdev_priv(dev);
375 	struct lan966x *lan966x = port->lan966x;
376 
377 	return lan966x_mac_cpu_learn(lan966x, addr, HOST_PVID);
378 }
379 
380 static void lan966x_port_set_rx_mode(struct net_device *dev)
381 {
382 	__dev_mc_sync(dev, lan966x_mc_sync, lan966x_mc_unsync);
383 }
384 
385 static int lan966x_port_get_parent_id(struct net_device *dev,
386 				      struct netdev_phys_item_id *ppid)
387 {
388 	struct lan966x_port *port = netdev_priv(dev);
389 	struct lan966x *lan966x = port->lan966x;
390 
391 	ppid->id_len = sizeof(lan966x->base_mac);
392 	memcpy(&ppid->id, &lan966x->base_mac, ppid->id_len);
393 
394 	return 0;
395 }
396 
397 static int lan966x_port_ioctl(struct net_device *dev, struct ifreq *ifr,
398 			      int cmd)
399 {
400 	struct lan966x_port *port = netdev_priv(dev);
401 
402 	if (!phy_has_hwtstamp(dev->phydev) && port->lan966x->ptp) {
403 		switch (cmd) {
404 		case SIOCSHWTSTAMP:
405 			return lan966x_ptp_hwtstamp_set(port, ifr);
406 		case SIOCGHWTSTAMP:
407 			return lan966x_ptp_hwtstamp_get(port, ifr);
408 		}
409 	}
410 
411 	if (!dev->phydev)
412 		return -ENODEV;
413 
414 	return phy_mii_ioctl(dev->phydev, ifr, cmd);
415 }
416 
417 static const struct net_device_ops lan966x_port_netdev_ops = {
418 	.ndo_open			= lan966x_port_open,
419 	.ndo_stop			= lan966x_port_stop,
420 	.ndo_start_xmit			= lan966x_port_xmit,
421 	.ndo_change_mtu			= lan966x_port_change_mtu,
422 	.ndo_set_rx_mode		= lan966x_port_set_rx_mode,
423 	.ndo_get_phys_port_name		= lan966x_port_get_phys_port_name,
424 	.ndo_get_stats64		= lan966x_stats_get,
425 	.ndo_set_mac_address		= lan966x_port_set_mac_address,
426 	.ndo_get_port_parent_id		= lan966x_port_get_parent_id,
427 	.ndo_eth_ioctl			= lan966x_port_ioctl,
428 };
429 
430 bool lan966x_netdevice_check(const struct net_device *dev)
431 {
432 	return dev->netdev_ops == &lan966x_port_netdev_ops;
433 }
434 
435 static bool lan966x_hw_offload(struct lan966x *lan966x, u32 port,
436 			       struct sk_buff *skb)
437 {
438 	u32 val;
439 
440 	/* The IGMP and MLD frames are not forward by the HW if
441 	 * multicast snooping is enabled, therefor don't mark as
442 	 * offload to allow the SW to forward the frames accordingly.
443 	 */
444 	val = lan_rd(lan966x, ANA_CPU_FWD_CFG(port));
445 	if (!(val & (ANA_CPU_FWD_CFG_IGMP_REDIR_ENA |
446 		     ANA_CPU_FWD_CFG_MLD_REDIR_ENA)))
447 		return true;
448 
449 	if (skb->protocol == htons(ETH_P_IP) &&
450 	    ip_hdr(skb)->protocol == IPPROTO_IGMP)
451 		return false;
452 
453 	if (IS_ENABLED(CONFIG_IPV6) &&
454 	    skb->protocol == htons(ETH_P_IPV6) &&
455 	    ipv6_addr_is_multicast(&ipv6_hdr(skb)->daddr) &&
456 	    !ipv6_mc_check_mld(skb))
457 		return false;
458 
459 	return true;
460 }
461 
462 static int lan966x_port_xtr_status(struct lan966x *lan966x, u8 grp)
463 {
464 	return lan_rd(lan966x, QS_XTR_RD(grp));
465 }
466 
467 static int lan966x_port_xtr_ready(struct lan966x *lan966x, u8 grp)
468 {
469 	u32 val;
470 
471 	return read_poll_timeout(lan966x_port_xtr_status, val,
472 				 val != XTR_NOT_READY,
473 				 READL_SLEEP_US, READL_TIMEOUT_US, false,
474 				 lan966x, grp);
475 }
476 
477 static int lan966x_rx_frame_word(struct lan966x *lan966x, u8 grp, u32 *rval)
478 {
479 	u32 bytes_valid;
480 	u32 val;
481 	int err;
482 
483 	val = lan_rd(lan966x, QS_XTR_RD(grp));
484 	if (val == XTR_NOT_READY) {
485 		err = lan966x_port_xtr_ready(lan966x, grp);
486 		if (err)
487 			return -EIO;
488 	}
489 
490 	switch (val) {
491 	case XTR_ABORT:
492 		return -EIO;
493 	case XTR_EOF_0:
494 	case XTR_EOF_1:
495 	case XTR_EOF_2:
496 	case XTR_EOF_3:
497 	case XTR_PRUNED:
498 		bytes_valid = XTR_VALID_BYTES(val);
499 		val = lan_rd(lan966x, QS_XTR_RD(grp));
500 		if (val == XTR_ESCAPE)
501 			*rval = lan_rd(lan966x, QS_XTR_RD(grp));
502 		else
503 			*rval = val;
504 
505 		return bytes_valid;
506 	case XTR_ESCAPE:
507 		*rval = lan_rd(lan966x, QS_XTR_RD(grp));
508 
509 		return 4;
510 	default:
511 		*rval = val;
512 
513 		return 4;
514 	}
515 }
516 
517 static void lan966x_ifh_get_src_port(void *ifh, u64 *src_port)
518 {
519 	packing(ifh, src_port, IFH_POS_SRCPORT + IFH_WID_SRCPORT - 1,
520 		IFH_POS_SRCPORT, IFH_LEN * 4, UNPACK, 0);
521 }
522 
523 static void lan966x_ifh_get_len(void *ifh, u64 *len)
524 {
525 	packing(ifh, len, IFH_POS_LEN + IFH_WID_LEN - 1,
526 		IFH_POS_LEN, IFH_LEN * 4, UNPACK, 0);
527 }
528 
529 static void lan966x_ifh_get_timestamp(void *ifh, u64 *timestamp)
530 {
531 	packing(ifh, timestamp, IFH_POS_TIMESTAMP + IFH_WID_TIMESTAMP - 1,
532 		IFH_POS_TIMESTAMP, IFH_LEN * 4, UNPACK, 0);
533 }
534 
535 static irqreturn_t lan966x_xtr_irq_handler(int irq, void *args)
536 {
537 	struct lan966x *lan966x = args;
538 	int i, grp = 0, err = 0;
539 
540 	if (!(lan_rd(lan966x, QS_XTR_DATA_PRESENT) & BIT(grp)))
541 		return IRQ_NONE;
542 
543 	do {
544 		u64 src_port, len, timestamp;
545 		struct net_device *dev;
546 		struct sk_buff *skb;
547 		int sz = 0, buf_len;
548 		u32 ifh[IFH_LEN];
549 		u32 *buf;
550 		u32 val;
551 
552 		for (i = 0; i < IFH_LEN; i++) {
553 			err = lan966x_rx_frame_word(lan966x, grp, &ifh[i]);
554 			if (err != 4)
555 				goto recover;
556 		}
557 
558 		err = 0;
559 
560 		lan966x_ifh_get_src_port(ifh, &src_port);
561 		lan966x_ifh_get_len(ifh, &len);
562 		lan966x_ifh_get_timestamp(ifh, &timestamp);
563 
564 		WARN_ON(src_port >= lan966x->num_phys_ports);
565 
566 		dev = lan966x->ports[src_port]->dev;
567 		skb = netdev_alloc_skb(dev, len);
568 		if (unlikely(!skb)) {
569 			netdev_err(dev, "Unable to allocate sk_buff\n");
570 			err = -ENOMEM;
571 			break;
572 		}
573 		buf_len = len - ETH_FCS_LEN;
574 		buf = (u32 *)skb_put(skb, buf_len);
575 
576 		len = 0;
577 		do {
578 			sz = lan966x_rx_frame_word(lan966x, grp, &val);
579 			if (sz < 0) {
580 				kfree_skb(skb);
581 				goto recover;
582 			}
583 
584 			*buf++ = val;
585 			len += sz;
586 		} while (len < buf_len);
587 
588 		/* Read the FCS */
589 		sz = lan966x_rx_frame_word(lan966x, grp, &val);
590 		if (sz < 0) {
591 			kfree_skb(skb);
592 			goto recover;
593 		}
594 
595 		/* Update the statistics if part of the FCS was read before */
596 		len -= ETH_FCS_LEN - sz;
597 
598 		if (unlikely(dev->features & NETIF_F_RXFCS)) {
599 			buf = (u32 *)skb_put(skb, ETH_FCS_LEN);
600 			*buf = val;
601 		}
602 
603 		lan966x_ptp_rxtstamp(lan966x, skb, timestamp);
604 		skb->protocol = eth_type_trans(skb, dev);
605 
606 		if (lan966x->bridge_mask & BIT(src_port)) {
607 			skb->offload_fwd_mark = 1;
608 
609 			skb_reset_network_header(skb);
610 			if (!lan966x_hw_offload(lan966x, src_port, skb))
611 				skb->offload_fwd_mark = 0;
612 		}
613 
614 		if (!skb_defer_rx_timestamp(skb))
615 			netif_rx(skb);
616 
617 		dev->stats.rx_bytes += len;
618 		dev->stats.rx_packets++;
619 
620 recover:
621 		if (sz < 0 || err)
622 			lan_rd(lan966x, QS_XTR_RD(grp));
623 
624 	} while (lan_rd(lan966x, QS_XTR_DATA_PRESENT) & BIT(grp));
625 
626 	return IRQ_HANDLED;
627 }
628 
629 static irqreturn_t lan966x_ana_irq_handler(int irq, void *args)
630 {
631 	struct lan966x *lan966x = args;
632 
633 	return lan966x_mac_irq_handler(lan966x);
634 }
635 
636 static void lan966x_cleanup_ports(struct lan966x *lan966x)
637 {
638 	struct lan966x_port *port;
639 	int p;
640 
641 	for (p = 0; p < lan966x->num_phys_ports; p++) {
642 		port = lan966x->ports[p];
643 		if (!port)
644 			continue;
645 
646 		if (port->dev)
647 			unregister_netdev(port->dev);
648 
649 		if (port->phylink) {
650 			rtnl_lock();
651 			lan966x_port_stop(port->dev);
652 			rtnl_unlock();
653 			phylink_destroy(port->phylink);
654 			port->phylink = NULL;
655 		}
656 
657 		if (port->fwnode)
658 			fwnode_handle_put(port->fwnode);
659 	}
660 
661 	disable_irq(lan966x->xtr_irq);
662 	lan966x->xtr_irq = -ENXIO;
663 
664 	if (lan966x->ana_irq) {
665 		disable_irq(lan966x->ana_irq);
666 		lan966x->ana_irq = -ENXIO;
667 	}
668 }
669 
670 static int lan966x_probe_port(struct lan966x *lan966x, u32 p,
671 			      phy_interface_t phy_mode,
672 			      struct fwnode_handle *portnp)
673 {
674 	struct lan966x_port *port;
675 	struct phylink *phylink;
676 	struct net_device *dev;
677 	int err;
678 
679 	if (p >= lan966x->num_phys_ports)
680 		return -EINVAL;
681 
682 	dev = devm_alloc_etherdev_mqs(lan966x->dev,
683 				      sizeof(struct lan966x_port), 8, 1);
684 	if (!dev)
685 		return -ENOMEM;
686 
687 	SET_NETDEV_DEV(dev, lan966x->dev);
688 	port = netdev_priv(dev);
689 	port->dev = dev;
690 	port->lan966x = lan966x;
691 	port->chip_port = p;
692 	lan966x->ports[p] = port;
693 
694 	dev->max_mtu = ETH_MAX_MTU;
695 
696 	dev->netdev_ops = &lan966x_port_netdev_ops;
697 	dev->ethtool_ops = &lan966x_ethtool_ops;
698 	dev->features |= NETIF_F_HW_VLAN_CTAG_TX |
699 			 NETIF_F_HW_VLAN_STAG_TX;
700 	dev->needed_headroom = IFH_LEN * sizeof(u32);
701 
702 	eth_hw_addr_gen(dev, lan966x->base_mac, p + 1);
703 
704 	lan966x_mac_learn(lan966x, PGID_CPU, dev->dev_addr, HOST_PVID,
705 			  ENTRYTYPE_LOCKED);
706 
707 	port->phylink_config.dev = &port->dev->dev;
708 	port->phylink_config.type = PHYLINK_NETDEV;
709 	port->phylink_pcs.poll = true;
710 	port->phylink_pcs.ops = &lan966x_phylink_pcs_ops;
711 
712 	port->phylink_config.mac_capabilities = MAC_ASYM_PAUSE | MAC_SYM_PAUSE |
713 		MAC_10 | MAC_100 | MAC_1000FD | MAC_2500FD;
714 
715 	__set_bit(PHY_INTERFACE_MODE_MII,
716 		  port->phylink_config.supported_interfaces);
717 	__set_bit(PHY_INTERFACE_MODE_GMII,
718 		  port->phylink_config.supported_interfaces);
719 	__set_bit(PHY_INTERFACE_MODE_SGMII,
720 		  port->phylink_config.supported_interfaces);
721 	__set_bit(PHY_INTERFACE_MODE_QSGMII,
722 		  port->phylink_config.supported_interfaces);
723 	__set_bit(PHY_INTERFACE_MODE_1000BASEX,
724 		  port->phylink_config.supported_interfaces);
725 	__set_bit(PHY_INTERFACE_MODE_2500BASEX,
726 		  port->phylink_config.supported_interfaces);
727 
728 	phylink = phylink_create(&port->phylink_config,
729 				 portnp,
730 				 phy_mode,
731 				 &lan966x_phylink_mac_ops);
732 	if (IS_ERR(phylink)) {
733 		port->dev = NULL;
734 		return PTR_ERR(phylink);
735 	}
736 
737 	port->phylink = phylink;
738 
739 	err = register_netdev(dev);
740 	if (err) {
741 		dev_err(lan966x->dev, "register_netdev failed\n");
742 		return err;
743 	}
744 
745 	lan966x_vlan_port_set_vlan_aware(port, 0);
746 	lan966x_vlan_port_set_vid(port, HOST_PVID, false, false);
747 	lan966x_vlan_port_apply(port);
748 
749 	return 0;
750 }
751 
752 static void lan966x_init(struct lan966x *lan966x)
753 {
754 	u32 p, i;
755 
756 	/* MAC table initialization */
757 	lan966x_mac_init(lan966x);
758 
759 	lan966x_vlan_init(lan966x);
760 
761 	/* Flush queues */
762 	lan_wr(lan_rd(lan966x, QS_XTR_FLUSH) |
763 	       GENMASK(1, 0),
764 	       lan966x, QS_XTR_FLUSH);
765 
766 	/* Allow to drain */
767 	mdelay(1);
768 
769 	/* All Queues normal */
770 	lan_wr(lan_rd(lan966x, QS_XTR_FLUSH) &
771 	       ~(GENMASK(1, 0)),
772 	       lan966x, QS_XTR_FLUSH);
773 
774 	/* Set MAC age time to default value, the entry is aged after
775 	 * 2 * AGE_PERIOD
776 	 */
777 	lan_wr(ANA_AUTOAGE_AGE_PERIOD_SET(BR_DEFAULT_AGEING_TIME / 2 / HZ),
778 	       lan966x, ANA_AUTOAGE);
779 
780 	/* Disable learning for frames discarded by VLAN ingress filtering */
781 	lan_rmw(ANA_ADVLEARN_VLAN_CHK_SET(1),
782 		ANA_ADVLEARN_VLAN_CHK,
783 		lan966x, ANA_ADVLEARN);
784 
785 	/* Setup frame ageing - "2 sec" - The unit is 6.5 us on lan966x */
786 	lan_wr(SYS_FRM_AGING_AGE_TX_ENA_SET(1) |
787 	       (20000000 / 65),
788 	       lan966x,  SYS_FRM_AGING);
789 
790 	/* Map the 8 CPU extraction queues to CPU port */
791 	lan_wr(0, lan966x, QSYS_CPU_GROUP_MAP);
792 
793 	/* Do byte-swap and expect status after last data word
794 	 * Extraction: Mode: manual extraction) | Byte_swap
795 	 */
796 	lan_wr(QS_XTR_GRP_CFG_MODE_SET(1) |
797 	       QS_XTR_GRP_CFG_BYTE_SWAP_SET(1),
798 	       lan966x, QS_XTR_GRP_CFG(0));
799 
800 	/* Injection: Mode: manual injection | Byte_swap */
801 	lan_wr(QS_INJ_GRP_CFG_MODE_SET(1) |
802 	       QS_INJ_GRP_CFG_BYTE_SWAP_SET(1),
803 	       lan966x, QS_INJ_GRP_CFG(0));
804 
805 	lan_rmw(QS_INJ_CTRL_GAP_SIZE_SET(0),
806 		QS_INJ_CTRL_GAP_SIZE,
807 		lan966x, QS_INJ_CTRL(0));
808 
809 	/* Enable IFH insertion/parsing on CPU ports */
810 	lan_wr(SYS_PORT_MODE_INCL_INJ_HDR_SET(1) |
811 	       SYS_PORT_MODE_INCL_XTR_HDR_SET(1),
812 	       lan966x, SYS_PORT_MODE(CPU_PORT));
813 
814 	/* Setup flooding PGIDs */
815 	lan_wr(ANA_FLOODING_IPMC_FLD_MC4_DATA_SET(PGID_MCIPV4) |
816 	       ANA_FLOODING_IPMC_FLD_MC4_CTRL_SET(PGID_MC) |
817 	       ANA_FLOODING_IPMC_FLD_MC6_DATA_SET(PGID_MCIPV6) |
818 	       ANA_FLOODING_IPMC_FLD_MC6_CTRL_SET(PGID_MC),
819 	       lan966x, ANA_FLOODING_IPMC);
820 
821 	/* There are 8 priorities */
822 	for (i = 0; i < 8; ++i)
823 		lan_rmw(ANA_FLOODING_FLD_MULTICAST_SET(PGID_MC) |
824 			ANA_FLOODING_FLD_UNICAST_SET(PGID_UC) |
825 			ANA_FLOODING_FLD_BROADCAST_SET(PGID_BC),
826 			ANA_FLOODING_FLD_MULTICAST |
827 			ANA_FLOODING_FLD_UNICAST |
828 			ANA_FLOODING_FLD_BROADCAST,
829 			lan966x, ANA_FLOODING(i));
830 
831 	for (i = 0; i < PGID_ENTRIES; ++i)
832 		/* Set all the entries to obey VLAN_VLAN */
833 		lan_rmw(ANA_PGID_CFG_OBEY_VLAN_SET(1),
834 			ANA_PGID_CFG_OBEY_VLAN,
835 			lan966x, ANA_PGID_CFG(i));
836 
837 	for (p = 0; p < lan966x->num_phys_ports; p++) {
838 		/* Disable bridging by default */
839 		lan_rmw(ANA_PGID_PGID_SET(0x0),
840 			ANA_PGID_PGID,
841 			lan966x, ANA_PGID(p + PGID_SRC));
842 
843 		/* Do not forward BPDU frames to the front ports and copy them
844 		 * to CPU
845 		 */
846 		lan_wr(0xffff, lan966x, ANA_CPU_FWD_BPDU_CFG(p));
847 	}
848 
849 	/* Set source buffer size for each priority and each port to 1500 bytes */
850 	for (i = 0; i <= QSYS_Q_RSRV; ++i) {
851 		lan_wr(1500 / 64, lan966x, QSYS_RES_CFG(i));
852 		lan_wr(1500 / 64, lan966x, QSYS_RES_CFG(512 + i));
853 	}
854 
855 	/* Enable switching to/from cpu port */
856 	lan_wr(QSYS_SW_PORT_MODE_PORT_ENA_SET(1) |
857 	       QSYS_SW_PORT_MODE_SCH_NEXT_CFG_SET(1) |
858 	       QSYS_SW_PORT_MODE_INGRESS_DROP_MODE_SET(1),
859 	       lan966x,  QSYS_SW_PORT_MODE(CPU_PORT));
860 
861 	/* Configure and enable the CPU port */
862 	lan_rmw(ANA_PGID_PGID_SET(0),
863 		ANA_PGID_PGID,
864 		lan966x, ANA_PGID(CPU_PORT));
865 	lan_rmw(ANA_PGID_PGID_SET(BIT(CPU_PORT)),
866 		ANA_PGID_PGID,
867 		lan966x, ANA_PGID(PGID_CPU));
868 
869 	/* Multicast to all other ports */
870 	lan_rmw(GENMASK(lan966x->num_phys_ports - 1, 0),
871 		ANA_PGID_PGID,
872 		lan966x, ANA_PGID(PGID_MC));
873 
874 	/* This will be controlled by mrouter ports */
875 	lan_rmw(GENMASK(lan966x->num_phys_ports - 1, 0),
876 		ANA_PGID_PGID,
877 		lan966x, ANA_PGID(PGID_MCIPV4));
878 
879 	lan_rmw(GENMASK(lan966x->num_phys_ports - 1, 0),
880 		ANA_PGID_PGID,
881 		lan966x, ANA_PGID(PGID_MCIPV6));
882 
883 	/* Unicast to all other ports */
884 	lan_rmw(GENMASK(lan966x->num_phys_ports - 1, 0),
885 		ANA_PGID_PGID,
886 		lan966x, ANA_PGID(PGID_UC));
887 
888 	/* Broadcast to the CPU port and to other ports */
889 	lan_rmw(ANA_PGID_PGID_SET(BIT(CPU_PORT) | GENMASK(lan966x->num_phys_ports - 1, 0)),
890 		ANA_PGID_PGID,
891 		lan966x, ANA_PGID(PGID_BC));
892 
893 	lan_wr(REW_PORT_CFG_NO_REWRITE_SET(1),
894 	       lan966x, REW_PORT_CFG(CPU_PORT));
895 
896 	lan_rmw(ANA_ANAINTR_INTR_ENA_SET(1),
897 		ANA_ANAINTR_INTR_ENA,
898 		lan966x, ANA_ANAINTR);
899 
900 	spin_lock_init(&lan966x->tx_lock);
901 }
902 
903 static int lan966x_ram_init(struct lan966x *lan966x)
904 {
905 	return lan_rd(lan966x, SYS_RAM_INIT);
906 }
907 
908 static int lan966x_reset_switch(struct lan966x *lan966x)
909 {
910 	struct reset_control *switch_reset, *phy_reset;
911 	int val = 0;
912 	int ret;
913 
914 	switch_reset = devm_reset_control_get_shared(lan966x->dev, "switch");
915 	if (IS_ERR(switch_reset))
916 		return dev_err_probe(lan966x->dev, PTR_ERR(switch_reset),
917 				     "Could not obtain switch reset");
918 
919 	phy_reset = devm_reset_control_get_shared(lan966x->dev, "phy");
920 	if (IS_ERR(phy_reset))
921 		return dev_err_probe(lan966x->dev, PTR_ERR(phy_reset),
922 				     "Could not obtain phy reset\n");
923 
924 	reset_control_reset(switch_reset);
925 	reset_control_reset(phy_reset);
926 
927 	lan_wr(SYS_RESET_CFG_CORE_ENA_SET(0), lan966x, SYS_RESET_CFG);
928 	lan_wr(SYS_RAM_INIT_RAM_INIT_SET(1), lan966x, SYS_RAM_INIT);
929 	ret = readx_poll_timeout(lan966x_ram_init, lan966x,
930 				 val, (val & BIT(1)) == 0, READL_SLEEP_US,
931 				 READL_TIMEOUT_US);
932 	if (ret)
933 		return ret;
934 
935 	lan_wr(SYS_RESET_CFG_CORE_ENA_SET(1), lan966x, SYS_RESET_CFG);
936 
937 	return 0;
938 }
939 
940 static int lan966x_probe(struct platform_device *pdev)
941 {
942 	struct fwnode_handle *ports, *portnp;
943 	struct lan966x *lan966x;
944 	u8 mac_addr[ETH_ALEN];
945 	int err, i;
946 
947 	lan966x = devm_kzalloc(&pdev->dev, sizeof(*lan966x), GFP_KERNEL);
948 	if (!lan966x)
949 		return -ENOMEM;
950 
951 	platform_set_drvdata(pdev, lan966x);
952 	lan966x->dev = &pdev->dev;
953 
954 	if (!device_get_mac_address(&pdev->dev, mac_addr)) {
955 		ether_addr_copy(lan966x->base_mac, mac_addr);
956 	} else {
957 		pr_info("MAC addr was not set, use random MAC\n");
958 		eth_random_addr(lan966x->base_mac);
959 		lan966x->base_mac[5] &= 0xf0;
960 	}
961 
962 	ports = device_get_named_child_node(&pdev->dev, "ethernet-ports");
963 	if (!ports)
964 		return dev_err_probe(&pdev->dev, -ENODEV,
965 				     "no ethernet-ports child found\n");
966 
967 	err = lan966x_create_targets(pdev, lan966x);
968 	if (err)
969 		return dev_err_probe(&pdev->dev, err,
970 				     "Failed to create targets");
971 
972 	err = lan966x_reset_switch(lan966x);
973 	if (err)
974 		return dev_err_probe(&pdev->dev, err, "Reset failed");
975 
976 	i = 0;
977 	fwnode_for_each_available_child_node(ports, portnp)
978 		++i;
979 
980 	lan966x->num_phys_ports = i;
981 	lan966x->ports = devm_kcalloc(&pdev->dev, lan966x->num_phys_ports,
982 				      sizeof(struct lan966x_port *),
983 				      GFP_KERNEL);
984 	if (!lan966x->ports)
985 		return -ENOMEM;
986 
987 	/* There QS system has 32KB of memory */
988 	lan966x->shared_queue_sz = LAN966X_BUFFER_MEMORY;
989 
990 	/* set irq */
991 	lan966x->xtr_irq = platform_get_irq_byname(pdev, "xtr");
992 	if (lan966x->xtr_irq <= 0)
993 		return -EINVAL;
994 
995 	err = devm_request_threaded_irq(&pdev->dev, lan966x->xtr_irq, NULL,
996 					lan966x_xtr_irq_handler, IRQF_ONESHOT,
997 					"frame extraction", lan966x);
998 	if (err) {
999 		pr_err("Unable to use xtr irq");
1000 		return -ENODEV;
1001 	}
1002 
1003 	lan966x->ana_irq = platform_get_irq_byname(pdev, "ana");
1004 	if (lan966x->ana_irq) {
1005 		err = devm_request_threaded_irq(&pdev->dev, lan966x->ana_irq, NULL,
1006 						lan966x_ana_irq_handler, IRQF_ONESHOT,
1007 						"ana irq", lan966x);
1008 		if (err)
1009 			return dev_err_probe(&pdev->dev, err, "Unable to use ana irq");
1010 	}
1011 
1012 	lan966x->ptp_irq = platform_get_irq_byname(pdev, "ptp");
1013 	if (lan966x->ptp_irq > 0) {
1014 		err = devm_request_threaded_irq(&pdev->dev, lan966x->ptp_irq, NULL,
1015 						lan966x_ptp_irq_handler, IRQF_ONESHOT,
1016 						"ptp irq", lan966x);
1017 		if (err)
1018 			return dev_err_probe(&pdev->dev, err, "Unable to use ptp irq");
1019 
1020 		lan966x->ptp = 1;
1021 	}
1022 
1023 	/* init switch */
1024 	lan966x_init(lan966x);
1025 	lan966x_stats_init(lan966x);
1026 
1027 	/* go over the child nodes */
1028 	fwnode_for_each_available_child_node(ports, portnp) {
1029 		phy_interface_t phy_mode;
1030 		struct phy *serdes;
1031 		u32 p;
1032 
1033 		if (fwnode_property_read_u32(portnp, "reg", &p))
1034 			continue;
1035 
1036 		phy_mode = fwnode_get_phy_mode(portnp);
1037 		err = lan966x_probe_port(lan966x, p, phy_mode, portnp);
1038 		if (err)
1039 			goto cleanup_ports;
1040 
1041 		/* Read needed configuration */
1042 		lan966x->ports[p]->config.portmode = phy_mode;
1043 		lan966x->ports[p]->fwnode = fwnode_handle_get(portnp);
1044 
1045 		serdes = devm_of_phy_get(lan966x->dev, to_of_node(portnp), NULL);
1046 		if (!IS_ERR(serdes))
1047 			lan966x->ports[p]->serdes = serdes;
1048 
1049 		lan966x_port_init(lan966x->ports[p]);
1050 	}
1051 
1052 	lan966x_mdb_init(lan966x);
1053 	err = lan966x_fdb_init(lan966x);
1054 	if (err)
1055 		goto cleanup_ports;
1056 
1057 	err = lan966x_ptp_init(lan966x);
1058 	if (err)
1059 		goto cleanup_fdb;
1060 
1061 	return 0;
1062 
1063 cleanup_fdb:
1064 	lan966x_fdb_deinit(lan966x);
1065 
1066 cleanup_ports:
1067 	fwnode_handle_put(portnp);
1068 
1069 	lan966x_cleanup_ports(lan966x);
1070 
1071 	cancel_delayed_work_sync(&lan966x->stats_work);
1072 	destroy_workqueue(lan966x->stats_queue);
1073 	mutex_destroy(&lan966x->stats_lock);
1074 
1075 	return err;
1076 }
1077 
1078 static int lan966x_remove(struct platform_device *pdev)
1079 {
1080 	struct lan966x *lan966x = platform_get_drvdata(pdev);
1081 
1082 	lan966x_cleanup_ports(lan966x);
1083 
1084 	cancel_delayed_work_sync(&lan966x->stats_work);
1085 	destroy_workqueue(lan966x->stats_queue);
1086 	mutex_destroy(&lan966x->stats_lock);
1087 
1088 	lan966x_mac_purge_entries(lan966x);
1089 	lan966x_mdb_deinit(lan966x);
1090 	lan966x_fdb_deinit(lan966x);
1091 	lan966x_ptp_deinit(lan966x);
1092 
1093 	return 0;
1094 }
1095 
1096 static struct platform_driver lan966x_driver = {
1097 	.probe = lan966x_probe,
1098 	.remove = lan966x_remove,
1099 	.driver = {
1100 		.name = "lan966x-switch",
1101 		.of_match_table = lan966x_match,
1102 	},
1103 };
1104 
1105 static int __init lan966x_switch_driver_init(void)
1106 {
1107 	int ret;
1108 
1109 	lan966x_register_notifier_blocks();
1110 
1111 	ret = platform_driver_register(&lan966x_driver);
1112 	if (ret)
1113 		goto err;
1114 
1115 	return 0;
1116 
1117 err:
1118 	lan966x_unregister_notifier_blocks();
1119 	return ret;
1120 }
1121 
1122 static void __exit lan966x_switch_driver_exit(void)
1123 {
1124 	platform_driver_unregister(&lan966x_driver);
1125 	lan966x_unregister_notifier_blocks();
1126 }
1127 
1128 module_init(lan966x_switch_driver_init);
1129 module_exit(lan966x_switch_driver_exit);
1130 
1131 MODULE_DESCRIPTION("Microchip LAN966X switch driver");
1132 MODULE_AUTHOR("Horatiu Vultur <horatiu.vultur@microchip.com>");
1133 MODULE_LICENSE("Dual MIT/GPL");
1134