blob: b327368a3848238013cf0f6f62445569d7e29251 [file] [log] [blame]
Jesse Grossccb13522011-10-25 19:26:31 -07001/*
Raju Subramaniancaf2ee12012-05-03 18:55:23 -07002 * Copyright (c) 2007-2012 Nicira, Inc.
Jesse Grossccb13522011-10-25 19:26:31 -07003 *
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#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
20
21#include <linux/if_arp.h>
22#include <linux/if_bridge.h>
23#include <linux/if_vlan.h>
24#include <linux/kernel.h>
25#include <linux/llc.h>
26#include <linux/rtnetlink.h>
27#include <linux/skbuff.h>
Jiri Pirko2537b4d2013-07-26 14:01:54 +020028#include <linux/openvswitch.h>
Thomas Grafdcc38c02015-07-29 13:52:06 +020029#include <linux/export.h>
Jesse Grossccb13522011-10-25 19:26:31 -070030
Thomas Graf614732e2015-07-21 10:44:06 +020031#include <net/ip_tunnels.h>
32#include <net/rtnetlink.h>
Jesse Grossccb13522011-10-25 19:26:31 -070033
34#include "datapath.h"
Thomas Graf614732e2015-07-21 10:44:06 +020035#include "vport.h"
Jesse Grossccb13522011-10-25 19:26:31 -070036#include "vport-internal_dev.h"
37#include "vport-netdev.h"
38
Thomas Graf62b9c8d2014-10-22 17:29:06 +020039static struct vport_ops ovs_netdev_vport_ops;
40
Jesse Grossccb13522011-10-25 19:26:31 -070041/* Must be called with rcu_read_lock. */
Pravin B Shelar8c876632015-08-29 17:44:07 -070042static void netdev_port_receive(struct sk_buff *skb)
Jesse Grossccb13522011-10-25 19:26:31 -070043{
Pravin B Shelar8c876632015-08-29 17:44:07 -070044 struct vport *vport;
45
46 vport = ovs_netdev_get_vport(skb->dev);
Jesse Grossd9d59082013-01-21 23:57:26 -080047 if (unlikely(!vport))
48 goto error;
49
50 if (unlikely(skb_warn_if_lro(skb)))
51 goto error;
Jesse Grossccb13522011-10-25 19:26:31 -070052
53 /* Make our own copy of the packet. Otherwise we will mangle the
54 * packet for anyone who came before us (e.g. tcpdump via AF_PACKET).
Cong Wangd176ca22013-02-22 19:41:26 +080055 */
Jesse Grossccb13522011-10-25 19:26:31 -070056 skb = skb_share_check(skb, GFP_ATOMIC);
57 if (unlikely(!skb))
58 return;
59
60 skb_push(skb, ETH_HLEN);
Pravin B Shelarb34df5e2013-06-13 11:11:44 -070061 ovs_skb_postpush_rcsum(skb, skb->data, ETH_HLEN);
Jiri Benc61adedf2015-08-20 13:56:25 +020062 ovs_vport_receive(vport, skb, skb_tunnel_info(skb));
Jesse Grossd9d59082013-01-21 23:57:26 -080063 return;
Jesse Grossd9d59082013-01-21 23:57:26 -080064error:
65 kfree_skb(skb);
Jesse Grossccb13522011-10-25 19:26:31 -070066}
67
68/* Called with rcu_read_lock and bottom-halves disabled. */
69static rx_handler_result_t netdev_frame_hook(struct sk_buff **pskb)
70{
71 struct sk_buff *skb = *pskb;
Jesse Grossccb13522011-10-25 19:26:31 -070072
73 if (unlikely(skb->pkt_type == PACKET_LOOPBACK))
74 return RX_HANDLER_PASS;
75
Pravin B Shelar8c876632015-08-29 17:44:07 -070076 netdev_port_receive(skb);
Jesse Grossccb13522011-10-25 19:26:31 -070077 return RX_HANDLER_CONSUMED;
78}
79
Thomas Graf12eb18f2014-11-06 06:58:52 -080080static struct net_device *get_dpdev(const struct datapath *dp)
Jiri Pirko2537b4d2013-07-26 14:01:54 +020081{
82 struct vport *local;
83
84 local = ovs_vport_ovsl(dp, OVSP_LOCAL);
85 BUG_ON(!local);
Thomas Grafbe4ace62015-07-21 10:44:04 +020086 return local->dev;
Jiri Pirko2537b4d2013-07-26 14:01:54 +020087}
88
Thomas Grafdcc38c02015-07-29 13:52:06 +020089struct vport *ovs_netdev_link(struct vport *vport, const char *name)
Jesse Grossccb13522011-10-25 19:26:31 -070090{
Jesse Grossccb13522011-10-25 19:26:31 -070091 int err;
92
Thomas Grafbe4ace62015-07-21 10:44:04 +020093 vport->dev = dev_get_by_name(ovs_dp_get_net(vport->dp), name);
94 if (!vport->dev) {
Jesse Grossccb13522011-10-25 19:26:31 -070095 err = -ENODEV;
96 goto error_free_vport;
97 }
98
Thomas Grafbe4ace62015-07-21 10:44:04 +020099 if (vport->dev->flags & IFF_LOOPBACK ||
100 vport->dev->type != ARPHRD_ETHER ||
101 ovs_is_internal_dev(vport->dev)) {
Jesse Grossccb13522011-10-25 19:26:31 -0700102 err = -EINVAL;
103 goto error_put;
104 }
105
Pravin B Shelar8e4e1712013-04-15 13:23:03 -0700106 rtnl_lock();
Thomas Grafbe4ace62015-07-21 10:44:04 +0200107 err = netdev_master_upper_dev_link(vport->dev,
Jiri Pirko2537b4d2013-07-26 14:01:54 +0200108 get_dpdev(vport->dp));
109 if (err)
110 goto error_unlock;
111
Thomas Grafbe4ace62015-07-21 10:44:04 +0200112 err = netdev_rx_handler_register(vport->dev, netdev_frame_hook,
Jesse Grossccb13522011-10-25 19:26:31 -0700113 vport);
114 if (err)
Jiri Pirko2537b4d2013-07-26 14:01:54 +0200115 goto error_master_upper_dev_unlink;
Jesse Grossccb13522011-10-25 19:26:31 -0700116
Thomas Grafbe4ace62015-07-21 10:44:04 +0200117 dev_disable_lro(vport->dev);
118 dev_set_promiscuity(vport->dev, 1);
119 vport->dev->priv_flags |= IFF_OVS_DATAPATH;
Pravin B Shelar8e4e1712013-04-15 13:23:03 -0700120 rtnl_unlock();
Jesse Grossccb13522011-10-25 19:26:31 -0700121
122 return vport;
123
Jiri Pirko2537b4d2013-07-26 14:01:54 +0200124error_master_upper_dev_unlink:
Thomas Grafbe4ace62015-07-21 10:44:04 +0200125 netdev_upper_dev_unlink(vport->dev, get_dpdev(vport->dp));
Pravin B Shelar8e4e1712013-04-15 13:23:03 -0700126error_unlock:
127 rtnl_unlock();
Jesse Grossccb13522011-10-25 19:26:31 -0700128error_put:
Thomas Grafbe4ace62015-07-21 10:44:04 +0200129 dev_put(vport->dev);
Jesse Grossccb13522011-10-25 19:26:31 -0700130error_free_vport:
131 ovs_vport_free(vport);
Jesse Grossccb13522011-10-25 19:26:31 -0700132 return ERR_PTR(err);
133}
Thomas Grafdcc38c02015-07-29 13:52:06 +0200134EXPORT_SYMBOL_GPL(ovs_netdev_link);
Jesse Grossccb13522011-10-25 19:26:31 -0700135
Thomas Grafbe4ace62015-07-21 10:44:04 +0200136static struct vport *netdev_create(const struct vport_parms *parms)
137{
138 struct vport *vport;
139
140 vport = ovs_vport_alloc(0, &ovs_netdev_vport_ops, parms);
141 if (IS_ERR(vport))
142 return vport;
143
Thomas Grafdcc38c02015-07-29 13:52:06 +0200144 return ovs_netdev_link(vport, parms->name);
Thomas Grafbe4ace62015-07-21 10:44:04 +0200145}
146
Pravin B Shelara9020fd2015-08-07 23:51:33 -0700147static void vport_netdev_free(struct rcu_head *rcu)
Jesse Gross92eb1d42012-11-28 14:01:52 -0800148{
Thomas Grafbe4ace62015-07-21 10:44:04 +0200149 struct vport *vport = container_of(rcu, struct vport, rcu);
Jesse Gross92eb1d42012-11-28 14:01:52 -0800150
Thomas Graf614732e2015-07-21 10:44:06 +0200151 if (vport->dev)
152 dev_put(vport->dev);
Thomas Grafbe4ace62015-07-21 10:44:04 +0200153 ovs_vport_free(vport);
Jesse Gross92eb1d42012-11-28 14:01:52 -0800154}
155
Alexei Starovoitovb07c2652013-10-15 14:54:11 -0700156void ovs_netdev_detach_dev(struct vport *vport)
157{
Alexei Starovoitovb07c2652013-10-15 14:54:11 -0700158 ASSERT_RTNL();
Thomas Grafbe4ace62015-07-21 10:44:04 +0200159 vport->dev->priv_flags &= ~IFF_OVS_DATAPATH;
160 netdev_rx_handler_unregister(vport->dev);
161 netdev_upper_dev_unlink(vport->dev,
162 netdev_master_upper_dev_get(vport->dev));
163 dev_set_promiscuity(vport->dev, -1);
Alexei Starovoitovb07c2652013-10-15 14:54:11 -0700164}
Thomas Grafdcc38c02015-07-29 13:52:06 +0200165EXPORT_SYMBOL_GPL(ovs_netdev_detach_dev);
Alexei Starovoitovb07c2652013-10-15 14:54:11 -0700166
Jesse Grossccb13522011-10-25 19:26:31 -0700167static void netdev_destroy(struct vport *vport)
168{
Pravin B Shelar8e4e1712013-04-15 13:23:03 -0700169 rtnl_lock();
Thomas Grafbe4ace62015-07-21 10:44:04 +0200170 if (vport->dev->priv_flags & IFF_OVS_DATAPATH)
Alexei Starovoitovb07c2652013-10-15 14:54:11 -0700171 ovs_netdev_detach_dev(vport);
Pravin B Shelar8e4e1712013-04-15 13:23:03 -0700172 rtnl_unlock();
Jesse Grossccb13522011-10-25 19:26:31 -0700173
Pravin B Shelara9020fd2015-08-07 23:51:33 -0700174 call_rcu(&vport->rcu, vport_netdev_free);
Jesse Grossccb13522011-10-25 19:26:31 -0700175}
176
Pravin B Shelara9020fd2015-08-07 23:51:33 -0700177void ovs_netdev_tunnel_destroy(struct vport *vport)
178{
179 rtnl_lock();
180 if (vport->dev->priv_flags & IFF_OVS_DATAPATH)
181 ovs_netdev_detach_dev(vport);
182
183 /* Early release so we can unregister the device */
184 dev_put(vport->dev);
185 rtnl_delete_link(vport->dev);
186 vport->dev = NULL;
187 rtnl_unlock();
188
189 call_rcu(&vport->rcu, vport_netdev_free);
190}
191EXPORT_SYMBOL_GPL(ovs_netdev_tunnel_destroy);
192
Jesse Grossccb13522011-10-25 19:26:31 -0700193/* Returns null if this device is not attached to a datapath. */
194struct vport *ovs_netdev_get_vport(struct net_device *dev)
195{
196 if (likely(dev->priv_flags & IFF_OVS_DATAPATH))
197 return (struct vport *)
198 rcu_dereference_rtnl(dev->rx_handler_data);
199 else
200 return NULL;
201}
202
Thomas Graf62b9c8d2014-10-22 17:29:06 +0200203static struct vport_ops ovs_netdev_vport_ops = {
Jesse Grossccb13522011-10-25 19:26:31 -0700204 .type = OVS_VPORT_TYPE_NETDEV,
205 .create = netdev_create,
206 .destroy = netdev_destroy,
Pravin B Shelaraec15922015-10-20 23:00:10 -0700207 .send = dev_queue_xmit,
Jesse Grossccb13522011-10-25 19:26:31 -0700208};
Thomas Graf62b9c8d2014-10-22 17:29:06 +0200209
210int __init ovs_netdev_init(void)
211{
Thomas Grafdcc38c02015-07-29 13:52:06 +0200212 return ovs_vport_ops_register(&ovs_netdev_vport_ops);
Thomas Graf62b9c8d2014-10-22 17:29:06 +0200213}
214
215void ovs_netdev_exit(void)
216{
217 ovs_vport_ops_unregister(&ovs_netdev_vport_ops);
218}