tests: Add test suite for packets.h.
[openvswitch] / datapath / vport-netdev.c
1 /*
2  * Copyright (c) 2010, 2011 Nicira Networks.
3  * Distributed under the terms of the GNU GPL version 2.
4  *
5  * Significant portions of this file may be copied from parts of the Linux
6  * kernel, by Linus Torvalds and others.
7  */
8
9 #include <linux/if_arp.h>
10 #include <linux/if_bridge.h>
11 #include <linux/if_vlan.h>
12 #include <linux/kernel.h>
13 #include <linux/llc.h>
14 #include <linux/rtnetlink.h>
15 #include <linux/skbuff.h>
16
17 #include <net/llc.h>
18
19 #include "checksum.h"
20 #include "datapath.h"
21 #include "vport-internal_dev.h"
22 #include "vport-netdev.h"
23
24 /* If the native device stats aren't 64 bit use the vport stats tracking instead. */
25 #define USE_VPORT_STATS (sizeof(((struct net_device_stats *)0)->rx_bytes) < sizeof(u64))
26
27 static void netdev_port_receive(struct vport *vport, struct sk_buff *skb);
28
29 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,36)
30 /* Called with rcu_read_lock and bottom-halves disabled. */
31 static struct sk_buff *netdev_frame_hook(struct sk_buff *skb)
32 {
33         struct vport *vport;
34
35         if (unlikely(skb->pkt_type == PACKET_LOOPBACK))
36                 return skb;
37
38         vport = netdev_get_vport(skb->dev);
39
40         netdev_port_receive(vport, skb);
41
42         return NULL;
43 }
44 #elif LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,22)
45 /*
46  * Used as br_handle_frame_hook.  (Cannot run bridge at the same time, even on
47  * different set of devices!)
48  */
49 /* Called with rcu_read_lock and bottom-halves disabled. */
50 static struct sk_buff *netdev_frame_hook(struct net_bridge_port *p,
51                                          struct sk_buff *skb)
52 {
53         netdev_port_receive((struct vport *)p, skb);
54         return NULL;
55 }
56 #elif LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,0)
57 /*
58  * Used as br_handle_frame_hook.  (Cannot run bridge at the same time, even on
59  * different set of devices!)
60  */
61 /* Called with rcu_read_lock and bottom-halves disabled. */
62 static int netdev_frame_hook(struct net_bridge_port *p, struct sk_buff **pskb)
63 {
64         netdev_port_receive((struct vport *)p, *pskb);
65         return 1;
66 }
67 #else
68 #error
69 #endif
70
71 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,36)
72 static int netdev_init(void) { return 0; }
73 static void netdev_exit(void) { }
74 #else
75 static int netdev_init(void)
76 {
77         /* Hook into callback used by the bridge to intercept packets.
78          * Parasites we are. */
79         br_handle_frame_hook = netdev_frame_hook;
80
81         return 0;
82 }
83
84 static void netdev_exit(void)
85 {
86         br_handle_frame_hook = NULL;
87 }
88 #endif
89
90 static struct vport *netdev_create(const struct vport_parms *parms)
91 {
92         struct vport *vport;
93         struct netdev_vport *netdev_vport;
94         int err;
95
96         vport = vport_alloc(sizeof(struct netdev_vport), &netdev_vport_ops, parms);
97         if (IS_ERR(vport)) {
98                 err = PTR_ERR(vport);
99                 goto error;
100         }
101
102         netdev_vport = netdev_vport_priv(vport);
103
104         netdev_vport->dev = dev_get_by_name(&init_net, parms->name);
105         if (!netdev_vport->dev) {
106                 err = -ENODEV;
107                 goto error_free_vport;
108         }
109
110         if (netdev_vport->dev->flags & IFF_LOOPBACK ||
111             netdev_vport->dev->type != ARPHRD_ETHER ||
112             is_internal_dev(netdev_vport->dev)) {
113                 err = -EINVAL;
114                 goto error_put;
115         }
116
117         /* If we are using the vport stats layer initialize it to the current
118          * values so we are roughly consistent with the device stats. */
119         if (USE_VPORT_STATS) {
120                 struct rtnl_link_stats64 stats;
121
122                 err = netdev_get_stats(vport, &stats);
123                 if (!err)
124                         vport_set_stats(vport, &stats);
125         }
126
127         err = netdev_rx_handler_register(netdev_vport->dev, netdev_frame_hook,
128                                          vport);
129         if (err)
130                 goto error_put;
131
132         dev_set_promiscuity(netdev_vport->dev, 1);
133         dev_disable_lro(netdev_vport->dev);
134         netdev_vport->dev->priv_flags |= IFF_OVS_DATAPATH;
135
136         return vport;
137
138 error_put:
139         dev_put(netdev_vport->dev);
140 error_free_vport:
141         vport_free(vport);
142 error:
143         return ERR_PTR(err);
144 }
145
146 static int netdev_destroy(struct vport *vport)
147 {
148         struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
149
150         netdev_vport->dev->priv_flags &= ~IFF_OVS_DATAPATH;
151         netdev_rx_handler_unregister(netdev_vport->dev);
152         dev_set_promiscuity(netdev_vport->dev, -1);
153
154         synchronize_rcu();
155
156         dev_put(netdev_vport->dev);
157         vport_free(vport);
158
159         return 0;
160 }
161
162 int netdev_set_mtu(struct vport *vport, int mtu)
163 {
164         struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
165         return dev_set_mtu(netdev_vport->dev, mtu);
166 }
167
168 int netdev_set_addr(struct vport *vport, const unsigned char *addr)
169 {
170         struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
171         struct sockaddr sa;
172
173         sa.sa_family = ARPHRD_ETHER;
174         memcpy(sa.sa_data, addr, ETH_ALEN);
175
176         return dev_set_mac_address(netdev_vport->dev, &sa);
177 }
178
179 const char *netdev_get_name(const struct vport *vport)
180 {
181         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
182         return netdev_vport->dev->name;
183 }
184
185 const unsigned char *netdev_get_addr(const struct vport *vport)
186 {
187         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
188         return netdev_vport->dev->dev_addr;
189 }
190
191 struct kobject *netdev_get_kobj(const struct vport *vport)
192 {
193         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
194         return &netdev_vport->dev->NETDEV_DEV_MEMBER.kobj;
195 }
196
197 int netdev_get_stats(const struct vport *vport, struct rtnl_link_stats64 *stats)
198 {
199         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
200         dev_get_stats(netdev_vport->dev, stats);
201         return 0;
202 }
203
204 unsigned netdev_get_dev_flags(const struct vport *vport)
205 {
206         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
207         return dev_get_flags(netdev_vport->dev);
208 }
209
210 int netdev_is_running(const struct vport *vport)
211 {
212         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
213         return netif_running(netdev_vport->dev);
214 }
215
216 unsigned char netdev_get_operstate(const struct vport *vport)
217 {
218         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
219         return netdev_vport->dev->operstate;
220 }
221
222 int netdev_get_ifindex(const struct vport *vport)
223 {
224         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
225         return netdev_vport->dev->ifindex;
226 }
227
228 int netdev_get_iflink(const struct vport *vport)
229 {
230         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
231         return netdev_vport->dev->iflink;
232 }
233
234 int netdev_get_mtu(const struct vport *vport)
235 {
236         const struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
237         return netdev_vport->dev->mtu;
238 }
239
240 /* Must be called with rcu_read_lock. */
241 static void netdev_port_receive(struct vport *vport, struct sk_buff *skb)
242 {
243         /* Make our own copy of the packet.  Otherwise we will mangle the
244          * packet for anyone who came before us (e.g. tcpdump via AF_PACKET).
245          * (No one comes after us, since we tell handle_bridge() that we took
246          * the packet.) */
247         skb = skb_share_check(skb, GFP_ATOMIC);
248         if (unlikely(!skb))
249                 return;
250
251         skb_warn_if_lro(skb);
252
253         skb_push(skb, ETH_HLEN);
254         compute_ip_summed(skb, false);
255
256         vport_receive(vport, skb);
257 }
258
259 static int netdev_send(struct vport *vport, struct sk_buff *skb)
260 {
261         struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
262         int len = skb->len;
263
264         skb->dev = netdev_vport->dev;
265         forward_ip_summed(skb);
266         dev_queue_xmit(skb);
267
268         return len;
269 }
270
271 /* Returns null if this device is not attached to a datapath. */
272 struct vport *netdev_get_vport(struct net_device *dev)
273 {
274 #ifdef IFF_BRIDGE_PORT
275 #if IFF_BRIDGE_PORT != IFF_OVS_DATAPATH
276         if (likely(dev->priv_flags & IFF_OVS_DATAPATH))
277 #else
278         if (likely(rcu_access_pointer(dev->rx_handler) == netdev_frame_hook))   
279 #endif
280                 return (struct vport *)rcu_dereference_rtnl(dev->rx_handler_data);
281         else
282                 return NULL;
283 #else
284         return (struct vport *)rcu_dereference_rtnl(dev->br_port);
285 #endif
286 }
287
288 const struct vport_ops netdev_vport_ops = {
289         .type           = ODP_VPORT_TYPE_NETDEV,
290         .flags          = (VPORT_F_REQUIRED |
291                           (USE_VPORT_STATS ? VPORT_F_GEN_STATS : 0)),
292         .init           = netdev_init,
293         .exit           = netdev_exit,
294         .create         = netdev_create,
295         .destroy        = netdev_destroy,
296         .set_mtu        = netdev_set_mtu,
297         .set_addr       = netdev_set_addr,
298         .get_name       = netdev_get_name,
299         .get_addr       = netdev_get_addr,
300         .get_kobj       = netdev_get_kobj,
301         .get_stats      = netdev_get_stats,
302         .get_dev_flags  = netdev_get_dev_flags,
303         .is_running     = netdev_is_running,
304         .get_operstate  = netdev_get_operstate,
305         .get_ifindex    = netdev_get_ifindex,
306         .get_iflink     = netdev_get_iflink,
307         .get_mtu        = netdev_get_mtu,
308         .send           = netdev_send,
309 };
310
311 #if LINUX_VERSION_CODE < KERNEL_VERSION(2,6,36)
312 /*
313  * In kernels earlier than 2.6.36, Open vSwitch cannot safely coexist with
314  * the Linux bridge module on any released version of Linux, because there
315  * is only a single bridge hook function and only a single br_port member
316  * in struct net_device.
317  *
318  * Declaring and exporting this symbol enforces mutual exclusion.  The bridge
319  * module also exports the same symbol, so the module loader will refuse to
320  * load both modules at the same time (e.g. "bridge: exports duplicate symbol
321  * br_should_route_hook (owned by openvswitch_mod)").
322  *
323  * The use of "typeof" here avoids the need to track changes in the type of
324  * br_should_route_hook over various kernel versions.
325  */
326 typeof(br_should_route_hook) br_should_route_hook;
327 EXPORT_SYMBOL(br_should_route_hook);
328 #endif