Commit | Line | Data |
---|---|---|
ccb1352e | 1 | /* |
caf2ee14 | 2 | * Copyright (c) 2007-2012 Nicira, Inc. |
ccb1352e JG |
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 | |
17 | */ | |
18 | ||
19 | #include <linux/netdevice.h> | |
20 | #include <net/genetlink.h> | |
8e4e1713 | 21 | #include <net/netns/generic.h> |
ccb1352e JG |
22 | |
23 | #include "datapath.h" | |
24 | #include "vport-internal_dev.h" | |
25 | #include "vport-netdev.h" | |
26 | ||
8e4e1713 PS |
27 | static void dp_detach_port_notify(struct vport *vport) |
28 | { | |
29 | struct sk_buff *notify; | |
30 | struct datapath *dp; | |
31 | ||
32 | dp = vport->dp; | |
33 | notify = ovs_vport_cmd_build_info(vport, 0, 0, | |
34 | OVS_VPORT_CMD_DEL); | |
35 | ovs_dp_detach_port(vport); | |
36 | if (IS_ERR(notify)) { | |
68eb5503 | 37 | genl_set_err(&dp_vport_genl_family, ovs_dp_get_net(dp), 0, |
2a94fe48 | 38 | 0, PTR_ERR(notify)); |
8e4e1713 PS |
39 | return; |
40 | } | |
41 | ||
68eb5503 JB |
42 | genlmsg_multicast_netns(&dp_vport_genl_family, |
43 | ovs_dp_get_net(dp), notify, 0, | |
2a94fe48 | 44 | 0, GFP_KERNEL); |
8e4e1713 PS |
45 | } |
46 | ||
47 | void ovs_dp_notify_wq(struct work_struct *work) | |
48 | { | |
49 | struct ovs_net *ovs_net = container_of(work, struct ovs_net, dp_notify_work); | |
50 | struct datapath *dp; | |
51 | ||
52 | ovs_lock(); | |
53 | list_for_each_entry(dp, &ovs_net->dps, list_node) { | |
54 | int i; | |
55 | ||
56 | for (i = 0; i < DP_VPORT_HASH_BUCKETS; i++) { | |
57 | struct vport *vport; | |
58 | struct hlist_node *n; | |
59 | ||
60 | hlist_for_each_entry_safe(vport, n, &dp->ports[i], dp_hash_node) { | |
13175303 | 61 | if (vport->ops->type == OVS_VPORT_TYPE_INTERNAL) |
8e4e1713 PS |
62 | continue; |
63 | ||
be4ace6e | 64 | if (!(vport->dev->priv_flags & IFF_OVS_DATAPATH)) |
8e4e1713 PS |
65 | dp_detach_port_notify(vport); |
66 | } | |
67 | } | |
68 | } | |
69 | ovs_unlock(); | |
70 | } | |
71 | ||
ccb1352e JG |
72 | static int dp_device_event(struct notifier_block *unused, unsigned long event, |
73 | void *ptr) | |
74 | { | |
8e4e1713 | 75 | struct ovs_net *ovs_net; |
351638e7 | 76 | struct net_device *dev = netdev_notifier_info_to_dev(ptr); |
8e4e1713 | 77 | struct vport *vport = NULL; |
ccb1352e | 78 | |
8e4e1713 | 79 | if (!ovs_is_internal_dev(dev)) |
ccb1352e JG |
80 | vport = ovs_netdev_get_vport(dev); |
81 | ||
82 | if (!vport) | |
83 | return NOTIFY_DONE; | |
84 | ||
8e4e1713 | 85 | if (event == NETDEV_UNREGISTER) { |
b07c2651 AS |
86 | /* upper_dev_unlink and decrement promisc immediately */ |
87 | ovs_netdev_detach_dev(vport); | |
88 | ||
89 | /* schedule vport destroy, dev_put and genl notification */ | |
8e4e1713 PS |
90 | ovs_net = net_generic(dev_net(dev), ovs_net_id); |
91 | queue_work(system_wq, &ovs_net->dp_notify_work); | |
ccb1352e JG |
92 | } |
93 | ||
94 | return NOTIFY_DONE; | |
95 | } | |
96 | ||
97 | struct notifier_block ovs_dp_device_notifier = { | |
98 | .notifier_call = dp_device_event | |
99 | }; |