[linux.git] / net / dsa / master.c

/*
 * Handling of a master device, switching frames via its switch fabric CPU port
 *
 * Copyright (c) 2017 Savoir-faire Linux Inc.
 *	Vivien Didelot <[email protected]>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 */

#include "dsa_priv.h"

static void dsa_master_get_ethtool_stats(struct net_device *dev,
					 struct ethtool_stats *stats,
					 uint64_t *data)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	struct dsa_switch *ds = cpu_dp->ds;
	int port = cpu_dp->index;
	int count = 0;

	if (ops->get_sset_count && ops->get_ethtool_stats) {
		count = ops->get_sset_count(dev, ETH_SS_STATS);
		ops->get_ethtool_stats(dev, stats, data);
	}

	if (ds->ops->get_ethtool_stats)
		ds->ops->get_ethtool_stats(ds, port, data + count);
}

static void dsa_master_get_ethtool_phy_stats(struct net_device *dev,
					     struct ethtool_stats *stats,
					     uint64_t *data)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	struct dsa_switch *ds = cpu_dp->ds;
	int port = cpu_dp->index;
	int count = 0;

	if (dev->phydev && !ops->get_ethtool_phy_stats) {
		count = phy_ethtool_get_sset_count(dev->phydev);
		if (count >= 0)
			phy_ethtool_get_stats(dev->phydev, stats, data);
	} else if (ops->get_sset_count && ops->get_ethtool_phy_stats) {
		count = ops->get_sset_count(dev, ETH_SS_PHY_STATS);
		ops->get_ethtool_phy_stats(dev, stats, data);
	}

	if (count < 0)
		count = 0;

	if (ds->ops->get_ethtool_phy_stats)
		ds->ops->get_ethtool_phy_stats(ds, port, data + count);
}

static int dsa_master_get_sset_count(struct net_device *dev, int sset)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	struct dsa_switch *ds = cpu_dp->ds;
	int count = 0;

	if (sset == ETH_SS_PHY_STATS && dev->phydev &&
	    !ops->get_ethtool_phy_stats)
		count = phy_ethtool_get_sset_count(dev->phydev);
	else if (ops->get_sset_count)
		count = ops->get_sset_count(dev, sset);

	if (count < 0)
		count = 0;

	if (ds->ops->get_sset_count)
		count += ds->ops->get_sset_count(ds, cpu_dp->index, sset);

	return count;
}

static void dsa_master_get_strings(struct net_device *dev, uint32_t stringset,
				   uint8_t *data)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	struct dsa_switch *ds = cpu_dp->ds;
	int port = cpu_dp->index;
	int len = ETH_GSTRING_LEN;
	int mcount = 0, count;
	unsigned int i;
	uint8_t pfx[4];
	uint8_t *ndata;

	snprintf(pfx, sizeof(pfx), "p%.2d", port);
	/* We do not want to be NULL-terminated, since this is a prefix */
	pfx[sizeof(pfx) - 1] = '_';

	if (stringset == ETH_SS_PHY_STATS && dev->phydev &&
	    !ops->get_ethtool_phy_stats) {
		mcount = phy_ethtool_get_sset_count(dev->phydev);
		if (mcount < 0)
			mcount = 0;
		else
			phy_ethtool_get_strings(dev->phydev, data);
	} else if (ops->get_sset_count && ops->get_strings) {
		mcount = ops->get_sset_count(dev, stringset);
		if (mcount < 0)
			mcount = 0;
		ops->get_strings(dev, stringset, data);
	}

	if (ds->ops->get_strings) {
		ndata = data + mcount * len;
		/* This function copies ETH_GSTRINGS_LEN bytes, we will mangle
		 * the output after to prepend our CPU port prefix we
		 * constructed earlier
		 */
		ds->ops->get_strings(ds, port, stringset, ndata);
		count = ds->ops->get_sset_count(ds, port, stringset);
		for (i = 0; i < count; i++) {
			memmove(ndata + (i * len + sizeof(pfx)),
				ndata + i * len, len - sizeof(pfx));
			memcpy(ndata + i * len, pfx, sizeof(pfx));
		}
	}
}

