| lists.openwall.net | lists / announce owl-users owl-dev john-users john-dev passwdqc-users yescrypt popa3d-users / oss-security kernel-hardening musl sabotage tlsify passwords / crypt-dev xvendor / Bugtraq Full-Disclosure linux-kernel linux-netdev linux-ext4 linux-hardening linux-cve-announce PHC | |
|
Open Source and information security mailing list archives
| ||
|
Message-ID: <20150316092132.GA2058@nanopsycho.orion>
Date: Mon, 16 Mar 2015 10:21:32 +0100
From: Jiri Pirko <jiri@...nulli.us>
To: Jonas Johansson <jonasj76@...il.com>
Cc: netdev@...r.kernel.org, ogerlitz@...lanox.com, monis@...lanox.com,
jonas.johansson@...termo.se
Subject: Re: [PATCH net-next] team: Notify state change on ports
Mon, Mar 16, 2015 at 10:09:12AM CET, jonasj76@...il.com wrote:
>
>
>On Sun, 15 Mar 2015, Jiri Pirko wrote:
>
>>Thu, Mar 12, 2015 at 05:03:56PM CET, jonasj76@...il.com wrote:
>>>From: Jonas Johansson <jonasj76@...il.com>
>>>
>>>Use notifier chain to dispatch an event upon a change in port state. The event
>>>is dispatched with the notifier_bonding_info struct.
>>>The notifier_bonding_info struct was introduced to notify state change on
>>>bonding slaves (commit 61bd3857), so some fields are set to -1, due that the
>>>data is not available in team.
>>>
>>>Signed-off-by: Jonas Johansson <jonasj76@...il.com>
>>>---
>>>This patch is just a step into introducing HW bonding support. In a previous
>>>(not applied) patchset [1], I added two (2) new ndo ops which was used to
>>>receive a port state change. This patch will instead use the same mechanism
>>>as introduced in [2] and [3] to notify a port state change.
>>>
>>>A state change on a port can be used by a switching device to e.g. load
>>>balance packets over the active ports. Due to that HW bonding isn't added to
>>>the kernel yet this patch may atm only be of use for [4] to use the team
>>>driver instead of the bonding driver. But I hope it will become useful as a
>>>first step to introduce HW bonding.
>>>
>>>[1] - [PATCH net-next 0/2] dsa: implement HW bonding'
>>> http://marc.info/?l=linux-netdev&m=142442948421049&w=2
>>>[2] - net/core: Add event for a change in slave state'
>>> commit: 61bd3857
>>>[3] - net/bonding: Move slave state changes to a helper function
>>> commit: 69a2338e
>>>[4] - [PATCH 00/10] Add HA and LAG support to mlx4 RoCE and SRIOV services
>>> http://marc.info/?l=linux-netdev&m=142309529514580&w=2
>>>
>>>drivers/net/team/team.c | 85 +++++++++++++++++++++++++++++++++++++++++++++++++
>>>include/linux/if_team.h | 10 ++++++
>>>2 files changed, 95 insertions(+)
>>>
>>>diff --git a/drivers/net/team/team.c b/drivers/net/team/team.c
>>>index a23319f..aef8120 100644
>>>--- a/drivers/net/team/team.c
>>>+++ b/drivers/net/team/team.c
>>>@@ -659,6 +659,86 @@ static void team_notify_peers_fini(struct team *team)
>>> cancel_delayed_work_sync(&team->notify_peers.dw);
>>>}
>>>
>>>+/*********************
>>>+ * Port notification
>>>+ *********************/
>>>+
>>>+static void team_fill_ifbond(struct team *team, struct ifbond *info)
>>>+{
>>>+ info->bond_mode = -1;
>>>+ info->miimon = -1;
>>>+ info->num_slaves = team->en_port_count;
>>>+}
>>>+
>>>+static void team_fill_ifslave(struct team_port *port, struct ifslave *info)
>>>+{
>>>+ strcpy(info->slave_name, port->dev->name);
>>>+ info->link = port->state.linkup;
>>>+ if (team_port_enabled(port))
>>>+ info->state = BOND_STATE_ACTIVE;
>>>+ else
>>>+ info->state = BOND_STATE_BACKUP;
>>>+ info->link_failure_count = 0;
>>>+}
>>>+
>>>+static void team_notify_port_work(struct work_struct *work)
>>>+{
>>>+ struct team *team;
>>>+ struct team_port_notify *notify;
>>>+
>>>+ team = container_of(work, struct team, notify_ports.dw.work);
>>>+
>>>+ if (!rtnl_trylock()) {
>>>+ schedule_delayed_work(&team->notify_ports.dw, 0);
>>>+ return;
>>>+ }
>>>+ rcu_read_lock();
>>>+
>>>+ notify = list_first_or_null_rcu(&team->notify_ports.port_list,
>>>+ struct team_port_notify, list);
>>>+ if (!notify)
>>>+ goto unlock;
>>>+
>>>+ netdev_bonding_info_change(notify->dev, ¬ify->bonding_info);
>>
>>
>>I must say I don't like to see "bonding code" in team driver. Also this
>>code emulates bonding in team for nofitication consumer. How about to
>>make it more generic. Notifier consumer should not care if it is bonding
>>or team, it should receive generic info and act accordingly.
>>
>>So how about something like netdev_aggregation_change ?
>>
>>
>>
>The intentions of this patch (from my perspective) was to notify a hardware
>(switch device) of a aggregate member port change. So from this perspective,
>a switchdev callback should maybe be used instead
>(netdev_switch_port_lag_change).
I agree, on the way down, use ops, on the way up, use notifier
>
>To be consistent, a switchdev callback should maybe also be used when adding
>a port to an LAG. Today NETDEV_CHANGEUPPER can be used by a driver to
>accomplish this, but this will not 'pass through' switchdev, which might want
>to do or keep track of something.
>
>However, the approach above will result in two more ndo ops.
With switchdev ops pushed out into separate struct, I don't this adding
couple more ndos is a problem.
>
>Thoughts?
>
>>>+ dev_put(notify->dev);
>>>+ list_del_rcu(¬ify->list);
>>>+ kfree(notify);
>>>+
>>>+ if (list_first_or_null_rcu(&team->notify_ports.port_list,
>>>+ struct team_port_notify, list))
>>>+ schedule_delayed_work(&team->notify_ports.dw, msecs_to_jiffies(1));
>>>+unlock:
>>>+ rcu_read_unlock();
>>>+ rtnl_unlock();
>>>+}
>>>+
>>>+static void team_notify_port(struct team *team, struct team_port *port)
>>>+{
>>>+ struct team_port_notify *notify;
>>>+
>>>+ notify = kmalloc(sizeof(*notify), GFP_KERNEL);
>>>+ if (!notify)
>>>+ return;
>>>+
>>>+ dev_hold(port->dev);
>>>+ notify->dev = port->dev;
>>>+ team_fill_ifslave(port, ¬ify->bonding_info.slave);
>>>+ team_fill_ifbond(team, ¬ify->bonding_info.master);
>>>+
>>>+ list_add_tail_rcu(¬ify->list, &team->notify_ports.port_list);
>>>+ schedule_delayed_work(&team->notify_ports.dw, 0);
>>>+}
>>>+
>>>+static void team_notify_port_init(struct team *team)
>>>+{
>>>+ INIT_LIST_HEAD(&team->notify_ports.port_list);
>>>+ INIT_DELAYED_WORK(&team->notify_ports.dw, team_notify_port_work);
>>>+}
>>>+
>>>+static void team_notify_port_fini(struct team *team)
>>>+{
>>>+ cancel_delayed_work_sync(&team->notify_ports.dw);
>>>+}
>>>
>>>/*******************************
>>> * Send multicast group rejoins
>>>@@ -932,6 +1012,7 @@ static void team_port_enable(struct team *team,
>>> team->ops.port_enabled(team, port);
>>> team_notify_peers(team);
>>> team_mcast_rejoin(team);
>>>+ team_notify_port(team, port);
>>>}
>>>
>>>static void __reconstruct_port_hlist(struct team *team, int rm_index)
>>>@@ -963,6 +1044,7 @@ static void team_port_disable(struct team *team,
>>> team_adjust_ops(team);
>>> team_notify_peers(team);
>>> team_mcast_rejoin(team);
>>>+ team_notify_port(team, port);
>>>}
>>>
>>>#define TEAM_VLAN_FEATURES (NETIF_F_ALL_CSUM | NETIF_F_SG | \
>>>@@ -1581,6 +1663,7 @@ static int team_init(struct net_device *dev)
>>>
>>> team_notify_peers_init(team);
>>> team_mcast_rejoin_init(team);
>>>+ team_notify_port_init(team);
>>>
>>> err = team_options_register(team, team_options, ARRAY_SIZE(team_options));
>>> if (err)
>>>@@ -1592,6 +1675,7 @@ static int team_init(struct net_device *dev)
>>> return 0;
>>>
>>>err_options_register:
>>>+ team_notify_port_fini(team);
>>> team_mcast_rejoin_fini(team);
>>> team_notify_peers_fini(team);
>>> team_queue_override_fini(team);
>>>@@ -1613,6 +1697,7 @@ static void team_uninit(struct net_device *dev)
>>>
>>> __team_change_mode(team, NULL); /* cleanup */
>>> __team_options_unregister(team, team_options, ARRAY_SIZE(team_options));
>>>+ team_notify_port_fini(team);
>>> team_mcast_rejoin_fini(team);
>>> team_notify_peers_fini(team);
>>> team_queue_override_fini(team);
>>>diff --git a/include/linux/if_team.h b/include/linux/if_team.h
>>>index a6aa970..fc59e39 100644
>>>--- a/include/linux/if_team.h
>>>+++ b/include/linux/if_team.h
>>>@@ -28,6 +28,12 @@ struct team_pcpu_stats {
>>>
>>>struct team;
>>>
>>>+struct team_port_notify {
>>>+ struct list_head list; /* node in notify list */
>>>+ struct net_device *dev;
>>>+ struct netdev_bonding_info bonding_info;
>>>+};
>>>+
>>>struct team_port {
>>> struct net_device *dev;
>>> struct hlist_node hlist; /* node in enabled ports hash list */
>>>@@ -207,6 +213,10 @@ struct team {
>>> atomic_t count_pending;
>>> struct delayed_work dw;
>>> } mcast_rejoin;
>>>+ struct {
>>>+ struct list_head port_list; /* list of ports to be notified */
>>>+ struct delayed_work dw;
>>>+ } notify_ports;
>>> long mode_priv[TEAM_MODE_PRIV_LONGS];
>>>};
>>>
>>>--
>>>2.1.0
>>>
>>
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
the body of a message to majordomo@...r.kernel.org
More majordomo info at http://vger.kernel.org/majordomo-info.html
Powered by blists - more mailing lists