niansa-misc/linux
1
0
Fork 0
mirror of synced 2025-03-06 20:59:54 +01:00
Code Issues Projects Releases Packages Wiki Activity

openvswitch: Move dev pointer into vport itself

Browse source 
This is the first step in representing all OVS vports as regular
struct net_devices. Move the net_device pointer into the vport
structure itself to get rid of struct vport_netdev.

Signed-off-by: Thomas Graf <tgraf@suug.ch>
Signed-off-by: Pravin B Shelar <pshelar@nicira.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
Thomas Graf 2015-07-21 10:44:04 +02:00 • committed by David S. Miller
parent 34ae932a40
commit be4ace6e6b
6 changed files with 59 additions and 91 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
net/openvswitch/datapath.c
View file

@ -188,7 +188,7 @@ static int get_dpifindex(const struct datapath *dp)
local = ovs_vport_rcu(dp, OVSP_LOCAL); local = ovs_vport_rcu(dp, OVSP_LOCAL);
if (local) if (local)
ifindex = netdev_vport_priv(local)->dev->ifindex; ifindex = local->dev->ifindex;
else else
ifindex = 0; ifindex = 0;
@ -2219,13 +2219,10 @@ static void __net_exit list_vports_from_net(struct net *net, struct net *dnet,
struct vport *vport; struct vport *vport;
hlist_for_each_entry(vport, &dp->ports[i], dp_hash_node) { hlist_for_each_entry(vport, &dp->ports[i], dp_hash_node) {
struct netdev_vport *netdev_vport;
if (vport->ops->type != OVS_VPORT_TYPE_INTERNAL) if (vport->ops->type != OVS_VPORT_TYPE_INTERNAL)
continue; continue;
netdev_vport = netdev_vport_priv(vport); if (dev_net(vport->dev) == dnet)
if (dev_net(netdev_vport->dev) == dnet)
list_add(&vport->detach_list, head); list_add(&vport->detach_list, head);
} }
} }

5
net/openvswitch/dp_notify.c
View file

@ -58,13 +58,10 @@ void ovs_dp_notify_wq(struct work_struct *work)
struct hlist_node *n; struct hlist_node *n;
hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) {
struct netdev_vport *netdev_vport;
if (vport->ops->type != OVS_VPORT_TYPE_NETDEV) if (vport->ops->type != OVS_VPORT_TYPE_NETDEV)
continue; continue;
netdev_vport = netdev_vport_priv(vport); if (!(vport->dev->priv_flags & IFF_OVS_DATAPATH))
if (!(netdev_vport->dev->priv_flags & IFF_OVS_DATAPATH))
dp_detach_port_notify(vport); dp_detach_port_notify(vport);
} }
} }

37
net/openvswitch/vport-internal_dev.c
View file

