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) { | |
61 | struct netdev_vport *netdev_vport; | |
62 | ||
63 | if (vport->ops->type != OVS_VPORT_TYPE_NETDEV) | |
64 | continue; | |
65 | ||
66 | netdev_vport = netdev_vport_priv(vport); | |
b07c2651 | 67 | if (!(netdev_vport->dev->priv_flags & IFF_OVS_DATAPATH)) |
8e4e1713 PS |
68 | dp_detach_port_notify(vport); |
69 | } | |
70 | } | |
71 | } | |
72 | ovs_unlock(); | |
73 | } | |
74 | ||
ccb1352e JG |
75 | static int dp_device_event(struct notifier_block *unused, unsigned long event, |
76 | void *ptr) | |
77 | { | |
8e4e1713 | 78 | struct ovs_net *ovs_net; |
351638e7 | 79 | struct net_device *dev = netdev_notifier_info_to_dev(ptr); |
8e4e1713 | 80 | struct vport *vport = NULL; |
ccb1352e | 81 | |
8e4e1713 | 82 | if (!ovs_is_internal_dev(dev)) |
ccb1352e JG |
83 | vport = ovs_netdev_get_vport(dev); |
84 | ||
85 | if (!vport) | |
86 | return NOTIFY_DONE; | |
87 | ||
8e4e1713 | 88 | if (event == NETDEV_UNREGISTER) { |
b07c2651 AS |
89 | /* upper_dev_unlink and decrement promisc immediately */ |
90 | ovs_netdev_detach_dev(vport); | |
91 | ||
92 | /* schedule vport destroy, dev_put and genl notification */ | |
8e4e1713 PS |
93 | ovs_net = net_generic(dev_net(dev), ovs_net_id); |
94 | queue_work(system_wq, &ovs_net->dp_notify_work); | |
ccb1352e JG |
95 | } |
96 | ||
97 | return NOTIFY_DONE; | |
98 | } | |
99 | ||
100 | struct notifier_block ovs_dp_device_notifier = { | |
101 | .notifier_call = dp_device_event | |
102 | }; |