Something went wrong. Try again.
Linux kernel mirror (for testing) git.kernel.org/pub/scm/linux/kernel/git/torvalds/linux.git
Something went wrong. Try again.
2.0 kB · 86 lines
C
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687// SPDX-License-Identifier: GPL-2.0-only/* * Copyright (c) 2007-2012 Nicira, Inc. */
#include <linux/netdevice.h>#include <net/genetlink.h>#include <net/netns/generic.h>
#include "datapath.h"#include "vport-internal_dev.h"#include "vport-netdev.h"
static void dp_detach_port_notify(struct vport *vport){ struct sk_buff *notify; struct datapath *dp;
dp = vport->dp; notify = ovs_vport_cmd_build_info(vport, ovs_dp_get_net(dp), 0, 0, OVS_VPORT_CMD_DEL); ovs_dp_detach_port(vport); if (IS_ERR(notify)) { genl_set_err(&dp_vport_genl_family, ovs_dp_get_net(dp), 0, 0, PTR_ERR(notify)); return; }
genlmsg_multicast_netns(&dp_vport_genl_family, ovs_dp_get_net(dp), notify, 0, 0, GFP_KERNEL);}
void ovs_dp_notify_wq(struct work_struct *work){ struct ovs_net *ovs_net = container_of(work, struct ovs_net, dp_notify_work); struct datapath *dp;
ovs_lock(); list_for_each_entry(dp, &ovs_net->dps, list_node) { int i;
for (i = 0; i < DP_VPORT_HASH_BUCKETS; i++) { struct vport *vport; struct hlist_node *n;
hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { if (vport->ops->type == OVS_VPORT_TYPE_INTERNAL) continue;
if (!(netif_is_ovs_port(vport->dev))) dp_detach_port_notify(vport); } } } ovs_unlock();}
static int dp_device_event(struct notifier_block *unused, unsigned long event, void *ptr){ struct ovs_net *ovs_net; struct net_device *dev = netdev_notifier_info_to_dev(ptr); struct vport *vport = NULL;
if (!ovs_is_internal_dev(dev)) vport = ovs_netdev_get_vport(dev);
if (!vport) return NOTIFY_DONE;
if (event == NETDEV_UNREGISTER) { /* upper_dev_unlink and decrement promisc immediately */ ovs_netdev_detach_dev(vport);
/* schedule vport destroy, dev_put and genl notification */ ovs_net = net_generic(dev_net(dev), ovs_net_id); queue_work(system_percpu_wq, &ovs_net->dp_notify_work); }
return NOTIFY_DONE;}
struct notifier_block ovs_dp_device_notifier = { .notifier_call = dp_device_event};