static int dsa_master_get_phys_port_name(struct net_device *dev,
					 char *name, size_t len)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;

	if (snprintf(name, len, "p%d", cpu_dp->index) >= len)
		return -EINVAL;

	return 0;
}

static int dsa_master_ethtool_setup(struct net_device *dev)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	struct dsa_switch *ds = cpu_dp->ds;
	struct ethtool_ops *ops;

	ops = devm_kzalloc(ds->dev, sizeof(*ops), GFP_KERNEL);
	if (!ops)
		return -ENOMEM;

	cpu_dp->orig_ethtool_ops = dev->ethtool_ops;
	if (cpu_dp->orig_ethtool_ops)
		memcpy(ops, cpu_dp->orig_ethtool_ops, sizeof(*ops));

	ops->get_sset_count = dsa_master_get_sset_count;
	ops->get_ethtool_stats = dsa_master_get_ethtool_stats;
	ops->get_strings = dsa_master_get_strings;
	ops->get_ethtool_phy_stats = dsa_master_get_ethtool_phy_stats;

	dev->ethtool_ops = ops;

	return 0;
}

static void dsa_master_ethtool_teardown(struct net_device *dev)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;

	dev->ethtool_ops = cpu_dp->orig_ethtool_ops;
	cpu_dp->orig_ethtool_ops = NULL;
}

static int dsa_master_ndo_setup(struct net_device *dev)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;
	struct dsa_switch *ds = cpu_dp->ds;
	struct net_device_ops *ops;

	if (dev->netdev_ops->ndo_get_phys_port_name)
		return 0;

	ops = devm_kzalloc(ds->dev, sizeof(*ops), GFP_KERNEL);
	if (!ops)
		return -ENOMEM;

	cpu_dp->orig_ndo_ops = dev->netdev_ops;
	if (cpu_dp->orig_ndo_ops)
		memcpy(ops, cpu_dp->orig_ndo_ops, sizeof(*ops));

	ops->ndo_get_phys_port_name = dsa_master_get_phys_port_name;

	dev->netdev_ops  = ops;

	return 0;
}

static void dsa_master_ndo_teardown(struct net_device *dev)
{
	struct dsa_port *cpu_dp = dev->dsa_ptr;

	dev->netdev_ops = cpu_dp->orig_ndo_ops;
	cpu_dp->orig_ndo_ops = NULL;
}

static ssize_t tagging_show(struct device *d, struct device_attribute *attr,
			    char *buf)
{
	struct net_device *dev = to_net_dev(d);
	struct dsa_port *cpu_dp = dev->dsa_ptr;

	return sprintf(buf, "%s\n",
		       dsa_tag_protocol_to_str(cpu_dp->tag_ops));
}
static DEVICE_ATTR_RO(tagging);

static struct attribute *dsa_slave_attrs[] = {
	&dev_attr_tagging.attr,
	NULL
};

static const struct attribute_group dsa_group = {
	.name	= "dsa",
	.attrs	= dsa_slave_attrs,
};

static void dsa_master_set_mtu(struct net_device *dev, struct dsa_port *cpu_dp)
{
	unsigned int mtu = ETH_DATA_LEN + cpu_dp->tag_ops->overhead;
	int err;

	rtnl_lock();
	if (mtu <= dev->max_mtu) {
		err = dev_set_mtu(dev, mtu);
		if (err)
			netdev_dbg(dev, "Unable to set MTU to include for DSA overheads\n");
	}
	rtnl_unlock();
}

static void dsa_master_reset_mtu(struct net_device *dev)
{
	int err;

	rtnl_lock();
	err = dev_set_mtu(dev, ETH_DATA_LEN);
	if (err)
		netdev_dbg(dev,
			   "Unable to reset MTU to exclude DSA overheads\n");
	rtnl_unlock();
}