@ -156,49 +156,44 @@ static void do_setup(struct net_device *netdev)
static struct vport *internal_dev_create(const struct vport_parms *parms) static struct vport *internal_dev_create(const struct vport_parms *parms)
{ {
struct vport *vport; struct vport *vport;
struct netdev_vport *netdev_vport;
struct internal_dev *internal_dev; struct internal_dev *internal_dev;
int err; int err;
vport = ovs_vport_alloc(sizeof(struct netdev_vport), vport = ovs_vport_alloc(0, &ovs_internal_vport_ops, parms);
&ovs_internal_vport_ops, parms);
if (IS_ERR(vport)) { if (IS_ERR(vport)) {
err = PTR_ERR(vport); err = PTR_ERR(vport);
goto error; goto error;
} }
netdev_vport = netdev_vport_priv(vport); vport->dev = alloc_netdev(sizeof(struct internal_dev),
parms->name, NET_NAME_UNKNOWN, do_setup);
netdev_vport->dev = alloc_netdev(sizeof(struct internal_dev), if (!vport->dev) {
parms->name, NET_NAME_UNKNOWN,
do_setup);
if (!netdev_vport->dev) {
err = -ENOMEM; err = -ENOMEM;
goto error_free_vport; goto error_free_vport;
} }
dev_net_set(netdev_vport->dev, ovs_dp_get_net(vport->dp)); dev_net_set(vport->dev, ovs_dp_get_net(vport->dp));
internal_dev = internal_dev_priv(netdev_vport->dev); internal_dev = internal_dev_priv(vport->dev);
internal_dev->vport = vport; internal_dev->vport = vport;
/* Restrict bridge port to current netns. */ /* Restrict bridge port to current netns. */
if (vport->port_no == OVSP_LOCAL) if (vport->port_no == OVSP_LOCAL)
netdev_vport->dev->features |= NETIF_F_NETNS_LOCAL; vport->dev->features |= NETIF_F_NETNS_LOCAL;
rtnl_lock(); rtnl_lock();
err = register_netdevice(netdev_vport->dev); err = register_netdevice(vport->dev);
if (err) if (err)
goto error_free_netdev; goto error_free_netdev;
dev_set_promiscuity(netdev_vport->dev, 1); dev_set_promiscuity(vport->dev, 1);
rtnl_unlock(); rtnl_unlock();
netif_start_queue(netdev_vport->dev); netif_start_queue(vport->dev);
return vport; return vport;
error_free_netdev: error_free_netdev:
rtnl_unlock(); rtnl_unlock();
free_netdev(netdev_vport->dev); free_netdev(vport->dev);
error_free_vport: error_free_vport:
ovs_vport_free(vport); ovs_vport_free(vport);
error: error:
@ -207,21 +202,19 @@ error:
static void internal_dev_destroy(struct vport *vport) static void internal_dev_destroy(struct vport *vport)
{ {
struct netdev_vport *netdev_vport = netdev_vport_priv(vport); netif_stop_queue(vport->dev);
netif_stop_queue(netdev_vport->dev);
rtnl_lock(); rtnl_lock();
dev_set_promiscuity(netdev_vport->dev, -1); dev_set_promiscuity(vport->dev, -1);
/* unregister_netdevice() waits for an RCU grace period. */ /* unregister_netdevice() waits for an RCU grace period. */
unregister_netdevice(netdev_vport->dev); unregister_netdevice(vport->dev);
rtnl_unlock(); rtnl_unlock();
} }
static int internal_dev_recv(struct vport *vport, struct sk_buff *skb) static int internal_dev_recv(struct vport *vport, struct sk_buff *skb)
{ {
struct net_device *netdev = netdev_vport_priv(vport)->dev; struct net_device *netdev = vport->dev;
int len; int len;
if (unlikely(!(netdev->flags & IFF_UP))) { if (unlikely(!(netdev->flags & IFF_UP))) {

86
net/openvswitch/vport-netdev.c
View file

@ -83,104 +83,97 @@ static struct net_device *get_dpdev(const struct datapath *dp)
local = ovs_vport_ovsl(dp, OVSP_LOCAL); local = ovs_vport_ovsl(dp, OVSP_LOCAL);
BUG_ON(!local); BUG_ON(!local);
return netdev_vport_priv(local)->dev; return local->dev;
} }
static struct vport *netdev_create(const struct vport_parms *parms) static struct vport *netdev_link(struct vport *vport, const char *name)
{ {
struct vport *vport;
struct netdev_vport *netdev_vport;
int err; int err;
vport = ovs_vport_alloc(sizeof(struct netdev_vport), vport->dev = dev_get_by_name(ovs_dp_get_net(vport->dp), name);
&ovs_netdev_vport_ops, parms); if (!vport->dev) {
if (IS_ERR(vport)) {
err = PTR_ERR(vport);
goto error;
}
netdev_vport = netdev_vport_priv(vport);
netdev_vport->dev = dev_get_by_name(ovs_dp_get_net(vport->dp), parms->name);
if (!netdev_vport->dev) {
err = -ENODEV; err = -ENODEV;
goto error_free_vport; goto error_free_vport;
} }
if (netdev_vport->dev->flags & IFF_LOOPBACK || if (vport->dev->flags & IFF_LOOPBACK ||
netdev_vport->dev->type != ARPHRD_ETHER || vport->dev->type != ARPHRD_ETHER ||
ovs_is_internal_dev(netdev_vport->dev)) { ovs_is_internal_dev(vport->dev)) {
err = -EINVAL; err = -EINVAL;
goto error_put; goto error_put;
} }
rtnl_lock(); rtnl_lock();
err = netdev_master_upper_dev_link(netdev_vport->dev, err = netdev_master_upper_dev_link(vport->dev,
get_dpdev(vport->dp)); get_dpdev(vport->dp));
if (err) if (err)
goto error_unlock; goto error_unlock;
err = netdev_rx_handler_register(netdev_vport->dev, netdev_frame_hook, err = netdev_rx_handler_register(vport->dev, netdev_frame_hook,
vport); vport);
if (err) if (err)
goto error_master_upper_dev_unlink; goto error_master_upper_dev_unlink;
dev_disable_lro(netdev_vport->dev); dev_disable_lro(vport->dev);
dev_set_promiscuity(netdev_vport->dev, 1); dev_set_promiscuity(vport->dev, 1);
netdev_vport->dev->priv_flags |= IFF_OVS_DATAPATH; vport->dev->priv_flags |= IFF_OVS_DATAPATH;
rtnl_unlock(); rtnl_unlock();
return vport; return vport;
error_master_upper_dev_unlink: error_master_upper_dev_unlink:
netdev_upper_dev_unlink(netdev_vport->dev, get_dpdev(vport->dp)); netdev_upper_dev_unlink(vport->dev, get_dpdev(vport->dp));
error_unlock: error_unlock:
rtnl_unlock(); rtnl_unlock();
error_put: error_put:
dev_put(netdev_vport->dev); dev_put(vport->dev);
error_free_vport: error_free_vport:
ovs_vport_free(vport); ovs_vport_free(vport);
error:
return ERR_PTR(err); return ERR_PTR(err);
} }
static struct vport *netdev_create(const struct vport_parms *parms)
{
struct vport *vport;
vport = ovs_vport_alloc(0, &ovs_netdev_vport_ops, parms);
if (IS_ERR(vport))
return vport;
return netdev_link(vport, parms->name);
}
static void free_port_rcu(struct rcu_head *rcu) static void free_port_rcu(struct rcu_head *rcu)
{ {
struct netdev_vport *netdev_vport = container_of(rcu, struct vport *vport = container_of(rcu, struct vport, rcu);
struct netdev_vport, rcu);
dev_put(netdev_vport->dev); dev_put(vport->dev);
ovs_vport_free(vport_from_priv(netdev_vport)); ovs_vport_free(vport);
} }
void ovs_netdev_detach_dev(struct vport *vport) void ovs_netdev_detach_dev(struct vport *vport)
{ {
struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
ASSERT_RTNL(); ASSERT_RTNL();
netdev_vport->dev->priv_flags &= ~IFF_OVS_DATAPATH; vport->dev->priv_flags &= ~IFF_OVS_DATAPATH;
netdev_rx_handler_unregister(netdev_vport->dev); netdev_rx_handler_unregister(vport->dev);
netdev_upper_dev_unlink(netdev_vport->dev, netdev_upper_dev_unlink(vport->dev,
netdev_master_upper_dev_get(netdev_vport->dev)); netdev_master_upper_dev_get(vport->dev));
dev_set_promiscuity(netdev_vport->dev, -1); dev_set_promiscuity(vport->dev, -1);
} }
static void netdev_destroy(struct vport *vport) static void netdev_destroy(struct vport *vport)
{ {
struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
rtnl_lock(); rtnl_lock();
if (netdev_vport->dev->priv_flags & IFF_OVS_DATAPATH) if (vport->dev->priv_flags & IFF_OVS_DATAPATH)
ovs_netdev_detach_dev(vport); ovs_netdev_detach_dev(vport);
rtnl_unlock(); rtnl_unlock();
call_rcu(&netdev_vport->rcu, free_port_rcu); call_rcu(&vport->rcu, free_port_rcu);
} }
const char *ovs_netdev_get_name(const struct vport *vport) const char *ovs_netdev_get_name(const struct vport *vport)
{ {
const struct netdev_vport *netdev_vport = netdev_vport_priv(vport); return vport->dev->name;
return netdev_vport->dev->name;
} }
static unsigned int packet_length(const struct sk_buff *skb) static unsigned int packet_length(const struct sk_buff *skb)
@ -195,18 +188,17 @@ static unsigned int packet_length(const struct sk_buff *skb)
static int netdev_send(struct vport *vport, struct sk_buff *skb) static int netdev_send(struct vport *vport, struct sk_buff *skb)
{ {
struct netdev_vport *netdev_vport = netdev_vport_priv(vport); int mtu = vport->dev->mtu;
int mtu = netdev_vport->dev->mtu;
int len; int len;
if (unlikely(packet_length(skb) > mtu && !skb_is_gso(skb))) { if (unlikely(packet_length(skb) > mtu && !skb_is_gso(skb))) {
net_warn_ratelimited("%s: dropped over-mtu packet: %d > %d\n", net_warn_ratelimited("%s: dropped over-mtu packet: %d > %d\n",
netdev_vport->dev->name, vport->dev->name,
packet_length(skb), mtu); packet_length(skb), mtu);
goto drop; goto drop;
} }
skb->dev = netdev_vport->dev; skb->dev = vport->dev;
len = skb->len; len = skb->len;
dev_queue_xmit(skb); dev_queue_xmit(skb);

12
net/openvswitch/vport-netdev.h
View file

@ -26,18 +26,6 @@
struct vport *ovs_netdev_get_vport(struct net_device *dev); struct vport *ovs_netdev_get_vport(struct net_device *dev);
struct netdev_vport {
struct rcu_head rcu;
struct net_device *dev;
};
static inline struct netdev_vport *
netdev_vport_priv(const struct vport *vport)
{
return vport_priv(vport);
}
const char *ovs_netdev_get_name(const struct vport *); const char *ovs_netdev_get_name(const struct vport *);
void ovs_netdev_detach_dev(struct vport *); void ovs_netdev_detach_dev(struct vport *);

3
net/openvswitch/vport.h
View file

@ -107,7 +107,7 @@ struct vport_portids {
* @detach_list: list used for detaching vport in net-exit call. * @detach_list: list used for detaching vport in net-exit call.
*/ */
struct vport { struct vport {
struct rcu_head rcu; struct net_device *dev;
struct datapath *dp; struct datapath *dp;
struct vport_portids __rcu *upcall_portids; struct vport_portids __rcu *upcall_portids;
u16 port_no; u16 port_no;
@ -120,6 +120,7 @@ struct vport {
struct vport_err_stats err_stats; struct vport_err_stats err_stats;
struct list_head detach_list; struct list_head detach_list;
struct rcu_head rcu;
}; };
/** /**