| |
| |
| |
| |
| |
| #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) { |
| <------><------> |
| <------><------>ovs_netdev_detach_dev(vport); |
| |
| <------><------> |
| <------><------>ovs_net = net_generic(dev_net(dev), ovs_net_id); |
| <------><------>queue_work(system_wq, &ovs_net->dp_notify_work); |
| <------>} |
| |
| <------>return NOTIFY_DONE; |
| } |
| |
| struct notifier_block ovs_dp_device_notifier = { |
| <------>.notifier_call = dp_device_event |
| }; |
| |