static struct lock_class_key dsa_master_addr_list_lock_key;

int dsa_master_setup(struct net_device *dev, struct dsa_port *cpu_dp)
{
	int ret;

	dsa_master_set_mtu(dev,  cpu_dp);

	/* If we use a tagging format that doesn't have an ethertype
	 * field, make sure that all packets from this point on get
	 * sent to the tag format's receive function.
	 */
	wmb();

	dev->dsa_ptr = cpu_dp;
	lockdep_set_class(&dev->addr_list_lock,
			  &dsa_master_addr_list_lock_key);

	ret = dsa_master_ethtool_setup(dev);
	if (ret)
		return ret;

	ret = dsa_master_ndo_setup(dev);
	if (ret)
		goto out_err_ethtool_teardown;

	ret = sysfs_create_group(&dev->dev.kobj, &dsa_group);
	if (ret)
		goto out_err_ndo_teardown;

	return ret;

out_err_ndo_teardown:
	dsa_master_ndo_teardown(dev);
out_err_ethtool_teardown:
	dsa_master_ethtool_teardown(dev);
	return ret;
}

void dsa_master_teardown(struct net_device *dev)
{
	sysfs_remove_group(&dev->dev.kobj, &dsa_group);
	dsa_master_ndo_teardown(dev);
	dsa_master_ethtool_teardown(dev);
	dsa_master_reset_mtu(dev);

	dev->dsa_ptr = NULL;

	/* If we used a tagging format that doesn't have an ethertype
	 * field, make sure that all packets from this point get sent
	 * without the tag and go through the regular receive path.
	 */
	wmb();
}
Commit	Line	Data
f2f23566 VD	1	/*
	2	* Handling of a master device, switching frames via its switch fabric CPU port
	3	*
	4	* Copyright (c) 2017 Savoir-faire Linux Inc.
	5	* Vivien Didelot <[email protected]>
	6	*
	7	* This program is free software; you can redistribute it and/or modify
	8	* it under the terms of the GNU General Public License as published by
	9	* the Free Software Foundation; either version 2 of the License, or
	10	* (at your option) any later version.
	11	*/
	12
	13	#include "dsa_priv.h"
	14
	15	static void dsa_master_get_ethtool_stats(struct net_device *dev,
	16	struct ethtool_stats *stats,
	17	uint64_t *data)
	18	{
2f657a60	19	struct dsa_port *cpu_dp = dev->dsa_ptr;
7ec764ee VD	20	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	21	struct dsa_switch *ds = cpu_dp->ds;
	22	int port = cpu_dp->index;
f2f23566 VD	23	int count = 0;
f2f23566 VD	24
1d1e79f1	25	if (ops->get_sset_count && ops->get_ethtool_stats) {
f2f23566 VD	26	count = ops->get_sset_count(dev, ETH_SS_STATS);
	27	ops->get_ethtool_stats(dev, stats, data);
	28	}
	29
	30	if (ds->ops->get_ethtool_stats)
7ec764ee	31	ds->ops->get_ethtool_stats(ds, port, data + count);
f2f23566 VD	32	}
f2f23566 VD	33
cf963573 FF	34	static void dsa_master_get_ethtool_phy_stats(struct net_device *dev,
	35	struct ethtool_stats *stats,
	36	uint64_t *data)
	37	{
	38	struct dsa_port *cpu_dp = dev->dsa_ptr;
	39	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	40	struct dsa_switch *ds = cpu_dp->ds;
	41	int port = cpu_dp->index;
	42	int count = 0;
	43
	44	if (dev->phydev && !ops->get_ethtool_phy_stats) {
	45	count = phy_ethtool_get_sset_count(dev->phydev);
	46	if (count >= 0)
	47	phy_ethtool_get_stats(dev->phydev, stats, data);
	48	} else if (ops->get_sset_count && ops->get_ethtool_phy_stats) {
	49	count = ops->get_sset_count(dev, ETH_SS_PHY_STATS);
	50	ops->get_ethtool_phy_stats(dev, stats, data);
	51	}
	52
	53	if (count < 0)
	54	count = 0;
	55
	56	if (ds->ops->get_ethtool_phy_stats)
	57	ds->ops->get_ethtool_phy_stats(ds, port, data + count);
	58	}
	59
