1 /*
2  * Copyright (c) 2014 Nicira, Inc.
3  *
4  * This program is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU General Public License
6  * as published by the Free Software Foundation; either version
7  * 2 of the License, or (at your option) any later version.
8  */
9 
10 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
11 
12 #include <linux/in.h>
13 #include <linux/ip.h>
14 #include <linux/net.h>
15 #include <linux/rculist.h>
16 #include <linux/udp.h>
17 #include <linux/if_vlan.h>
18 #include <linux/module.h>
19 
20 #include <net/geneve.h>
21 #include <net/icmp.h>
22 #include <net/ip.h>
23 #include <net/route.h>
24 #include <net/udp.h>
25 #include <net/xfrm.h>
26 
27 #include "datapath.h"
28 #include "vport.h"
29 #include "vport-netdev.h"
30 
31 static struct vport_ops ovs_geneve_vport_ops;
32 /**
33  * struct geneve_port - Keeps track of open UDP ports
34  * @dst_port: destination port.
35  */
36 struct geneve_port {
37 	u16 dst_port;
38 };
39 
40 static inline struct geneve_port *geneve_vport(const struct vport *vport)
41 {
42 	return vport_priv(vport);
43 }
44 
45 static int geneve_get_options(const struct vport *vport,
46 			      struct sk_buff *skb)
47 {
48 	struct geneve_port *geneve_port = geneve_vport(vport);
49 
50 	if (nla_put_u16(skb, OVS_TUNNEL_ATTR_DST_PORT, geneve_port->dst_port))
51 		return -EMSGSIZE;
52 	return 0;
53 }
54 
55 static struct vport *geneve_tnl_create(const struct vport_parms *parms)
56 {
57 	struct net *net = ovs_dp_get_net(parms->dp);
58 	struct nlattr *options = parms->options;
59 	struct geneve_port *geneve_port;
60 	struct net_device *dev;
61 	struct vport *vport;
62 	struct nlattr *a;
63 	u16 dst_port;
64 	int err;
65 
66 	if (!options) {
67 		err = -EINVAL;
68 		goto error;
69 	}
70 
71 	a = nla_find_nested(options, OVS_TUNNEL_ATTR_DST_PORT);
72 	if (a && nla_len(a) == sizeof(u16)) {
73 		dst_port = nla_get_u16(a);
74 	} else {
75 		/* Require destination port from userspace. */
76 		err = -EINVAL;
77 		goto error;
78 	}
79 
80 	vport = ovs_vport_alloc(sizeof(struct geneve_port),
81 				&ovs_geneve_vport_ops, parms);
82 	if (IS_ERR(vport))
83 		return vport;
84 
85 	geneve_port = geneve_vport(vport);
86 	geneve_port->dst_port = dst_port;
87 
88 	rtnl_lock();
89 	dev = geneve_dev_create_fb(net, parms->name, NET_NAME_USER, dst_port);
90 	if (IS_ERR(dev)) {
91 		rtnl_unlock();
92 		ovs_vport_free(vport);
93 		return ERR_CAST(dev);
94 	}
95 
96 	dev_change_flags(dev, dev->flags | IFF_UP);
97 	rtnl_unlock();
98 	return vport;
99 error:
100 	return ERR_PTR(err);
101 }
102 
103 static struct vport *geneve_create(const struct vport_parms *parms)
104 {
105 	struct vport *vport;
106 
107 	vport = geneve_tnl_create(parms);
108 	if (IS_ERR(vport))
109 		return vport;
110 
111 	return ovs_netdev_link(vport, parms->name);
112 }
113 
114 static struct vport_ops ovs_geneve_vport_ops = {
115 	.type		= OVS_VPORT_TYPE_GENEVE,
116 	.create		= geneve_create,
117 	.destroy	= ovs_netdev_tunnel_destroy,
118 	.get_options	= geneve_get_options,
119 	.send		= dev_queue_xmit,
120 };
121 
122 static int __init ovs_geneve_tnl_init(void)
123 {
124 	return ovs_vport_ops_register(&ovs_geneve_vport_ops);
125 }
126 
127 static void __exit ovs_geneve_tnl_exit(void)
128 {
129 	ovs_vport_ops_unregister(&ovs_geneve_vport_ops);
130 }
131 
132 module_init(ovs_geneve_tnl_init);
133 module_exit(ovs_geneve_tnl_exit);
134 
135 MODULE_DESCRIPTION("OVS: Geneve switching port");
136 MODULE_LICENSE("GPL");
137 MODULE_ALIAS("vport-type-5");
138