1 // SPDX-License-Identifier: GPL-2.0-only << 2 /* 1 /* 3 * Copyright (c) 2007-2012 Nicira, Inc. 2 * Copyright (c) 2007-2012 Nicira, Inc. >> 3 * >> 4 * This program is free software; you can redistribute it and/or >> 5 * modify it under the terms of version 2 of the GNU General Public >> 6 * License as published by the Free Software Foundation. >> 7 * >> 8 * This program is distributed in the hope that it will be useful, but >> 9 * WITHOUT ANY WARRANTY; without even the implied warranty of >> 10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU >> 11 * General Public License for more details. >> 12 * >> 13 * You should have received a copy of the GNU General Public License >> 14 * along with this program; if not, write to the Free Software >> 15 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA >> 16 * 02110-1301, USA 4 */ 17 */ 5 18 6 #include <linux/netdevice.h> 19 #include <linux/netdevice.h> 7 #include <net/genetlink.h> 20 #include <net/genetlink.h> 8 #include <net/netns/generic.h> 21 #include <net/netns/generic.h> 9 22 10 #include "datapath.h" 23 #include "datapath.h" 11 #include "vport-internal_dev.h" 24 #include "vport-internal_dev.h" 12 #include "vport-netdev.h" 25 #include "vport-netdev.h" 13 26 14 static void dp_detach_port_notify(struct vport 27 static void dp_detach_port_notify(struct vport *vport) 15 { 28 { 16 struct sk_buff *notify; 29 struct sk_buff *notify; 17 struct datapath *dp; 30 struct datapath *dp; 18 31 19 dp = vport->dp; 32 dp = vport->dp; 20 notify = ovs_vport_cmd_build_info(vpor !! 33 notify = ovs_vport_cmd_build_info(vport, 0, 0, 21 0, 0 !! 34 OVS_VPORT_CMD_DEL); 22 ovs_dp_detach_port(vport); 35 ovs_dp_detach_port(vport); 23 if (IS_ERR(notify)) { 36 if (IS_ERR(notify)) { 24 genl_set_err(&dp_vport_genl_fa !! 37 netlink_set_err(ovs_dp_get_net(dp)->genl_sock, 0, 25 0, PTR_ERR(notify !! 38 ovs_dp_vport_multicast_group.id, >> 39 PTR_ERR(notify)); 26 return; 40 return; 27 } 41 } 28 42 29 genlmsg_multicast_netns(&dp_vport_genl !! 43 genlmsg_multicast_netns(ovs_dp_get_net(dp), notify, 0, 30 ovs_dp_get_net !! 44 ovs_dp_vport_multicast_group.id, 31 0, GFP_KERNEL) !! 45 GFP_KERNEL); 32 } 46 } 33 47 34 void ovs_dp_notify_wq(struct work_struct *work 48 void ovs_dp_notify_wq(struct work_struct *work) 35 { 49 { 36 struct ovs_net *ovs_net = container_of 50 struct ovs_net *ovs_net = container_of(work, struct ovs_net, dp_notify_work); 37 struct datapath *dp; 51 struct datapath *dp; 38 52 39 ovs_lock(); 53 ovs_lock(); 40 list_for_each_entry(dp, &ovs_net->dps, 54 list_for_each_entry(dp, &ovs_net->dps, list_node) { 41 int i; 55 int i; 42 56 43 for (i = 0; i < DP_VPORT_HASH_ 57 for (i = 0; i < DP_VPORT_HASH_BUCKETS; i++) { 44 struct vport *vport; 58 struct vport *vport; 45 struct hlist_node *n; 59 struct hlist_node *n; 46 60 47 hlist_for_each_entry_s 61 hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { 48 if (vport->ops !! 62 struct netdev_vport *netdev_vport; >> 63 >> 64 if (vport->ops->type != OVS_VPORT_TYPE_NETDEV) 49 contin 65 continue; 50 66 51 if (!(netif_is !! 67 netdev_vport = netdev_vport_priv(vport); >> 68 if (netdev_vport->dev->reg_state == NETREG_UNREGISTERED || >> 69 netdev_vport->dev->reg_state == NETREG_UNREGISTERING) 52 dp_det 70 dp_detach_port_notify(vport); 53 } 71 } 54 } 72 } 55 } 73 } 56 ovs_unlock(); 74 ovs_unlock(); 57 } 75 } 58 76 59 static int dp_device_event(struct notifier_blo 77 static int dp_device_event(struct notifier_block *unused, unsigned long event, 60 void *ptr) 78 void *ptr) 61 { 79 { 62 struct ovs_net *ovs_net; 80 struct ovs_net *ovs_net; 63 struct net_device *dev = netdev_notifi !! 81 struct net_device *dev = ptr; 64 struct vport *vport = NULL; 82 struct vport *vport = NULL; 65 83 66 if (!ovs_is_internal_dev(dev)) 84 if (!ovs_is_internal_dev(dev)) 67 vport = ovs_netdev_get_vport(d 85 vport = ovs_netdev_get_vport(dev); 68 86 69 if (!vport) 87 if (!vport) 70 return NOTIFY_DONE; 88 return NOTIFY_DONE; 71 89 72 if (event == NETDEV_UNREGISTER) { 90 if (event == NETDEV_UNREGISTER) { 73 /* upper_dev_unlink and decrem << 74 ovs_netdev_detach_dev(vport); << 75 << 76 /* schedule vport destroy, dev << 77 ovs_net = net_generic(dev_net( 91 ovs_net = net_generic(dev_net(dev), ovs_net_id); 78 queue_work(system_wq, &ovs_net 92 queue_work(system_wq, &ovs_net->dp_notify_work); 79 } 93 } 80 94 81 return NOTIFY_DONE; 95 return NOTIFY_DONE; 82 } 96 } 83 97 84 struct notifier_block ovs_dp_device_notifier = 98 struct notifier_block ovs_dp_device_notifier = { 85 .notifier_call = dp_device_event 99 .notifier_call = dp_device_event 86 }; 100 }; 87 101
Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.