f2f23566 VD	60	static int dsa_master_get_sset_count(struct net_device *dev, int sset)
f2f23566 VD	61	{
2f657a60	62	struct dsa_port *cpu_dp = dev->dsa_ptr;
7ec764ee VD	63	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
7ec764ee VD	64	struct dsa_switch *ds = cpu_dp->ds;
f2f23566 VD	65	int count = 0;
f2f23566 VD	66
cf963573 FF	67	if (sset == ETH_SS_PHY_STATS && dev->phydev &&
	68	!ops->get_ethtool_phy_stats)
	69	count = phy_ethtool_get_sset_count(dev->phydev);
	70	else if (ops->get_sset_count)
89f09048	71	count = ops->get_sset_count(dev, sset);
cf963573 FF	72
	73	if (count < 0)
	74	count = 0;
f2f23566	75
89f09048 FF	76	if (ds->ops->get_sset_count)
89f09048 FF	77	count += ds->ops->get_sset_count(ds, cpu_dp->index, sset);
f2f23566 VD	78
	79	return count;
	80	}
	81
	82	static void dsa_master_get_strings(struct net_device *dev, uint32_t stringset,
	83	uint8_t *data)
	84	{
2f657a60	85	struct dsa_port *cpu_dp = dev->dsa_ptr;
7ec764ee VD	86	const struct ethtool_ops *ops = cpu_dp->orig_ethtool_ops;
	87	struct dsa_switch *ds = cpu_dp->ds;
	88	int port = cpu_dp->index;
f2f23566 VD	89	int len = ETH_GSTRING_LEN;
	90	int mcount = 0, count;
	91	unsigned int i;
	92	uint8_t pfx[4];
	93	uint8_t *ndata;
	94
7ec764ee	95	snprintf(pfx, sizeof(pfx), "p%.2d", port);
f2f23566 VD	96	/* We do not want to be NULL-terminated, since this is a prefix */
	97	pfx[sizeof(pfx) - 1] = '_';
	98
cf963573 FF	99	if (stringset == ETH_SS_PHY_STATS && dev->phydev &&
	100	!ops->get_ethtool_phy_stats) {
	101	mcount = phy_ethtool_get_sset_count(dev->phydev);
	102	if (mcount < 0)
	103	mcount = 0;
	104	else
	105	phy_ethtool_get_strings(dev->phydev, data);
	106	} else if (ops->get_sset_count && ops->get_strings) {
89f09048 FF	107	mcount = ops->get_sset_count(dev, stringset);
	108	if (mcount < 0)
	109	mcount = 0;
f2f23566 VD	110	ops->get_strings(dev, stringset, data);
	111	}
	112
89f09048	113	if (ds->ops->get_strings) {
f2f23566 VD	114	ndata = data + mcount * len;
	115	/* This function copies ETH_GSTRINGS_LEN bytes, we will mangle
	116	* the output after to prepend our CPU port prefix we
	117	* constructed earlier
	118	*/
89f09048 FF	119	ds->ops->get_strings(ds, port, stringset, ndata);
89f09048 FF	120	count = ds->ops->get_sset_count(ds, port, stringset);
f2f23566 VD	121	for (i = 0; i < count; i++) {
	122	memmove(ndata + (i * len + sizeof(pfx)),
	123	ndata + i * len, len - sizeof(pfx));
	124	memcpy(ndata + i * len, pfx, sizeof(pfx));
	125	}
	126	}
	127	}
	128
da7b9e9b FF	129	static int dsa_master_get_phys_port_name(struct net_device *dev,
	130	char *name, size_t len)
	131	{
	132	struct dsa_port *cpu_dp = dev->dsa_ptr;
	133
	134	if (snprintf(name, len, "p%d", cpu_dp->index) >= len)
	135	return -EINVAL;
	136
	137	return 0;
	138	}
	139
17a22fcf	140	static int dsa_master_ethtool_setup(struct net_device *dev)
f2f23566	141	{
2f657a60	142	struct dsa_port *cpu_dp = dev->dsa_ptr;
7ec764ee	143	struct dsa_switch *ds = cpu_dp->ds;
f2f23566 VD	144	struct ethtool_ops *ops;
	145
	146	ops = devm_kzalloc(ds->dev, sizeof(*ops), GFP_KERNEL);
	147	if (!ops)
	148	return -ENOMEM;
	149
7ec764ee VD	150	cpu_dp->orig_ethtool_ops = dev->ethtool_ops;
	151	if (cpu_dp->orig_ethtool_ops)
	152	memcpy(ops, cpu_dp->orig_ethtool_ops, sizeof(*ops));
f2f23566 VD	153
	154	ops->get_sset_count = dsa_master_get_sset_count;
	155	ops->get_ethtool_stats = dsa_master_get_ethtool_stats;
	156	ops->get_strings = dsa_master_get_strings;
cf963573	157	ops->get_ethtool_phy_stats = dsa_master_get_ethtool_phy_stats;
f2f23566 VD	158
	159	dev->ethtool_ops = ops;
	160
	161	return 0;
	162	}
	163
17a22fcf	164	static void dsa_master_ethtool_teardown(struct net_device *dev)
f2f23566	165	{
2f657a60	166	struct dsa_port *cpu_dp = dev->dsa_ptr;
f2f23566	167
7ec764ee VD	168	dev->ethtool_ops = cpu_dp->orig_ethtool_ops;
7ec764ee VD	169	cpu_dp->orig_ethtool_ops = NULL;
f2f23566	170	}
17a22fcf	171
da7b9e9b FF	172	static int dsa_master_ndo_setup(struct net_device *dev)
	173	{
	174	struct dsa_port *cpu_dp = dev->dsa_ptr;
	175	struct dsa_switch *ds = cpu_dp->ds;
	176	struct net_device_ops *ops;
	177
	178	if (dev->netdev_ops->ndo_get_phys_port_name)
	179	return 0;
	180
	181	ops = devm_kzalloc(ds->dev, sizeof(*ops), GFP_KERNEL);
	182	if (!ops)
	183	return -ENOMEM;
	184
	185	cpu_dp->orig_ndo_ops = dev->netdev_ops;
	186	if (cpu_dp->orig_ndo_ops)
	187	memcpy(ops, cpu_dp->orig_ndo_ops, sizeof(*ops));
	188
	189	ops->ndo_get_phys_port_name = dsa_master_get_phys_port_name;
	190
	191	dev->netdev_ops = ops;
	192
	193	return 0;
	194	}
	195
	196	static void dsa_master_ndo_teardown(struct net_device *dev)
	197	{
	198	struct dsa_port *cpu_dp = dev->dsa_ptr;
	199
	200	dev->netdev_ops = cpu_dp->orig_ndo_ops;
	201	cpu_dp->orig_ndo_ops = NULL;
	202	}
	203
a3d7e01d FF	204	static ssize_t tagging_show(struct device d, struct device_attribute attr,
	205	char *buf)
	206	{
	207	struct net_device *dev = to_net_dev(d);
	208	struct dsa_port *cpu_dp = dev->dsa_ptr;
	209
	210	return sprintf(buf, "%s\n",
	211	dsa_tag_protocol_to_str(cpu_dp->tag_ops));
	212	}
	213	static DEVICE_ATTR_RO(tagging);
	214
	215	static struct attribute *dsa_slave_attrs[] = {
	216	&dev_attr_tagging.attr,
	217	NULL
	218	};
	219
	220	static const struct attribute_group dsa_group = {
	221	.name = "dsa",
	222	.attrs = dsa_slave_attrs,
	223	};
	224
a60956ed	225	static void dsa_master_set_mtu(struct net_device dev, struct dsa_port cpu_dp)
dc0fe7d4 AL	226	{
	227	unsigned int mtu = ETH_DATA_LEN + cpu_dp->tag_ops->overhead;
	228	int err;
	229
	230	rtnl_lock();
	231	if (mtu <= dev->max_mtu) {
	232	err = dev_set_mtu(dev, mtu);
	233	if (err)
	234	netdev_dbg(dev, "Unable to set MTU to include for DSA overheads\n");
	235	}
	236	rtnl_unlock();
	237	}
	238
91ba4795 AL	239	static void dsa_master_reset_mtu(struct net_device *dev)
	240	{
	241	int err;
	242
	243	rtnl_lock();
	244	err = dev_set_mtu(dev, ETH_DATA_LEN);
	245	if (err)
	246	netdev_dbg(dev,
	247	"Unable to reset MTU to exclude DSA overheads\n");
	248	rtnl_unlock();
	249	}
	250
c8101f77 MZ	251	static struct lock_class_key dsa_master_addr_list_lock_key;
c8101f77 MZ	252
17a22fcf VD	253	int dsa_master_setup(struct net_device dev, struct dsa_port cpu_dp)
17a22fcf VD	254	{
a3d7e01d FF	255	int ret;
a3d7e01d FF	256
dc0fe7d4 AL	257	dsa_master_set_mtu(dev, cpu_dp);
dc0fe7d4 AL	258
17a22fcf VD	259	/* If we use a tagging format that doesn't have an ethertype
	260	* field, make sure that all packets from this point on get
	261	* sent to the tag format's receive function.
	262	*/
	263	wmb();
	264
	265	dev->dsa_ptr = cpu_dp;
c8101f77 MZ	266	lockdep_set_class(&dev->addr_list_lock,
c8101f77 MZ	267	&dsa_master_addr_list_lock_key);
17a22fcf	268
a3d7e01d FF	269	ret = dsa_master_ethtool_setup(dev);
	270	if (ret)
	271	return ret;
	272
da7b9e9b FF	273	ret = dsa_master_ndo_setup(dev);
	274	if (ret)
	275	goto out_err_ethtool_teardown;
	276
a3d7e01d FF	277	ret = sysfs_create_group(&dev->dev.kobj, &dsa_group);
a3d7e01d FF	278	if (ret)
da7b9e9b FF	279	goto out_err_ndo_teardown;
	280
	281	return ret;
a3d7e01d	282
da7b9e9b FF	283	out_err_ndo_teardown:
	284	dsa_master_ndo_teardown(dev);
	285	out_err_ethtool_teardown:
	286	dsa_master_ethtool_teardown(dev);
a3d7e01d	287	return ret;
17a22fcf VD	288	}
	289
	290	void dsa_master_teardown(struct net_device *dev)
	291	{
a3d7e01d	292	sysfs_remove_group(&dev->dev.kobj, &dsa_group);
da7b9e9b	293	dsa_master_ndo_teardown(dev);
17a22fcf	294	dsa_master_ethtool_teardown(dev);
91ba4795	295	dsa_master_reset_mtu(dev);
17a22fcf VD	296
	297	dev->dsa_ptr = NULL;
	298
	299	/* If we used a tagging format that doesn't have an ethertype
	300	* field, make sure that all packets from this point get sent
	301	* without the tag and go through the regular receive path.
	302	*/
	303	wmb();
	304	}